----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/44405/ -----------------------------------------------------------
Review request for samza, Boris Shkolnik, Jake Maes, Jagadish Venkatraman, Xinyu Liu, and Yi Pan (Data Infrastructure). Bugs: SAMZA-882 https://issues.apache.org/jira/browse/SAMZA-882 Repository: samza Description ------- Adding loop.done in stream metadata cache Adding comments in Test Adding configuration to the docs Fixing the swallowed exception from Scala immutable map Updating config docs Fixed some comments and javadoc Diffs ----- docs/learn/documentation/versioned/jobs/configuration-table.html 2745a22daf3626db56da2bedad07690751a34a27 samza-api/src/main/java/org/apache/samza/system/ExtendedSystemAdmin.java PRE-CREATION samza-core/src/main/scala/org/apache/samza/config/JobConfig.scala 4f3e9a297ce2c0df0f5f25e0aad62f7bed774cd6 samza-core/src/main/scala/org/apache/samza/coordinator/JobCoordinator.scala 06a96ad6ed786c22924017f894413bfa1ea34c06 samza-core/src/main/scala/org/apache/samza/coordinator/StreamPartitionCountMonitor.scala PRE-CREATION samza-core/src/main/scala/org/apache/samza/system/StreamMetadataCache.scala 155c3d16d33d9bb9cd5410d786004c1bf2a57ed3 samza-core/src/main/scala/org/apache/samza/util/Util.scala bd0fe5fc8128c59fa6d08941ad88eed66dda622b samza-core/src/test/scala/org/apache/samza/coordinator/TestJobCoordinator.scala 9ab1dd516871b1755ef64fa25cea47491ad781e2 samza-core/src/test/scala/org/apache/samza/coordinator/TestStreamPartitionCountMonitor.scala PRE-CREATION samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemAdmin.scala 9dc436a40afd7190626a8be0d716c70e0fe83c7a samza-yarn/src/test/java/org/apache/samza/job/yarn/TestContainerAllocator.java e2b45d7577dea5a4a71af22521c93a7fd75eaefc samza-yarn/src/test/java/org/apache/samza/job/yarn/TestHostAwareContainerAllocator.java 269d82479650b3bc2890d250da0391d34104b1eb samza-yarn/src/test/java/org/apache/samza/job/yarn/TestSamzaTaskManager.java 88d9f24d16fc3d9842b387cfc22edaf1dfa6fd06 Diff: https://reviews.apache.org/r/44405/diff/ Testing ------- ./gradlew clean build Tested with a simple Samza job using hello-samza -> Verified that the metrics gauge is getting updated and published correctly. Thanks, Navina Ramesh