[jira] [Work logged] (BEAM-6271) initial support for portable api in samza runner

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

[jira] [Work logged] (BEAM-6271) initial support for portable api in samza runner

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

[jira] [Work logged] (BEAM-6271) initial support for portable api in samza runner

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

[jira] [Work logged] (BEAM-6386) Add named variant of PTransform::compose

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

[jira] [Work logged] (BEAM-4620) UnboundedReadFromBoundedSource.split() should always call split()

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

[jira] [Work logged] (BEAM-6271) initial support for portable api in samza runner

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

[jira] [Work logged] (BEAM-6408) beam_Java_LoadTests_GroupByKey_Dataflow_Small timeouts

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

[jira] [Work logged] (BEAM-6161) Add ElementCount MonitoringInfos for the Java SDK

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

[jira] [Created] (BEAM-6467) Impulse.create() emitting more than one element

Alex Amato created BEAM-6467: Summary: Impulse.create() emitting more than one element Key: BEAM-6467 URL: https://issues.apache.org/jira/browse/BEAM-6467 Project: Beam Issue Type: New Feature

[jira] [Work logged] (BEAM-6184) PortableRunner dependency missed in wordcount example maven artifact

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

[jira] [Work logged] (BEAM-6184) PortableRunner dependency missed in wordcount example maven artifact

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

[jira] [Commented] (BEAM-3580) Do not use Go BytesCoder to encode string

