[jira] [Work logged] (BEAM-6985) TypeHints Py3 Error: Native type compatibility tests fail on Python 3.7+

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

[jira] [Work logged] (BEAM-6985) TypeHints Py3 Error: Native type compatibility tests fail on Python 3.7+

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

[jira] [Work logged] (BEAM-7173) Bigquery connector should not enable schema autodetection without a user explicitly instructing to do so.

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

[jira] [Work logged] (BEAM-6892) Use temp_location for BQ FILE_LOADS on DirectRunner, and autocreate it in GCS if not specified by user.

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

[jira] [Work logged] (BEAM-6892) Use temp_location for BQ FILE_LOADS on DirectRunner, and autocreate it in GCS if not specified by user.

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

[jira] [Work logged] (BEAM-7175) Run Spark validatesPortableRunner test as a postcommit

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

[jira] [Work logged] (BEAM-7173) Bigquery connector should not enable schema autodetection without a user explicitly instructing to do so.

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

[jira] [Updated] (BEAM-7236) Support transcoding for Flatten in Spark Runner

[ https://issues.apache.org/jira/browse/BEAM-7236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-7236: -- Description: The Beam documentation mentions that Flatten does not require coders of all inputs to be

[jira] [Created] (BEAM-7236) Support transcoding for Flatten in Spark Runner

Kyle Weaver created BEAM-7236: - Summary: Support transcoding for Flatten in Spark Runner Key: BEAM-7236 URL: https://issues.apache.org/jira/browse/BEAM-7236 Project: Beam Issue Type: New Feature

[jira] [Work logged] (BEAM-6493) examples in Kotlin

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

[jira] [Work logged] (BEAM-6892) Use temp_location for BQ FILE_LOADS on DirectRunner, and autocreate it in GCS if not specified by user.

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

[jira] [Work logged] (BEAM-7235) GrpcWindmillServer creates commit streams before necessary

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

[jira] [Work logged] (BEAM-7235) GrpcWindmillServer creates commit streams before necessary

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

[jira] [Created] (BEAM-7235) GrpcWindmillServer creates commit streams before necessary

Sam Whittle created BEAM-7235: - Summary: GrpcWindmillServer creates commit streams before necessary Key: BEAM-7235 URL: https://issues.apache.org/jira/browse/BEAM-7235 Project: Beam Issue Type:

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Created] (BEAM-7234) Improve batching for GrpcWindmillServer GetData streams

Sam Whittle created BEAM-7234: - Summary: Improve batching for GrpcWindmillServer GetData streams Key: BEAM-7234 URL: https://issues.apache.org/jira/browse/BEAM-7234 Project: Beam Issue Type: Bug

[jira] [Work logged] (BEAM-7229) ParDoLifecycleTest: remove duplicated test methods

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

[jira] [Updated] (BEAM-7233) Spark portable runner: support Bundle Finalization

