apache/samza issues and pull requests

#1715 - SAMZA-2803 Remove Google Analytics from the Samza Website

Pull Request - State: open - Opened by niallkp 14 days ago

#1714 - Publish build scans to develocity.apache.org

Pull Request - State: open - Opened by clayburn 19 days ago - 5 comments

#1713 - Clear local logged stores if input checkpoints are empty

Pull Request - State: closed - Opened by ajothomas about 2 months ago

#1712 - Fix exception message in BlobStoreUtil's getSnapshotIndex

Pull Request - State: closed - Opened by ajothomas 4 months ago

#1711 - Log bob deserialization exception for snapshot blobs

Pull Request - State: closed - Opened by ajothomas 4 months ago

#1710 - SAMZA-2802: fetch empty topic metadata

Pull Request - State: open - Opened by Anilochka 4 months ago

#1709 - Update org.ysb33r.gradle:grolifant version and use io.github.rburgst instead of com.burgstaller

Pull Request - State: closed - Opened by ajothomas 4 months ago

#1708 - Add new configuration allowing to keep processing when there are fatal exceptions or timeout

Pull Request - State: closed - Opened by yehaolan 4 months ago - 3 comments

#1707 - SAMZA-2801: fix the case when waterrmark is not aggregated when quorum is not met

Pull Request - State: closed - Opened by xinyuiscool 5 months ago

#1706 - Add Default Configuration for RocksDB MaxManifestFileSize

Pull Request - State: closed - Opened by yehaolan 6 months ago

#1705 - SAMZA-2801: Support excluding tasks from watermark computation when exceeding idle time

Pull Request - State: closed - Opened by xinyuiscool 6 months ago

#1704 - BUG FIX: set target file size multiplier

Pull Request - State: closed - Opened by yehaolan 6 months ago - 1 comment

#1703 - Handle transitive buildscript dependencies that were only present in JCenter

Pull Request - State: closed - Opened by clayburn 6 months ago - 1 comment

#1702 - Output Current Timestamp at run-class.sh script

Pull Request - State: closed - Opened by yehaolan 6 months ago

#1701 - Improve Samza AM retry count logging

Pull Request - State: closed - Opened by MikeBarskii 7 months ago

#1700 - New interface & factory for AzureHTTPClient providers

Pull Request - State: closed - Opened by khandelwal-ayush 8 months ago - 2 comments

#1699 - [SAMZA-2800] A new Control Group Metric for Samza

Pull Request - State: closed - Opened by li-afaris 8 months ago - 1 comment

#1698 - Auto-generated brief summary for the open-source code repository.

Pull Request - State: open - Opened by GOptimistic 10 months ago

#1697 - Create store directory paths in CSM constructor for disk space monitor

Pull Request - State: closed - Opened by shekhars-li 10 months ago

#1696 - SAMZA-2799: Remove worker.opts handling in shell command builder

Pull Request - State: closed - Opened by mynameborat about 1 year ago

#1695 - SAMZA-2784: Remove excessive commit logs

Pull Request - State: closed - Opened by dxichen about 1 year ago

#1694 - Add MAX_BACKGROUND_JOBS config for RocksDB

Pull Request - State: closed - Opened by shekhars-li about 1 year ago

#1693 - SAMZA-2798: Populate worker.opts in environment variable only if available

Pull Request - State: closed - Opened by mynameborat about 1 year ago

#1692 - SAMZA-2797: Add flush to CoordinatorStreamSystemProducer and call it during CoordinatorStreamWriter stop

Pull Request - State: closed - Opened by ajothomas about 1 year ago

#1691 - SAMZA-2796: Introduce config knob for framework thread sub DAG execution

Pull Request - State: closed - Opened by mynameborat about 1 year ago - 1 comment

#1690 - SAMZA-2795: Set thread to daemon thread for operator executor service

Pull Request - State: closed - Opened by mynameborat about 1 year ago

#1689 - SAMZA-2763: Support worker JVM opts for Samza Beam portable mode

Pull Request - State: closed - Opened by mynameborat over 1 year ago - 1 comment

#1688 - SAMZA-2794: SSPGrouperProxy Partition Count Change Error

Pull Request - State: open - Opened by Agonnee over 1 year ago

#1687 - Added cache for file blobs that are already TTL removed

Pull Request - State: closed - Opened by shekhars-li over 1 year ago

#1686 - SAMZA-2792: Unique System.exit in ContainerLaunchUtil

Pull Request - State: closed - Opened by guanjun1 over 1 year ago - 2 comments

#1685 - Clear exit path in ContainerLaunchUtil

Pull Request - State: closed - Opened by guanjun1 over 1 year ago

#1684 - Ignore file owners comparison on restore when config is set

Pull Request - State: closed - Opened by shekhars-li over 1 year ago

#1683 - Asautins/samza 2783 create are same file earlier

Pull Request - State: open - Opened by asautins over 1 year ago

#1682 - Fix race condition in ContainerStorageManager

Pull Request - State: closed - Opened by shekhars-li over 1 year ago - 1 comment

#1681 - SAMZA-2791: Introduce callback timeout specific to watermark messages

Pull Request - State: closed - Opened by mynameborat over 1 year ago - 1 comment

#1680 - SAMZA-2790: Cleanup RunLoop constructor explosion

Pull Request - State: closed - Opened by mynameborat over 1 year ago - 4 comments

#1679 - SAMZA-2789: Remove cap on intermediate stream partition count for stream mode

Pull Request - State: closed - Opened by mynameborat over 1 year ago - 1 comment

#1678 - SAMZA-2788: Add new metric to emit 1 when containers are processing

Pull Request - State: closed - Opened by Zhangyx39 over 1 year ago - 3 comments

#1677 - Add new SamzaApplicationMaster metric to track allocated containers buffered in AM

Pull Request - State: closed - Opened by jia-gao over 1 year ago

#1677 - Add new SamzaApplicationMaster metric to track allocated containers buffered in AM

Pull Request - State: closed - Opened by jia-gao over 1 year ago

#1676 - [SAMZA-2787] GetDeleted API and Recover from DeletedException

Pull Request - State: closed - Opened by shekhars-li over 1 year ago

#1675 - [SAMZA-2786] remove the docs gradle project

Pull Request - State: closed - Opened by li-afaris over 1 year ago - 2 comments

#1675 - [SAMZA-2786] remove the docs gradle project

Pull Request - State: closed - Opened by li-afaris over 1 year ago - 2 comments

#1674 - Close SystemConsumer properly

Pull Request - State: open - Opened by ryucc over 1 year ago - 6 comments

#1674 - Close SystemConsumer properly

Pull Request - State: open - Opened by ryucc over 1 year ago - 6 comments

#1673 - SAMZA-2778: Remove deprecated constructor.

Pull Request - State: open - Opened by ehoner over 1 year ago - 2 comments

#1672 - Authenticate GitHub Actions builds to ge.apache.org

Pull Request - State: closed - Opened by clayburn over 1 year ago

#1671 - Fix scope of caches for DirDiffUtil.areSameFile

Pull Request - State: closed - Opened by asautins over 1 year ago

#1670 - SAMZA-2776: Fix unused parameter - EventHubSystemConsumer

Pull Request - State: closed - Opened by ehoner over 1 year ago

#1669 - Re-factor DirDiffUtil.getDirDiff to traverse and test files once.

Pull Request - State: closed - Opened by asautins over 1 year ago - 10 comments

#1668 - SAMZA-2782: Clean up container thread pool DI into StreamOperatorTask

Pull Request - State: closed - Opened by mynameborat over 1 year ago

#1667 - SAMZA-2781: Use framework thread to execute hand-offs and sub-DAG execution

