[jira] [Commented] (SAMZA-1143) Universal config support for localized resource

[ https://issues.apache.org/jira/browse/SAMZA-1143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958312#comment-15958312 ] ASF GitHub Bot commented on SAMZA-1143: --- Github user asfgit closed the pull request at:

samza git commit: SAMZA-1143; Include fs..impl.* subkeys to YarnConfiguration used in YarnJobFactory and YarnClusterResourceManager

Repository: samza Updated Branches: refs/heads/master b5e45b7ec -> c1b778a01 SAMZA-1143; Include fs..impl.* subkeys to YarnConfiguration used in YarnJobFactory and YarnClusterResourceManager SAMZA-1143 Include fs.scheme.impl.* subkeys, in addition tofs.scheme.impl, to YarnConfiguration used

[jira] [Commented] (SAMZA-1191) Flaky test: TestExponentialSleepStrategy testThreadInterruptInRetryLoop

[ https://issues.apache.org/jira/browse/SAMZA-1191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958311#comment-15958311 ] ASF GitHub Bot commented on SAMZA-1191: --- Github user asfgit closed the pull request at:

samza git commit: SAMZA-1191; Fixed flaky test: TestExponentialSleepStrategy testThreadInterruptInRetryLoop

Repository: samza Updated Branches: refs/heads/master 4bf8ab6eb -> b5e45b7ec SAMZA-1191; Fixed flaky test: TestExponentialSleepStrategy testThreadInterruptInRetryLoop It's possible that the interruptee thread (see `#interruptedThread`) gets pre-empted before it has a chance to run the

[jira] [Commented] (SAMZA-1191) Flaky test: TestExponentialSleepStrategy testThreadInterruptInRetryLoop

[ https://issues.apache.org/jira/browse/SAMZA-1191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958145#comment-15958145 ] ASF GitHub Bot commented on SAMZA-1191: --- GitHub user prateekm opened a pull request:

[jira] [Created] (SAMZA-1191) Flaky test: TestExponentialSleepStrategy testThreadInterruptInRetryLoop

Prateek Maheshwari created SAMZA-1191: - Summary: Flaky test: TestExponentialSleepStrategy testThreadInterruptInRetryLoop Key: SAMZA-1191 URL: https://issues.apache.org/jira/browse/SAMZA-1191

[jira] [Created] (SAMZA-1190) Flaky unit tests

Prateek Maheshwari created SAMZA-1190: - Summary: Flaky unit tests Key: SAMZA-1190 URL: https://issues.apache.org/jira/browse/SAMZA-1190 Project: Samza Issue Type: Bug Affects

[jira] [Commented] (SAMZA-1094) Removal of MessageEnvelope class from the top-level API

[ https://issues.apache.org/jira/browse/SAMZA-1094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15958038#comment-15958038 ] ASF GitHub Bot commented on SAMZA-1094: --- Github user asfgit closed the pull request at:

[2/4] samza git commit: SAMZA-1094 SAMZA-1101 SAMZA-1159; Remove MessageEnvelope from public operator APIs. : Delay the creation of SinkFunction for output streams. : Move StreamSpec from a public API

http://git-wip-us.apache.org/repos/asf/samza/blob/4bf8ab6e/samza-core/src/test/java/org/apache/samza/example/TestBroadcastExample.java -- diff --git a/samza-core/src/test/java/org/apache/samza/example/TestBroadcastExample.java

[4/4] samza git commit: SAMZA-1094 SAMZA-1101 SAMZA-1159; Remove MessageEnvelope from public operator APIs. : Delay the creation of SinkFunction for output streams. : Move StreamSpec from a public API

SAMZA-1094 SAMZA-1101 SAMZA-1159; Remove MessageEnvelope from public operator APIs. : Delay the creation of SinkFunction for output streams. : Move StreamSpec from a public API to an internal class. Removed the MessageEnvelope and OutputStream interfaces from public operator APIs. Moved the

[1/4] samza git commit: SAMZA-1094 SAMZA-1101 SAMZA-1159; Remove MessageEnvelope from public operator APIs. : Delay the creation of SinkFunction for output streams. : Move StreamSpec from a public API

Repository: samza Updated Branches: refs/heads/master 65af13df1 -> 4bf8ab6eb http://git-wip-us.apache.org/repos/asf/samza/blob/4bf8ab6e/samza-core/src/test/java/org/apache/samza/operators/triggers/TestWindowOperator.java --

[jira] [Resolved] (SAMZA-1180) RocksDB config "stores.store-name.container. cache.size.bytes" does not take into account the number of KVStores per task

[ https://issues.apache.org/jira/browse/SAMZA-1180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes resolved SAMZA-1180. -- Resolution: Not A Problem I'm not smart sometimes. The config table clearly specifies these values per