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

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

[GitHub] incubator-beam pull request: [BEAM-77] Move flink and spark runner...

Github user jbonofre closed the pull request at: https://github.com/apache/incubator-beam/pull/160 --- 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-151) Create Dataflow Runner Package

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

[GitHub] incubator-beam pull request: [BEAM-151] Enable integration tests u...

GitHub user lukecwik opened a pull request: https://github.com/apache/incubator-beam/pull/170 [BEAM-151] Enable integration tests underneath google-cloud-dataflow-java Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [X]

[jira] [Commented] (BEAM-53) PubSubIO: reimplement in Java

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

[jira] [Commented] (BEAM-160) Port 'NexMark Queries' to Beam for use as integration test

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

[GitHub] incubator-beam pull request: [BEAM-160] Import NexMark integration...

Github user mshields822 closed the pull request at: https://github.com/apache/incubator-beam/pull/99 --- 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: [BEAM-53] Java-only pub/sub source an...

Github user mshields822 closed the pull request at: https://github.com/apache/incubator-beam/pull/85 --- 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-22) DirectPipelineRunner: support for unbounded collections

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

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

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/169 [BEAM-22] Add InProcessRegistrar 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 #86

See

Jenkins build is still unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: SDKs :: Java :: Core #86

See

Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: SDKs :: Java :: Core #85

See

[jira] [Commented] (BEAM-151) Create Dataflow Runner Package

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

[17/18] incubator-beam git commit: [BEAM-151] Move a large portion of the Dataflow runner to separate maven module

[BEAM-151] Move a large portion of the Dataflow runner to separate maven module Note that Flink runner and Java examples both depend on the Dataflow runner still. So I needed to make the Dataflow runner a top level component to satisfy these dependencies. Project:

[15/18] incubator-beam git commit: [BEAM-151] Move a large portion of the Dataflow runner to separate maven module

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6b4857cc/runners/google-cloud-dataflow-java/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java -- diff --git

[13/18] incubator-beam git commit: [BEAM-151] Move a large portion of the Dataflow runner to separate maven module

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6b4857cc/runners/google-cloud-dataflow-java/src/main/java/com/google/cloud/dataflow/sdk/testing/TestDataflowPipelineRunner.java -- diff --git

[06/18] incubator-beam git commit: [BEAM-151] Move a large portion of the Dataflow runner to separate maven module

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6b4857cc/sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunnerHooks.java -- diff --git

[10/18] incubator-beam git commit: [BEAM-151] Move a large portion of the Dataflow runner to separate maven module

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6b4857cc/runners/google-cloud-dataflow-java/src/test/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineTranslatorTest.java -- diff --git

[09/18] incubator-beam git commit: [BEAM-151] Move a large portion of the Dataflow runner to separate maven module

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6b4857cc/runners/google-cloud-dataflow-java/src/test/java/com/google/cloud/dataflow/sdk/util/PackageUtilTest.java -- diff --git

[14/18] incubator-beam git commit: [BEAM-151] Move a large portion of the Dataflow runner to separate maven module

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6b4857cc/runners/google-cloud-dataflow-java/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunnerHooks.java -- diff --git

[08/18] incubator-beam git commit: [BEAM-151] Move a large portion of the Dataflow runner to separate maven module

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6b4857cc/sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowJobExecutionException.java -- diff --git

[04/18] incubator-beam git commit: [BEAM-151] Move a large portion of the Dataflow runner to separate maven module

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6b4857cc/sdks/java/core/src/test/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineJobTest.java -- diff --git

[07/18] incubator-beam git commit: [BEAM-151] Move a large portion of the Dataflow runner to separate maven module

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6b4857cc/sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java -- diff --git

[GitHub] incubator-beam pull request: [BEAM-151] Move Dataflow runner to ne...

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

[18/18] incubator-beam git commit: [BEAM-151] This closes #165

[BEAM-151] This closes #165 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/af1e5755 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/af1e5755 Diff:

