[GitHub] samza pull request #591: SAMZA-1733: Adding filter mechanism to MetricsSnaps...

Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/591 ---

[GitHub] samza pull request #596: SAMZA-1733: Defaulting to non-null serde, in case n...

GitHub user rmatharu opened a pull request: https://github.com/apache/samza/pull/596 SAMZA-1733: Defaulting to non-null serde, in case none is specified Currently, if no system or stream serde is specified the SnapshotReporter simply crashes because a MetricsSnapshot cannot be

[GitHub] samza pull request #568: Samza 1759: Stream Assert utilities for low level a...

Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/568 ---

[GitHub] samza pull request #595: SAMZA-1796: PassthroughJobCoordinator doesn't creat...

Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/595 ---

[GitHub] samza pull request #595: SAMZA-1796: PassthroughJobCoordinator doesn't creat...

GitHub user xinyuiscool opened a pull request: https://github.com/apache/samza/pull/595 SAMZA-1796: PassthroughJobCoordinator doesn't create changelog streams Currently only the ClusterBasedJobCoordinator and ZkJobCoordinator are creating changelog streams. The Passthrough one shoul

[GitHub] samza pull request #592: SAMZA-1794: setting application acl in launch conte...

Github user asfgit closed the pull request at: https://github.com/apache/samza/pull/592 ---

[GitHub] samza pull request #594: SideInput: Added tests and fixed serde issue during...

GitHub user bharathkk opened a pull request: https://github.com/apache/samza/pull/594 SideInput: Added tests and fixed serde issue during writing offsets - Fixed serde issues during persisted offsets locally - Added unit tests for TaskSideInputStorageManager - Added integrati