[GitHub] incubator-beam pull request #907: Test that multiple instances of TestStream...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/907 Test that multiple instances of TestStream are supported Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR

[jira] [Updated] (BEAM-92) Data-dependent sinks

[ https://issues.apache.org/jira/browse/BEAM-92?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-92: Assignee: Vikas Kedigehalli > Data-dependent sinks > > > Key:

[jira] [Commented] (BEAM-604) Use Watermark Check Streaming Job Finish in TestDataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15450087#comment-15450087 ] Pei He commented on BEAM-604: - agree. But, before that happens, we can easily support this functionality in

[jira] [Commented] (BEAM-604) Use Watermark Check Streaming Job Finish in TestDataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15450084#comment-15450084 ] Pei He commented on BEAM-604: - Consider implement it in DataflowPipelineJob.waitUntilFinish()

[jira] [Updated] (BEAM-603) Update python sdk README examples

[ https://issues.apache.org/jira/browse/BEAM-603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] María GH updated BEAM-603: -- Summary: Update python sdk README examples (was: Update python sdk README) > Update python sdk README examples >

[jira] [Resolved] (BEAM-569) JMS IO should set maxNumRecords to Long.MAX_VALUE by default

[ https://issues.apache.org/jira/browse/BEAM-569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jean-Baptiste Onofré resolved BEAM-569. --- Resolution: Fixed > JMS IO should set maxNumRecords to Long.MAX_VALUE by default >

[GitHub] incubator-beam pull request #898: [BEAM-569] Define maxNumRecords default va...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/898 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (BEAM-569) JMS IO should set maxNumRecords to Long.MAX_VALUE by default

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

[2/2] incubator-beam git commit: [BEAM-569] This closes #898

[BEAM-569] This closes #898 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/33d747ef Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/33d747ef Diff:

[1/2] incubator-beam git commit: [BEAM-569] Define maxNumRecords default value to Long.MAX_VALUE in JmsIO

Repository: incubator-beam Updated Branches: refs/heads/master 92451d071 -> 33d747efa [BEAM-569] Define maxNumRecords default value to Long.MAX_VALUE in JmsIO Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request #854: Add LeaderBoardTest

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/854 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[1/2] incubator-beam git commit: Add LeaderBoardTest

Repository: incubator-beam Updated Branches: refs/heads/master e3d170c13 -> 92451d071 Add LeaderBoardTest This test exercises the PTransforms that make up the LeaderBoard example. This includes speculative and late trigger firings to produce team and individual scores on a global and fixed

[2/2] incubator-beam git commit: Add LeaderBoardTest

Add LeaderBoardTest This closes #854 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/92451d07 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/92451d07 Diff:

[jira] [Commented] (BEAM-604) Use Watermark Check Streaming Job Finish in TestDataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15449381#comment-15449381 ] Mark Liu commented on BEAM-604: --- Right. [~pei...@gmail.com] may have some context on this. > Use Watermark

[jira] [Updated] (BEAM-604) Use Watermark Check Streaming Job Finish in TestDataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-604: --- Issue Type: Improvement (was: Bug) > Use Watermark Check Streaming Job Finish in TestDataflowRunner >

[jira] [Updated] (BEAM-604) Use Watermark Check Streaming Job Finish in TestDataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-604: --- Priority: Minor (was: Major) > Use Watermark Check Streaming Job Finish in TestDataflowRunner >

[jira] [Commented] (BEAM-604) Use Watermark Check Streaming Job Finish in TestDataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15449366#comment-15449366 ] Luke Cwik commented on BEAM-604: Would be better if the Dataflow service just shutdown jobs that hit max

[jira] [Created] (BEAM-606) Create MqttIO

Jean-Baptiste Onofré created BEAM-606: - Summary: Create MqttIO Key: BEAM-606 URL: https://issues.apache.org/jira/browse/BEAM-606 Project: Beam Issue Type: New Feature

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1052

See