Build failed in Jenkins: beam_PerformanceTests_Python #546

See Changes: [chamikara] [BEAM-3060] Adds TextIOIT for DirectRunner and local filesystem -- Started by timer [EnvInject] - Loading node environment variables. B

[jira] [Commented] (BEAM-3035) Extract ReifyTimestampsAndWindows from GatherAllPanes

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

[jira] [Commented] (BEAM-3035) Extract ReifyTimestampsAndWindows from GatherAllPanes

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

[GitHub] beam pull request #4057: [BEAM-3035] Extract ReifyTimestampsAndWindows

Github user wtanaka closed the pull request at: https://github.com/apache/beam/pull/4057 ---

[GitHub] beam pull request #4057: [BEAM-3035] Extract ReifyTimestampsAndWindows

GitHub user wtanaka reopened a pull request: https://github.com/apache/beam/pull/4057 [BEAM-3035] Extract ReifyTimestampsAndWindows from GatherAllPanes --- - [x] Make sure there is a [JIRA issue](https://issues.apache.org/jira/projects/BEAM/issues/) filed for the

[jira] [Commented] (BEAM-3171) convert a join into lookup

[ https://issues.apache.org/jira/browse/BEAM-3171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16248314#comment-16248314 ] Xu Mingmin commented on BEAM-3171: -- [~takidau] Yes, and here's the definition {code} publi

[GitHub] beam pull request #4115: [BEAM-3170] support topicPartition in BeamKafkaTabl...

GitHub user XuMingmin opened a pull request: https://github.com/apache/beam/pull/4115 [BEAM-3170] support topicPartition in BeamKafkaTable Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue](https://is

[jira] [Commented] (BEAM-3170) support topicPartition in BeamKafkaTable

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

Build failed in Jenkins: beam_PostCommit_Python_Verify #3527

See -- [...truncated 932.50 KB...] copying apache_beam/runners/dataflow/native_io/iobase_test.py -> apache-beam-2.3.0.dev0/apache_beam/runners/dataflow/native_io copying ap

[jira] [Commented] (BEAM-3171) convert a join into lookup

[ https://issues.apache.org/jira/browse/BEAM-3171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16248295#comment-16248295 ] James Xu commented on BEAM-3171: I like the ability to external joining a dimension table.

Build failed in Jenkins: beam_PostCommit_Python_Verify #3526

See Changes: [chamikara] [BEAM-3060] Adds TextIOIT for DirectRunner and local filesystem -- [...truncated 931.19 KB...] copying apache_beam/runners/dataflow/n

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Dataflow #4326

See

[jira] [Commented] (BEAM-3171) convert a join into lookup

[ https://issues.apache.org/jira/browse/BEAM-3171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16248272#comment-16248272 ] Tyler Akidau commented on BEAM-3171: BeamSeekableTable is a new addition as part of thi

[GitHub] beam pull request #4081: [BEAM-3060] Adds TextIOIT for DirectRunner and loca...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/4081 ---

[jira] [Commented] (BEAM-3060) Add performance tests for commonly used file-based I/O PTransforms

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

[1/2] beam git commit: [BEAM-3060] Adds TextIOIT for DirectRunner and local filesystem

Repository: beam Updated Branches: refs/heads/master 51c938d4e -> acfab8965 [BEAM-3060] Adds TextIOIT for DirectRunner and local filesystem This is one of multiple commits to resolve the 3060 issue. Currently only local filesystem, relatively small datasets and DirectRunner are supported. Mor

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

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

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #4325

See

Build failed in Jenkins: beam_PerformanceTests_Python #545

See Changes: [lcwik] Add A FnService, FnServer to runner Fn Execution [chamikara] Properly handle side input exception when all reader threads complete -- Sta

[jira] [Created] (BEAM-3173) Proto code generation fails in Python on Jenkins

holdenk created BEAM-3173: - Summary: Proto code generation fails in Python on Jenkins Key: BEAM-3173 URL: https://issues.apache.org/jira/browse/BEAM-3173 Project: Beam Issue Type: Bug Compo

[jira] [Commented] (BEAM-3172) Side input reader exceptions are not properly handled when no elements are emitted

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

[GitHub] beam pull request #4114: [BEAM-3172] CP PR 4113: Properly handle side input ...

GitHub user charlesccychen opened a pull request: https://github.com/apache/beam/pull/4114 [BEAM-3172] CP PR 4113: Properly handle side input exception when all reader threads complete R: @reuvenlax CC: @chamikaramj You can merge this pull request into a Git repository by run

[jira] [Commented] (BEAM-3172) Side input reader exceptions are not properly handled when no elements are emitted

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

[1/2] beam git commit: Properly handle side input exception when all reader threads complete

Repository: beam Updated Branches: refs/heads/master a0eb00e73 -> 51c938d4e Properly handle side input exception when all reader threads complete Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6779b8ec Tree: http://git-wip-

[GitHub] beam pull request #4112: [BEAM-3172] Properly handle side input exception wh...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/4112 ---

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

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

[jira] [Commented] (BEAM-2718) Add bundle retry logic to the DirectRunner

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

[GitHub] beam pull request #4113: [BEAM-2718] Integrate bundle retry code for the Dir...

GitHub user mariapython opened a pull request: https://github.com/apache/beam/pull/4113 [BEAM-2718] Integrate bundle retry code for the DirectRunner When processing of a bundle fails, the bundle is retried. - [x] Remove opt-in flag, make it happen by default. You can merge thi

Build failed in Jenkins: beam_PostCommit_Python_Verify #3524

See -- [...truncated 934.15 KB...] copying apache_beam/runners/dataflow/native_io/iobase_test.py -> apache-beam-2.3.0.dev0/apache_beam/runners/dataflow/native_io copying ap

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Dataflow #4324

See

[jira] [Updated] (BEAM-3172) Side input reader exceptions are not properly handled when no elements are emitted

[ https://issues.apache.org/jira/browse/BEAM-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath updated BEAM-3172: - Fix Version/s: 2.2.0 > Side input reader exceptions are not properly handled when no elemen

[jira] [Updated] (BEAM-3172) Side input reader exceptions are not properly handled when no elements are emitted

[ https://issues.apache.org/jira/browse/BEAM-3172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath updated BEAM-3172: - Priority: Blocker (was: Major) > Side input reader exceptions are not properly handled whe

[jira] [Commented] (BEAM-3169) WriteFiles data loss with some triggers

[ https://issues.apache.org/jira/browse/BEAM-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247982#comment-16247982 ] Eugene Kirpichov commented on BEAM-3169: I was able to reproduce this in a few seco

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #5214

See -- [...truncated 1.44 MB...] 2017-11-10T19:52:07.404 [INFO] Excluding org.fusesource.hawtdispatch:hawtdispatch-transport:jar:1.22 from the shaded jar. 2017-11-10T19

[jira] [Commented] (BEAM-3172) Side input reader exceptions are not properly handled when no elements are emitted

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

[GitHub] beam pull request #4112: [BEAM-3172] Properly handle side input exception wh...

GitHub user charlesccychen opened a pull request: https://github.com/apache/beam/pull/4112 [BEAM-3172] Properly handle side input exception when all reader threads complete R: @chamikaramj You can merge this pull request into a Git repository by running: $ git pull https://gi

[jira] [Created] (BEAM-3172) Side input reader exceptions are not properly handled when no elements are emitted

Charles Chen created BEAM-3172: -- Summary: Side input reader exceptions are not properly handled when no elements are emitted Key: BEAM-3172 URL: https://issues.apache.org/jira/browse/BEAM-3172 Project: B

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Apex #2775

See

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Dataflow #4323

See Changes: [bchambers] Dataflow: Add option to upload heap dumps to GCS -- [...truncated 21.21 MB...] [INFO] 2017-11-10T19:01:21.031Z: (a126

Build failed in Jenkins: beam_PostCommit_Java_MavenInstall #5213

See Changes: [bchambers] Dataflow: Add option to upload heap dumps to GCS -- [...truncated 1.43 MB...] 2017-11-10T18:42:45.712 [INFO] Excluding org.fuses

[jira] [Created] (BEAM-3171) convert a join into lookup

Xu Mingmin created BEAM-3171: Summary: convert a join into lookup Key: BEAM-3171 URL: https://issues.apache.org/jira/browse/BEAM-3171 Project: Beam Issue Type: New Feature Components: d

[jira] [Comment Edited] (BEAM-3169) WriteFiles data loss with some triggers

[ https://issues.apache.org/jira/browse/BEAM-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247891#comment-16247891 ] Eugene Kirpichov edited comment on BEAM-3169 at 11/10/17 6:41 PM: ---

[jira] [Updated] (BEAM-3169) WriteFiles data loss with some triggers

[ https://issues.apache.org/jira/browse/BEAM-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov updated BEAM-3169: --- Fix Version/s: 2.2.0 > WriteFiles data loss with some triggers > --

[jira] [Updated] (BEAM-3169) WriteFiles data loss with some triggers

[ https://issues.apache.org/jira/browse/BEAM-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eugene Kirpichov updated BEAM-3169: --- Affects Version/s: 2.2.0 2.0.0 2.1.0 > WriteFiles

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Spark #3459

See

[jira] [Commented] (BEAM-3169) WriteFiles data loss with some triggers

[ https://issues.apache.org/jira/browse/BEAM-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247891#comment-16247891 ] Eugene Kirpichov commented on BEAM-3169: I think the proper fix to this is to eithe

[jira] [Commented] (BEAM-3169) WriteFiles data loss with some triggers

[ https://issues.apache.org/jira/browse/BEAM-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247890#comment-16247890 ] Eugene Kirpichov commented on BEAM-3169: With the user's configuration (windowed wr

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Flink #4249

See

[jira] [Created] (BEAM-3170) support topicPartition in BeamKafkaTable

Xu Mingmin created BEAM-3170: Summary: support topicPartition in BeamKafkaTable Key: BEAM-3170 URL: https://issues.apache.org/jira/browse/BEAM-3170 Project: Beam Issue Type: Improvement

[jira] [Commented] (BEAM-2899) Universal Local Runner

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

[1/2] beam git commit: Add A FnService, FnServer to runner Fn Execution

Repository: beam Updated Branches: refs/heads/master 6e4781b5d -> a0eb00e73 Add A FnService, FnServer to runner Fn Execution A FnService is a closeable BindableService. A FnServer is exactly one FnService and a server which exposes it as an endpoint. Project: http://git-wip-us.apache.org/rep

[GitHub] beam pull request #4088: [BEAM-2899] Add A FnService, FnServer to runner Fn ...

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/4088 ---

[2/2] beam git commit: [BEAM-2899] Add A FnService, FnServer to runner Fn Execution

[BEAM-2899] Add A FnService, FnServer to runner Fn Execution This closes #4088 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a0eb00e7 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a0eb00e7 Diff: http://git-wip-us.apa

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Apex #2774

See Changes: [bchambers] Dataflow: Add option to upload heap dumps to GCS -- [...truncated 221.88 KB...] 2017-11-10T17:47:42.485 [INFO] Excluding

[jira] [Commented] (BEAM-3169) WriteFiles data loss with some triggers

[ https://issues.apache.org/jira/browse/BEAM-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16247876#comment-16247876 ] Eugene Kirpichov commented on BEAM-3169: User reads data from pubsub and windows it

Build failed in Jenkins: beam_PostCommit_Python_Verify #3522

See Changes: [bchambers] Dataflow: Add option to upload heap dumps to GCS -- [...truncated 931.61 KB...] copying apache_beam/runners/dataflow/native_io/iobase

[jira] [Created] (BEAM-3169) WriteFiles data loss with some triggers

Eugene Kirpichov created BEAM-3169: -- Summary: WriteFiles data loss with some triggers Key: BEAM-3169 URL: https://issues.apache.org/jira/browse/BEAM-3169 Project: Beam Issue Type: Bug

[GitHub] beam pull request #4109: Cherrypicks for 2 2 0 rc 4

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/4109 ---

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Flink #4248

See -- [...truncated 223.38 KB...] 2017-11-10T18:05:43.711 [INFO] Excluding com.google.code.gson:gson:jar:2.7 from the shaded jar. 2017-11-10T18:05:43.711 [INF

[3/4] beam git commit: Update urns.py

Update urns.py Fix typo in GLOBAL_WINDOW_CODER urn constant. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/13dcec9c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/13dcec9c Diff: http://git-wip-us.apache.org/repos/asf/b

[2/4] beam git commit: Set OnTimeBehavior in windowing strategy to FIRE_ALWAYS.

Set OnTimeBehavior in windowing strategy to FIRE_ALWAYS. This fixes python side of https://issues.apache.org/jira/browse/BEAM-2961. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/bddb8699 Tree: http://git-wip-us.apache.org/repo

[4/4] beam git commit: Cherrypicks for 2 2 0 rc 4

Cherrypicks for 2 2 0 rc 4 This closes #4109 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d28ee9b9 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d28ee9b9 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d28ee9

[1/4] beam git commit: Set save_main_session to True for csv module

Repository: beam Updated Branches: refs/heads/release-2.2.0 36ae989af -> d28ee9b9f Set save_main_session to True for csv module Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/22dcd730 Tree: http://git-wip-us.apache.org/repo

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Spark #3458

See Changes: [bchambers] Dataflow: Add option to upload heap dumps to GCS -- [...truncated 265.89 KB...] 2017-11-10T17:51:00.601 [INFO]

Build failed in Jenkins: beam_PerformanceTests_Python #544

See Changes: [bchambers] Dataflow: Add option to upload heap dumps to GCS -- Started by timer [EnvInject] - Loading node environment variables. Building remotel

Jenkins build is back to normal : beam_PostCommit_Python_ValidatesRunner_Dataflow #244

See

[GitHub] beam pull request #4100: Dataflow: Add option to upload heap dumps to GCS

Github user asfgit closed the pull request at: https://github.com/apache/beam/pull/4100 ---

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

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

[1/2] beam git commit: Dataflow: Add option to upload heap dumps to GCS

Repository: beam Updated Branches: refs/heads/master e40e88252 -> 6e4781b5d Dataflow: Add option to upload heap dumps to GCS This flag needs to go in before backend runner code that reads it. It will have no effect until that code is deployed. Project: http://git-wip-us.apache.org/repos/asf/

[jira] [Commented] (BEAM-2899) Universal Local Runner

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

[GitHub] beam pull request #4111: [BEAM-2899] Migrate Stream Control to the fn-execut...

GitHub user tgroh opened a pull request: https://github.com/apache/beam/pull/4111 [BEAM-2899] Migrate Stream Control to the fn-execution module Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] Make sure there is a [JIRA issue](https

Build failed in Jenkins: beam_PostCommit_Python_Verify #3521

See -- [...truncated 936.11 KB...] copying apache_beam/runners/dataflow/native_io/iobase_test.py -> apache-beam-2.3.0.dev0/apache_beam/runners/dataflow/native_io copying ap

Build failed in Jenkins: beam_PostCommit_Python_ValidatesRunner_Dataflow #243

See -- [...truncated 157.52 KB...] } ], "is_pair_like": true

Build failed in Jenkins: beam_PostCommit_Python_Verify #3520

See -- [...truncated 939.29 KB...] copying apache_beam/runners/experimental/python_rpc_direct/python_rpc_direct_runner.py -> apache-beam-2.3.0.dev0/apache_beam/runners/exp

Jenkins build is back to normal : beam_PostCommit_Python_ValidatesRunner_Dataflow #242

See