[jira] [Work logged] (BEAM-6715) ./gradlew :beam-runners-google-cloud-dataflow-java:validatesRunner fails due to invalid GCS path

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

[jira] [Work logged] (BEAM-6914) Use BigQuerySink as default for 2.12.

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

[jira] [Commented] (BEAM-6923) OOM errors in jobServer when using GCS artifactDir

[ https://issues.apache.org/jira/browse/BEAM-6923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805616#comment-16805616 ] Pablo Estrada commented on BEAM-6923: - Oops. Sorry about retagging you. I didn't see you were tagged

[jira] [Commented] (BEAM-6923) OOM errors in jobServer when using GCS artifactDir

[ https://issues.apache.org/jira/browse/BEAM-6923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805614#comment-16805614 ] Pablo Estrada commented on BEAM-6923: - [~angoenka] do you know about this issue? > OOM errors in

[jira] [Commented] (BEAM-6740) Combine.globally translation is never called

[ https://issues.apache.org/jira/browse/BEAM-6740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805587#comment-16805587 ] Kenneth Knowles commented on BEAM-6740: --- I think you should just add a URN for Combine.globally.

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

[jira] [Work logged] (BEAM-6894) ExternalTransform.expand() does not create the proper AppliedPTransform sub-graph

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

[jira] [Work logged] (BEAM-6894) ExternalTransform.expand() does not create the proper AppliedPTransform sub-graph

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

[jira] [Work logged] (BEAM-6865) Refactor common portable runner infrastructure for better reuse

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

[jira] [Work logged] (BEAM-5732) expose runner mode to user through samza pipeline option

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

[jira] [Work logged] (BEAM-6914) Use BigQuerySink as default for 2.12.

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

[jira] [Work logged] (BEAM-6914) Use BigQuerySink as default for 2.12.

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

[jira] [Work logged] (BEAM-6944) Add support for MeanByteCount metric for Python Streaming to Java DF Runner

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

[jira] [Work logged] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

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

[jira] [Created] (BEAM-6945) Utilize label and urn values from metrics.proto in Java DF Runner

Mikhail Gryzykhin created BEAM-6945: --- Summary: Utilize label and urn values from metrics.proto in Java DF Runner Key: BEAM-6945 URL: https://issues.apache.org/jira/browse/BEAM-6945 Project: Beam

[jira] [Work logged] (BEAM-5191) Add support for writing to BigQuery clustered tables

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

[jira] [Work logged] (BEAM-6876) User state cleanup in portable Flink runner

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

[jira] [Commented] (BEAM-6813) Issues with state + timers in java Direct Runner

[ https://issues.apache.org/jira/browse/BEAM-6813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805506#comment-16805506 ] Steve Niemitz commented on BEAM-6813: - I believe this was using a 4 hour fixed window without any

[jira] [Work logged] (BEAM-6894) ExternalTransform.expand() does not create the proper AppliedPTransform sub-graph

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

[jira] [Work logged] (BEAM-6894) ExternalTransform.expand() does not create the proper AppliedPTransform sub-graph

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

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

[jira] [Commented] (BEAM-6813) Issues with state + timers in java Direct Runner

[ https://issues.apache.org/jira/browse/BEAM-6813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805486#comment-16805486 ] Kenneth Knowles commented on BEAM-6813: --- What windowing are you using? > Issues with state + timers

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

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

[ https://issues.apache.org/jira/browse/BEAM-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805474#comment-16805474 ] Kenneth Knowles commented on BEAM-5723: --- I think we are in the state where we are ready to simply

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

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

[ https://issues.apache.org/jira/browse/BEAM-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805473#comment-16805473 ] Kenneth Knowles commented on BEAM-5723: --- Ah the problem is that it extends the

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

[ https://issues.apache.org/jira/browse/BEAM-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805472#comment-16805472 ] Kenneth Knowles commented on BEAM-5723: --- I would expect overriding the shadow closure to do it,

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

[jira] [Work logged] (BEAM-3312) Add convenient "with" to MqttIO.ConnectionConfiguration

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

[jira] [Work logged] (BEAM-6944) Add support for MeanByteCount metric for Python Streaming to Java DF Runner

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

[jira] [Work logged] (BEAM-4610) RedisIO should allow to configure SSL

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

[jira] [Work logged] (BEAM-4610) RedisIO should allow to configure SSL

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

[jira] [Work logged] (BEAM-4610) RedisIO should allow to configure SSL

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

[jira] [Work logged] (BEAM-3312) Add convenient "with" to MqttIO.ConnectionConfiguration

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

[jira] [Work logged] (BEAM-6944) Add support for MeanByteCount metric for Python Streaming to Java DF Runner

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

[jira] [Work logged] (BEAM-6944) Add support for MeanByteCount metric for Python Streaming to Java DF Runner

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

[jira] [Deleted] (BEAM-6939) Simon Poortman

[ https://issues.apache.org/jira/browse/BEAM-6939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Thistlethwaite deleted BEAM-6939: --- > Simon Poortman > -- > > Key: BEAM-6939 >

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

[jira] [Commented] (BEAM-2530) Make Beam compatible with next Java LTS version (Java 11)

[ https://issues.apache.org/jira/browse/BEAM-2530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805422#comment-16805422 ] Pablo Estrada commented on BEAM-2530: - The Beam 2.12.0 release has been tested by building with Java

[jira] [Work logged] (BEAM-6918) Github link requires login and example link is broken

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

[jira] [Work logged] (BEAM-6918) Github link requires login and example link is broken

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

[jira] [Work logged] (BEAM-6944) Add support for MeanByteCount metric for Python Streaming to Java DF Runner

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

[jira] [Updated] (BEAM-6944) Add support for MeanByteCount metric for Python Streaming to Java DF Runner

[ https://issues.apache.org/jira/browse/BEAM-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Gryzykhin updated BEAM-6944: Description: (was: # Add new UserDistributionCounter urn to metrics.proto # Report

[jira] [Created] (BEAM-6944) Add support for MeanByteCount metric for Python Streaming to Java DF Runner

Mikhail Gryzykhin created BEAM-6944: --- Summary: Add support for MeanByteCount metric for Python Streaming to Java DF Runner Key: BEAM-6944 URL: https://issues.apache.org/jira/browse/BEAM-6944

[jira] [Work logged] (BEAM-6876) User state cleanup in portable Flink runner

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

[jira] [Work logged] (BEAM-6876) User state cleanup in portable Flink runner

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

[jira] [Work logged] (BEAM-5732) expose runner mode to user through samza pipeline option

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

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

[jira] [Work logged] (BEAM-6914) Use BigQuerySink as default for 2.12.

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

[jira] [Commented] (BEAM-6668) use add experiment methods (Java and Python)

[ https://issues.apache.org/jira/browse/BEAM-6668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805335#comment-16805335 ] Udi Meiri commented on BEAM-6668: - [~tvalentyn] > use add experiment methods (Java and Python) >

[jira] [Commented] (BEAM-5061) Invisible parameter type exception in JDK 10

[ https://issues.apache.org/jira/browse/BEAM-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805314#comment-16805314 ] Pablo Estrada commented on BEAM-5061: - Is this still happening? We have SDK tests running now with

[jira] [Updated] (BEAM-6943) DataInputOperation object has no attribute 'needs_finalization' in Jupyter

[ https://issues.apache.org/jira/browse/BEAM-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyuan Zhang updated BEAM-6943: --- Summary: DataInputOperation object has no attribute 'needs_finalization' in Jupyter (was:

[jira] [Work logged] (BEAM-6876) User state cleanup in portable Flink runner

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

[jira] [Created] (BEAM-6943) DataInputOperation object has no attribute 'needs_finalization'

Boyuan Zhang created BEAM-6943: -- Summary: DataInputOperation object has no attribute 'needs_finalization' Key: BEAM-6943 URL: https://issues.apache.org/jira/browse/BEAM-6943 Project: Beam

[jira] [Work logged] (BEAM-6876) User state cleanup in portable Flink runner

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

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

[jira] [Work logged] (BEAM-6841) Support reading query results with the BigQuery storage API

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

[jira] [Commented] (BEAM-5865) Auto sharding of streaming sinks in FlinkRunner

[ https://issues.apache.org/jira/browse/BEAM-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805234#comment-16805234 ] Jozef Vilcek commented on BEAM-5865: Hello, I wanted to post update earlier but got swamped with other

[jira] [Work logged] (BEAM-6894) ExternalTransform.expand() does not create the proper AppliedPTransform sub-graph

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

[jira] [Commented] (BEAM-6942) Pipeline options to experiment propagation is not working in Dataflow runner.

[ https://issues.apache.org/jira/browse/BEAM-6942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805220#comment-16805220 ] Valentyn Tymofieiev commented on BEAM-6942: --- Clean up on the way. > Pipeline options to

[jira] [Assigned] (BEAM-6942) Pipeline options to experiment propagation is not working in Dataflow runner.

[ https://issues.apache.org/jira/browse/BEAM-6942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Pilloud reassigned BEAM-6942: Assignee: Valentyn Tymofieiev > Pipeline options to experiment propagation is not working

[jira] [Created] (BEAM-6942) Pipeline options to experiment propagation is not working in Dataflow runner.

Valentyn Tymofieiev created BEAM-6942: - Summary: Pipeline options to experiment propagation is not working in Dataflow runner. Key: BEAM-6942 URL: https://issues.apache.org/jira/browse/BEAM-6942

[jira] [Work logged] (BEAM-6909) Add location support for BigQueryWrapper._get_query_results()

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

[jira] [Created] (BEAM-6941) Logs include exception="None\n" when there is no exception

Eric Roshan Eisner created BEAM-6941: Summary: Logs include exception="None\n" when there is no exception Key: BEAM-6941 URL: https://issues.apache.org/jira/browse/BEAM-6941 Project: Beam

[jira] [Work logged] (BEAM-6914) Use BigQuerySink as default for 2.12.

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

[jira] [Work logged] (BEAM-6914) Use BigQuerySink as default for 2.12.

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

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

[ https://issues.apache.org/jira/browse/BEAM-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Pilloud reassigned BEAM-5723: Assignee: Ismaël Mejía > CassandraIO is broken because of use of bad relocation of guava >

[jira] [Resolved] (BEAM-6937) Streaming FlinkTransformOverrides are not applied without explicit streaming mode

[ https://issues.apache.org/jira/browse/BEAM-6937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-6937. Resolution: Fixed > Streaming FlinkTransformOverrides are not applied without explicit streaming >

[jira] [Resolved] (BEAM-6929) Session Windows with lateness cause NullPointerException in Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-6929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-6929. Resolution: Fixed > Session Windows with lateness cause NullPointerException in Flink Runner >

[jira] [Work logged] (BEAM-6929) Session Windows with lateness cause NullPointerException in Flink Runner

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

[jira] [Work logged] (BEAM-6932) SamzaRunner: migrate to use new Samza 1.1.0 liraries

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

[jira] [Work logged] (BEAM-6932) SamzaRunner: migrate to use new Samza 1.1.0 liraries

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

[jira] [Commented] (BEAM-6886) Change batch handling in ElasticsearchIO to avoid necessity for GroupIntoBatches

[ https://issues.apache.org/jira/browse/BEAM-6886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805162#comment-16805162 ] Etienne Chauchot commented on BEAM-6886: [~MadEgg]: - upgrading GroupIntoBatches for

[jira] [Commented] (BEAM-6939) Simon Poortman

[ https://issues.apache.org/jira/browse/BEAM-6939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805158#comment-16805158 ] Ismaël Mejía commented on BEAM-6939: [~Klootviool] it seems you forgot to put the title (and the

[jira] [Work logged] (BEAM-6932) SamzaRunner: migrate to use new Samza 1.1.0 liraries

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

[jira] [Work logged] (BEAM-3072) Improve error handling at staging time time for DataflowRunner

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

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

[ https://issues.apache.org/jira/browse/BEAM-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805153#comment-16805153 ] Ismaël Mejía commented on BEAM-5723: @srfrnk thanks for confirming this. So it is not as I expected

[jira] [Commented] (BEAM-6324) CassandraIO.Read - Add the ability to provide a filter to the query

[ https://issues.apache.org/jira/browse/BEAM-6324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805143#comment-16805143 ] Ismaël Mejía commented on BEAM-6324: You are right, this is error prone but a consequence of earlier

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

[ https://issues.apache.org/jira/browse/BEAM-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reopened BEAM-5723: Assignee: (was: Max Charas) > CassandraIO is broken because of use of bad relocation of guava

[jira] [Created] (BEAM-6940) Validate that namespace and table are part of the query in CassandraIO

Ismaël Mejía created BEAM-6940: -- Summary: Validate that namespace and table are part of the query in CassandraIO Key: BEAM-6940 URL: https://issues.apache.org/jira/browse/BEAM-6940 Project: Beam

[jira] [Work logged] (BEAM-6937) Streaming FlinkTransformOverrides are not applied without explicit streaming mode

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

[jira] [Work logged] (BEAM-6929) Session Windows with lateness cause NullPointerException in Flink Runner

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

[jira] [Work logged] (BEAM-6876) User state cleanup in portable Flink runner

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

[jira] [Work logged] (BEAM-6876) User state cleanup in portable Flink runner

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

[jira] [Created] (BEAM-6939) Simon Poortman

Simon Poortman created BEAM-6939: Summary: Simon Poortman Key: BEAM-6939 URL: https://issues.apache.org/jira/browse/BEAM-6939 Project: Beam Issue Type: New Feature Components:

[jira] [Work logged] (BEAM-4610) RedisIO should allow to configure SSL

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

[jira] [Work logged] (BEAM-6929) Session Windows with lateness cause NullPointerException in Flink Runner

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

[jira] [Work logged] (BEAM-6929) Session Windows with lateness cause NullPointerException in Flink Runner

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

[jira] [Work logged] (BEAM-6929) Session Windows with lateness cause NullPointerException in Flink Runner

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

[jira] [Work logged] (BEAM-2939) Fn API streaming SDF support

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

[jira] [Assigned] (BEAM-6938) Add support for dynamic destinations when writing to MQTT

[ https://issues.apache.org/jira/browse/BEAM-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-6938: -- Assignee: LI Guobao > Add support for dynamic destinations when writing to MQTT >

[jira] [Work logged] (BEAM-6876) User state cleanup in portable Flink runner

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

[jira] [Work logged] (BEAM-6876) User state cleanup in portable Flink runner

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

[jira] [Created] (BEAM-6938) Add support for dynamic destinations when writing to MQTT

Ismaël Mejía created BEAM-6938: -- Summary: Add support for dynamic destinations when writing to MQTT Key: BEAM-6938 URL: https://issues.apache.org/jira/browse/BEAM-6938 Project: Beam Issue Type:

  1   2   >