[jira] [Created] (BEAM-257) fix ConcurrentModificationException in KafkaIO

Raghu Angadi created BEAM-257: - Summary: fix ConcurrentModificationException in KafkaIO Key: BEAM-257 URL: https://issues.apache.org/jira/browse/BEAM-257 Project: Beam Issue Type: Bug

[GitHub] incubator-beam pull request: - after shutting down consumer poll t...

GitHub user rangadi opened a pull request: https://github.com/apache/incubator-beam/pull/290 - after shutting down consumer poll thread (and offset updater thread), wait for them to actually exit. Be sure to do all of the following to help us incorporate your contribution

[GitHub] incubator-beam pull request: [BEAM-22] Mark CheckpointMark as vola...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/289 [BEAM-22] Mark CheckpointMark as volatile in UnboundedReadEvaluator Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_GoogleCloudDataflow #278

See

[1/2] incubator-beam-site git commit: Added the /docs/ directory and a landing page at docs/index.md. Added coming-soon.md as a placeholder for missing content. Modified main landing page with SDK and

Repository: incubator-beam-site Updated Branches: refs/heads/asf-site 3b54e40ce -> c90dbf184 Added the /docs/ directory and a landing page at docs/index.md. Added coming-soon.md as a placeholder for missing content. Modified main landing page with SDK and Runner status tables and descriptions.

Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #277

See

[1/2] incubator-beam git commit: Speed up non-release builds

Repository: incubator-beam Updated Branches: refs/heads/master 928640df2 -> e63311fa4 Speed up non-release builds Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/119812a6 Tree:

[GitHub] incubator-beam pull request: Speed up non-release builds

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

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

[GitHub] incubator-beam pull request: Refactor BigQueryServices to support ...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/285 --- 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: [BEAM-48] Refactor BigQueryServices to support extract and query jobs

Repository: incubator-beam Updated Branches: refs/heads/master 97945648c -> 928640df2 [BEAM-48] Refactor BigQueryServices to support extract and query jobs Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[jira] [Commented] (BEAM-22) DirectPipelineRunner: support for unbounded collections

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

[GitHub] incubator-beam pull request: [BEAM-22] Add PushbackDoFnRunner

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/258 --- 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/3] incubator-beam git commit: Move ReadyCheckingSideInputReader to util

Repository: incubator-beam Updated Branches: refs/heads/master 32970c985 -> 97945648c Move ReadyCheckingSideInputReader to util This SideInputReader allows callers to check for a side input being available before attempting to read the contents Project:

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

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

[jira] [Commented] (BEAM-77) Reorganize Directory structure

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

[GitHub] incubator-beam pull request: [BEAM-77] Create runners/core module ...

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

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

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

[2/3] incubator-beam git commit: Create runners/core module for artifact org.apache.beam:runners-core

Create runners/core module for artifact org.apache.beam:runners-core This is strictly creating the module and moving one easy class to it. Many of the utilities in org.apache.beam.util and subpackages should move as developments allow. Project:

[jira] [Commented] (BEAM-254) Add maven-rat-plugin execution

[ https://issues.apache.org/jira/browse/BEAM-254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270899#comment-15270899 ] Jean-Baptiste Onofré commented on BEAM-254: --- Good point. Actually, I think it's better to exclude

[jira] [Commented] (BEAM-254) Add maven-rat-plugin execution

[ https://issues.apache.org/jira/browse/BEAM-254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270888#comment-15270888 ] Scott Wegner commented on BEAM-254: --- I see; I hadn't considered that we need a header on non-source files.