[jira] [Commented] (BEAM-600) Add TestCountingSource option to specify the number of splits returned by generateInitialSplits

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

[GitHub] incubator-beam pull request #902: [BEAM-600] Add TestCountingSource option t...

GitHub user drieber opened a pull request: https://github.com/apache/incubator-beam/pull/902 [BEAM-600] Add TestCountingSource option to specify the number of splits returned by generateInitialSplits. Be sure to do all of the following to help us incorporate your contribution

[jira] [Created] (BEAM-600) Add TestCountingSource option to specify the number of splits returned by generateInitialSplits

David Rieber created BEAM-600: - Summary: Add TestCountingSource option to specify the number of splits returned by generateInitialSplits Key: BEAM-600 URL: https://issues.apache.org/jira/browse/BEAM-600

[jira] [Commented] (BEAM-15) Applying windowing to cached RDDs fails

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

[GitHub] incubator-beam pull request #901: [BEAM-15] Fixed StorageLevel inconsistency...

GitHub user staslev opened a pull request: https://github.com/apache/incubator-beam/pull/901 [BEAM-15] Fixed StorageLevel inconsistency between DStream and RDD Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make

[GitHub] incubator-beam pull request #900: [BEAM-599] Return KafkaIO getWatermark log...

GitHub user aviemzur opened a pull request: https://github.com/apache/incubator-beam/pull/900 [BEAM-599] Return KafkaIO getWatermark log line in debug mode Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure

[jira] [Commented] (BEAM-599) Return KafkaIO getWatermark log in debug mode

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

[jira] [Updated] (BEAM-599) Return KafkaIO getWatermark log in debug mode

[ https://issues.apache.org/jira/browse/BEAM-599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aviem Zur updated BEAM-599: --- Description: https://issues.apache.org/jira/browse/BEAM-574 removes the getWatermark log line from KafkaIO PR:

[jira] [Created] (BEAM-599) Return KafkaIO getWatermark log in debug mode

Aviem Zur created BEAM-599: -- Summary: Return KafkaIO getWatermark log in debug mode Key: BEAM-599 URL: https://issues.apache.org/jira/browse/BEAM-599 Project: Beam Issue Type: Improvement