[DISCUSS] Change Apache Samza git comments/merge email recipient to commits@samza

2019-04-04 Thread Xinyu Liu
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

[GitHub] [samza] Zhangyx39 commented on a change in pull request #982: SAMZA-2153: Implement to Config for TableRetryPolicy

2019-04-04 Thread GitBox
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 ## @@

[GitHub] [samza] Zhangyx39 commented on a change in pull request #982: SAMZA-2153: Implement to Config for TableRetryPolicy

2019-04-04 Thread GitBox
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

[GitHub] [samza] prateekm commented on a change in pull request #985: SAMZA-2155: Remove log4j log4j2 dependency from samza-test

2019-04-04 Thread GitBox
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") {

[GitHub] [samza] rayman7718 closed pull request #542: JIRA: SAMZA-1733 Specify MetricsSnapshotStream partitionKey in config

2019-04-04 Thread GitBox
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

[GitHub] [samza] prateekm commented on a change in pull request #984: Samza 2116: Making sink, sendTo(table), sendTo(stream) non-terminal

2019-04-04 Thread GitBox
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

[GitHub] [samza] rmatharu commented on a change in pull request #985: SAMZA-2155: Remove log4j log4j2 dependency from samza-test

2019-04-04 Thread GitBox
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") {

[GitHub] [samza] prateekm commented on a change in pull request #985: SAMZA-2155: Remove log4j log4j2 dependency from samza-test

2019-04-04 Thread GitBox
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") {

[GitHub] [samza] prateekm commented on a change in pull request #984: Samza 2116: Making sink, sendTo(table), sendTo(stream) non-terminal

2019-04-04 Thread GitBox
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

[GitHub] [samza] prateekm commented on a change in pull request #984: Samza 2116: Making sink, sendTo(table), sendTo(stream) non-terminal

2019-04-04 Thread GitBox
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

[GitHub] [samza] prateekm commented on a change in pull request #984: Samza 2116: Making sink, sendTo(table), sendTo(stream) non-terminal

2019-04-04 Thread GitBox
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

[GitHub] [samza] weisong44 commented on a change in pull request #982: SAMZA-2153: Implement to Config for TableRetryPolicy

2019-04-04 Thread GitBox
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 ## @@

[GitHub] [samza] weisong44 commented on a change in pull request #982: SAMZA-2153: Implement to Config for TableRetryPolicy

2019-04-04 Thread GitBox
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

Re: Context when Converting from Yarn Task to Standalone LocalApplicationRunner

2019-04-04 Thread Jeremiah Adams
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