[ https://issues.apache.org/jira/browse/BEAM-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16746571#comment-16746571 ] Robert Burke commented on BEAM-3580: There may be one or two no longer necessary []byte -> string

[jira] [Resolved] (BEAM-3580) Do not use Go BytesCoder to encode string

[ https://issues.apache.org/jira/browse/BEAM-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Burke resolved BEAM-3580. Resolution: Fixed Fix Version/s: Not applicable > Do not use Go BytesCoder to encode string

[jira] [Commented] (BEAM-5298) Determine what painpoints exist for the Go SDK WRT the Go Generics Draft Design

[ https://issues.apache.org/jira/browse/BEAM-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16746566#comment-16746566 ] Robert Burke commented on BEAM-5298: I'm finally in a place where it's worth putting thought into

[jira] [Work logged] (BEAM-2928) ULR support for portable side input

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

[jira] [Work logged] (BEAM-3580) Do not use Go BytesCoder to encode string

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

[jira] [Work logged] (BEAM-6280) Failure in PortableRunnerTest.test_error_traceback_includes_user_code

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

[jira] [Work logged] (BEAM-6271) initial support for portable api in samza runner

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

[jira] [Work logged] (BEAM-6271) initial support for portable api in samza runner

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

[jira] [Assigned] (BEAM-6465) Flink: State accumulation during restoring from a savepoint

[ https://issues.apache.org/jira/browse/BEAM-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-6465: -- Assignee: Maximilian Michels (was: Kenneth Knowles) > Flink: State accumulation

[jira] [Updated] (BEAM-6465) Flink: State accumulation during restoring from a savepoint

[ https://issues.apache.org/jira/browse/BEAM-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-6465: --- Component/s: (was: beam-model) runner-flink > Flink: State accumulation

[jira] [Updated] (BEAM-6465) Flink: State accumulation during restoring from a savepoint

[ https://issues.apache.org/jira/browse/BEAM-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pawel Bartoszek updated BEAM-6465: -- Description: This ticket captures my findings when restoring a BEAM job from a savepoint on a

[jira] [Commented] (BEAM-6466) KafkaIO doesn't commit offsets while being used as bounded source

[ https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16746519#comment-16746519 ] Raghu Angadi commented on BEAM-6466: Added this comment to the above thread: Yeah, there is a timing

[jira] [Updated] (BEAM-6466) KafkaIO doesn't commit offsets while being used as bounded source

[ https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-6466: --- Summary: KafkaIO doesn't commit offsets while being used as bounded source (was: KafkaIO

[jira] [Created] (BEAM-6466) KafkaIO doesn't commit offsets while using as bounded source

Alexey Romanenko created BEAM-6466: -- Summary: KafkaIO doesn't commit offsets while using as bounded source Key: BEAM-6466 URL: https://issues.apache.org/jira/browse/BEAM-6466 Project: Beam

[jira] [Updated] (BEAM-6465) Flink: State accumulation during restoring from a savepoint

[ https://issues.apache.org/jira/browse/BEAM-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pawel Bartoszek updated BEAM-6465: -- Attachment: Screen Shot 2019-01-18 at 11.38.02.png > Flink: State accumulation during restoring

[jira] [Assigned] (BEAM-6466) KafkaIO doesn't commit offsets while using as bounded source

[ https://issues.apache.org/jira/browse/BEAM-6466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko reassigned BEAM-6466: -- Assignee: (was: Raghu Angadi) > KafkaIO doesn't commit offsets while using as

[jira] [Work logged] (BEAM-5313) Finish Python 3 porting for examples module

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

[jira] [Updated] (BEAM-6465) Flink: State accumulation during restoring from a savepoint

[ https://issues.apache.org/jira/browse/BEAM-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pawel Bartoszek updated BEAM-6465: -- Attachment: (was: Screen Shot 2019-01-18 at 12.07.03.png) > Flink: State accumulation

[jira] [Updated] (BEAM-6465) Flink: State accumulation during restoring from a savepoint

[ https://issues.apache.org/jira/browse/BEAM-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pawel Bartoszek updated BEAM-6465: -- Description: This ticket captures my findings when restoring a BEAM job from a savepoint on a

[jira] [Commented] (BEAM-6352) Watch PTransform is broken

[ https://issues.apache.org/jira/browse/BEAM-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16746489#comment-16746489 ] Scott Wegner commented on BEAM-6352: Status update: untangling {{Watch.Growth}} to implement with the

[jira] [Work logged] (BEAM-6460) PipelineOptionsFactory may hold on to Classloader after pipeline restart

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

[jira] [Work logged] (BEAM-6460) PipelineOptionsFactory may hold on to Classloader after pipeline restart

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

[jira] [Updated] (BEAM-6465) Flink: State accumulation during restoring from a savepoint

[ https://issues.apache.org/jira/browse/BEAM-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pawel Bartoszek updated BEAM-6465: -- Description: This ticket captures my findings when restoring a BEAM job from a savepoint on

[jira] [Updated] (BEAM-6465) Flink: State accumulation during restoring from a savepoint

[ https://issues.apache.org/jira/browse/BEAM-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pawel Bartoszek updated BEAM-6465: -- Attachment: Screen Shot 2019-01-18 at 12.07.03 copy.png > Flink: State accumulation during

[jira] [Work logged] (BEAM-6460) PipelineOptionsFactory may hold on to Classloader after pipeline restart

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

[jira] [Updated] (BEAM-6465) Flink: State accumulation during restoring from a savepoint

[ https://issues.apache.org/jira/browse/BEAM-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pawel Bartoszek updated BEAM-6465: -- Attachment: Screen Shot 2019-01-18 at 12.07.03.png > Flink: State accumulation during restoring

[jira] [Created] (BEAM-6465) Flink: State accumulation during restoring from a savepoint

Pawel Bartoszek created BEAM-6465: - Summary: Flink: State accumulation during restoring from a savepoint Key: BEAM-6465 URL: https://issues.apache.org/jira/browse/BEAM-6465 Project: Beam

[jira] [Commented] (BEAM-6266) Newest AWS SDK causes errors on startup without usage

[ https://issues.apache.org/jira/browse/BEAM-6266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16746453#comment-16746453 ] Ismaël Mejía commented on BEAM-6266: Are you interested in contributing a fix for this one [~mikekap]

[jira] [Work logged] (BEAM-5442) PortableRunner swallows custom options for Runner

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

[jira] [Work logged] (BEAM-6464) PortableRunner should run dockerized SDK workers

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

[jira] [Work logged] (BEAM-5519) Spark Streaming Duplicated Encoding/Decoding Effort

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

[jira] [Closed] (BEAM-4097) Python SDK should set the environment in the job submission protos

[ https://issues.apache.org/jira/browse/BEAM-4097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Bradshaw closed BEAM-4097. - Resolution: Fixed Fix Version/s: 2.9.0 This was fixed as part of the work for

[jira] [Work logged] (BEAM-6464) PortableRunner should run dockerized SDK workers

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

[jira] [Created] (BEAM-6464) PortableRunner should run dockerized SDK workers

Robert Bradshaw created BEAM-6464: - Summary: PortableRunner should run dockerized SDK workers Key: BEAM-6464 URL: https://issues.apache.org/jira/browse/BEAM-6464 Project: Beam Issue Type:

[jira] [Work logged] (BEAM-6463) Apply windowing in load tests

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

[jira] [Work logged] (BEAM-6463) Apply windowing in load tests

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

[jira] [Created] (BEAM-6463) Apply windowing in load tests

Lukasz Gajowy created BEAM-6463: --- Summary: Apply windowing in load tests Key: BEAM-6463 URL: https://issues.apache.org/jira/browse/BEAM-6463 Project: Beam Issue Type: Sub-task

[jira] [Work started] (BEAM-6463) Apply windowing in load tests

[ https://issues.apache.org/jira/browse/BEAM-6463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-6463 started by Lukasz Gajowy. --- > Apply windowing in load tests > - > >

[jira] [Commented] (BEAM-5906) Remove pipeline for publishing nexmark results to bigQuery and publish using BigQuery API only

[ https://issues.apache.org/jira/browse/BEAM-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16746294#comment-16746294 ] Lukasz Gajowy commented on BEAM-5906: - No problem - I could have done it as well. :) > Remove

[jira] [Commented] (BEAM-5906) Remove pipeline for publishing nexmark results to bigQuery and publish using BigQuery API only

[ https://issues.apache.org/jira/browse/BEAM-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16746277#comment-16746277 ] Etienne Chauchot commented on BEAM-5906: Thx Lukasz, I forgot to close this ticket when I merged

[jira] [Commented] (BEAM-5906) Remove pipeline for publishing nexmark results to bigQuery and publish using BigQuery API only

[ https://issues.apache.org/jira/browse/BEAM-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16746211#comment-16746211 ] Lukasz Gajowy commented on BEAM-5906: - I belive this was fixed. Closing > Remove pipeline for

[jira] [Resolved] (BEAM-5906) Remove pipeline for publishing nexmark results to bigQuery and publish using BigQuery API only

[ https://issues.apache.org/jira/browse/BEAM-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukasz Gajowy resolved BEAM-5906. - Resolution: Fixed Fix Version/s: Not applicable > Remove pipeline for publishing nexmark

[jira] [Closed] (BEAM-6290) Make the schema for BQ tables storing metric results more generic (JAVA)

[ https://issues.apache.org/jira/browse/BEAM-6290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lukasz Gajowy closed BEAM-6290. --- Resolution: Done Fix Version/s: 2.11.0 > Make the schema for BQ tables storing metric results

[jira] [Work logged] (BEAM-6290) Make the schema for BQ tables storing metric results more generic (JAVA)

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

[jira] [Work logged] (BEAM-6290) Make the schema for BQ tables storing metric results more generic (JAVA)

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

[jira] [Work logged] (BEAM-6290) Make the schema for BQ tables storing metric results more generic (JAVA)

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

[jira] [Work logged] (BEAM-6280) Failure in PortableRunnerTest.test_error_traceback_includes_user_code

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

[jira] [Work logged] (BEAM-6280) Failure in PortableRunnerTest.test_error_traceback_includes_user_code

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

[jira] [Work logged] (BEAM-6280) Failure in PortableRunnerTest.test_error_traceback_includes_user_code

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

[jira] [Work logged] (BEAM-6280) Failure in PortableRunnerTest.test_error_traceback_includes_user_code

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

[jira] [Work logged] (BEAM-6231) Triage test failures introduced by use_executable_stage_bundle_execution

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

[jira] [Work logged] (BEAM-6280) Failure in PortableRunnerTest.test_error_traceback_includes_user_code

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

[jira] [Resolved] (BEAM-5910) FileSystems should retrieve lastModified time

[ https://issues.apache.org/jira/browse/BEAM-5910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-5910. Resolution: Fixed Fix Version/s: 2.11.0 > FileSystems should retrieve lastModified time >

[jira] [Work logged] (BEAM-5910) FileSystems should retrieve lastModified time

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

[jira] [Work logged] (BEAM-5910) FileSystems should retrieve lastModified time

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

[jira] [Work logged] (BEAM-6407) regression: FileIO.writeDynamic() with side inputs fails in DirectRunner

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

[jira] [Created] (BEAM-6462) Create an unbounded version of SyntheticIO based on SDF

Ismaël Mejía created BEAM-6462: -- Summary: Create an unbounded version of SyntheticIO based on SDF Key: BEAM-6462 URL: https://issues.apache.org/jira/browse/BEAM-6462 Project: Beam Issue Type:

[jira] [Work logged] (BEAM-6460) PipelineOptionsFactory may hold on to Classloader after pipeline restart

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

[jira] [Work logged] (BEAM-6404) FnAPI translation error

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

<    1   2