[05/18] incubator-beam git commit: [BEAM-151] Move a large portion of the Dataflow runner to separate maven module

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6b4857cc/sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/testing/TestDataflowPipelineRunner.java -- diff --git

[GitHub] incubator-beam pull request: Exclude more IDE files from Spark run...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/152 --- 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: Exclude more IDE files from Spark runner RAT check

Repository: incubator-beam Updated Branches: refs/heads/master 936d028f0 -> 1bbb7af7b Exclude more IDE files from Spark runner RAT check Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/97af4df3 Tree:

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

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

[jira] [Commented] (BEAM-115) Beam Runner API

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

[1/2] incubator-beam git commit: [BEAM-50] Implement BigQueryIO.Write as a custom sink.

Repository: incubator-beam Updated Branches: refs/heads/master d2b659b7c -> 936d028f0 [BEAM-50] Implement BigQueryIO.Write as a custom sink. Create BigQueryServices interface and added BigQueryIO pipeline tests. Removed BigQueryIO.Write evaluator. Project:

[GitHub] incubator-beam pull request: [BEAM-50] Implement BigQueryIO.Write ...

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

[GitHub] incubator-beam pull request: [BEAM-115] Remove extraneous type par...

GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/168 [BEAM-115] Remove extraneous type parameter from Trigger, etc This has no user-visible effect unless they have to declare a variable of type `Trigger`, etc, since we use factory methods

Jenkins build is back to stable : beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: SDKs :: Java :: Core #82

See

[GitHub] incubator-beam pull request: Select the runner in spark SparkPipel...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/167 Select the runner in spark SparkPipelineOptionsFactory Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR

Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #81

See

Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow » Apache Beam :: SDKs :: Java :: Core #81

See

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

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

[GitHub] incubator-beam pull request: Update Jenkins build badge in README....

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/164 --- 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: Update Jenkins build badge in README.md

Repository: incubator-beam Updated Branches: refs/heads/master e1a471176 -> d2b659b7c Update Jenkins build badge in README.md Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b3a458bc Tree:

[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=15235904#comment-15235904 ] ASF GitHub Bot commented on BEAM-22: Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request: [BEAM-22] Add ShardControlledWrite ov...

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

Repository: incubator-beam Updated Branches: refs/heads/master cd2a3a18f -> e1a471176 Add ShardControlledWrite override This is used for TextIO and AvroIO, which provide withNumOutputShards methods to control the number of output files. Apply this override in the InProcessPipelineRunner.

[jira] [Assigned] (BEAM-188) Merging WindowFn + GBK + Write => InvalidWindows throws UnsupportedOperationException

[ https://issues.apache.org/jira/browse/BEAM-188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Halperin reassigned BEAM-188: Assignee: Daniel Halperin (was: Kenneth Knowles) > Merging WindowFn + GBK + Write =>

[GitHub] incubator-beam pull request: Ignore generated bin/ directories

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/151 --- 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-22) DirectPipelineRunner: support for unbounded collections

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

[GitHub] incubator-beam pull request: [BEAM-22] Enforce non-null preconditi...

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

Repository: incubator-beam Updated Branches: refs/heads/master 43ef9fe5b -> cd2a3a18f Enforce non-null preconditions The InProcessPipelineRunner expects some result values to be non-null. Enforce those early. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[2/2] incubator-beam git commit: [BEAM-22] This closes #153

[BEAM-22] This closes #153 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/cd2a3a18 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/cd2a3a18 Diff:

[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=15235875#comment-15235875 ] ASF GitHub Bot commented on BEAM-22: Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request: [BEAM-22] Fix multithreaded visibilit...

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/161 --- 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: Update Jenkins build badge in README....

GitHub user davorbonaci opened a pull request: https://github.com/apache/incubator-beam/pull/164 Update Jenkins build badge in README.md You can merge this pull request into a Git repository by running: $ git pull https://github.com/davorbonaci/beam coveralls Alternatively

[1/2] incubator-beam git commit: Fix multithreaded visibility issue with TransformExecutor

Repository: incubator-beam Updated Branches: refs/heads/master ab7bca7d0 -> 43ef9fe5b Fix multithreaded visibility issue with TransformExecutor Use an AtomicReference to ensure the thread the Executor is being run on will be visible to other threads. Add a checkState to ensure that the

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

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

[jira] [Commented] (BEAM-151) Create Dataflow Runner Package

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

[GitHub] incubator-beam pull request: [BEAM-151] Move Dataflow runner to ne...

GitHub user lukecwik opened a pull request: https://github.com/apache/incubator-beam/pull/165 [BEAM-151] Move Dataflow runner to new Dataflow runner maven module Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [X] Make

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

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

[1/2] incubator-beam git commit: Add Coveralls badge to README.md

Repository: incubator-beam Updated Branches: refs/heads/master 1cef64261 -> aa17c9165 Add Coveralls badge to README.md Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1e493377 Tree:

[jira] [Commented] (BEAM-78) Rename Dataflow to Beam

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

[GitHub] incubator-beam pull request: [BEAM-78] Move annotations in org.apa...

GitHub user jbonofre opened a pull request: https://github.com/apache/incubator-beam/pull/163 [BEAM-78] Move annotations in org.apache.beam.sdk package 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: Add Coveralls badge to README.md

GitHub user davorbonaci opened a pull request: https://github.com/apache/incubator-beam/pull/162 Add Coveralls badge to README.md You can merge this pull request into a Git repository by running: $ git pull https://github.com/davorbonaci/beam coveralls Alternatively you can

[jira] [Created] (BEAM-188) Merging WindowFn + GBK + Write => InvalidWindows throws UnsupportedOperationException

Kenneth Knowles created BEAM-188: Summary: Merging WindowFn + GBK + Write => InvalidWindows throws UnsupportedOperationException Key: BEAM-188 URL: https://issues.apache.org/jira/browse/BEAM-188

[jira] [Created] (BEAM-187) Terminating Jenkins job doesn't terminate child processes / pending jobs on Dataflow

Davor Bonaci created BEAM-187: - Summary: Terminating Jenkins job doesn't terminate child processes / pending jobs on Dataflow Key: BEAM-187 URL: https://issues.apache.org/jira/browse/BEAM-187 Project:

[jira] [Commented] (BEAM-154) Provide Maven BOM

[ https://issues.apache.org/jira/browse/BEAM-154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235542#comment-15235542 ] Jean-Baptiste Onofré commented on BEAM-154: --- Related to that, most of the Beam modules pom.xml

[jira] [Closed] (BEAM-162) assert fail using session windows

[ https://issues.apache.org/jira/browse/BEAM-162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Shields closed BEAM-162. - Resolution: Fixed > assert fail using session windows > - > >

[jira] [Updated] (BEAM-167) TextIO can't read concatenated gzip files

[ https://issues.apache.org/jira/browse/BEAM-167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-167: -- Component/s: (was: sdk-java-extensions) sdk-java-core > TextIO can't read

[jira] [Closed] (BEAM-172) Add "Apache Beam Public Meetings" page to website

[ https://issues.apache.org/jira/browse/BEAM-172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci closed BEAM-172. - Resolution: Fixed > Add "Apache Beam Public Meetings" page to website >

[jira] [Commented] (BEAM-162) assert fail using session windows

[ https://issues.apache.org/jira/browse/BEAM-162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235483#comment-15235483 ] Davor Bonaci commented on BEAM-162: --- Done? > assert fail using session windows >

[jira] [Commented] (BEAM-178) stdout vs logging in DataflowPipelineRunner?

[ https://issues.apache.org/jira/browse/BEAM-178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235464#comment-15235464 ] Davor Bonaci commented on BEAM-178: --- Let's call this working as intended. > stdout vs logging in

[jira] [Updated] (BEAM-185) XmlSink output file pattern missing "." in extension

[ https://issues.apache.org/jira/browse/BEAM-185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-185: -- Component/s: sdk-java-core > XmlSink output file pattern missing "." in extension >

[jira] [Updated] (BEAM-176) Enable FindBugs static analysis during maven build

[ https://issues.apache.org/jira/browse/BEAM-176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-176: -- Component/s: sdk-java-core > Enable FindBugs static analysis during maven build >

[jira] [Updated] (BEAM-166) Version annotations in capability matrix

[ https://issues.apache.org/jira/browse/BEAM-166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-166: -- Component/s: project-management > Version annotations in capability matrix >

[jira] [Updated] (BEAM-166) Version annotations in capability matrix

[ https://issues.apache.org/jira/browse/BEAM-166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-166: -- Component/s: website > Version annotations in capability matrix >

[jira] [Closed] (BEAM-178) stdout vs logging in DataflowPipelineRunner?

[ https://issues.apache.org/jira/browse/BEAM-178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci closed BEAM-178. - Resolution: Not A Bug > stdout vs logging in DataflowPipelineRunner? >

[jira] [Commented] (BEAM-178) stdout vs logging in DataflowPipelineRunner?

[ https://issues.apache.org/jira/browse/BEAM-178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235462#comment-15235462 ] Davor Bonaci commented on BEAM-178: --- >From Luke: I think this was because we wanted to make sure the user

[jira] [Commented] (BEAM-185) XmlSink output file pattern missing "." in extension

[ https://issues.apache.org/jira/browse/BEAM-185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235461#comment-15235461 ] Davor Bonaci commented on BEAM-185: --- >From Luke: There is some automatic "." adding logic inside

[jira] [Commented] (BEAM-185) XmlSink output file pattern missing "." in extension

[ https://issues.apache.org/jira/browse/BEAM-185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235392#comment-15235392 ] Jean-Baptiste Onofré commented on BEAM-185: --- It's weird, because the {{XmlSink.Bound}} constructor

[GitHub] incubator-beam pull request: [BEAM-22] Fix multithreaded visibilit...

GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/161 [BEAM-22] Fix multithreaded visibility issue with TransformExecutor Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] 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=15235377#comment-15235377 ] ASF GitHub Bot commented on BEAM-22: GitHub user tgroh opened a pull request:

[jira] [Commented] (BEAM-185) XmlSink output file pattern missing "." in extension

[ https://issues.apache.org/jira/browse/BEAM-185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235325#comment-15235325 ] Scott Wegner commented on BEAM-185: --- I believe XmlSink.writeOf would have the same issue. In the

[jira] [Resolved] (BEAM-186) The streaming WindowedWordCount example is broken on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henning Korsholm Rohde resolved BEAM-186. - Resolution: Fixed > The streaming WindowedWordCount example is broken on Dataflow >

[jira] [Commented] (BEAM-185) XmlSink output file pattern missing "." in extension

[ https://issues.apache.org/jira/browse/BEAM-185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15234950#comment-15234950 ] Jean-Baptiste Onofré commented on BEAM-185: --- I guess it doesn't occur with you use

[jira] [Commented] (BEAM-186) The streaming WindowedWordCount example is broken on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15234877#comment-15234877 ] Jean-Baptiste Onofré commented on BEAM-186: --- Is it related to Beam or Google Dataflow SDK ? > The

[GitHub] incubator-beam pull request: [BEAM-77] Move flink and spark runner...

GitHub user jbonofre opened a pull request: https://github.com/apache/incubator-beam/pull/160 [BEAM-77] Move flink and spark runners into runners/java module as de… This pull request moves the flink and spark runners in the runners/java module as described in the Repository

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

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

[jira] [Closed] (BEAM-43) Upgrade to Spark 1.6

[ https://issues.apache.org/jira/browse/BEAM-43?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela closed BEAM-43. - Resolution: Fixed PR-159 > Upgrade to Spark 1.6 > > > Key: BEAM-43 >

[GitHub] incubator-beam pull request: [Beam-43] Upgrade to Spark 1.6

Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/159 --- 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-43] Upgrade to Spark 1.6.1

Repository: incubator-beam Updated Branches: refs/heads/master d42a07086 -> 1cef64261 [BEAM-43] Upgrade to Spark 1.6.1 Replace deprecated Function with VoidFunction Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: