[2/2] incubator-beam git commit: Verify in unit test that BigQuery executing project is used.

2016-05-24 Thread dhalperi
Verify in unit test that BigQuery executing project is used. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/70c1e2c7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/70c1e2c7 Diff:

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

2016-05-24 Thread dhalperi
Repository: incubator-beam Updated Branches: refs/heads/master ffed1d479 -> 78c8c528e Closes #376 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/78c8c528 Tree:

[GitHub] incubator-beam pull request: Verify in unit test that BigQuery exe...

2016-05-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/376 --- 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: Relocate Immutability Enforcement tes...

2016-05-24 Thread tgroh
GitHub user tgroh opened a pull request: https://github.com/apache/incubator-beam/pull/387 Relocate Immutability Enforcement tests Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

[jira] [Created] (BEAM-306) Make java-only PubsubIO work in InProcessRunner

2016-05-24 Thread Mark Shields (JIRA)
Mark Shields created BEAM-306: - Summary: Make java-only PubsubIO work in InProcessRunner Key: BEAM-306 URL: https://issues.apache.org/jira/browse/BEAM-306 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-117) Implement the API for Static Display Metadata

2016-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15299100#comment-15299100 ] ASF GitHub Bot commented on BEAM-117: - Github user asfgit closed the pull request at:

[GitHub] incubator-beam pull request: [BEAM-117] Evaluate display data from...

2016-05-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/375 --- 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: Evaluate display data from InProcessPipelineRunner

2016-05-24 Thread bchambers
Repository: incubator-beam Updated Branches: refs/heads/master 5535fc3fd -> ffed1d479 Evaluate display data from InProcessPipelineRunner Display data can be added to any PTransform to be used for display from any runner. Runners are not required to consume display data, and currently many

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

2016-05-24 Thread bchambers
This closes #375 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ffed1d47 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ffed1d47 Diff:

[jira] [Updated] (BEAM-175) Don't leak garbage collection timers in GlobalWindow