[ https://issues.apache.org/jira/browse/BEAM-7233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-7233: -- Status: Open (was: Triage Needed) > Spark portable runner: support Bundle Finalization >

[jira] [Assigned] (BEAM-7233) Spark portable runner: support Bundle Finalization

[ https://issues.apache.org/jira/browse/BEAM-7233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver reassigned BEAM-7233: - Assignee: Kyle Weaver > Spark portable runner: support Bundle Finalization >

[jira] [Work logged] (BEAM-7229) ParDoLifecycleTest: remove duplicated test methods

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

[jira] [Created] (BEAM-7233) Spark portable runner: support Bundle Finalization

Kyle Weaver created BEAM-7233: - Summary: Spark portable runner: support Bundle Finalization Key: BEAM-7233 URL: https://issues.apache.org/jira/browse/BEAM-7233 Project: Beam Issue Type: New

[jira] [Commented] (BEAM-6847) Add Streaming wordcount test to Dataflow ValidatesContainer test suite

[ https://issues.apache.org/jira/browse/BEAM-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16834236#comment-16834236 ] Valentyn Tymofieiev commented on BEAM-6847: --- Sure. ValidateContainer suite is defined here:

[jira] [Work logged] (BEAM-6916) Reorganize Beam SQL docs

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

[jira] [Work logged] (BEAM-7173) Bigquery connector should not enable schema autodetection without a user explicitly instructing to do so.

[ https://issues.apache.org/jira/browse/BEAM-7173?focusedWorklogId=238167=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-238167 ] ASF GitHub Bot logged work on BEAM-7173: 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=238162=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-238162 ] ASF GitHub Bot logged work on BEAM-3489: 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=238159=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-238159 ] ASF GitHub Bot logged work on BEAM-3489: 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=238160=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-238160 ] ASF GitHub Bot logged work on BEAM-3489: 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=238161=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-238161 ] ASF GitHub Bot logged work on BEAM-3489: Author: ASF GitHub Bot

[jira] [Commented] (BEAM-3055) Retry downloading required test artifacts with a backoff when download fails.

[ https://issues.apache.org/jira/browse/BEAM-3055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16834215#comment-16834215 ] Chamikara Jayalath commented on BEAM-3055: -- Few more flakes due to this.  

[jira] [Work logged] (BEAM-6986) TypeHints Py3 Error: Multiple tests fail with a generator StopIteration error on Python 3.7

[ https://issues.apache.org/jira/browse/BEAM-6986?focusedWorklogId=238156=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-238156 ] ASF GitHub Bot logged work on BEAM-6986: 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=238155=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-238155 ] ASF GitHub Bot logged work on BEAM-3489: Author: ASF GitHub Bot

[jira] [Work logged] (BEAM-7210) Test ParDoSchemaTest#testInferredSchemaPipeline is flaky

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

[jira] [Assigned] (BEAM-2535) Allow explicit output time independent of firing specification for all timers

[ https://issues.apache.org/jira/browse/BEAM-2535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Reuven Lax reassigned BEAM-2535: Assignee: Shehzaad Nakhoda (was: Batkhuyag Batsaikhan) > Allow explicit output time independent

[jira] [Work logged] (BEAM-7229) ParDoLifecycleTest: remove duplicated test methods

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

[jira] [Updated] (BEAM-7223) Enable Python3 tests for Flink

[ https://issues.apache.org/jira/browse/BEAM-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-7223: -- Issue Type: Sub-task (was: Improvement) Parent: BEAM-1251 > Enable Python3

[jira] [Work logged] (BEAM-6985) TypeHints Py3 Error: Native type compatibility tests fail on Python 3.7+

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

[jira] [Work logged] (BEAM-6985) TypeHints Py3 Error: Native type compatibility tests fail on Python 3.7+

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

[jira] [Work logged] (BEAM-6985) TypeHints Py3 Error: Native type compatibility tests fail on Python 3.7+

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

[jira] [Work logged] (BEAM-6985) TypeHints Py3 Error: Native type compatibility tests fail on Python 3.7+

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

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Work logged] (BEAM-6986) TypeHints Py3 Error: Multiple tests fail with a generator StopIteration error on Python 3.7

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

[jira] [Work logged] (BEAM-6986) TypeHints Py3 Error: Multiple tests fail with a generator StopIteration error on Python 3.7

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

[jira] [Work logged] (BEAM-7214) Run Python validates runner tests on Spark

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

[jira] [Work logged] (BEAM-5197) Flaky test: UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest

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

[jira] [Reopened] (BEAM-5197) Flaky test: UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest

[ https://issues.apache.org/jira/browse/BEAM-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reopened BEAM-5197: > Flaky test: UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest >

[jira] [Updated] (BEAM-5197) Flaky test: UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest

[ https://issues.apache.org/jira/browse/BEAM-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5197: --- Fix Version/s: 2.13.0 > Flaky test:

[jira] [Resolved] (BEAM-5197) Flaky test: UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest

[ https://issues.apache.org/jira/browse/BEAM-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía resolved BEAM-5197. Resolution: Fixed > Flaky test: UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest

[jira] [Updated] (BEAM-5197) Flaky test: UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest

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

[jira] [Updated] (BEAM-5197) Flaky test: UnboundedSourceWrapperTest$ParameterizedUnboundedSourceWrapperTest

[ https://issues.apache.org/jira/browse/BEAM-5197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5197: --- Fix Version/s: (was: 2.10.0) > Flaky test:

[jira] [Updated] (BEAM-7232) Python test_external_transforms fails on Spark runner

[ https://issues.apache.org/jira/browse/BEAM-7232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver updated BEAM-7232: -- Status: Open (was: Triage Needed) > Python test_external_transforms fails on Spark runner >

[jira] [Work logged] (BEAM-6986) TypeHints Py3 Error: Multiple tests fail with a generator StopIteration error on Python 3.7

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

[jira] [Created] (BEAM-7232) Python test_external_transforms fails on Spark runner

Kyle Weaver created BEAM-7232: - Summary: Python test_external_transforms fails on Spark runner Key: BEAM-7232 URL: https://issues.apache.org/jira/browse/BEAM-7232 Project: Beam Issue Type: Bug

[jira] [Resolved] (BEAM-6965) Spark portable translator: translate READ

[ https://issues.apache.org/jira/browse/BEAM-6965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Weaver resolved BEAM-6965. --- Resolution: Fixed Fix Version/s: 2.13.0 > Spark portable translator: translate READ >

[jira] [Commented] (BEAM-6908) Add Python3 performance benchmarks

[ https://issues.apache.org/jira/browse/BEAM-6908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16834141#comment-16834141 ] Mark Liu commented on BEAM-6908: wordcount benchmark metrics is available in

[jira] [Assigned] (BEAM-7081) MongoDbIO.splitKeysToFilters returns incorrect filters with only one splitkey

[ https://issues.apache.org/jira/browse/BEAM-7081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía reassigned BEAM-7081: -- Assignee: Roman van der Krogt > MongoDbIO.splitKeysToFilters returns incorrect filters with

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

[ https://issues.apache.org/jira/browse/BEAM-5519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5519: --- Fix Version/s: 2.14.0 > Spark Streaming Duplicated Encoding/Decoding Effort >

[jira] [Updated] (BEAM-5775) Make the spark runner not serialize data unless spark is spilling to disk

[ https://issues.apache.org/jira/browse/BEAM-5775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5775: --- Fix Version/s: 2.14.0 > Make the spark runner not serialize data unless spark is spilling to disk >

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

[ https://issues.apache.org/jira/browse/BEAM-5519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5519: --- Fix Version/s: (was: 2.13.0) > Spark Streaming Duplicated Encoding/Decoding Effort >

[jira] [Updated] (BEAM-5775) Make the spark runner not serialize data unless spark is spilling to disk

[ https://issues.apache.org/jira/browse/BEAM-5775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5775: --- Fix Version/s: (was: 2.13.0) > Make the spark runner not serialize data unless spark is spilling

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Work logged] (BEAM-7216) beam-sdks-java-io-kafka error with kafka brokers < 0.11

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

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Work logged] (BEAM-7216) beam-sdks-java-io-kafka error with kafka brokers < 0.11

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

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Work logged] (BEAM-7216) beam-sdks-java-io-kafka error with kafka brokers < 0.11

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

[jira] [Work logged] (BEAM-7173) Bigquery connector should not enable schema autodetection without a user explicitly instructing to do so.

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

[jira] [Updated] (BEAM-6522) Avro RecordSchema class is not picklable

[ https://issues.apache.org/jira/browse/BEAM-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-6522: -- Fix Version/s: 2.13.0 > Avro RecordSchema class is not picklable >

[jira] [Commented] (BEAM-6522) Avro RecordSchema class is not picklable

[ https://issues.apache.org/jira/browse/BEAM-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16834082#comment-16834082 ] Valentyn Tymofieiev commented on BEAM-6522: --- Set Fix version to 2.13 to make sure

[jira] [Commented] (BEAM-7143) adding withConsumerConfigUpdates

[ https://issues.apache.org/jira/browse/BEAM-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16834077#comment-16834077 ] Raghu Angadi commented on BEAM-7143: Yes, it will be good to go with 'with' prefix to be consistent

[jira] [Work logged] (BEAM-6695) Latest transform for Python SDK

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

[jira] [Work logged] (BEAM-6986) TypeHints Py3 Error: Multiple tests fail with a generator StopIteration error on Python 3.7

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

[jira] [Commented] (BEAM-562) DoFn Reuse: Add new methods to DoFn

[ https://issues.apache.org/jira/browse/BEAM-562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16834040#comment-16834040 ] Ahmet Altay commented on BEAM-562: -- [~shehzaadn] I believe [~myffi...@gmail.com] is close to completing

[jira] [Work logged] (BEAM-7220) add JavaReadViaImpulse substitution to Java expansion service

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

[jira] [Work logged] (BEAM-562) DoFn Reuse: Add new methods to DoFn

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

[jira] [Created] (BEAM-7231) Add Bigtable to Python supported Beam connectors doc

Rose Nguyen created BEAM-7231: - Summary: Add Bigtable to Python supported Beam connectors doc Key: BEAM-7231 URL: https://issues.apache.org/jira/browse/BEAM-7231 Project: Beam Issue Type:

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Work logged] (BEAM-7043) Add DynamoDBIO

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

[jira] [Work logged] (BEAM-7066) Finish reimaging the remaining half of Beam Jenkins workers

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

[jira] [Work logged] (BEAM-6493) examples in Kotlin

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

[jira] [Work logged] (BEAM-7138) keep Java serialized coder in length-prefixed wire coder construction

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

[jira] [Work logged] (BEAM-7220) add JavaReadViaImpulse substitution to Java expansion service

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

[jira] [Work logged] (BEAM-7173) Bigquery connector should not enable schema autodetection without a user explicitly instructing to do so.

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

[jira] [Work logged] (BEAM-7216) beam-sdks-java-io-kafka error with kafka brokers < 0.11

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

[jira] [Work logged] (BEAM-7173) Bigquery connector should not enable schema autodetection without a user explicitly instructing to do so.

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

[jira] [Work logged] (BEAM-7173) Bigquery connector should not enable schema autodetection without a user explicitly instructing to do so.

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

[jira] [Work logged] (BEAM-7173) Bigquery connector should not enable schema autodetection without a user explicitly instructing to do so.

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

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

[ https://issues.apache.org/jira/browse/BEAM-5878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833962#comment-16833962 ] Valentyn Tymofieiev commented on BEAM-5878: --- And, thanks for the investigation, [~Juta]. >

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

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

[jira] [Commented] (BEAM-7143) adding withConsumerConfigUpdates

[ https://issues.apache.org/jira/browse/BEAM-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16833955#comment-16833955 ] Alexey Romanenko commented on BEAM-7143: I'm not aware about any specific reasons why these two

[jira] [Work logged] (BEAM-7194) EXCEPT DISTINCT behavior when right set contains a value is incorrect

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

[jira] [Work logged] (BEAM-7194) EXCEPT DISTINCT behavior when right set contains a value is incorrect

[ https://issues.apache.org/jira/browse/BEAM-7194?focusedWorklogId=237878=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-237878 ] ASF GitHub Bot logged work on BEAM-7194: 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=237863=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-237863 ] ASF GitHub Bot logged work on BEAM-5878: Author: ASF GitHub Bot

  1   2   >