[jira] [Commented] (BEAM-1061) PreCommit test with side inputs

[ https://issues.apache.org/jira/browse/BEAM-1061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15707749#comment-15707749 ] Daniel Halperin commented on BEAM-1061: --- It is covered by ROS tests, but they do not

[jira] [Commented] (BEAM-1062) Shade SDK based on a whitelist instead of a blacklist

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

[GitHub] incubator-beam pull request #1462: [BEAM-1062] Shade the SDK more fully; eve...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1462 [BEAM-1062] Shade the SDK more fully; everything but a whitelist Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make

[jira] [Created] (BEAM-1062) Shade SDK based on a whitelist instead of a blacklist

Kenneth Knowles created BEAM-1062: - Summary: Shade SDK based on a whitelist instead of a blacklist Key: BEAM-1062 URL: https://issues.apache.org/jira/browse/BEAM-1062 Project: Beam Issue Type

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1685

See

[jira] [Commented] (BEAM-1061) PreCommit test with side inputs

[ https://issues.apache.org/jira/browse/BEAM-1061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15707206#comment-15707206 ] Luke Cwik commented on BEAM-1061: - Is this not covered by the RunnableOnService tests found

[jira] [Created] (BEAM-1061) PreCommit test with side inputs

Daniel Halperin created BEAM-1061: - Summary: PreCommit test with side inputs Key: BEAM-1061 URL: https://issues.apache.org/jira/browse/BEAM-1061 Project: Beam Issue Type: Test Compo

[2/2] incubator-beam git commit: Closes #1460

Closes #1460 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8042d52f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8042d52f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff

[1/2] incubator-beam git commit: Revert "Remove WindowedValue.valueInEmptyWindows"

Repository: incubator-beam Updated Branches: refs/heads/master b1f7013d8 -> 8042d52fc Revert "Remove WindowedValue.valueInEmptyWindows" This reverts commit 0e49b150e83d85ae432c640da937a9497068e71b, which breaks some DataflowRunner integration tests. Project: http://git-wip-us.apache.org/repo

[jira] [Created] (BEAM-1060) Make DoFnTester use new DoFn

Eugene Kirpichov created BEAM-1060: -- Summary: Make DoFnTester use new DoFn Key: BEAM-1060 URL: https://issues.apache.org/jira/browse/BEAM-1060 Project: Beam Issue Type: Improvement

[jira] [Commented] (BEAM-1060) Make DoFnTester use new DoFn

[ https://issues.apache.org/jira/browse/BEAM-1060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15707197#comment-15707197 ] ASF GitHub Bot commented on BEAM-1060: -- GitHub user jkff opened a pull request: h

[GitHub] incubator-beam pull request #1460: Revert "Remove WindowedValue.valueInEmpty...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1460 --- 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 featur

[GitHub] incubator-beam pull request #1461: [BEAM-1060] Makes DoFnTester use new DoFn...

GitHub user jkff opened a pull request: https://github.com/apache/incubator-beam/pull/1461 [BEAM-1060] Makes DoFnTester use new DoFn internally. There were 2 remaining users of DoFnTester.of(OldDoFn): - SplittableParDo.ProcessElements: this is fixed in https://github.com/ap

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1684

See

[GitHub] incubator-beam pull request #1458: Restore a private ValueInEmptyWindows to ...

Github user kennknowles closed the pull request at: https://github.com/apache/incubator-beam/pull/1458 --- 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 f

[jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions

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

[GitHub] incubator-beam pull request #1460: Revert "Remove WindowedValue.valueInEmpty...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1460 Revert "Remove WindowedValue.valueInEmptyWindows" Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR tit

[GitHub] incubator-beam pull request #1459: [BEAM-551] Changes to BigQuery validation...

GitHub user sammcveety opened a pull request: https://github.com/apache/incubator-beam/pull/1459 [BEAM-551] Changes to BigQuery validation to support dynamic values R: @dhalperi You can merge this pull request into a Git repository by running: $ git pull https://github.com/sam

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1683

See

[1/2] incubator-beam git commit: This closes #1382

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 5ce75a2ea -> 70c1de9b9 This closes #1382 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/70c1de9b Tree: http://git-wip-us.apache.org/repo

[2/2] incubator-beam git commit: Support ValidatesRunner Attribute in Python

Support ValidatesRunner Attribute in Python This is roughly equivalent to "RunnableOnService" in the Java SDK. See BEAM-655 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/81e7a0f6 Tree: http://git-wip-us.ap

[GitHub] incubator-beam pull request #1457: Remove TransformApplicationsForTesting

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1457 --- 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 featur

[2/2] incubator-beam git commit: This closes #1457

This closes #1457 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b1f7013d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b1f7013d Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam

[1/2] incubator-beam git commit: Remove TransformApplicationsForTesting

Repository: incubator-beam Updated Branches: refs/heads/master 8d127beb8 -> b1f7013d8 Remove TransformApplicationsForTesting This field is mutated but never queried. Remove Pipeline#addValueInternal This method is never called and not suitable for use. Project: http://git-wip-us.apache.org

[GitHub] incubator-beam pull request #1458: Restore a private ValueInEmptyWindows to ...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1458 Restore a private ValueInEmptyWindows to DataflowRunner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the

[GitHub] incubator-beam pull request #1457: Remove TransformApplicationsForTesting

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/1457 Remove TransformApplicationsForTesting Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted l

[GitHub] incubator-beam pull request #1453: Update googledatastore version

Github user vikkyrk closed the pull request at: https://github.com/apache/incubator-beam/pull/1453 --- 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 featu

[2/2] incubator-beam git commit: Update googledatastore version

Update googledatastore version Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6c8c17a1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6c8c17a1 Diff: http://git-wip-us.apache.org/repos/asf/i

[1/2] incubator-beam git commit: Closes #1453

Repository: incubator-beam Updated Branches: refs/heads/python-sdk ad4dc87a4 -> 5ce75a2ea Closes #1453 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5ce75a2e Tree: http://git-wip-us.apache.org/repos/asf

[GitHub] incubator-beam pull request #1456: Testing travis python issue

GitHub user pabloem opened a pull request: https://github.com/apache/incubator-beam/pull/1456 Testing travis python issue Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like:

[GitHub] incubator-beam pull request #1455: Exploring travis issue in Python SDK's li...

Github user pabloem closed the pull request at: https://github.com/apache/incubator-beam/pull/1455 --- 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 featu

[GitHub] incubator-beam pull request #1455: Exploring travis issue in Python SDK's li...

GitHub user pabloem opened a pull request: https://github.com/apache/incubator-beam/pull/1455 Exploring travis issue in Python SDK's linux runs Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title i

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1682

See

Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1681

See

[jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions

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

[GitHub] incubator-beam pull request #1452: [BEAM-551] Add a test to demonstrate NVP ...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1452 --- 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 featur

[2/2] incubator-beam git commit: Closes #1452

Closes #1452 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8d127beb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8d127beb Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff

[1/2] incubator-beam git commit: Add a test demonstrating how to use ValueProvider with non-serializable data

Repository: incubator-beam Updated Branches: refs/heads/master 4ce85ed94 -> 8d127beb8 Add a test demonstrating how to use ValueProvider with non-serializable data Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/

[GitHub] incubator-beam pull request #1441: Fix double-close bug

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1441 --- 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 featur

[1/2] incubator-beam git commit: Fix double-close bug

Repository: incubator-beam Updated Branches: refs/heads/master 0d95d8c56 -> 4ce85ed94 Fix double-close bug The WritableByteChannel returned for GCS locations has a bug where calling close twice throws an Exception, so we cannot safely use AutoCloseable here. Project: http://git-wip-us.apach

[2/2] incubator-beam git commit: Closes #1441

Closes #1441 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4ce85ed9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4ce85ed9 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff

Jenkins build is back to stable : beam_PostCommit_MavenVerify #1936

See

[1/3] incubator-beam git commit: Transmit new DoFn, not OldDoFn, in Dataflow translator

Repository: incubator-beam Updated Branches: refs/heads/master 1716bfc49 -> 2f86a6ad0 Transmit new DoFn, not OldDoFn, in Dataflow translator Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f52ac3ec Tree:

[jira] [Commented] (BEAM-230) Remove WindowedValue#valueInEmptyWindows

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

[GitHub] incubator-beam pull request #1440: [BEAM-230] Remove WindowedValue.valueInEm...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1440 --- 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 featur

[1/2] incubator-beam git commit: This closes #1440

Repository: incubator-beam Updated Branches: refs/heads/master 2f86a6ad0 -> 0d95d8c56 This closes #1440 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0d95d8c5 Tree: http://git-wip-us.apache.org/repos/as

[2/2] incubator-beam git commit: Remove WindowedValue.valueInEmptyWindows

Remove WindowedValue.valueInEmptyWindows A value in empty windows expands to no values, so it can be dropped at any time, perhaps unintentionally. This has bitten runner authors, including Spark & Dataflow. While creating such a thing in memory is not automatically problematic, it is also not rea

[jira] [Commented] (BEAM-498) Make DoFnWithContext the new DoFn

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

[GitHub] incubator-beam pull request #1368: [BEAM-498] Transmit new DoFn in Dataflow ...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1368 --- 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 featur

[3/3] incubator-beam git commit: This closes #1368

This closes #1368 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2f86a6ad Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2f86a6ad Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam

[2/3] incubator-beam git commit: Update Dataflow worker to beam-master-20161129

Update Dataflow worker to beam-master-20161129 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c21167ce Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c21167ce Diff: http://git-wip

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_SparkLocal #261

See

Jenkins build became unstable: beam_PostCommit_MavenVerify #1935

See

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1679

See

[GitHub] incubator-beam pull request #1454: Move datastore example to cookbook

GitHub user vikkyrk opened a pull request: https://github.com/apache/incubator-beam/pull/1454 Move datastore example to cookbook Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted lik

[GitHub] incubator-beam pull request #1453: Update googledatastore version

GitHub user vikkyrk opened a pull request: https://github.com/apache/incubator-beam/pull/1453 Update googledatastore version Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like:

Jenkins build became unstable: beam_PostCommit_RunnableOnService_SparkLocal #260

See

[jira] [Commented] (BEAM-551) Support Dynamic PipelineOptions

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

[GitHub] incubator-beam pull request #1452: [BEAM-551] Add a test to demonstrate NVP ...

GitHub user sammcveety opened a pull request: https://github.com/apache/incubator-beam/pull/1452 [BEAM-551] Add a test to demonstrate NVP serialization R: @dhalperi You can merge this pull request into a Git repository by running: $ git pull https://github.com/sammcveety/incu

[jira] [Commented] (BEAM-25) Add user-ready API for interacting with state

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

[3/3] incubator-beam git commit: Add isStateful() to DoFnSignature

Add isStateful() to DoFnSignature Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bdd3e086 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bdd3e086 Diff: http://git-wip-us.apache.org/repos/as

[GitHub] incubator-beam pull request #1411: [BEAM-25] Temporarily reject stateful Par...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1411 --- 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 featur

[2/3] incubator-beam git commit: Reject stateful DoFn in DataflowRunner

Reject stateful DoFn in DataflowRunner Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/31a55f40 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/31a55f40 Diff: http://git-wip-us.apache.org/rep

[1/3] incubator-beam git commit: This closes #1411

Repository: incubator-beam Updated Branches: refs/heads/master 3a8b9b521 -> 1716bfc49 This closes #1411 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1716bfc4 Tree: http://git-wip-us.apache.org/repos/as

[jira] [Commented] (BEAM-506) Fill in the documentation/runners/flink portion of the website

[ https://issues.apache.org/jira/browse/BEAM-506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15705589#comment-15705589 ] Maximilian Michels commented on BEAM-506: - +1 > Fill in the documentation/runners/f

[GitHub] incubator-beam-site pull request #97: [BEAM-506] Fill in the documentation/r...

GitHub user aljoscha opened a pull request: https://github.com/apache/incubator-beam-site/pull/97 [BEAM-506] Fill in the documentation/runners/flink portion of the website The outline of this is based on the doc for the Cloud Dataflow runner. R: @davorbonaci and @mxm You c

[jira] [Commented] (BEAM-506) Fill in the documentation/runners/flink portion of the website

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

[jira] [Assigned] (BEAM-506) Fill in the documentation/runners/flink portion of the website

[ https://issues.apache.org/jira/browse/BEAM-506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned BEAM-506: - Assignee: Aljoscha Krettek (was: James Malone) > Fill in the documentation/runners/flink p

[jira] [Commented] (BEAM-1059) Create ExecIO

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

[GitHub] incubator-beam pull request #1451: [BEAM-1059] Create ExecIO

GitHub user jbonofre opened a pull request: https://github.com/apache/incubator-beam/pull/1451 [BEAM-1059] Create ExecIO Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [X] Make sure the PR title is formatted like:

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1678

See

[jira] [Created] (BEAM-1059) Create ExecIO

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

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1677

See

[jira] [Resolved] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used.

[ https://issues.apache.org/jira/browse/BEAM-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela resolved BEAM-1052. - Resolution: Fixed Fix Version/s: 0.4.0-incubating > UnboundedSource splitId uniqueness breaks if mor

[jira] [Commented] (BEAM-1052) UnboundedSource splitId uniqueness breaks if more than one source is used.

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

[2/2] incubator-beam git commit: This closes #1450

This closes #1450 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3a8b9b52 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3a8b9b52 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam

[GitHub] incubator-beam pull request #1450: [BEAM-1052] Add InputDStream id to Microb...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1450 --- 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 featur

[1/2] incubator-beam git commit: [BEAM-1052] Add InputDStream id to MicrobatchSource hashcode.

Repository: incubator-beam Updated Branches: refs/heads/master 3f16f2660 -> 3a8b9b521 [BEAM-1052] Add InputDStream id to MicrobatchSource hashcode. Done to avoid collisions between splits of different sources. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http:/

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1676

See