Hi, All,
Our dev mailing list has been flooded with github comments/merges so it's
really hard to see the meaningful discussions and user engagement. Shall we
move dev@Samza off the JIRA/github messages? We will use
comm...@samza.apache.org as the recipients.
In addition, I think we should have
Zhangyx39 commented on a change in pull request #982: SAMZA-2153: Implement to
Config for TableRetryPolicy
URL: https://github.com/apache/samza/pull/982#discussion_r272306302
##
File path:
samza-api/src/main/java/org/apache/samza/table/retry/TableRetryPolicy.java
##
@@
Zhangyx39 commented on a change in pull request #982: SAMZA-2153: Implement to
Config for TableRetryPolicy
URL: https://github.com/apache/samza/pull/982#discussion_r272306285
##
File path:
samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java
prateekm commented on a change in pull request #985: SAMZA-2155: Remove log4j
log4j2 dependency from samza-test
URL: https://github.com/apache/samza/pull/985#discussion_r272291959
##
File path: build.gradle
##
@@ -819,8 +819,6 @@ project(":samza-test_$scalaSuffix") {
rayman7718 closed pull request #542: JIRA: SAMZA-1733 Specify
MetricsSnapshotStream partitionKey in config
URL: https://github.com/apache/samza/pull/542
This is an automated message from the Apache Git Service.
To respond
prateekm commented on a change in pull request #984: Samza 2116: Making sink,
sendTo(table), sendTo(stream) non-terminal
URL: https://github.com/apache/samza/pull/984#discussion_r272282281
##
File path:
samza-api/src/main/java/org/apache/samza/operators/MessageStream.java
rmatharu commented on a change in pull request #985: SAMZA-2155: Remove log4j
log4j2 dependency from samza-test
URL: https://github.com/apache/samza/pull/985#discussion_r272281320
##
File path: build.gradle
##
@@ -819,8 +819,6 @@ project(":samza-test_$scalaSuffix") {
prateekm commented on a change in pull request #985: SAMZA-2155: Remove log4j
log4j2 dependency from samza-test
URL: https://github.com/apache/samza/pull/985#discussion_r272269026
##
File path: build.gradle
##
@@ -819,8 +819,6 @@ project(":samza-test_$scalaSuffix") {
prateekm commented on a change in pull request #984: Samza 2116: Making sink,
sendTo(table), sendTo(stream) non-terminal
URL: https://github.com/apache/samza/pull/984#discussion_r272253480
##
File path:
samza-core/src/main/java/org/apache/samza/operators/MessageStreamImpl.java
prateekm commented on a change in pull request #984: Samza 2116: Making sink,
sendTo(table), sendTo(stream) non-terminal
URL: https://github.com/apache/samza/pull/984#discussion_r272252941
##
File path:
samza-api/src/main/java/org/apache/samza/operators/functions/SinkFunction.java
prateekm commented on a change in pull request #984: Samza 2116: Making sink,
sendTo(table), sendTo(stream) non-terminal
URL: https://github.com/apache/samza/pull/984#discussion_r272252096
##
File path:
samza-api/src/main/java/org/apache/samza/operators/MessageStream.java
weisong44 commented on a change in pull request #982: SAMZA-2153: Implement to
Config for TableRetryPolicy
URL: https://github.com/apache/samza/pull/982#discussion_r272237553
##
File path:
samza-api/src/main/java/org/apache/samza/table/retry/TableRetryPolicy.java
##
@@
weisong44 commented on a change in pull request #982: SAMZA-2153: Implement to
Config for TableRetryPolicy
URL: https://github.com/apache/samza/pull/982#discussion_r272238645
##
File path:
samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java
Thanks for the clarification. I completely missed that there
LocalApplicationRunner could accept a TaskApplication. The javadocs are
actually hard to find.
Jeremiah Adams
Software Engineer
www.helixeducation.com
Blog | Twitter | Facebook | LinkedIn
14 matches
Mail list logo