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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[jira] [Work logged] (BEAM-7909) Write integration tests to test customized containers

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

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

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

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

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

[jira] [Work logged] (BEAM-7984) [python] The coder returned for typehints.List should be IterableCoder

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

[jira] [Work logged] (BEAM-5878) Support DoFns with Keyword-only arguments in Python 3.

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

[jira] [Work logged] (BEAM-8111) SchemaCoder broken on DataflowRunner

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

[jira] [Created] (BEAM-8112) Support passing stateBackend through pipeline options in python sdks

Catlyn Kong created BEAM-8112: - Summary: Support passing stateBackend through pipeline options in python sdks Key: BEAM-8112 URL: https://issues.apache.org/jira/browse/BEAM-8112 Project: Beam

[jira] [Commented] (BEAM-2466) Add Kafka Streams runner

[ https://issues.apache.org/jira/browse/BEAM-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16918157#comment-16918157 ] Kai Jiang commented on BEAM-2466: - Nice progress. I reassigned the ticket to [~winkelman.kyle].

[jira] [Assigned] (BEAM-2466) Add Kafka Streams runner

[ https://issues.apache.org/jira/browse/BEAM-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Jiang reassigned BEAM-2466: --- Assignee: Kyle Winkelman (was: Kai Jiang) > Add Kafka Streams runner > > >

[jira] [Work logged] (BEAM-8107) Update commons-compress to version 1.19

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

[jira] [Work logged] (BEAM-8107) Update commons-compress to version 1.19

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

[jira] [Updated] (BEAM-8111) SchemaCoder broken on DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-8111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Hulette updated BEAM-8111: Description: https://github.com/apache/beam/commit/e65c176a9f34e45d408281e1101a2ae54cef0f6c broke

[jira] [Work logged] (BEAM-8111) SchemaCoder broken on DataflowRunner

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

[jira] [Work logged] (BEAM-8111) SchemaCoder broken on DataflowRunner

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Created] (BEAM-8111) SchemaCoder broken on DataflowRunner

Brian Hulette created BEAM-8111: --- Summary: SchemaCoder broken on DataflowRunner Key: BEAM-8111 URL: https://issues.apache.org/jira/browse/BEAM-8111 Project: Beam Issue Type: Bug

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Commented] (BEAM-7518) Protobuf Schema: Introduce logical type for Timestamp, Duration and other

[ https://issues.apache.org/jira/browse/BEAM-7518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16917968#comment-16917968 ] Mikhail Gryzykhin commented on BEAM-7518: - Seem to be connected to BEAM-7711 BEAM-7554 > Protobuf

[jira] [Commented] (BEAM-7711) Support DATETIME as a logical type in BeamSQL

[ https://issues.apache.org/jira/browse/BEAM-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16917966#comment-16917966 ] Mikhail Gryzykhin commented on BEAM-7711: - partially duplicates BEAM-7554 > Support DATETIME as a

[jira] [Commented] (BEAM-7554) datetime and decimal should be logical types

[ https://issues.apache.org/jira/browse/BEAM-7554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16917967#comment-16917967 ] Mikhail Gryzykhin commented on BEAM-7554: - relates to BEAM-7711 > datetime and decimal should be

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Created] (BEAM-8110) Fedora 30: ImportError: libnsl.so.1 when importing apache_beam in Python 3

Robert Lugg created BEAM-8110: - Summary: Fedora 30: ImportError: libnsl.so.1 when importing apache_beam in Python 3 Key: BEAM-8110 URL: https://issues.apache.org/jira/browse/BEAM-8110 Project: Beam

[jira] [Work logged] (BEAM-7389) Colab examples for element-wise transforms (Python)

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-7990) Add ability to read parquet files into PCollection

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

[jira] [Work logged] (BEAM-8032) JdbcIO.readRows() throws exception when the statementPreparator is not provided for simple Select statement

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-7829) AvroUtils.toAvroSchema should put a Schema name to pass Avro Schema validation

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

[jira] [Work logged] (BEAM-8021) Add Automatic-Module-Name headers for Beam Java modules

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

[jira] [Work logged] (BEAM-8045) Publish custom windows pattern

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

[jira] [Work logged] (BEAM-8021) Add Automatic-Module-Name headers for Beam Java modules

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

[jira] [Work logged] (BEAM-8021) Add Automatic-Module-Name headers for Beam Java modules

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

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

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

[jira] [Work logged] (BEAM-7829) AvroUtils.toAvroSchema should put a Schema name to pass Avro Schema validation

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

[jira] [Work logged] (BEAM-8021) Add Automatic-Module-Name headers for Beam Java modules

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

[jira] [Work logged] (BEAM-8021) Add Automatic-Module-Name headers for Beam Java modules

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

[jira] [Work logged] (BEAM-7829) AvroUtils.toAvroSchema should put a Schema name to pass Avro Schema validation

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

[jira] [Work logged] (BEAM-1009) Upgrade to Mockito 3

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

[jira] [Work logged] (BEAM-1009) Upgrade to Mockito 3

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

[jira] [Work logged] (BEAM-1009) Upgrade to Mockito 3

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

[jira] [Work logged] (BEAM-1009) Upgrade to Mockito 3

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

[jira] [Work logged] (BEAM-8021) Add Automatic-Module-Name headers for Beam Java modules

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

[jira] [Work logged] (BEAM-8021) Add Automatic-Module-Name headers for Beam Java modules

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Commented] (BEAM-2466) Add Kafka Streams runner

[ https://issues.apache.org/jira/browse/BEAM-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16917622#comment-16917622 ] Alexey Romanenko commented on BEAM-2466: Good idea to share it on dev@ list but I'd suggest to

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-8107) Update commons-compress to version 1.19

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

[jira] [Work logged] (BEAM-8107) Update commons-compress to version 1.19

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Closed] (BEAM-6127) Beam Dependency Update Request: junit:junit

[ https://issues.apache.org/jira/browse/BEAM-6127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jan Lukavský closed BEAM-6127. -- > Beam Dependency Update Request: junit:junit > --- > >

[jira] [Updated] (BEAM-8032) JdbcIO.readRows() throws exception when the statementPreparator is not provided for simple Select statement

[ https://issues.apache.org/jira/browse/BEAM-8032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-8032: --- Fix Version/s: 2.16.0 > JdbcIO.readRows() throws exception when the statementPreparator is not >

[jira] [Work logged] (BEAM-7829) AvroUtils.toAvroSchema should put a Schema name to pass Avro Schema validation

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

[jira] [Work logged] (BEAM-7864) Portable Spark Reshuffle coder cast exception

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

[jira] [Work logged] (BEAM-7864) Portable Spark Reshuffle coder cast exception

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Work logged] (BEAM-7829) AvroUtils.toAvroSchema should put a Schema name to pass Avro Schema validation

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

[jira] [Work logged] (BEAM-8107) Update commons-compress to version 1.19

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

[jira] [Work logged] (BEAM-8107) Update commons-compress to version 1.19

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

[jira] [Updated] (BEAM-8102) Portable Flink and Spark failing testSideInputAnnotation[WithMultipleSideInputs]

[ https://issues.apache.org/jira/browse/BEAM-8102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-8102: --- Status: Open (was: Triage Needed) > Portable Flink and Spark failing >

[jira] [Work logged] (BEAM-5428) Implement cross-bundle state caching.

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

[jira] [Commented] (BEAM-2466) Add Kafka Streams runner

[ https://issues.apache.org/jira/browse/BEAM-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16917524#comment-16917524 ] Ismaël Mejía commented on BEAM-2466: Another idea to maybe catch interest is to mention this work

[jira] [Commented] (BEAM-2466) Add Kafka Streams runner

[ https://issues.apache.org/jira/browse/BEAM-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16917519#comment-16917519 ] Ismaël Mejía commented on BEAM-2466: [~vectorijk] since [~winkelman.kyle] seems to have a good level

[jira] [Commented] (BEAM-2466) Add Kafka Streams runner

[ https://issues.apache.org/jira/browse/BEAM-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16917517#comment-16917517 ] Ismaël Mejía commented on BEAM-2466: Hello Kyle, this is great news! As Jan suggests this is

[jira] [Updated] (BEAM-8103) Stop job service when pipeline execution finishes

[ https://issues.apache.org/jira/browse/BEAM-8103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8103: - Status: Open (was: Triage Needed) > Stop job service when pipeline execution finishes >

[jira] [Updated] (BEAM-8108) Run Chicago Taxi Example on Flink

[ https://issues.apache.org/jira/browse/BEAM-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski updated BEAM-8108: --- Priority: Minor (was: Major) > Run Chicago Taxi Example on Flink >

[jira] [Created] (BEAM-8108) Run Chicago Taxi Example on Flink

Kamil Wasilewski created BEAM-8108: -- Summary: Run Chicago Taxi Example on Flink Key: BEAM-8108 URL: https://issues.apache.org/jira/browse/BEAM-8108 Project: Beam Issue Type: Test

[jira] [Resolved] (BEAM-7872) Simpler Flink cluster set up in load tests

[ https://issues.apache.org/jira/browse/BEAM-7872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kamil Wasilewski resolved BEAM-7872. Fix Version/s: 2.16.0 Resolution: Fixed > Simpler Flink cluster set up in load tests

[jira] [Work logged] (BEAM-8107) Update commons-compress to version 1.19

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

[jira] [Created] (BEAM-8107) Update commons-compress to version 1.19

Ismaël Mejía created BEAM-8107: -- Summary: Update commons-compress to version 1.19 Key: BEAM-8107 URL: https://issues.apache.org/jira/browse/BEAM-8107 Project: Beam Issue Type: Improvement

[jira] [Updated] (BEAM-8107) Update commons-compress to version 1.19

[ https://issues.apache.org/jira/browse/BEAM-8107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-8107: --- Status: Open (was: Triage Needed) > Update commons-compress to version 1.19 >

[jira] [Commented] (BEAM-2466) Add Kafka Streams runner

[ https://issues.apache.org/jira/browse/BEAM-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16917495#comment-16917495 ] Jan Lukavský commented on BEAM-2466: Hi, this is cool. I'd suggest you notify dev@beam and dev@kafka

  1   2   >