ajothomas commented on code in PR #1639:
URL: https://github.com/apache/samza/pull/1639#discussion_r1013123301
##
samza-core/src/main/java/org/apache/samza/container/RunLoop.java:
##
@@ -875,49 +876,40 @@ private boolean shouldDrain() {
return false;
}
- i
ajothomas commented on code in PR #1639:
URL: https://github.com/apache/samza/pull/1639#discussion_r1013123456
##
samza-core/src/main/java/org/apache/samza/container/RunLoop.java:
##
@@ -875,49 +876,40 @@ private boolean shouldDrain() {
return false;
}
- i
ajothomas commented on code in PR #1639:
URL: https://github.com/apache/samza/pull/1639#discussion_r1013123821
##
samza-test/src/test/java/org/apache/samza/test/drain/DrainHighLevelApiIntegrationTest.java:
##
@@ -74,20 +74,30 @@ public void describe(StreamApplicationDescriptor
xinyuiscool merged PR #1639:
URL: https://github.com/apache/samza/pull/1639
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@samza.ap
This is an automated email from the ASF dual-hosted git repository.
xinyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git
The following commit(s) were added to refs/heads/master by this push:
new 3d4747c5c SAMZA-2741: Pipeline Drain- Fix processi
mynameborat commented on code in PR #1637:
URL: https://github.com/apache/samza/pull/1637#discussion_r1013403151
##
samza-core/src/main/java/org/apache/samza/task/TaskCallbackManager.java:
##
@@ -106,7 +110,10 @@ public void run() {
callback.failure(new SamzaException
mynameborat merged PR #1638:
URL: https://github.com/apache/samza/pull/1638
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@samza.ap
This is an automated email from the ASF dual-hosted git repository.
bharathkk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git
The following commit(s) were added to refs/heads/master by this push:
new 95a0c3334 add the metric "container-active-thr