[jira] [Assigned] (BEAM-659) WindowFn#isCompatible should provide a meaningful reason

[ https://issues.apache.org/jira/browse/BEAM-659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neelesh Srinivas Salian reassigned BEAM-659: Assignee: Neelesh Srinivas Salian > WindowFn#isCompatible should provide a

[2/8] incubator-beam-site git commit: Update mailing lists to use new lists site.

Update mailing lists to use new lists site. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/7f234a5a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/7f234a5a Diff:

[5/8] incubator-beam-site git commit: Updated Contribution Guide & added Work In Progress * Added section on feature branches. * Revamped website section. * Standardized code formatting. * Added a "wo

Updated Contribution Guide & added Work In Progress * Added section on feature branches. * Revamped website section. * Standardized code formatting. * Added a "work in progress" page to help make new and ongoing work more visible to the community. Project:

[3/8] incubator-beam-site git commit: Remove page title from TOCs

Remove page title from TOCs Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/229020ce Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/229020ce Diff:

[GitHub] incubator-beam-site pull request #42: Update Contribution Guide and add Work...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam-site/pull/42 --- 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] [Created] (BEAM-777) KafkaIO Test should handle reader.start() better

Raghu Angadi created BEAM-777: - Summary: KafkaIO Test should handle reader.start() better Key: BEAM-777 URL: https://issues.apache.org/jira/browse/BEAM-777 Project: Beam Issue Type: Bug

[GitHub] incubator-beam-site pull request #48: Stage pull requests in Google Cloud St...

GitHub user davorbonaci opened a pull request: https://github.com/apache/incubator-beam-site/pull/48 Stage pull requests in Google Cloud Storage This is work-in-progress. Several aspects need to be taken care of. R: @francesperry CC: @dhalperi You can merge this pull

[4/8] incubator-beam-site git commit: Add Design Principles (take from the original Beam technical vision document).

Add Design Principles (take from the original Beam technical vision document). Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/99783418 Tree:

[jira] [Updated] (BEAM-744) A runner should be able to override KafkaIO max wait properties.

[ https://issues.apache.org/jira/browse/BEAM-744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-744: --- Description: KafkaIO has two "wait" properties: {{START_NEW_RECORDS_POLL_TIMEOUT}} - wait for new records

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1560

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #1560

See

Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Direct Java #1560

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1560

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1358

See

[jira] [Commented] (BEAM-744) A runner should be able to override KafkaIO max wait properties.

[ https://issues.apache.org/jira/browse/BEAM-744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585107#comment-15585107 ] Amit Sela commented on BEAM-744: That's Correct, I updated the JIRA, thanks! > A runner should be able to

[jira] [Commented] (BEAM-744) A runner should be able to override KafkaIO max wait properties.

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

[GitHub] incubator-beam pull request #1125: [BEAM-744] A runner should be able to ove...

GitHub user amitsela opened a pull request: https://github.com/apache/incubator-beam/pull/1125 [BEAM-744] A runner should be able to override KafkaIO max wait prope… Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ]

Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Spark #1561

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1561

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1561

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #1561

See

Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Direct Java #1561

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1359

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #1563

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1563

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1360

See

[GitHub] incubator-beam pull request #1122: [BEAM-755] SplittableParDoTest does not r...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1122 --- 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-755) beam-runners-core-java NeedsRunner tests not executing

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

[2/2] incubator-beam git commit: SplittableParDoTest does not require RunnableOnService

SplittableParDoTest does not require RunnableOnService Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7f5542e0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7f5542e0 Diff:

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

Repository: incubator-beam Updated Branches: refs/heads/master ecc2abfdb -> c81376bc7 Closes #1122 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c81376bc Tree:

Jenkins build is still unstable: beam_PostCommit_MavenVerify #1562

See

[jira] [Created] (BEAM-767) Add DisplayData builder '.nested(..)' operation

Scott Wegner created BEAM-767: - Summary: Add DisplayData builder '.nested(..)' operation Key: BEAM-767 URL: https://issues.apache.org/jira/browse/BEAM-767 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-767) Add DisplayData builder '.nested(..)' operation

[ https://issues.apache.org/jira/browse/BEAM-767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner updated BEAM-767: -- Description: See: https://github.com/apache/incubator-beam/pull/1088#discussion_r83332515 In the Java

[jira] [Created] (BEAM-768) Update Dataflow API to beta

Daniel Halperin created BEAM-768: Summary: Update Dataflow API to beta Key: BEAM-768 URL: https://issues.apache.org/jira/browse/BEAM-768 Project: Beam Issue Type: Improvement

[1/2] incubator-beam git commit: Update Dataflow container image for current version of Apache Beam.

Repository: incubator-beam Updated Branches: refs/heads/master 6b5ff4c4a -> ecc2abfdb Update Dataflow container image for current version of Apache Beam. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[GitHub] incubator-beam pull request #1124: Update Dataflow container image for curre...

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

Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Spark #1562

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #1562

See

Jenkins build is still unstable: beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1562

See

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_GoogleCloudDataflow #1361

See

Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: SDKs :: Java :: IO :: Google Cloud Platform #1564

See

Jenkins build is back to stable : beam_PostCommit_MavenVerify #1564

See

[jira] [Commented] (BEAM-768) Update Dataflow API to beta

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

[GitHub] incubator-beam pull request #1126: [BEAM-768] Dataflow: API is in beta now

GitHub user dhalperi opened a pull request: https://github.com/apache/incubator-beam/pull/1126 [BEAM-768] Dataflow: API is in beta now You can merge this pull request into a Git repository by running: $ git pull https://github.com/dhalperi/incubator-beam

[jira] [Updated] (BEAM-655) Rename @RunnableOnService to something more descriptive

[ https://issues.apache.org/jira/browse/BEAM-655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-655: - Summary: Rename @RunnableOnService to something more descriptive (was: Rename @RunnableonService to

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

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

[GitHub] incubator-beam pull request #1093: [BEAM-593] avoid throwing Exception in wa...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1093 --- 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-593) Support unblocking run() in FlinkRunner and cancel() and waitUntilFinish() in FlinkRunnerResult

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

[GitHub] incubator-beam pull request #1094: Build in eclipse/eclipse-jdt

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1094 --- 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: Build in eclipse/eclipse-jdt

Repository: incubator-beam Updated Branches: refs/heads/master c5329f9b4 -> a2c342cfd Build in eclipse/eclipse-jdt Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/957c545e Tree:

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

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

[1/2] incubator-beam git commit: [BEAM-593] avoid throwing Exception in waitUntilFinish

Repository: incubator-beam Updated Branches: refs/heads/master a2c342cfd -> 6b5ff4c4a [BEAM-593] avoid throwing Exception in waitUntilFinish The current implementation of Flink's PipelineResult assumes that the pipeline has already been processed. Hence, we can return State.Done when

Jenkins build is unstable: beam_PostCommit_MavenVerify » Apache Beam :: Examples :: Java #1563

See

[GitHub] incubator-beam pull request #1127: Restore trigger-related tests missed in #...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/1127 Restore trigger-related tests missed in #1083 Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title

[jira] [Commented] (BEAM-756) Checkstyle suppression for JavadocPackage not working on Windows

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

[jira] [Resolved] (BEAM-768) Update Dataflow API to beta

[ https://issues.apache.org/jira/browse/BEAM-768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin resolved BEAM-768. -- Resolution: Fixed Fix Version/s: 0.3.0-incubating > Update Dataflow API to beta >

[jira] [Updated] (BEAM-744) UnboundedKafkaReader should return as soon as it can.

[ https://issues.apache.org/jira/browse/BEAM-744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-744: --- Summary: UnboundedKafkaReader should return as soon as it can. (was: A runner should be able to override

[2/2] incubator-beam git commit: Resolve Registered Runners that don't end with Runner

Resolve Registered Runners that don't end with Runner Resolve runners in a case-insensitive manner. This reduces duplication in specifying a runner e.g. the DirectRunner can be specified with (among others) any of "--runner=direct", "--runner=directrunner", "--runner=DirectRunner",

[jira] [Commented] (BEAM-770) Improve registered runner resolution

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

[1/2] incubator-beam git commit: Restore trigger-related tests missed in #1083

Repository: incubator-beam Updated Branches: refs/heads/master 71c69b31b -> 6d686288e Restore trigger-related tests missed in #1083 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8d43e8aa Tree:

[GitHub] incubator-beam pull request #1127: Restore trigger-related tests missed in #...

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

Jenkins build became unstable: beam_PostCommit_MavenVerify #1569

See

[2/2] incubator-beam git commit: Restore ReshuffleTriggerTest to SDK

Restore ReshuffleTriggerTest to SDK This closes #1118 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4e14ac2c Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4e14ac2c Diff:

[1/2] incubator-beam git commit: BEAM-756 fix JavadocPackage checkstyle suppression

Repository: incubator-beam Updated Branches: refs/heads/master 4e14ac2c2 -> 006cb127e BEAM-756 fix JavadocPackage checkstyle suppression Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6a691843 Tree:

[GitHub] incubator-beam pull request #1114: BEAM-756 fix JavadocPackage checkstyle su...

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

[2/2] incubator-beam git commit: BEAM-756 fix JavadocPackage checkstyle suppression

BEAM-756 fix JavadocPackage checkstyle suppression This closes #1114 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/006cb127 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/006cb127 Diff:

[GitHub] incubator-beam pull request #1070: [BEAM-733] Prohibit windowed side inputs ...

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

[2/3] incubator-beam git commit: Dissallow (unimplemented) windowed side inputs.

Dissallow (unimplemented) windowed side inputs. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/552f6d7b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/552f6d7b Diff:

[jira] [Commented] (BEAM-733) Windowed side-inputs not supported in Python

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

[jira] [Updated] (BEAM-770) Improve registered runner resolution

[ https://issues.apache.org/jira/browse/BEAM-770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-770: - Labels: forward-incompatible (was: ) > Improve registered runner resolution >

[jira] [Commented] (BEAM-770) Improve registered runner resolution

[ https://issues.apache.org/jira/browse/BEAM-770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15586153#comment-15586153 ] Daniel Halperin commented on BEAM-770: -- Mild compatibility change -- new feature. > Improve registered

incubator-beam git commit: [BEAM-764] Remove cloneAs from PipelineOptions

Repository: incubator-beam Updated Branches: refs/heads/master 75f54682a -> 71c69b31b [BEAM-764] Remove cloneAs from PipelineOptions Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/71c69b31 Tree:

[jira] [Issue Comment Deleted] (BEAM-770) Improve registered runner resolution

[ https://issues.apache.org/jira/browse/BEAM-770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-770: - Comment: was deleted (was: Mild compatibility change -- new feature.) > Improve registered runner

[jira] [Updated] (BEAM-770) Improve registered runner resolution

[ https://issues.apache.org/jira/browse/BEAM-770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-770: - Labels: (was: forward-incompatible) > Improve registered runner resolution >

Jenkins build is back to stable : beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Spark #1568

See

Jenkins build became unstable: beam_PostCommit_MavenVerify #1567

See

Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Spark #1567

See

[GitHub] incubator-beam pull request #1118: Restore ReshuffleTriggerTest to SDK

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/1118 --- 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] [Updated] (BEAM-655) Rename @RunnableOnService to something more descriptive

[ https://issues.apache.org/jira/browse/BEAM-655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh updated BEAM-655: - Description: There are currently two categories for unit tests in the Core Beam Java SDK: {{NeedsRunner}}

[2/2] incubator-beam git commit: Restore trigger-related tests missed in #1083

Restore trigger-related tests missed in #1083 This closes #1127 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6d686288 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6d686288 Diff:

[jira] [Commented] (BEAM-769) Spark translation tests failing with NullPointerException

[ https://issues.apache.org/jira/browse/BEAM-769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15586248#comment-15586248 ] Jason Kuster commented on BEAM-769: --- This also seems to have caused a postcommit failure:

[1/2] incubator-beam git commit: Restore ReshuffleTriggerTest to SDK

Repository: incubator-beam Updated Branches: refs/heads/master c81376bc7 -> 4e14ac2c2 Restore ReshuffleTriggerTest to SDK Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/619746b6 Tree:

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

Closes #1126 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/44694794 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/44694794 Diff:

[jira] [Updated] (BEAM-769) Spark translation tests failing with NullPointerException

[ https://issues.apache.org/jira/browse/BEAM-769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin updated BEAM-769: - Description: https://builds.apache.org/job/beam_PreCommit_MavenVerify/4071/ {code}

[jira] [Created] (BEAM-769) Spark translation tests failing with NullPointerException

Daniel Halperin created BEAM-769: Summary: Spark translation tests failing with NullPointerException Key: BEAM-769 URL: https://issues.apache.org/jira/browse/BEAM-769 Project: Beam Issue

[GitHub] incubator-beam pull request #1126: [BEAM-768] Dataflow: API is in beta now

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

[GitHub] incubator-beam pull request #1087: [BEAM-770] Resolve Registered Runners tha...

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

Repository: incubator-beam Updated Branches: refs/heads/master 446947947 -> 75f54682a Closes #1087 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/75f54682 Tree:

[jira] [Updated] (BEAM-744) UnboundedKafkaReader should return as soon as it can.

[ https://issues.apache.org/jira/browse/BEAM-744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-744: --- Description: KafkaIO has two "wait" properties: {{START_NEW_RECORDS_POLL_TIMEOUT}} - wait for new records

Jenkins build became unstable: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Spark #1569

See

[1/2] incubator-beam git commit: Dataflow: API is in beta now

Repository: incubator-beam Updated Branches: refs/heads/master 006cb127e -> 446947947 Dataflow: API is in beta now Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/772fb3f1 Tree:

[jira] [Created] (BEAM-770) Improve registered runner resolution

Thomas Groh created BEAM-770: Summary: Improve registered runner resolution Key: BEAM-770 URL: https://issues.apache.org/jira/browse/BEAM-770 Project: Beam Issue Type: Improvement

[3/3] incubator-beam git commit: Closes #1070

Closes #1070 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/afa5ebc7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/afa5ebc7 Diff:

[1/3] incubator-beam git commit: Fix tests unnecessarily using windowed side inputs

Repository: incubator-beam Updated Branches: refs/heads/python-sdk 24b7bcc26 -> afa5ebc70 Fix tests unnecessarily using windowed side inputs Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5d9506df Tree:

[GitHub] incubator-beam pull request #1128: [BEAM-771] Add a Residual Shard for Empty...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/1128 [BEAM-771] Add a Residual Shard for Empty Readers Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[jira] [Commented] (BEAM-771) UnboundedReadEvaluator should reuse the input reader if it contains no elements

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

[1/2] incubator-beam git commit: Add support for experiments

Repository: incubator-beam Updated Branches: refs/heads/python-sdk afa5ebc70 -> fe1f39609 Add support for experiments Adds a new --experiment flag, to allow runners to optionally enable experimental features. This is similar to the same flag in the java sdk. Project:

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

Closes #1123 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fe1f3960 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fe1f3960 Diff:

[1/3] incubator-beam git commit: Document that source objects should not be mutated.

Repository: incubator-beam Updated Branches: refs/heads/python-sdk fe1f39609 -> 6e6d89d48 Document that source objects should not be mutated. Updates textio._TextSource so that it does not get mutated while reading. Updates source_test_utils so that sources objects do not get cloned while

[2/3] incubator-beam git commit: Adds an assertion to source_test_utils for testing reentrancy.

Adds an assertion to source_test_utils for testing reentrancy. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bdcb04cb Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bdcb04cb Diff:

  1   2   >