Pull Request - State: closed - Opened by mynameborat over 1 year ago

#1666 - SAMZA-2780: Implement ZkSystemEnvironmentSetter

Pull Request - State: closed - Opened by ryucc over 1 year ago - 6 comments

#1665 - Capture build scans on ge.apache.org to benefit from deep build insights

Pull Request - State: closed - Opened by clayburn over 1 year ago

#1664 - Removed unnecessary logging for configs

Pull Request - State: closed - Opened by prateekm almost 2 years ago - 1 comment

#1663 - Wait for pending commits to finish during shutdown.

Pull Request - State: open - Opened by prateekm almost 2 years ago - 2 comments

#1662 - SAMZA-2778: Make AzureBlobOutputStream buffer initialization size configurable.

Pull Request - State: closed - Opened by ehoner almost 2 years ago - 2 comments

#1661 - SAMZA-2777: Add support for GenericFixed to AzureBlobAvroWriter

Pull Request - State: closed - Opened by ehoner almost 2 years ago

#1661 - SAMZA-2777: Add support for GenericFixed to AzureBlobAvroWriter

Pull Request - State: closed - Opened by ehoner almost 2 years ago

#1660 - SAMZA-2776: Upgrade Azure libraries in module samza-azure.

Pull Request - State: closed - Opened by ehoner almost 2 years ago - 1 comment

#1659 - Only verify permissions for file owner after blob store restore.

Pull Request - State: closed - Opened by prateekm almost 2 years ago - 1 comment

#1659 - Only verify permissions for file owner after blob store restore.

Pull Request - State: closed - Opened by prateekm almost 2 years ago - 1 comment

#1658 - Changed uses of Apache Commons IO FileUtils.deleteDirectory to PathUtils.deleteDirectory

Pull Request - State: closed - Opened by prateekm almost 2 years ago - 1 comment

#1658 - Changed uses of Apache Commons IO FileUtils.deleteDirectory to PathUtils.deleteDirectory

Pull Request - State: closed - Opened by prateekm almost 2 years ago - 1 comment

#1657 - Side Inputs + Blob Store Backups - Part 2 - Allow bulk restore from blob store for side input stores

Pull Request - State: closed - Opened by prateekm almost 2 years ago - 1 comment

#1656 - Fixed line-length related formatting issues

Pull Request - State: closed - Opened by prateekm almost 2 years ago

#1655 - Refactored ContainerStorageManager for readability and manageability

Pull Request - State: closed - Opened by prateekm almost 2 years ago - 1 comment

#1654 - Side Inputs + Blob Store Backups - Part 1 - Fix duplicate uploads and broken metrics

Pull Request - State: closed - Opened by prateekm almost 2 years ago - 1 comment

#1654 - Side Inputs + Blob Store Backups - Part 1 - Fix duplicate uploads and broken metrics

Pull Request - State: closed - Opened by prateekm almost 2 years ago - 1 comment

#1653 - SAMZA-2774: Resolve classpath symlinks

Pull Request - State: closed - Opened by bringhurst almost 2 years ago - 2 comments

#1652 - Fix deadlock in StreamAppender

Pull Request - State: closed - Opened by jia-gao about 2 years ago

#1652 - Fix deadlock in StreamAppender

Pull Request - State: closed - Opened by jia-gao about 2 years ago

#1651 - [SAMZA-2773] Migrate zkclient library

Pull Request - State: closed - Opened by ryucc about 2 years ago

#1650 - Make blob store related retry tunables configurable

Pull Request - State: closed - Opened by shekhars-li about 2 years ago

#1650 - Make blob store related retry tunables configurable

Pull Request - State: closed - Opened by shekhars-li about 2 years ago

#1649 - [Docs] Samza 1.8.0 release website updates

Pull Request - State: closed - Opened by ajothomas about 2 years ago

#1648 - Update RocksDB to version 7.8.3 to reduce write amplification

