apache/samza issues and pull requests

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

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

#1695 - SAMZA-2784: Remove excessive commit logs

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

#1694 - Add MAX_BACKGROUND_JOBS config for RocksDB

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

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

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

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

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

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

Pull Request - State: closed - Opened by mynameborat 7 months ago - 1 comment

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

Pull Request - State: closed - Opened by mynameborat 8 months ago

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

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

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

Pull Request - State: open - Opened by Agonnee 9 months ago

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

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

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

Pull Request - State: closed - Opened by guanjun1 10 months ago - 2 comments

#1685 - Clear exit path in ContainerLaunchUtil

Pull Request - State: closed - Opened by guanjun1 10 months ago

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

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

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

Pull Request - State: open - Opened by asautins 11 months ago

#1682 - Fix race condition in ContainerStorageManager

Pull Request - State: closed - Opened by shekhars-li 11 months ago - 1 comment

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

Pull Request - State: closed - Opened by mynameborat 11 months ago - 1 comment

#1680 - SAMZA-2790: Cleanup RunLoop constructor explosion

Pull Request - State: closed - Opened by mynameborat 11 months ago - 4 comments

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

Pull Request - State: closed - Opened by mynameborat 11 months ago - 1 comment

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

Pull Request - State: closed - Opened by Zhangyx39 11 months ago - 3 comments

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

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

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

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

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

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

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

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

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

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

#1674 - Close SystemConsumer properly

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

#1674 - Close SystemConsumer properly

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

#1673 - SAMZA-2778: Remove deprecated constructor.

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

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

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

#1671 - Fix scope of caches for DirDiffUtil.areSameFile

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

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

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

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

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

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

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

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

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

#1666 - SAMZA-2780: Implement ZkSystemEnvironmentSetter

Pull Request - State: closed - Opened by ryucc about 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 about 1 year ago

#1664 - Removed unnecessary logging for configs

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

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

Pull Request - State: open - Opened by prateekm about 1 year ago - 2 comments

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

Pull Request - State: closed - Opened by ehoner about 1 year ago - 2 comments

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

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

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

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

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

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

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

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

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

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

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

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

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

Pull Request - State: closed - Opened by prateekm over 1 year 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 over 1 year ago - 1 comment

#1656 - Fixed line-length related formatting issues

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

#1655 - Refactored ContainerStorageManager for readability and manageability

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

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

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

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

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

#1653 - SAMZA-2774: Resolve classpath symlinks

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

#1652 - Fix deadlock in StreamAppender

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

#1652 - Fix deadlock in StreamAppender

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

#1651 - [SAMZA-2773] Migrate zkclient library

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

#1650 - Make blob store related retry tunables configurable

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

#1650 - Make blob store related retry tunables configurable

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

#1649 - [Docs] Samza 1.8.0 release website updates

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

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

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

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

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

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

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

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

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

#1645 - Fix restore factory not configured log

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

#1645 - Fix restore factory not configured log

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

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

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

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

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

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

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

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

Pull Request - State: closed - Opened by jia-gao over 1 year 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 over 1 year 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 1 year ago

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

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

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

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

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

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

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

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

#1634 - Update zookeeper and kazoo version

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

#1633 - Add GraalSystems in "powered-by"

Pull Request - State: open - Opened by Treydone over 1 year 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 1 year 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 1 year 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 almost 2 years ago - 7 comments

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

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

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

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

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

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

#1628 - SAMZA-2757: Make Samza Compatible with Java 11

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

#1627 - Make StreamAppender extensible for sending event to SystemProducer

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

#1627 - Make StreamAppender extensible for sending event to SystemProducer

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

#1626 - Revert elasticity commits - bug found with broadcast input

Pull Request - State: closed - Opened by lakshmi-manasa-g almost 2 years ago - 1 comment

#1625 - remove keyBucket from checkpoint serde to allow for simpler rollback

Pull Request - State: closed - Opened by lakshmi-manasa-g almost 2 years ago

#1624 - Bump redcarpet from 3.4.0 to 3.5.1 in /docs

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

#1624 - Bump redcarpet from 3.4.0 to 3.5.1 in /docs

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

#1623 - Bump json from 2.1.0 to 2.3.0 in /docs

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

#1623 - Bump json from 2.1.0 to 2.3.0 in /docs

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

#1622 - Bump addressable from 2.5.2 to 2.8.0 in /docs

Pull Request - State: closed - Opened by dependabot[bot] almost 2 years ago - 1 comment
Labels: dependencies

#1621 - Bump ffi from 1.9.23 to 1.15.5 in /docs

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

#1618 - SAMZA-2754: Set default scala suffix to 2.12

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

#1618 - SAMZA-2754: Set default scala suffix to 2.12

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

#1616 - SAMZA-2751: [Pipeline Drain] RunLoop and High Level API changes for Drain

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

#1606 - Fixed check for files both present and removed in DirIndex. Added a check for blobs too.

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

#1606 - Fixed check for files both present and removed in DirIndex. Added a check for blobs too.

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

#1570 - Made ContainerStorageManager restore non-blocking to prevent deadlock when num restoreExecutor threads <= num tasks

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

#1555 - Improve GRADLE build Performance

Pull Request - State: open - Opened by shisheng-1 over 2 years ago - 1 comment

#1552 - Upgrading kafka to 2.4

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

GitHub / apache/samza issues and pull requests