[jira] [Work logged] (BEAM-6240) Allow users to annotate POJOs and JavaBeans for richer functionality

[ https://issues.apache.org/jira/browse/BEAM-6240?focusedWorklogId=175678=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175678 ] ASF GitHub Bot logged work on BEAM-6240: Author: ASF GitHub Bot

[jira] [Assigned] (BEAM-6240) Allow users to annotate POJOs and JavaBeans for richer functionality

[ https://issues.apache.org/jira/browse/BEAM-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax reassigned BEAM-6240: Assignee: Reuven Lax (was: Kenneth Knowles) > Allow users to annotate POJOs and JavaBeans for

[jira] [Created] (BEAM-6240) Allow users to annotate POJOs and JavaBeans for richer functionality

Reuven Lax created BEAM-6240: Summary: Allow users to annotate POJOs and JavaBeans for richer functionality Key: BEAM-6240 URL: https://issues.apache.org/jira/browse/BEAM-6240 Project: Beam

[jira] [Work logged] (BEAM-6197) Log time for Dataflow GCS upload of staged files

[ https://issues.apache.org/jira/browse/BEAM-6197?focusedWorklogId=175675=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175675 ] ASF GitHub Bot logged work on BEAM-6197: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6197) Log time for Dataflow GCS upload of staged files

[ https://issues.apache.org/jira/browse/BEAM-6197?focusedWorklogId=175674=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175674 ] ASF GitHub Bot logged work on BEAM-6197: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6239) Nexmark benchmark for raw sessionization then stream enrichment

[ https://issues.apache.org/jira/browse/BEAM-6239?focusedWorklogId=175672=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175672 ] ASF GitHub Bot logged work on BEAM-6239: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6239) Nexmark benchmark for raw sessionization then stream enrichment

[ https://issues.apache.org/jira/browse/BEAM-6239?focusedWorklogId=175659=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175659 ] ASF GitHub Bot logged work on BEAM-6239: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6239) Nexmark benchmark for raw sessionization then stream enrichment

[ https://issues.apache.org/jira/browse/BEAM-6239?focusedWorklogId=175657=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175657 ] ASF GitHub Bot logged work on BEAM-6239: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6239) Nexmark benchmark for raw sessionization then stream enrichment

[ https://issues.apache.org/jira/browse/BEAM-6239?focusedWorklogId=175656=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175656 ] ASF GitHub Bot logged work on BEAM-6239: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6239) Nexmark benchmark for raw sessionization then stream enrichment

Kenneth Knowles created BEAM-6239: - Summary: Nexmark benchmark for raw sessionization then stream enrichment Key: BEAM-6239 URL: https://issues.apache.org/jira/browse/BEAM-6239 Project: Beam

[jira] [Work logged] (BEAM-4594) Implement Beam Python User State and Timer API

[ https://issues.apache.org/jira/browse/BEAM-4594?focusedWorklogId=175650=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175650 ] ASF GitHub Bot logged work on BEAM-4594: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6197) Log time for Dataflow GCS upload of staged files

[ https://issues.apache.org/jira/browse/BEAM-6197?focusedWorklogId=175638=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175638 ] ASF GitHub Bot logged work on BEAM-6197: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6197) Log time for Dataflow GCS upload of staged files

[ https://issues.apache.org/jira/browse/BEAM-6197?focusedWorklogId=175635=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175635 ] ASF GitHub Bot logged work on BEAM-6197: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6197) Log time for Dataflow GCS upload of staged files

[ https://issues.apache.org/jira/browse/BEAM-6197?focusedWorklogId=175636=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175636 ] ASF GitHub Bot logged work on BEAM-6197: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6197) Log time for Dataflow GCS upload of staged files

[ https://issues.apache.org/jira/browse/BEAM-6197?focusedWorklogId=175622=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175622 ] ASF GitHub Bot logged work on BEAM-6197: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6056) Migrate gRPC to use vendoring library and vendoring format

[ https://issues.apache.org/jira/browse/BEAM-6056?focusedWorklogId=175619=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175619 ] ASF GitHub Bot logged work on BEAM-6056: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6188) Create unbounded synthetic source

[ https://issues.apache.org/jira/browse/BEAM-6188?focusedWorklogId=175618=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175618 ] ASF GitHub Bot logged work on BEAM-6188: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6188) Create unbounded synthetic source

[ https://issues.apache.org/jira/browse/BEAM-6188?focusedWorklogId=175617=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175617 ] ASF GitHub Bot logged work on BEAM-6188: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6238) ULR shows error when successfully finishing a job: "StatusRuntimeException: CANCELLED: cancelled before receiving half close"

Daniel Oliveira created BEAM-6238: - Summary: ULR shows error when successfully finishing a job: "StatusRuntimeException: CANCELLED: cancelled before receiving half close" Key: BEAM-6238 URL:

[jira] [Resolved] (BEAM-6225) Setup Jenkins VR job for new bundle processing code

[ https://issues.apache.org/jira/browse/BEAM-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyuan Zhang resolved BEAM-6225. Resolution: Fixed Fix Version/s: 2.10.0 > Setup Jenkins VR job for new bundle processing

[jira] [Comment Edited] (BEAM-5953) Support DataflowRunner on Python 3

[ https://issues.apache.org/jira/browse/BEAM-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702207#comment-16702207 ] Mark Liu edited comment on BEAM-5953 at 12/14/18 10:34 PM: --- Thanks Valentyn. If

[jira] [Work logged] (BEAM-6225) Setup Jenkins VR job for new bundle processing code

[ https://issues.apache.org/jira/browse/BEAM-6225?focusedWorklogId=175593=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175593 ] ASF GitHub Bot logged work on BEAM-6225: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6225) Setup Jenkins VR job for new bundle processing code

[ https://issues.apache.org/jira/browse/BEAM-6225?focusedWorklogId=175594=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175594 ] ASF GitHub Bot logged work on BEAM-6225: Author: ASF GitHub Bot

[jira] [Comment Edited] (BEAM-5419) Build multiple versions of the Flink Runner against different Flink versions

[ https://issues.apache.org/jira/browse/BEAM-5419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721719#comment-16721719 ] Giorgos Stamatakis edited comment on BEAM-5419 at 12/14/18 8:56 PM:

[jira] [Work logged] (BEAM-6150) Provide alternatives to SerializableFunction and SimpleFunction that may declare exceptions

[ https://issues.apache.org/jira/browse/BEAM-6150?focusedWorklogId=175569=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175569 ] ASF GitHub Bot logged work on BEAM-6150: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6150) Provide alternatives to SerializableFunction and SimpleFunction that may declare exceptions

[ https://issues.apache.org/jira/browse/BEAM-6150?focusedWorklogId=175570=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175570 ] ASF GitHub Bot logged work on BEAM-6150: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6150) Provide alternatives to SerializableFunction and SimpleFunction that may declare exceptions

[ https://issues.apache.org/jira/browse/BEAM-6150?focusedWorklogId=175568=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175568 ] ASF GitHub Bot logged work on BEAM-6150: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6150) Provide alternatives to SerializableFunction and SimpleFunction that may declare exceptions

[ https://issues.apache.org/jira/browse/BEAM-6150?focusedWorklogId=175567=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175567 ] ASF GitHub Bot logged work on BEAM-6150: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6179) Batch size estimation failing

[ https://issues.apache.org/jira/browse/BEAM-6179?focusedWorklogId=175562=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175562 ] ASF GitHub Bot logged work on BEAM-6179: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6237) ULR ValidatesRunner tests not deleting artifacts.

Daniel Oliveira created BEAM-6237: - Summary: ULR ValidatesRunner tests not deleting artifacts. Key: BEAM-6237 URL: https://issues.apache.org/jira/browse/BEAM-6237 Project: Beam Issue Type:

[jira] [Work logged] (BEAM-6179) Batch size estimation failing

[ https://issues.apache.org/jira/browse/BEAM-6179?focusedWorklogId=175561=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175561 ] ASF GitHub Bot logged work on BEAM-6179: Author: ASF GitHub Bot

[jira] [Comment Edited] (BEAM-5419) Build multiple versions of the Flink Runner against different Flink versions

[ https://issues.apache.org/jira/browse/BEAM-5419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721719#comment-16721719 ] Giorgos Stamatakis edited comment on BEAM-5419 at 12/14/18 7:25 PM:

[jira] [Commented] (BEAM-5419) Build multiple versions of the Flink Runner against different Flink versions

[ https://issues.apache.org/jira/browse/BEAM-5419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721719#comment-16721719 ] Giorgos Stamatakis commented on BEAM-5419: -- Thank you for your time but it appears that even

[jira] [Work logged] (BEAM-6197) Log time for Dataflow GCS upload of staged files

[ https://issues.apache.org/jira/browse/BEAM-6197?focusedWorklogId=175557=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175557 ] ASF GitHub Bot logged work on BEAM-6197: Author: ASF GitHub Bot

[jira] [Comment Edited] (BEAM-5419) Build multiple versions of the Flink Runner against different Flink versions

[ https://issues.apache.org/jira/browse/BEAM-5419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721719#comment-16721719 ] Giorgos Stamatakis edited comment on BEAM-5419 at 12/14/18 7:27 PM:

[jira] [Resolved] (BEAM-3211) Add an integration test for TextIO ReadAll transform and dynamic writes

[ https://issues.apache.org/jira/browse/BEAM-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Jayalath resolved BEAM-3211. -- Resolution: Fixed Fix Version/s: Not applicable > Add an integration test for

[jira] [Work logged] (BEAM-6179) Batch size estimation failing

[ https://issues.apache.org/jira/browse/BEAM-6179?focusedWorklogId=175558=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175558 ] ASF GitHub Bot logged work on BEAM-6179: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-3211) Add an integration test for TextIO ReadAll transform and dynamic writes

[ https://issues.apache.org/jira/browse/BEAM-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721721#comment-16721721 ] Chamikara Jayalath commented on BEAM-3211: -- Yeah, we can close this. > Add an integration test

[jira] [Comment Edited] (BEAM-5419) Build multiple versions of the Flink Runner against different Flink versions

[ https://issues.apache.org/jira/browse/BEAM-5419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721719#comment-16721719 ] Giorgos Stamatakis edited comment on BEAM-5419 at 12/14/18 7:24 PM:

[jira] [Comment Edited] (BEAM-5419) Build multiple versions of the Flink Runner against different Flink versions

[ https://issues.apache.org/jira/browse/BEAM-5419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721719#comment-16721719 ] Giorgos Stamatakis edited comment on BEAM-5419 at 12/14/18 7:24 PM:

[jira] [Work logged] (BEAM-6150) Provide alternatives to SerializableFunction and SimpleFunction that may declare exceptions

[ https://issues.apache.org/jira/browse/BEAM-6150?focusedWorklogId=175556=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175556 ] ASF GitHub Bot logged work on BEAM-6150: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6150) Provide alternatives to SerializableFunction and SimpleFunction that may declare exceptions

[ https://issues.apache.org/jira/browse/BEAM-6150?focusedWorklogId=17=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-17 ] ASF GitHub Bot logged work on BEAM-6150: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6150) Provide alternatives to SerializableFunction and SimpleFunction that may declare exceptions

[ https://issues.apache.org/jira/browse/BEAM-6150?focusedWorklogId=175554=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175554 ] ASF GitHub Bot logged work on BEAM-6150: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6190) "Processing stuck" messages should be visible on Pantheon

[ https://issues.apache.org/jira/browse/BEAM-6190?focusedWorklogId=175549=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175549 ] ASF GitHub Bot logged work on BEAM-6190: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6225) Setup Jenkins VR job for new bundle processing code

[ https://issues.apache.org/jira/browse/BEAM-6225?focusedWorklogId=175541=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175541 ] ASF GitHub Bot logged work on BEAM-6225: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6225) Setup Jenkins VR job for new bundle processing code

[ https://issues.apache.org/jira/browse/BEAM-6225?focusedWorklogId=175523=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175523 ] ASF GitHub Bot logged work on BEAM-6225: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6179) Batch size estimation failing

[ https://issues.apache.org/jira/browse/BEAM-6179?focusedWorklogId=175527=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175527 ] ASF GitHub Bot logged work on BEAM-6179: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6179) Batch size estimation failing

[ https://issues.apache.org/jira/browse/BEAM-6179?focusedWorklogId=175535=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175535 ] ASF GitHub Bot logged work on BEAM-6179: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6186) Cleanup FnApiRunner optimization phases.

[ https://issues.apache.org/jira/browse/BEAM-6186?focusedWorklogId=175532=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175532 ] ASF GitHub Bot logged work on BEAM-6186: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6179) Batch size estimation failing

[ https://issues.apache.org/jira/browse/BEAM-6179?focusedWorklogId=175534=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175534 ] ASF GitHub Bot logged work on BEAM-6179: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6179) Batch size estimation failing

[ https://issues.apache.org/jira/browse/BEAM-6179?focusedWorklogId=175537=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175537 ] ASF GitHub Bot logged work on BEAM-6179: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6179) Batch size estimation failing

[ https://issues.apache.org/jira/browse/BEAM-6179?focusedWorklogId=175533=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175533 ] ASF GitHub Bot logged work on BEAM-6179: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6179) Batch size estimation failing

[ https://issues.apache.org/jira/browse/BEAM-6179?focusedWorklogId=175529=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175529 ] ASF GitHub Bot logged work on BEAM-6179: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6179) Batch size estimation failing

[ https://issues.apache.org/jira/browse/BEAM-6179?focusedWorklogId=175530=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175530 ] ASF GitHub Bot logged work on BEAM-6179: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6225) Setup Jenkins VR job for new bundle processing code

[ https://issues.apache.org/jira/browse/BEAM-6225?focusedWorklogId=175522=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175522 ] ASF GitHub Bot logged work on BEAM-6225: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6236) Enable VR test job for ExecutableStage after Dataflow service roll out

Boyuan Zhang created BEAM-6236: -- Summary: Enable VR test job for ExecutableStage after Dataflow service roll out Key: BEAM-6236 URL: https://issues.apache.org/jira/browse/BEAM-6236 Project: Beam

[jira] [Work logged] (BEAM-5723) CassandraIO is broken because of use of bad relocation of guava

[ https://issues.apache.org/jira/browse/BEAM-5723?focusedWorklogId=175520=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175520 ] ASF GitHub Bot logged work on BEAM-5723: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6225) Setup Jenkins VR job for new bundle processing code

[ https://issues.apache.org/jira/browse/BEAM-6225?focusedWorklogId=175509=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175509 ] ASF GitHub Bot logged work on BEAM-6225: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6225) Setup Jenkins VR job for new bundle processing code

[ https://issues.apache.org/jira/browse/BEAM-6225?focusedWorklogId=175508=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175508 ] ASF GitHub Bot logged work on BEAM-6225: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6225) Setup Jenkins VR job for new bundle processing code

[ https://issues.apache.org/jira/browse/BEAM-6225?focusedWorklogId=175504=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175504 ] ASF GitHub Bot logged work on BEAM-6225: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6191) Redundant error messages for failures in Dataflow runner

[ https://issues.apache.org/jira/browse/BEAM-6191?focusedWorklogId=175502=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175502 ] ASF GitHub Bot logged work on BEAM-6191: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5959) Add Cloud KMS support to GCS copies

[ https://issues.apache.org/jira/browse/BEAM-5959?focusedWorklogId=175506=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175506 ] ASF GitHub Bot logged work on BEAM-5959: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6225) Setup Jenkins VR job for new bundle processing code

[ https://issues.apache.org/jira/browse/BEAM-6225?focusedWorklogId=175505=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175505 ] ASF GitHub Bot logged work on BEAM-6225: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-6191) Redundant error messages for failures in Dataflow runner

[ https://issues.apache.org/jira/browse/BEAM-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Wegner resolved BEAM-6191. Resolution: Fixed Fix Version/s: 2.10.0 > Redundant error messages for failures in Dataflow

[jira] [Work logged] (BEAM-6191) Redundant error messages for failures in Dataflow runner

[ https://issues.apache.org/jira/browse/BEAM-6191?focusedWorklogId=175501=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175501 ] ASF GitHub Bot logged work on BEAM-6191: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6235) Upgrade AutoValue to version 1.6.3

[ https://issues.apache.org/jira/browse/BEAM-6235?focusedWorklogId=175492=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175492 ] ASF GitHub Bot logged work on BEAM-6235: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6206) Dataflow template which reads from BigQuery fails if used more than once

[ https://issues.apache.org/jira/browse/BEAM-6206?focusedWorklogId=175489=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175489 ] ASF GitHub Bot logged work on BEAM-6206: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4454) Provide automatic schema registration for AVROs

[ https://issues.apache.org/jira/browse/BEAM-4454?focusedWorklogId=175470=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175470 ] ASF GitHub Bot logged work on BEAM-4454: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-4454) Provide automatic schema registration for AVROs

[ https://issues.apache.org/jira/browse/BEAM-4454?focusedWorklogId=175457=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175457 ] ASF GitHub Bot logged work on BEAM-4454: Author: ASF GitHub Bot

[jira] [Resolved] (BEAM-6227) FlinkRunner errors if GroupByKey contains null values (streaming mode only)

[ https://issues.apache.org/jira/browse/BEAM-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved BEAM-6227. Resolution: Fixed > FlinkRunner errors if GroupByKey contains null values (streaming mode only) >

[jira] [Work logged] (BEAM-6227) FlinkRunner errors if GroupByKey contains null values (streaming mode only)

[ https://issues.apache.org/jira/browse/BEAM-6227?focusedWorklogId=175447=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175447 ] ASF GitHub Bot logged work on BEAM-6227: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6235) Upgrade AutoValue to version 1.6.3

[ https://issues.apache.org/jira/browse/BEAM-6235?focusedWorklogId=175438=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175438 ] ASF GitHub Bot logged work on BEAM-6235: Author: ASF GitHub Bot

[jira] [Created] (BEAM-6235) Upgrade AutoValue to version 1.6.3

Ismaël Mejía created BEAM-6235: -- Summary: Upgrade AutoValue to version 1.6.3 Key: BEAM-6235 URL: https://issues.apache.org/jira/browse/BEAM-6235 Project: Beam Issue Type: Improvement

[jira] [Commented] (BEAM-4678) Support portable combiner lifting in Java Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-4678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721570#comment-16721570 ] Maximilian Michels commented on BEAM-4678: -- Has been implemented for Python. AFAIK Go and Java do

[jira] [Work logged] (BEAM-5723) CassandraIO is broken because of use of bad relocation of guava

[ https://issues.apache.org/jira/browse/BEAM-5723?focusedWorklogId=175426=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175426 ] ASF GitHub Bot logged work on BEAM-5723: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-3472) Create a callback triggered at the end of a batch in flink runner

[ https://issues.apache.org/jira/browse/BEAM-3472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721543#comment-16721543 ] Etienne Chauchot commented on BEAM-3472: Thanks [~mxm] for reviving this subject. I workarounded

[jira] [Work logged] (BEAM-6234) [Flink Runner] Make failOnCheckpointingErrors setting available in FlinkPipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-6234?focusedWorklogId=175411=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175411 ] ASF GitHub Bot logged work on BEAM-6234: Author: ASF GitHub Bot

[jira] [Updated] (BEAM-6234) [Flink Runner] Make failOnCheckpointingErrors setting available in FlinkPipelineOptions

[ https://issues.apache.org/jira/browse/BEAM-6234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Harper updated BEAM-6234: Description: The configuration setting {{failOnCheckpointingErrors}} [1] is available in Flink to

[jira] [Created] (BEAM-6234) [Flink Runner] Make failOnCheckpointingErrors setting available in FlinkPipelineOptions

Daniel Harper created BEAM-6234: --- Summary: [Flink Runner] Make failOnCheckpointingErrors setting available in FlinkPipelineOptions Key: BEAM-6234 URL: https://issues.apache.org/jira/browse/BEAM-6234

[jira] [Work logged] (BEAM-6229) BigQuery returns value error while retrieving load test metrics

[ https://issues.apache.org/jira/browse/BEAM-6229?focusedWorklogId=175374=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175374 ] ASF GitHub Bot logged work on BEAM-6229: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-5985) Create jenkins jobs to run the load tests for Java SDK

[ https://issues.apache.org/jira/browse/BEAM-5985?focusedWorklogId=175376=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175376 ] ASF GitHub Bot logged work on BEAM-5985: Author: ASF GitHub Bot

[jira] [Closed] (BEAM-3949) IOIT's setup() and teardown() db connection attempt sometimes fail resulting in test flakiness

[ https://issues.apache.org/jira/browse/BEAM-3949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukasz Gajowy closed BEAM-3949. --- Resolution: Fixed Fix Version/s: 2.6.0 > IOIT's setup() and teardown() db connection attempt

[jira] [Resolved] (BEAM-4691) Rename (and reorganize?) jenkins jobs

[ https://issues.apache.org/jira/browse/BEAM-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukasz Gajowy resolved BEAM-4691. - Resolution: Fixed Fix Version/s: Not applicable Done only renaming. Reorganizing to

[jira] [Work logged] (BEAM-6229) BigQuery returns value error while retrieving load test metrics

[ https://issues.apache.org/jira/browse/BEAM-6229?focusedWorklogId=175373=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175373 ] ASF GitHub Bot logged work on BEAM-6229: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-3211) Add an integration test for TextIO ReadAll transform and dynamic writes

[ https://issues.apache.org/jira/browse/BEAM-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721516#comment-16721516 ] Lukasz Gajowy commented on BEAM-3211: - is this still needed or should we close this ticket? We have

[jira] [Assigned] (BEAM-981) Not possible to directly submit a pipeline on spark cluster

[ https://issues.apache.org/jira/browse/BEAM-981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukasz Gajowy reassigned BEAM-981: -- Assignee: Amit Sela (was: Lukasz Gajowy) > Not possible to directly submit a pipeline on spark

[jira] [Resolved] (BEAM-3747) Performance tests flaky due to database connection problems

[ https://issues.apache.org/jira/browse/BEAM-3747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukasz Gajowy resolved BEAM-3747. - Resolution: Fixed Fix Version/s: Not applicable Not flaky any more thanks to solutions

[jira] [Commented] (BEAM-3216) Add an integration test for HadoopInputFormatIO Read transform

[ https://issues.apache.org/jira/browse/BEAM-3216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721518#comment-16721518 ] Lukasz Gajowy commented on BEAM-3216: - is this ticket still valid? > Add an integration test for

[jira] [Closed] (BEAM-1603) Enable programmatic execution of spark pipelines.

[ https://issues.apache.org/jira/browse/BEAM-1603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukasz Gajowy closed BEAM-1603. --- Resolution: Fixed Fix Version/s: Not applicable This is possible since

[jira] [Closed] (BEAM-5037) HashFunction is not intialized in SyntheticOptions

[ https://issues.apache.org/jira/browse/BEAM-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukasz Gajowy closed BEAM-5037. --- Resolution: Fixed Fix Version/s: 2.7.0 > HashFunction is not intialized in SyntheticOptions >

[jira] [Resolved] (BEAM-6076) NEXMark flakiness: NPE thrown from BigQuery client library once in a while

[ https://issues.apache.org/jira/browse/BEAM-6076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukasz Gajowy resolved BEAM-6076. - Resolution: Fixed Fix Version/s: 2.9.0 > NEXMark flakiness: NPE thrown from BigQuery

[jira] [Work logged] (BEAM-5723) CassandraIO is broken because of use of bad relocation of guava

[ https://issues.apache.org/jira/browse/BEAM-5723?focusedWorklogId=175359=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175359 ] ASF GitHub Bot logged work on BEAM-5723: Author: ASF GitHub Bot

[jira] [Work started] (BEAM-6229) BigQuery returns value error while retrieving load test metrics

[ https://issues.apache.org/jira/browse/BEAM-6229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-6229 started by Lukasz Gajowy. --- > BigQuery returns value error while retrieving load test metrics >

[jira] [Work logged] (BEAM-5723) CassandraIO is broken because of use of bad relocation of guava

[ https://issues.apache.org/jira/browse/BEAM-5723?focusedWorklogId=175357=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175357 ] ASF GitHub Bot logged work on BEAM-5723: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-6229) BigQuery returns value error while retrieving load test metrics

[ https://issues.apache.org/jira/browse/BEAM-6229?focusedWorklogId=175356=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175356 ] ASF GitHub Bot logged work on BEAM-6229: Author: ASF GitHub Bot

[jira] [Closed] (BEAM-6187) Drop Scala suffix of FlinkRunner artifacts

[ https://issues.apache.org/jira/browse/BEAM-6187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed BEAM-6187. Resolution: Fixed The suffix has been dropped as part of upgrading to 1.6 with BEAM-5267.

[jira] [Work logged] (BEAM-6227) FlinkRunner errors if GroupByKey contains null values (streaming mode only)

[ https://issues.apache.org/jira/browse/BEAM-6227?focusedWorklogId=175352=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-175352 ] ASF GitHub Bot logged work on BEAM-6227: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-3472) Create a callback triggered at the end of a batch in flink runner

[ https://issues.apache.org/jira/browse/BEAM-3472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721464#comment-16721464 ] Maximilian Michels commented on BEAM-3472: -- It this still relevant? > Create a callback

[jira] [Commented] (BEAM-6218) TensorFlow Model Analysis Fails when using the portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16721459#comment-16721459 ] Maximilian Michels commented on BEAM-6218: -- This looks like an error from the Python SDK harness.

[jira] [Updated] (BEAM-6218) TensorFlow Model Analysis Fails when using the portable Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-6218: - Component/s: sdk-py-harness > TensorFlow Model Analysis Fails when using the portable

  1   2   >