Pull Request - State: closed - Opened by shekhars-li about 2 years ago - 1 comment

#1647 - [SAMZA-2772] Manage Jekyll dependencies with Gradle

Pull Request - State: closed - Opened by li-afaris about 2 years ago - 5 comments

#1646 - [Docs] Add Ajo Thomas to committers list and GPG keys

Pull Request - State: closed - Opened by ajothomas about 2 years ago

#1646 - [Docs] Add Ajo Thomas to committers list and GPG keys

Pull Request - State: closed - Opened by ajothomas about 2 years ago

#1645 - Fix restore factory not configured log

Pull Request - State: closed - Opened by dxichen about 2 years ago

#1645 - Fix restore factory not configured log

Pull Request - State: closed - Opened by dxichen about 2 years ago

#1644 - Fix performance bug in kafka/blobstore commit lifecycle.

Pull Request - State: closed - Opened by shekhars-li about 2 years ago

#1643 - SAMZA-2770: [Pipeline Drain] Enable drain monitor by default

Pull Request - State: closed - Opened by ajothomas about 2 years ago

#1642 - SAMZA-2769: [PipelineDrain] Add drainMode to DrainNotification

Pull Request - State: closed - Opened by ajothomas about 2 years ago

#1641 - LISAMZA-27395 removing the current recursive call prevention logic

Pull Request - State: closed - Opened by jia-gao about 2 years ago - 5 comments

#1640 - SAMZA-2741: [Pipeline Drain] Fix ApplicationUtil.isHighLevelApiJob to work for anonymous and lambda `SamzaApplication` classes

Pull Request - State: closed - Opened by ajothomas about 2 years ago

#1639 - SAMZA-2741: [Pipeline Drain] Fix processing of Drain messages for High-Level and Low-level API

Pull Request - State: closed - Opened by ajothomas over 2 years ago

#1638 - SAMZA-2764: add the metric "container-active-threads" back

Pull Request - State: closed - Opened by alnzng over 2 years ago - 1 comment

#1637 - SAMZA-2765: [Pipeline Drain] Adding config for task callback timeout during drain

Pull Request - State: closed - Opened by ajothomas over 2 years ago

#1636 - SAMZA-2762: new cpu usage metric which counts child processes usage

Pull Request - State: closed - Opened by alnzng over 2 years ago - 2 comments

#1635 - SAMZA-2763: Support worker JVM opts for Samza Beam portable mode

Pull Request - State: closed - Opened by mynameborat over 2 years ago - 1 comment

#1634 - Update zookeeper and kazoo version

Pull Request - State: closed - Opened by PawasChhokra over 2 years ago

#1633 - Add GraalSystems in "powered-by"

Pull Request - State: open - Opened by Treydone over 2 years ago - 2 comments

#1632 - Bump addressable from 2.5.2 to 2.8.1 in /docs

Pull Request - State: closed - Opened by dependabot[bot] over 2 years ago - 2 comments
Labels: dependencies

#1632 - Bump addressable from 2.5.2 to 2.8.1 in /docs

Pull Request - State: closed - Opened by dependabot[bot] over 2 years ago - 2 comments
Labels: dependencies

#1631 - emit to diagnostic kafka topic in round robin fashion to support increasing this topic partition count

Pull Request - State: closed - Opened by jia-gao over 2 years ago - 7 comments

#1630 - SAMZA-2758: Upgrade vulnerable versions jetty and jackson

Pull Request - State: closed - Opened by perkss over 2 years ago - 3 comments

#1630 - SAMZA-2758: Upgrade vulnerable versions jetty and jackson

Pull Request - State: closed - Opened by perkss over 2 years ago - 3 comments

#1629 - SAMZA-2741: [Pipeline Drain] Simplifying DrainUtils writeDrainNotification method and change tests

Pull Request - State: closed - Opened by ajothomas over 2 years ago

GitHub / apache/samza issues and pull requests