[jira] [Commented] (BEAM-3456) Enable large scale JdbcIOIT Performance Test

[ https://issues.apache.org/jira/browse/BEAM-3456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16330176#comment-16330176 ] ASF GitHub Bot commented on BEAM-3456: -- chamikaramj closed pull request #4392: [BEAM-3456] Enable

[beam] branch master updated: [BEAM-3456] Enable jenkins and large scale scenario in JDBC (#4392)

This is an automated email from the ASF dual-hosted git repository. chamikara pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/master by this push: new 2f235dd [BEAM-3456] Enable jenkins and large

Jenkins build is still unstable: beam_PostCommit_Java_MavenInstall #5680

See

[jira] [Commented] (BEAM-3487) GroupByKey stalls with GroupingShuffleReader split refusals

[ https://issues.apache.org/jira/browse/BEAM-3487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16330099#comment-16330099 ] Bei Zhang commented on BEAM-3487: - Also at one point it throws an error "Refusing to split at

Build failed in Jenkins: beam_PerformanceTests_Python #804

See Changes: [ekirpichov] Removes maxBundleSize option accidentally introduced in unrelated PR -- Started by timer [EnvInject] - Loading node environment

Jenkins build is back to normal : beam_PerformanceTests_Compressed_TextIOIT #28

See

Build failed in Jenkins: beam_PerformanceTests_AvroIOIT #29

See Changes: [ekirpichov] Removes maxBundleSize option accidentally introduced in unrelated PR -- Started by timer [EnvInject] - Loading node environment

Build failed in Jenkins: beam_PerformanceTests_TextIOIT #36

See Changes: [ekirpichov] Removes maxBundleSize option accidentally introduced in unrelated PR -- Started by timer [EnvInject] - Loading node environment

Build failed in Jenkins: beam_PerformanceTests_Spark #1248

See Changes: [ekirpichov] Removes maxBundleSize option accidentally introduced in unrelated PR -- Started by timer [EnvInject] - Loading node environment

Build failed in Jenkins: beam_PerformanceTests_TFRecordIOIT #28

See Changes: [ekirpichov] Removes maxBundleSize option accidentally introduced in unrelated PR -- Started by timer [EnvInject] - Loading node environment

[jira] [Commented] (BEAM-3494) Snapshot state of aggregated data of apache beam project is not maintained in flink's checkpointing

[ https://issues.apache.org/jira/browse/BEAM-3494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16330077#comment-16330077 ] suganya commented on BEAM-3494: --- he following code is using apache beam libraries to create a pipeline.Please

[jira] [Created] (BEAM-3494) Snapshot state of aggregated data of apache beam project is not maintained in flink's checkpointing

suganya created BEAM-3494: - Summary: Snapshot state of aggregated data of apache beam project is not maintained in flink's checkpointing Key: BEAM-3494 URL: https://issues.apache.org/jira/browse/BEAM-3494

Jenkins build is back to normal : beam_PostCommit_Java_ValidatesRunner_Dataflow #4739

See

[jira] [Commented] (BEAM-3414) AfterProcessingTime trigger issue with Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329998#comment-16329998 ] Kenneth Knowles commented on BEAM-3414: --- Can I give it to you Aljoscha, since you have that PR just

[jira] [Assigned] (BEAM-3414) AfterProcessingTime trigger issue with Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-3414: - Assignee: Aljoscha Krettek (was: Kenneth Knowles) > AfterProcessingTime trigger issue

[jira] [Created] (BEAM-3493) Prevent users from "implementing" PipelineOptions

Kenneth Knowles created BEAM-3493: - Summary: Prevent users from "implementing" PipelineOptions Key: BEAM-3493 URL: https://issues.apache.org/jira/browse/BEAM-3493 Project: Beam Issue Type:

Jenkins build became unstable: beam_PostCommit_Java_MavenInstall #5679

See

[jira] [Issue Comment Deleted] (BEAM-3414) AfterProcessingTime trigger issue with Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huangjianhuang updated BEAM-3414: - Comment: was deleted (was: Thanks for help. Does this bug appear in other Runner? Or can you give

Build failed in Jenkins: beam_PostCommit_Java_ValidatesRunner_Dataflow #4738

See -- [...truncated 22.86 MB...] [INFO] 2018-01-18T02:02:04.267Z: (1c7eb2542bc3e3ed): Unzipping flatten s15 for input s10.10 [INFO]

[beam] branch master updated (40c9081 -> b53100b)

This is an automated email from the ASF dual-hosted git repository. jkff pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 40c9081 Merge pull request #4386 add b764d36 Removes maxBundleSize option accidentally introduced in unrelated

[beam] 01/01: Merge pull request #4432 from jkff/rm-max-bundle-size

This is an automated email from the ASF dual-hosted git repository. jkff pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit b53100b335eefcb27ec9d0c124fafdda9fda11a4 Merge: 40c9081 b764d36 Author: Eugene Kirpichov AuthorDate:

[jira] [Commented] (BEAM-2715) Expose PubsubSource to create UnboundedSource and utilize withMaxNumRecords from BoundedReadFromUnboundedSource

[ https://issues.apache.org/jira/browse/BEAM-2715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329848#comment-16329848 ] Thomas Groh commented on BEAM-2715: --- Effectively, yes. Reading from a PubSub subscription either: *

[jira] [Resolved] (BEAM-3450) RemoteGrpcPorts should contain the wire format

[ https://issues.apache.org/jira/browse/BEAM-3450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Groh resolved BEAM-3450. --- Resolution: Fixed Fix Version/s: 2.3.0 > RemoteGrpcPorts should contain the wire format >

[jira] [Created] (BEAM-3492) Spark Integration Tests fail with a Closed Connection

Thomas Groh created BEAM-3492: - Summary: Spark Integration Tests fail with a Closed Connection Key: BEAM-3492 URL: https://issues.apache.org/jira/browse/BEAM-3492 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-3491) Issue with package of file and location

Ron Gonzalez created BEAM-3491: -- Summary: Issue with package of file and location Key: BEAM-3491 URL: https://issues.apache.org/jira/browse/BEAM-3491 Project: Beam Issue Type: Bug

Build failed in Jenkins: beam_PerformanceTests_TextIOIT #35

See Changes: [niemo] Update BigTableSource to use multiple key ranges [niemo] Add tests for supporting multiple key ranges. [niemo] Use multiple key ranges in BigtableServiceImpl [tgroh] Add

Build failed in Jenkins: beam_PerformanceTests_TFRecordIOIT #27

See Changes: [niemo] Update BigTableSource to use multiple key ranges [niemo] Add tests for supporting multiple key ranges. [niemo] Use multiple key ranges in BigtableServiceImpl [tgroh] Add

Build failed in Jenkins: beam_PerformanceTests_Spark #1247

See Changes: [niemo] Update BigTableSource to use multiple key ranges [niemo] Add tests for supporting multiple key ranges. [niemo] Use multiple key ranges in BigtableServiceImpl [tgroh] Add

Build failed in Jenkins: beam_PerformanceTests_Python #803

See Changes: [niemo] Update BigTableSource to use multiple key ranges [niemo] Add tests for supporting multiple key ranges. [niemo] Use multiple key ranges in BigtableServiceImpl [tgroh] Add

Build failed in Jenkins: beam_PerformanceTests_Compressed_TextIOIT #27

See Changes: [niemo] Update BigTableSource to use multiple key ranges [niemo] Add tests for supporting multiple key ranges. [niemo] Use multiple key ranges in BigtableServiceImpl

Build failed in Jenkins: beam_PerformanceTests_AvroIOIT #28

See Changes: [niemo] Update BigTableSource to use multiple key ranges [niemo] Add tests for supporting multiple key ranges. [niemo] Use multiple key ranges in BigtableServiceImpl [tgroh] Add

[jira] [Commented] (BEAM-3490) Reasonable Python direct runner batch performance.

[ https://issues.apache.org/jira/browse/BEAM-3490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329763#comment-16329763 ] ASF GitHub Bot commented on BEAM-3490: -- robertwb opened a new pull request #4437: [BEAM-3490] Curry

[jira] [Created] (BEAM-3490) Reasonable Python direct runner batch performance.

Robert Bradshaw created BEAM-3490: - Summary: Reasonable Python direct runner batch performance. Key: BEAM-3490 URL: https://issues.apache.org/jira/browse/BEAM-3490 Project: Beam Issue Type:

[jira] [Commented] (BEAM-3160) Type based coder inference incorrectly assumes that a coder for one type is equivalent to every other coder for that type.

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

[jira] [Commented] (BEAM-3450) RemoteGrpcPorts should contain the wire format

[ https://issues.apache.org/jira/browse/BEAM-3450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329694#comment-16329694 ] ASF GitHub Bot commented on BEAM-3450: -- tgroh closed pull request #4386: [BEAM-3450] Add wire_coder_id

[beam] 01/01: Merge pull request #4386

This is an automated email from the ASF dual-hosted git repository. tgroh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit 40c9081d4152462630558b12faa39d62a640d030 Merge: dacd1e4 62e2a77 Author: Thomas Groh

[beam] branch master updated (dacd1e4 -> 40c9081)

This is an automated email from the ASF dual-hosted git repository. tgroh pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from dacd1e4 Merge pull request #4312 from rniemo-g/multiple-row-ranges add 6a58c47 Add wire_coder_id to

[jira] [Updated] (BEAM-3046) De-javafy the Python Metrics API

[ https://issues.apache.org/jira/browse/BEAM-3046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pablo Estrada updated BEAM-3046: Labels: community-onboarding starter (was: community-onboarding) > De-javafy the Python Metrics API

[jira] [Assigned] (BEAM-3250) Migrate ValidatesRunner Jenkins PostCommits to Gradle

[ https://issues.apache.org/jira/browse/BEAM-3250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-3250: - Assignee: Ben Sidhom (was: Kenneth Knowles) > Migrate ValidatesRunner Jenkins

[jira] [Commented] (BEAM-3154) Support multiple KeyRanges when reading from BigTable

[ https://issues.apache.org/jira/browse/BEAM-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329498#comment-16329498 ] ASF GitHub Bot commented on BEAM-3154: -- jkff closed pull request #4312: [BEAM-3154] Support Multiple

[beam] branch master updated (4da548e -> dacd1e4)

This is an automated email from the ASF dual-hosted git repository. jkff pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 4da548e Merge pull request #4224 add a139fe8 Update BigTableSource to use multiple key ranges add 6131ca5

[beam] 01/01: Merge pull request #4312 from rniemo-g/multiple-row-ranges

This is an automated email from the ASF dual-hosted git repository. jkff pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit dacd1e41df9bb720fc3266624c5d50c82d83dc6c Merge: 4da548e d0a2a02 Author: Eugene Kirpichov AuthorDate:

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Dataflow #4736

See

[jira] [Updated] (BEAM-3489) Expose the message id of received messages within PubsubMessage

[ https://issues.apache.org/jira/browse/BEAM-3489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-3489: Issue Type: New Feature (was: Bug) > Expose the message id of received messages within PubsubMessage >

[beam-site] branch mergebot updated (2390f35 -> 7da45a1)

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a change to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git. from 2390f35 This closes #372 add 7da45a1 Prepare repository for deployment. No new revisions were

[jira] [Created] (BEAM-3489) Expose the message id of received messages within PubsubMessage

Luke Cwik created BEAM-3489: --- Summary: Expose the message id of received messages within PubsubMessage Key: BEAM-3489 URL: https://issues.apache.org/jira/browse/BEAM-3489 Project: Beam Issue

[beam-site] branch asf-site updated (45d0dc0 -> 7da45a1)

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git. from 45d0dc0 Prepare repository for deployment. add 8a62de4 fix language tabs after a language

[beam-site] 01/01: Prepare repository for deployment.

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 7da45a1b7a86e96264b213a927c5fd8a9e2dc10c Author: Mergebot AuthorDate: Wed Jan 17

[beam-site] branch mergebot updated (ddad4fe -> 2390f35)

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a change to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git. from ddad4fe This closes #375 add 45d0dc0 Prepare repository for deployment. new 8a62de4 fix

[beam-site] 02/02: This closes #372

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 2390f3537354235855b1353e2c9aed5099960bf5 Merge: 45d0dc0 8a62de4 Author: Mergebot

[beam-site] 01/02: fix language tabs after a language specific paragraph

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 8a62de44e0f118e683a20c4fe293ee82f03ce251 Author: melissa AuthorDate: Thu Jan 11

[beam-site] 01/01: Prepare repository for deployment.

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 45d0dc00a55e08075be81c5b95f4259d1644c584 Author: Mergebot AuthorDate: Wed Jan 17

[beam-site] branch asf-site updated (79e62e2 -> 45d0dc0)

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a change to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git. from 79e62e2 Prepare repository for deployment. add 2650eec Fix broken JIRA component links add

[beam-site] branch mergebot updated (7f22a3f -> ddad4fe)

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a change to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git. discard 7f22a3f This closes #375 new ddad4fe This closes #375 This update added new revisions after

[beam-site] 01/01: This closes #375

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit ddad4fec2962f2e5a3ec29112aedb709fa10f1b9 Merge: 79e62e2 2650eec Author: Mergebot

Jenkins build is back to normal : beam_PerformanceTests_Spark #1246

See

[beam-site] 02/02: This closes #375

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 7f22a3f522c47948be2d8cdd508261afde2a527f Merge: 79e62e2 2650eec Author: Mergebot

[beam-site] branch mergebot updated (a44b123 -> 7f22a3f)

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a change to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git. from a44b123 This closes #373 add 79e62e2 Prepare repository for deployment. new 2650eec Fix

[beam-site] 01/02: Fix broken JIRA component links

This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git commit 2650eece833ca1bc7787ba3a69c11eb2452a3ac7 Author: melissa AuthorDate: Tue Jan 16

Build failed in Jenkins: beam_PerformanceTests_TFRecordIOIT #26

See -- Started by timer [EnvInject] - Loading node environment variables. Building remotely on beam8 (beam) in workspace

Build failed in Jenkins: beam_PerformanceTests_Python #802

See -- Started by timer [EnvInject] - Loading node environment variables. Building remotely on beam4 (beam) in workspace

Build failed in Jenkins: beam_PerformanceTests_TextIOIT #34

See -- Started by timer [EnvInject] - Loading node environment variables. Building remotely on beam8 (beam) in workspace

Build failed in Jenkins: beam_PerformanceTests_Compressed_TextIOIT #26

See -- Started by timer [EnvInject] - Loading node environment variables. Building remotely on beam4 (beam) in workspace

Build failed in Jenkins: beam_PerformanceTests_AvroIOIT #27

See -- Started by timer [EnvInject] - Loading node environment variables. Building remotely on beam4 (beam) in workspace

[beam] 04/04: Add initialization of active plans map.

This is an automated email from the ASF dual-hosted git repository. lcwik pushed a commit to branch go-sdk in repository https://gitbox.apache.org/repos/asf/beam.git commit c5a3ce00eeb96ba4e357080d6bd27708273da295 Author: Bill Neubauer AuthorDate: Wed Jan 17 09:43:24 2018 -0800

[beam] 02/04: Remove GetId() call from under lock.

This is an automated email from the ASF dual-hosted git repository. lcwik pushed a commit to branch go-sdk in repository https://gitbox.apache.org/repos/asf/beam.git commit a86c25e372c39e6a6780fa262ad45105a46e00b9 Author: Bill Neubauer AuthorDate: Tue Jan 16 14:29:08 2018 -0800

[beam] branch go-sdk updated (864b359 -> c5a3ce0)

This is an automated email from the ASF dual-hosted git repository. lcwik pushed a change to branch go-sdk in repository https://gitbox.apache.org/repos/asf/beam.git. from 864b359 BEAM-3474 Include stacks in panic messages. new 0af2503 BEAM-3299: Add source reporting support.

[beam] 01/04: BEAM-3299: Add source reporting support.

This is an automated email from the ASF dual-hosted git repository. lcwik pushed a commit to branch go-sdk in repository https://gitbox.apache.org/repos/asf/beam.git commit 0af2503d72c20dd88b9e63a557c63319068d70af Author: Bill Neubauer AuthorDate: Sun Jan 14 20:15:13 2018 -0800

[beam] 03/04: Add additional comments about concurrency invariants.

This is an automated email from the ASF dual-hosted git repository. lcwik pushed a commit to branch go-sdk in repository https://gitbox.apache.org/repos/asf/beam.git commit efa1c20a9328177a6cd6ec4d744853417fd0ef48 Author: Bill Neubauer AuthorDate: Tue Jan 16 15:39:20 2018 -0800

[jira] [Commented] (BEAM-3488) Reduce log noise coming from File sink

[ https://issues.apache.org/jira/browse/BEAM-3488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329091#comment-16329091 ] Luke Cwik commented on BEAM-3488: - Its strange that it happens so many times since it should only happen

[jira] [Resolved] (BEAM-3285) Switch Beam to Java 8 only

[ https://issues.apache.org/jira/browse/BEAM-3285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-3285. Resolution: Duplicate Fix Version/s: (was: 2.3.0) Not applicable >

[jira] [Commented] (BEAM-3425) CassandraIO fails to estimate size: Codec not found for requested operation: [varchar <-> java.lang.Long]

[ https://issues.apache.org/jira/browse/BEAM-3425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16329051#comment-16329051 ] ASF GitHub Bot commented on BEAM-3425: -- jbonofre opened a new pull request #4426: [BEAM-3425] Get the

[jira] [Commented] (BEAM-71) Watermark library

[ https://issues.apache.org/jira/browse/BEAM-71?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328934#comment-16328934 ] Tarush Grover commented on BEAM-71: --- [~lcwik] Thanks for assigning, I will document the interface first and

[jira] [Created] (BEAM-3488) Reduce log noise coming from File sink

Pawel Bartoszek created BEAM-3488: - Summary: Reduce log noise coming from File sink Key: BEAM-3488 URL: https://issues.apache.org/jira/browse/BEAM-3488 Project: Beam Issue Type: Improvement

Jenkins build became unstable: beam_PostCommit_Java_ValidatesRunner_Dataflow #4735

See

Build failed in Jenkins: beam_PerformanceTests_Python #801

See Changes: [kedin] [Nexmark][SQL] Implement Query1 [tgroh] Move BeamFnDataGrpcMultiplexer to java-fn-execution [tgroh] Mark BeamFnDataGrpcMultiplexer ApiServiceDescriptor as Nullable [tgroh]

Build failed in Jenkins: beam_PerformanceTests_AvroIOIT #26

See Changes: [kedin] [Nexmark][SQL] Implement Query1 [tgroh] Move BeamFnDataGrpcMultiplexer to java-fn-execution [tgroh] Mark BeamFnDataGrpcMultiplexer ApiServiceDescriptor as Nullable [tgroh]

Build failed in Jenkins: beam_PerformanceTests_Spark #1245

See Changes: [kedin] [Nexmark][SQL] Implement Query1 [tgroh] Move BeamFnDataGrpcMultiplexer to java-fn-execution [tgroh] Mark BeamFnDataGrpcMultiplexer ApiServiceDescriptor as Nullable [tgroh]

Jenkins build is back to stable : beam_PostCommit_Java_ValidatesRunner_Dataflow #4734

See

[jira] [Created] (BEAM-3487) GroupByKey stalls with GroupingShuffleReader split refusals

Bei Zhang created BEAM-3487: --- Summary: GroupByKey stalls with GroupingShuffleReader split refusals Key: BEAM-3487 URL: https://issues.apache.org/jira/browse/BEAM-3487 Project: Beam Issue Type:

[jira] [Commented] (BEAM-3153) Allow streaming processing time domain timers in Beam Python DirectRunner

[ https://issues.apache.org/jira/browse/BEAM-3153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328473#comment-16328473 ] ASF GitHub Bot commented on BEAM-3153: -- mariapython opened a new pull request #4425: [BEAM-3153] Add