[GitHub] beam pull request #3293: [BEAM-2406] Fix NullPointerException when writing a...

GitHub user reuvenlax opened a pull request: https://github.com/apache/beam/pull/3293 [BEAM-2406] Fix NullPointerException when writing an empty table When writing to an empty table, BigQueryIO was throwing a NPE because WritePartitions was returning null. This was a regression in

[3/5] beam git commit: Add translation convenience for non-composites

Add translation convenience for non-composites Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9c3fbc37 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9c3fbc37 Diff:

[5/5] beam git commit: This closes #3283: [BEAM-3271] Add TestStream translation

This closes #3283: [BEAM-3271] Add TestStream translation Add TestStream translation Expose internal constructors for TestStream events Add TestStreamPayload to Runner API proto Add translation convenience for non-composites Project: http://git-wip-us.apache.org/repos/asf/beam/repo

[GitHub] beam pull request #3283: [BEAM-3271] Add TestStream translation

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

[2/5] beam git commit: Expose internal constructors for TestStream events

Expose internal constructors for TestStream events These are needed for deserialization from proto. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/47cea784 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/47cea784 Diff:

[1/5] beam git commit: Add TestStream translation

Repository: beam Updated Branches: refs/heads/master 462335caf -> 0cba43ee2 Add TestStream translation Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0cedc61f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0cedc61f

[4/5] beam git commit: Add TestStreamPayload to Runner API proto

Add TestStreamPayload to Runner API proto Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f5e30c52 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f5e30c52 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f5e30c52

[jira] [Commented] (BEAM-79) Gearpump runner

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

[GitHub] beam pull request #3292: [BEAM-79] Merge master into gearpump-runner

GitHub user manuzhang opened a pull request: https://github.com/apache/beam/pull/3292 [BEAM-79] Merge master into gearpump-runner Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #4010

See

Jenkins build is back to normal : beam_PostCommit_Java_JDK_Versions_Test » OpenJDK 7 (on Ubuntu only),beam #44

See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #94

See -- [...truncated 2.54 MB...] 2017-06-05T00:35:22.387 [INFO] Downloaded:

Build failed in Jenkins: beam_PostCommit_Java_JDK_Versions_Test » JDK 1.7 (latest),beam #44

See -- [...truncated 1.41 MB...] [javadoc] location: package java.util.concurrent [javadoc]

[GitHub] beam pull request #3291: Make all Hadoop related IOs use the same version pr...

GitHub user iemejia opened a pull request: https://github.com/apache/beam/pull/3291 Make all Hadoop related IOs use the same version property Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #4009

See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #93

See -- [...truncated 2.53 MB...] 2017-06-04T18:35:00.992 [INFO] Downloaded:

Build failed in Jenkins: beam_PostCommit_Java_JDK_Versions_Test » OpenJDK 7 (on Ubuntu only),beam #43

See -- [...truncated 899.35 KB...] at

Build failed in Jenkins: beam_PostCommit_Java_JDK_Versions_Test » OpenJDK 8 (on Ubuntu only),beam #43

See -- [...truncated 899.57 KB...] at

[jira] [Commented] (BEAM-1498) Use Flink-native side outputs

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

[GitHub] beam pull request #3290: [BEAM-1498] Use Flink-native side outputs

GitHub user JingsongLi opened a pull request: https://github.com/apache/beam/pull/3290 [BEAM-1498] Use Flink-native side outputs Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4008

See

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #92

See Changes: [aljoscha.krettek] Fix race condition when outputting pushed-back elements in Flink Runner [aljoscha.krettek] [BEAM-2401] Update Flink Runner to Flink 1.3.0 [hepei.hp]

Build failed in Jenkins: beam_PostCommit_Java_JDK_Versions_Test » OpenJDK 8 (on Ubuntu only),beam #42

See Changes: [aljoscha.krettek] Fix race condition when outputting pushed-back elements in Flink Runner [aljoscha.krettek] [BEAM-2401]

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Spark #2261

See

Build failed in Jenkins: beam_PostCommit_Java_JDK_Versions_Test » OpenJDK 7 (on Ubuntu only),beam #42

See Changes: [aljoscha.krettek] Fix race condition when outputting pushed-back elements in Flink Runner [aljoscha.krettek] [BEAM-2401]

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Spark #2260

See

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Gearpump #172

See -- GitHub pull request #3286 of commit 3be3911e15c58b4020ca0f32770dd99730ae6637, no merge conflicts. Setting status of

[GitHub] beam pull request #3289: Flink runner: support MapState in FlinkStateInterna...

GitHub user peihe opened a pull request: https://github.com/apache/beam/pull/3289 Flink runner: support MapState in FlinkStateInternals. Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[GitHub] beam pull request #3245: Flink runner: specify CheckpointingMode and Checkpo...

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

[3/3] beam git commit: This closes #3245

This closes #3245 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/462335ca Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/462335ca Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/462335ca Branch:

[2/3] beam git commit: Flink runner: specify CheckpointingMode through PipelineOptions.

Flink runner: specify CheckpointingMode through PipelineOptions. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b8035ae7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b8035ae7 Diff:

[1/3] beam git commit: Flink runner: specify checkpointTimeout through PipelineOptions.

Repository: beam Updated Branches: refs/heads/master 1866a0113 -> 462335caf Flink runner: specify checkpointTimeout through PipelineOptions. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/802f10af Tree:

Jenkins build is back to stable : beam_PostCommit_Java_MavenInstall #4005

See

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #4004

See

[jira] [Closed] (BEAM-567) FlinkRunner pollutes beam-examples-java[8] modules with SLF4J backend dependencies which are not optional (e.g. test/provided/system scoped, or marked optional)

[ https://issues.apache.org/jira/browse/BEAM-567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-567. - Resolution: Fixed Fix Version/s: 2.1.0 This was fixed by updating to Flink 1.3.0 which

Jenkins build is back to normal : beam_PostCommit_Java_JDK_Versions_Test » OpenJDK 7 (on Ubuntu only),beam #41

See

[jira] [Closed] (BEAM-2380) Flink Batch Runner does not forward additional outputs to operator

[ https://issues.apache.org/jira/browse/BEAM-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-2380. -- Resolution: Fixed > Flink Batch Runner does not forward additional outputs to operator >

[jira] [Closed] (BEAM-2401) Update Flink Runner to Flink 1.3.0

[ https://issues.apache.org/jira/browse/BEAM-2401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed BEAM-2401. -- Resolution: Fixed > Update Flink Runner to Flink 1.3.0 > -- > >

[jira] [Updated] (BEAM-2401) Update Flink Runner to Flink 1.3.0

[ https://issues.apache.org/jira/browse/BEAM-2401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated BEAM-2401: --- Fix Version/s: 2.1.0 > Update Flink Runner to Flink 1.3.0 > --

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall_Windows #91

See -- [...truncated 2.53 MB...] 2017-06-04T06:30:40.687 [INFO] 2017-06-04T06:30:40.687 [INFO] --- groovy-maven-plugin:2.0:execute

[jira] [Commented] (BEAM-2401) Update Flink Runner to Flink 1.3.0

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

[GitHub] beam pull request #3284: [BEAM-2401] Update Flink Runner to Flink 1.3.0

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

[2/2] beam git commit: This closes #3284

This closes #3284 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1866a011 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1866a011 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1866a011 Branch:

[1/2] beam git commit: [BEAM-2401] Update Flink Runner to Flink 1.3.0

Repository: beam Updated Branches: refs/heads/master ef56ea495 -> 1866a0113 [BEAM-2401] Update Flink Runner to Flink 1.3.0 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fbc6cc59 Tree:

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Spark #2256

See

Build failed in Jenkins: beam_PostCommit_Java_JDK_Versions_Test » OpenJDK 8 (on Ubuntu only),beam #41

See -- [...truncated 876.05 KB...] 2017-06-04\T\06:13:05.579 [INFO] Excluding

[GitHub] beam pull request #3285: Fix race condition when outputting pushed-back elem...

Github user aljoscha closed the pull request at: https://github.com/apache/beam/pull/3285 --- 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 is

[1/2] beam git commit: Fix race condition when outputting pushed-back elements in Flink Runner

Repository: beam Updated Branches: refs/heads/master 43c44232d -> ef56ea495 Fix race condition when outputting pushed-back elements in Flink Runner This affected the Flink Streaming Runner DoFnOperator. The recent fix of emitting pushed-back data when receiving a watermark on the first input

[2/2] beam git commit: This closes #3285

This closes #3285 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ef56ea49 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ef56ea49 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ef56ea49 Branch: