Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #2943

See -- [...truncated 2.15 MB...] 2017-03-18T06:37:40.222 [INFO] Installing

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Apex #797

See

[jira] [Commented] (BEAM-1744) add code snippet in page Design_Your_Pipeline

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

[GitHub] beam-site pull request #188: [BEAM-1744] add code snippet in page Design_You...

GitHub user XuMingmin opened a pull request: https://github.com/apache/beam-site/pull/188 [BEAM-1744] add code snippet in page Design_Your_Pipeline You can merge this pull request into a Git repository by running: $ git pull https://github.com/XuMingmin/beam-site asf-site Alt

[GitHub] beam-site pull request #187: Add aviemzur as committer

GitHub user aviemzur opened a pull request: https://github.com/apache/beam-site/pull/187 Add aviemzur as committer You can merge this pull request into a Git repository by running: $ git pull https://github.com/aviemzur/beam-site aviemzur-committer Alternatively you can revie

Build failed in Jenkins: beam_PostCommit_Python_Verify #1543

See -- [...truncated 425.66 KB...] root: INFO: Starting GCS upload to gs://temp-storage-for-end-to-end-tests/staging-validatesrunner-test/beamapp-jenkins-0318030552-455859.

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2581

See

[GitHub] beam-site pull request #186: Add chamikara as a committer

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

[1/3] beam-site git commit: Add chamikara as a committer

Repository: beam-site Updated Branches: refs/heads/asf-site b5748765f -> 046538547 Add chamikara as a committer Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/1fef9055 Tree: http://git-wip-us.apache.org/repos/asf/

[2/3] beam-site git commit: Regenerate website

Regenerate website Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/598706dc Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/598706dc Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/598706dc Bra

[3/3] beam-site git commit: This closes #186

This closes #186 Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/04653854 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/04653854 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/04653854 Branc

[GitHub] beam-site pull request #173: [BEAM-1665] Add Pipeline I/O section to website...

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

[1/4] beam-site git commit: Add Pipeline I/O section to website - outline + move some existing content

Repository: beam-site Updated Branches: refs/heads/asf-site cb6d7d77e -> b5748765f Add Pipeline I/O section to website - outline + move some existing content * I did not to go with a single page for all this content b/c both java and python have enough unique content that they deserve their o

[3/4] beam-site git commit: Regenerate website

Regenerate website Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/35c2d97b Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/35c2d97b Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/35c2d97b Bra

[4/4] beam-site git commit: This closes #173

This closes #173 Project: http://git-wip-us.apache.org/repos/asf/beam-site/repo Commit: http://git-wip-us.apache.org/repos/asf/beam-site/commit/b5748765 Tree: http://git-wip-us.apache.org/repos/asf/beam-site/tree/b5748765 Diff: http://git-wip-us.apache.org/repos/asf/beam-site/diff/b5748765 Branc

[2/4] beam-site git commit: Regenerate website

http://git-wip-us.apache.org/repos/asf/beam-site/blob/35c2d97b/content/documentation/io/contributing/index.html -- diff --git a/content/documentation/io/contributing/index.html b/content/documentation/io/contributing/index.html ne

[jira] [Commented] (BEAM-1665) Update Beam site to reflect new Pipeline I/O docs structure

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

Jenkins build is back to stable : beam_PostCommit_Java_RunnableOnService_Dataflow #2580

See

[GitHub] beam-site pull request #186: Add chamikara as a committer

GitHub user chamikaramj opened a pull request: https://github.com/apache/beam-site/pull/186 Add chamikara as a committer You can merge this pull request into a Git repository by running: $ git pull https://github.com/chamikaramj/beam-site website_add_to_team Alternatively you

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

This closes #2270 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3f0fe91a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3f0fe91a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3f0fe91a Branch: refs/heads/maste

[GitHub] beam pull request #2270: Update worker container

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

[1/2] beam git commit: New container

Repository: beam Updated Branches: refs/heads/master b672cde11 -> 3f0fe91aa New container Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ecf7bd91 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ecf7bd91 Diff: http://

[jira] [Created] (BEAM-1748) Clean DeprecationWarning from SDK/tests

Ahmet Altay created BEAM-1748: - Summary: Clean DeprecationWarning from SDK/tests Key: BEAM-1748 URL: https://issues.apache.org/jira/browse/BEAM-1748 Project: Beam Issue Type: Bug Compon

[GitHub] beam pull request #2270: Update worker container

GitHub user mariapython opened a pull request: https://github.com/apache/beam/pull/2270 Update worker container Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is formatted like: `[BEAM-

[jira] [Created] (BEAM-1749) Upgrade pep8 to pycodestyle

Ahmet Altay created BEAM-1749: - Summary: Upgrade pep8 to pycodestyle Key: BEAM-1749 URL: https://issues.apache.org/jira/browse/BEAM-1749 Project: Beam Issue Type: Bug Components: sdk-py

[jira] [Commented] (BEAM-1738) DataflowRunner should override Reshuffle transform

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

[GitHub] beam pull request #2269: [BEAM-1738] Do not reify timestamps in Reshuffle in...

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2269 [BEAM-1738] Do not reify timestamps in Reshuffle in Dataflow Be sure to do all of the following to help us incorporate your contribution quickly and easily: - [ ] Make sure the PR title is

[jira] [Created] (BEAM-1747) Add a postcommit test for version

Ahmet Altay created BEAM-1747: - Summary: Add a postcommit test for version Key: BEAM-1747 URL: https://issues.apache.org/jira/browse/BEAM-1747 Project: Beam Issue Type: Bug Components:

[jira] [Created] (BEAM-1746) Include LICENSE and NOTICE in python dist files

Ahmet Altay created BEAM-1746: - Summary: Include LICENSE and NOTICE in python dist files Key: BEAM-1746 URL: https://issues.apache.org/jira/browse/BEAM-1746 Project: Beam Issue Type: Bug

[jira] [Resolved] (BEAM-1653) Error when using PubsubIO with the DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-1653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh resolved BEAM-1653. --- Resolution: Fixed Fix Version/s: First stable release > Error when using PubsubIO with the Direc

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Gearpump #164

See

[jira] [Commented] (BEAM-1653) Error when using PubsubIO with the DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-1653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15930846#comment-15930846 ] Thomas Groh commented on BEAM-1653: --- This should be fixed in HEAD. There are future chang

[GitHub] beam pull request #2268: [BEAM-1655] Maintain Safe-to-ACK IDs through Coder ...

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/2268 [BEAM-1655] Maintain Safe-to-ACK IDs through Coder in PubsubIO 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-1655) Evaluate the PubsubUnboundedSource

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

[jira] [Comment Edited] (BEAM-1582) ResumeFromCheckpointStreamingTest flakes with what appears as a second firing.

[ https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895861#comment-15895861 ] Amit Sela edited comment on BEAM-1582 at 3/17/17 10:21 PM: --- Could

[jira] [Comment Edited] (BEAM-1582) ResumeFromCheckpointStreamingTest flakes with what appears as a second firing.

[ https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895861#comment-15895861 ] Amit Sela edited comment on BEAM-1582 at 3/17/17 10:21 PM: --- Could

[jira] [Comment Edited] (BEAM-1582) ResumeFromCheckpointStreamingTest flakes with what appears as a second firing.

[ https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895861#comment-15895861 ] Amit Sela edited comment on BEAM-1582 at 3/17/17 10:19 PM: --- Could

[jira] [Comment Edited] (BEAM-1582) ResumeFromCheckpointStreamingTest flakes with what appears as a second firing.

[ https://issues.apache.org/jira/browse/BEAM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895861#comment-15895861 ] Amit Sela edited comment on BEAM-1582 at 3/17/17 10:14 PM: --- Could

Jenkins build became unstable: beam_PostCommit_Java_RunnableOnService_Dataflow #2579

See

[jira] [Resolved] (BEAM-1365) Bigquery dataset names should allow for . inside them

[ https://issues.apache.org/jira/browse/BEAM-1365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay resolved BEAM-1365. --- Resolution: Won't Fix Fix Version/s: Not applicable > Bigquery dataset names should allow for .

[jira] [Closed] (BEAM-804) Python Pipeline Option save_main_session non-functional

[ https://issues.apache.org/jira/browse/BEAM-804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay closed BEAM-804. Resolution: Fixed Fix Version/s: Not applicable > Python Pipeline Option save_main_session non-function

[jira] [Closed] (BEAM-693) pydoc is not working

[ https://issues.apache.org/jira/browse/BEAM-693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay closed BEAM-693. Resolution: Fixed Fix Version/s: Not applicable > pydoc is not working > > >

[37/50] [abbrv] beam git commit: This closes #2222

This closes # Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/39688d8d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/39688d8d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/39688d8d Branch: refs/heads/gearp

[25/50] [abbrv] beam git commit: add unicode type to the typeDict attribute in Python SDK

add unicode type to the typeDict attribute in Python SDK Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7daf9abd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7daf9abd Diff: http://git-wip-us.apache.org/repos/asf/beam/

[18/50] [abbrv] beam git commit: This closes #1868

This closes #1868 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c12d432d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c12d432d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c12d432d Branch: refs/heads/gearp

[01/50] [abbrv] beam git commit: This closes #2142: Deprecate Pipeline.getOptions

Repository: beam Updated Branches: refs/heads/gearpump-runner 15a8ad62a -> 555842a1a This closes #2142: Deprecate Pipeline.getOptions Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ef256df1 Tree: http://git-wip-us.apache.or

[16/50] [abbrv] beam git commit: Move GC timer checking to StatefulDoFnRunner.CleanupTimer

Move GC timer checking to StatefulDoFnRunner.CleanupTimer Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bf6d2748 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bf6d2748 Diff: http://git-wip-us.apache.org/repos/asf/beam

[08/50] [abbrv] beam git commit: Auto-generated runner api proto bindings.

http://git-wip-us.apache.org/repos/asf/beam/blob/3bb125e1/sdks/python/apache_beam/runners/api/beam_runner_api_pb2.py -- diff --git a/sdks/python/apache_beam/runners/api/beam_runner_api_pb2.py b/sdks/python/apache_beam/runners/api/

[17/50] [abbrv] beam git commit: [BEAM-797] A PipelineVisitor that creates a Spark-native pipeline.

[BEAM-797] A PipelineVisitor that creates a Spark-native pipeline. [BEAM-797] Remove unnecessary temp dir from test Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/94bef14e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree

[35/50] [abbrv] beam git commit: This closes #2221

This closes #2221 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9299e263 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9299e263 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9299e263 Branch: refs/heads/gearp

[45/50] [abbrv] beam git commit: Revert BigQueryIO bit of 'Make all uses of CountingOutputStream close their resources'

Revert BigQueryIO bit of 'Make all uses of CountingOutputStream close their resources' This reverts the portion of commit 3115dbdca1858511e98476b5c79e6cca98782b0b that touches BigQueryIO, which caused a double close bug. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://g

[05/50] [abbrv] beam git commit: This closes #2197: Bump Dataflow ROS timeout to 120 minutes

This closes #2197: Bump Dataflow ROS timeout to 120 minutes Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f13a84d6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f13a84d6 Diff: http://git-wip-us.apache.org/repos/asf/be

[49/50] [abbrv] beam git commit: [BEAM-79] Fix gearpump-runner merge conflicts and test failure

[BEAM-79] Fix gearpump-runner merge conflicts and test failure Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3eab6a64 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3eab6a64 Diff: http://git-wip-us.apache.org/repos/asf

[19/50] [abbrv] beam git commit: [BEAM-1661] Shade guava in the JdbcIO

[BEAM-1661] Shade guava in the JdbcIO Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/818e521f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/818e521f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/818e521f Bran

[15/50] [abbrv] beam git commit: Introduce Flink-specific state GC implementations

Introduce Flink-specific state GC implementations We now set the GC timer for window.maxTimestamp() + 1 to ensure that a user timer set for window.maxTimestamp() still has all state. This also adds tests for late data dropping and state GC specifically for the Flink DoFnOperator. Project: http:

[38/50] [abbrv] beam git commit: Ignore results from the tox clean up phase

Ignore results from the tox clean up phase Some temporary files are generated only under certain conditions and this should not fail tox. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/12016e59 Tree: http://git-wip-us.apache.o

[41/50] [abbrv] beam git commit: This closes #2225

This closes #2225 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7c78480c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7c78480c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7c78480c Branch: refs/heads/gearp

[06/50] [abbrv] beam git commit: Runner API context helper classes.

Runner API context helper classes. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bc76a186 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/bc76a186 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/bc76a186 Branch:

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

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

[13/50] [abbrv] beam git commit: Move pipeline context and add more tests.

Move pipeline context and add more tests. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/deff128f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/deff128f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/deff128f

[GitHub] beam pull request #2241: [BEAM-79] Sync gearpump-runner branch with master

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

[26/50] [abbrv] beam git commit: This closes #2210

This closes #2210 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/54390a33 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/54390a33 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/54390a33 Branch: refs/heads/gearp

[23/50] [abbrv] beam git commit: [BEAM-1686] This closes #2219

[BEAM-1686] This closes #2219 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/818fc941 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/818fc941 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/818fc941 Branch: refs

[28/50] [abbrv] beam git commit: This closes #2144: Remove Pipeline.getRunner

This closes #2144: Remove Pipeline.getRunner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e31cb2b4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e31cb2b4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e31cb2b

[36/50] [abbrv] beam git commit: Add README to python tarball.

Add README to python tarball. And, delete test created files, to avoid them being included in the tarball. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ec6da893 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ec6da893

[07/50] [abbrv] beam git commit: Auto-generated runner api proto bindings.

http://git-wip-us.apache.org/repos/asf/beam/blob/3bb125e1/sdks/python/run_pylint.sh -- diff --git a/sdks/python/run_pylint.sh b/sdks/python/run_pylint.sh index afc5fb4..5e63856 100755 --- a/sdks/python/run_pylint.sh +++ b/sdks/pyth

[32/50] [abbrv] beam git commit: [BEAM-1551] Allow `PAssert`s to take a message

[BEAM-1551] Allow `PAssert`s to take a message Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e3cafb42 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e3cafb42 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e3caf

[39/50] [abbrv] beam git commit: This closes #2224

This closes #2224 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f29bf89c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f29bf89c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f29bf89c Branch: refs/heads/gearp

[47/50] [abbrv] beam git commit: Merge branch 'master' of https://github.com/apache/incubator-beam into gearpump-runner

Merge branch 'master' of https://github.com/apache/incubator-beam into gearpump-runner Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3f917987 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3f917987 Diff: http://git-wi

[42/50] [abbrv] beam git commit: This closes #2109: Allow `PAssert`s to take a message

This closes #2109: Allow `PAssert`s to take a message Remove exception suppression from PAssert.SideInputCheckerDoFn Added assertion failure tests for `PAssert#thatSingleton` Added a test of default PAssert failure reason Javadoc changes [BEAM-1551] Allow `PAssert`s to take a message P

[22/50] [abbrv] beam git commit: [BEAM-1686] Use random MQTT clientID when not defined to avoid NPE

[BEAM-1686] Use random MQTT clientID when not defined to avoid NPE Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/752ad8a0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/752ad8a0 Diff: http://git-wip-us.apache.org/repos

[20/50] [abbrv] beam git commit: Properly deal with late processing-time timers

Properly deal with late processing-time timers Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/dbfcf4b4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/dbfcf4b4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/dbfcf

[04/50] [abbrv] beam git commit: This closes #1994

This closes #1994 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b79dd642 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b79dd642 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b79dd642 Branch: refs/heads/gearp

[jira] [Commented] (BEAM-1727) Add setForNowAlign(period, offset) to Timer

[ https://issues.apache.org/jira/browse/BEAM-1727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15930787#comment-15930787 ] Kenneth Knowles commented on BEAM-1727: --- It seems like a real error to set a timer fo

[46/50] [abbrv] beam git commit: This closes #2226

This closes #2226 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/781e4172 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/781e4172 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/781e4172 Branch: refs/heads/gearp

[50/50] [abbrv] beam git commit: This closes #2241: merge master to gearpump-master and fixup

This closes #2241: merge master to gearpump-master and fixup [BEAM-79] Fix gearpump-runner merge conflicts and test failure Revert BigQueryIO bit of 'Make all uses of CountingOutputStream close their resources' [BEAM-1629] Init metrics/aggregators accumulators before traversing pipeline G

[14/50] [abbrv] beam git commit: Closes #2190

Closes #2190 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2c2424cb Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2c2424cb Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2c2424cb Branch: refs/heads/gearpump-r

[29/50] [abbrv] beam git commit: Javadoc changes

Javadoc changes Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/0d08d2a4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/0d08d2a4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/0d08d2a4 Branch: refs/heads/gearpum

[02/50] [abbrv] beam git commit: HadoopInputFormatIO with junits

http://git-wip-us.apache.org/repos/asf/beam/blob/d01620c0/sdks/java/io/hadoop-input-format/src/test/java/org/apache/beam/sdk/io/hadoop/inputformat/HadoopInputFormatIOTest.java -- diff --git a/sdks/java/io/hadoop-input-format/src/t

[44/50] [abbrv] beam git commit: This closes #2171

This closes #2171 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b6ca062f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b6ca062f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b6ca062f Branch: refs/heads/gearp

[31/50] [abbrv] beam git commit: Added assertion failure tests for `PAssert#thatSingleton`

Added assertion failure tests for `PAssert#thatSingleton` Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/59fd45b8 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/59fd45b8 Diff: http://git-wip-us.apache.org/repos/asf/beam

[43/50] [abbrv] beam git commit: [BEAM-1629] Init metrics/aggregators accumulators before traversing pipeline

[BEAM-1629] Init metrics/aggregators accumulators before traversing pipeline Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/874c8d0d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/874c8d0d Diff: http://git-wip-us.apache

[48/50] [abbrv] beam git commit: [BEAM-79] Fix gearpump-runner merge conflicts and test failure

http://git-wip-us.apache.org/repos/asf/beam/blob/3eab6a64/runners/gearpump/src/main/java/org/apache/beam/runners/gearpump/translators/WindowBoundTranslator.java -- diff --git a/runners/gearpump/src/main/java/org/apache/beam/runner

[30/50] [abbrv] beam git commit: Added a test of default PAssert failure reason

Added a test of default PAssert failure reason Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2485a4cc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2485a4cc Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2485a

[40/50] [abbrv] beam git commit: Generate zip distribution for pyhthon

Generate zip distribution for pyhthon Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/466e83fd Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/466e83fd Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/466e83fd Bran

[27/50] [abbrv] beam git commit: This closes #2217: Fix Flink State GC

This closes #2217: Fix Flink State GC Properly deal with late processing-time timers Introduce Flink-specific state GC implementations Move GC timer checking to StatefulDoFnRunner.CleanupTimer Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/re

[21/50] [abbrv] beam git commit: [BEAM-1661] This closes #2205

[BEAM-1661] This closes #2205 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/fdba784a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/fdba784a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/fdba784a Branch: refs

[12/50] [abbrv] beam git commit: Runner API encoding of WindowFns.

Runner API encoding of WindowFns. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aad32b7a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/aad32b7a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/aad32b7a Branch:

[03/50] [abbrv] beam git commit: HadoopInputFormatIO with junits

HadoopInputFormatIO with junits Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d01620c0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d01620c0 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d01620c0 Branch: re

[10/50] [abbrv] beam git commit: Add license to new files.

Add license to new files. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/b2da21e2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/b2da21e2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/b2da21e2 Branch: refs/hea

[11/50] [abbrv] beam git commit: Runner API translation of triggers and windowing strategies.

Runner API translation of triggers and windowing strategies. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5b86e1fc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5b86e1fc Diff: http://git-wip-us.apache.org/repos/asf/b

[24/50] [abbrv] beam git commit: Remove Pipeline.getRunner

Remove Pipeline.getRunner Runners need not be instantiated until after pipeline construction, so they should not be exposed by the Pipeline class. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d41fe1df Tree: http://git-wip-us

[33/50] [abbrv] beam git commit: Remove duplicated dependency from Dataflow runner pom.xml

Remove duplicated dependency from Dataflow runner pom.xml Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ed5cb8a6 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ed5cb8a6 Diff: http://git-wip-us.apache.org/repos/asf/beam

[09/50] [abbrv] beam git commit: Auto-generated runner api proto bindings.

Auto-generated runner api proto bindings. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3bb125e1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3bb125e1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3bb125e1

[34/50] [abbrv] beam git commit: Remove exception suppression from PAssert.SideInputCheckerDoFn

Remove exception suppression from PAssert.SideInputCheckerDoFn Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3669146c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3669146c Diff: http://git-wip-us.apache.org/repos/asf

[jira] [Resolved] (BEAM-782) Resolve runners in a case-insensitive manner.

[ https://issues.apache.org/jira/browse/BEAM-782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmet Altay resolved BEAM-782. -- Resolution: Fixed Fix Version/s: Not applicable > Resolve runners in a case-insensitive manner. >

[jira] [Commented] (BEAM-1730) Python post commits timing out

[ https://issues.apache.org/jira/browse/BEAM-1730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15930762#comment-15930762 ] Sourabh Bajaj commented on BEAM-1730: - Please close > Python post commits timing out >

[jira] [Commented] (BEAM-1365) Bigquery dataset names should allow for . inside them

[ https://issues.apache.org/jira/browse/BEAM-1365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15930760#comment-15930760 ] Sourabh Bajaj commented on BEAM-1365: - We didn't reach a conclusion on if we want it or

[jira] [Commented] (BEAM-693) pydoc is not working

[ https://issues.apache.org/jira/browse/BEAM-693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15930756#comment-15930756 ] Sourabh Bajaj commented on BEAM-693: Yes > pydoc is not working >

[jira] [Commented] (BEAM-804) Python Pipeline Option save_main_session non-functional

[ https://issues.apache.org/jira/browse/BEAM-804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15930759#comment-15930759 ] Sourabh Bajaj commented on BEAM-804: Yes > Python Pipeline Option save_main_session non

  1   2   >