2016-05-24 Thread Mark Shields (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Shields updated BEAM-175: -- Summary: Don't leak garbage collection timers in GlobalWindow (was: Leak garbage collection timers in

[jira] [Comment Edited] (BEAM-88) DataflowPipelineOptions.tempLocation doesn't really default to stagingLocation

2016-05-24 Thread Ilya Ganelin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-88?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298882#comment-15298882 ] Ilya Ganelin edited comment on BEAM-88 at 5/24/16 8:51 PM: --- I've spent some more

[jira] [Commented] (BEAM-88) DataflowPipelineOptions.tempLocation doesn't really default to stagingLocation

2016-05-24 Thread Ilya Ganelin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-88?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298882#comment-15298882 ] Ilya Ganelin commented on BEAM-88: -- I've spent some more time digging into this issue and it may actually be

[GitHub] incubator-beam pull request: Remove inheritance from Create.Timest...

2016-05-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/362 --- 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 #362

2016-05-24 Thread kenn
This closes #362 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5535fc3f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5535fc3f Diff:

[2/3] incubator-beam git commit: Clarify comment in Create coder inference

2016-05-24 Thread kenn
Clarify comment in Create coder inference Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ae80b5da Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ae80b5da Diff:

[jira] [Commented] (BEAM-305) In Spark runner tests - When using Create.of use it's #withCoder method instead of the created PCollection's #setCoder

2016-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298857#comment-15298857 ] ASF GitHub Bot commented on BEAM-305: - GitHub user ilganeli opened a pull request:

[GitHub] incubator-beam pull request: [BEAM-305] Replace usages of PCollect...

2016-05-24 Thread ilganeli
GitHub user ilganeli opened a pull request: https://github.com/apache/incubator-beam/pull/386 [BEAM-305] Replace usages of PCollection.setCoder with Create.of().withCoder in Spark Runner * Replaced all usages of ```PCollection.setCoder`` with the recommended ```withCoder``` in the

[2/4] incubator-beam git commit: Correctly forward dependsOnlyOnWindow(), etc, in WindowingStrategy

2016-05-24 Thread dhalperi
Correctly forward dependsOnlyOnWindow(), etc, in WindowingStrategy Previously, WindowingStrategy contained an implemenation of OutputTimeFn that did not properly forward these important methods. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit:

[4/4] incubator-beam git commit: Closes #385

2016-05-24 Thread dhalperi
Closes #385 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/65db44ce Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/65db44ce Diff:

[1/4] incubator-beam git commit: Improve the inheritance API for OutputTimeFn

2016-05-24 Thread dhalperi
Repository: incubator-beam Updated Branches: refs/heads/master a5d343b23 -> 65db44ce6 Improve the inheritance API for OutputTimeFn Previously, OutputTimeFn.Defaults enforced that any subclass *could not* return true for dependsOnlyOnWindow(), to encourage such subclasses to extend

[GitHub] incubator-beam pull request: Various fixes surrounding OutputTimeF...

2016-05-24 Thread kennknowles
GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/385 Various fixes surrounding OutputTimeFn Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR title is

Jenkins build became unstable: beam_PostCommit_RunnableOnService_GoogleCloudDataflow #408

2016-05-24 Thread Apache Jenkins Server
See

Jenkins build is back to normal : beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Flink :: Core #492

2016-05-24 Thread Apache Jenkins Server
See

Jenkins build is back to normal : beam_PostCommit_MavenVerify #492

2016-05-24 Thread Apache Jenkins Server
See

[jira] [Commented] (BEAM-305) In Spark runner tests - When using Create.of use it's #withCoder method instead of the created PCollection's #setCoder

2016-05-24 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298751#comment-15298751 ] Amit Sela commented on BEAM-305: Same as BEAM-211 but specifically for the Spark runner tests. > In Spark

[jira] [Updated] (BEAM-305) In Spark runner tests - When using Create.of use it's #withCoder method instead of the created PCollection's #setCoder

2016-05-24 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-305: --- Component/s: (was: sdk-java-core) runner-spark > In Spark runner tests - When using

[jira] [Updated] (BEAM-305) In Spark runner tests - When using Create.of use it's #withCoder method instead of the created PCollection's #setCoder

2016-05-24 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-305: --- Summary: In Spark runner tests - When using Create.of use it's #withCoder method instead of the created

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Flink :: Core #491

2016-05-24 Thread Apache Jenkins Server
See -- [...truncated 25 lines...] [INFO] --- maven-resources-plugin:2.7:testResources (default-testResources) @ flink_2.10 --- [INFO] Using 'UTF-8'

[jira] [Created] (BEAM-305) When using Create.of use it's #withCoder method instead of the created PCollection's #setCoder

2016-05-24 Thread Amit Sela (JIRA)
Amit Sela created BEAM-305: -- Summary: When using Create.of use it's #withCoder method instead of the created PCollection's #setCoder Key: BEAM-305 URL: https://issues.apache.org/jira/browse/BEAM-305

Build failed in Jenkins: beam_PostCommit_MavenVerify #491

2016-05-24 Thread Apache Jenkins Server
See Changes: [klk] Updated all existing instances of PCollection's #setCoder to use -- [...truncated 3508 lines...]

[jira] [Closed] (BEAM-211) When using Create.of use it's #withCoder method instead of the created PCollection's #setCoder

2016-05-24 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela closed BEAM-211. -- Resolution: Fixed PR-378 Will open another similar issue specifically about this issue in the Spark runner

[jira] [Updated] (BEAM-211) When using Create.of use it's #withCoder method instead of the created PCollection's #setCoder

2016-05-24 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-211: --- Assignee: Davor Bonaci > When using Create.of use it's #withCoder method instead of the created >

[jira] [Updated] (BEAM-211) When using Create.of use it's #withCoder method instead of the created PCollection's #setCoder

2016-05-24 Thread Amit Sela (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Amit Sela updated BEAM-211: --- Component/s: (was: runner-spark) sdk-java-core > When using Create.of use it's #withCoder

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

2016-05-24 Thread kenn
This closes #384 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a5d343b2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a5d343b2 Diff:

[GitHub] incubator-beam pull request: Temporarily skip javadoc for modules ...

2016-05-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/384 --- 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 #378

2016-05-24 Thread kenn
This closes #378 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8ff800b9 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8ff800b9 Diff:

[GitHub] incubator-beam pull request: Fix errors in Flink runner javadoc

2016-05-24 Thread kennknowles
Github user kennknowles closed the pull request at: https://github.com/apache/incubator-beam/pull/383 --- 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: Temporarily skip javadoc for modules ...

2016-05-24 Thread kennknowles
GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/384 Temporarily skip javadoc for modules where it fails Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [x] Make sure the PR

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Flink :: Core #490

2016-05-24 Thread Apache Jenkins Server
See -- [...truncated 25 lines...] [INFO] --- maven-resources-plugin:2.7:testResources (default-testResources) @ flink_2.10 --- [INFO] Using 'UTF-8'

Build failed in Jenkins: beam_PostCommit_MavenVerify #490

2016-05-24 Thread Apache Jenkins Server
See -- [...truncated 3491 lines...] * ^

[GitHub] incubator-beam pull request: Fix errors in Flink runner javadoc

2016-05-24 Thread kennknowles
GitHub user kennknowles opened a pull request: https://github.com/apache/incubator-beam/pull/383 Fix errors in Flink runner javadoc 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

[jira] [Commented] (BEAM-242) Enable Checkstyle check and Javadoc build for the Flink Runner

2016-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298525#comment-15298525 ] ASF GitHub Bot commented on BEAM-242: - GitHub user jbonofre opened a pull request:

[GitHub] incubator-beam pull request: [BEAM-242] Fix javadoc on Flink runne...

2016-05-24 Thread jbonofre
GitHub user jbonofre opened a pull request: https://github.com/apache/incubator-beam/pull/382 [BEAM-242] Fix javadoc on Flink runner. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [X] Make sure the PR title is

[jira] [Commented] (BEAM-103) Make UnboundedSourceWrapper parallel

2016-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15298188#comment-15298188 ] ASF GitHub Bot commented on BEAM-103: - GitHub user mxm opened a pull request:

Build failed in Jenkins: beam_PostCommit_MavenVerify #488

2016-05-24 Thread Apache Jenkins Server
See Changes: [davor] [BEAM-287] Introduce new org.apache.beam groupIds -- [...truncated 3505 lines...] * ^

Build failed in Jenkins: beam_PostCommit_MavenVerify #489

2016-05-24 Thread Apache Jenkins Server
See -- [...truncated 3508 lines...]

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Flink :: Core #488

2016-05-24 Thread Apache Jenkins Server
See -- [...truncated 25 lines...] [INFO] --- maven-resources-plugin:2.7:testResources (default-testResources) @ flink_2.10 --- [INFO] Using 'UTF-8'

[jira] [Updated] (BEAM-242) Enable Checkstyle check and Javadoc build for the Flink Runner

2016-05-24 Thread Davor Bonaci (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Davor Bonaci updated BEAM-242: -- Summary: Enable Checkstyle check and Javadoc build for the Flink Runner (was: Enable Checkstyle check

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

2016-05-24 Thread davor
This closes #365 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e2307f26 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e2307f26 Diff:

[GitHub] incubator-beam pull request: [Beam 287] Add new groupId

2016-05-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-beam/pull/365 --- 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-287] Introduce new org.apache.beam groupIds

2016-05-24 Thread davor
Repository: incubator-beam Updated Branches: refs/heads/master 68b8cbc81 -> e2307f263 [BEAM-287] Introduce new org.apache.beam groupIds Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/98aaf749 Tree:

Build failed in Jenkins: beam_PostCommit_MavenVerify #487

2016-05-24 Thread Apache Jenkins Server
See -- [...truncated 3492 lines...] * ^

Build failed in Jenkins: beam_PostCommit_MavenVerify » Apache Beam :: Runners :: Flink :: Core #487

2016-05-24 Thread Apache Jenkins Server
See -- [...truncated 25 lines...] [INFO] --- maven-resources-plugin:2.7:testResources (default-testResources) @ flink-runner_2.10 --- [INFO] Using 'UTF-8'