[jira] [Work logged] (BEAM-7305) Add first version of Hazelcast Jet Runner

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

[jira] [Created] (BEAM-7332) Blog post announcing Beam Kata

Henry Suryawirawan created BEAM-7332: Summary: Blog post announcing Beam Kata Key: BEAM-7332 URL: https://issues.apache.org/jira/browse/BEAM-7332 Project: Beam Issue Type: Task

[jira] [Commented] (BEAM-5510) Records including datetime to be saved as DATETIME or TIMESTAMP in BigQuery

[ https://issues.apache.org/jira/browse/BEAM-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840930#comment-16840930 ] Steven Ensslen commented on BEAM-5510: -- This defect remains in 2.12.0, and affects `datetime.date`

[jira] [Work logged] (BEAM-6988) TypeHints Py3 Error: test_non_function (apache_beam.typehints.typed_pipeline_test.MainInputTest) Fails on Python 3.7+

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

[jira] [Work logged] (BEAM-6988) TypeHints Py3 Error: test_non_function (apache_beam.typehints.typed_pipeline_test.MainInputTest) Fails on Python 3.7+

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

[jira] [Work logged] (BEAM-6988) TypeHints Py3 Error: test_non_function (apache_beam.typehints.typed_pipeline_test.MainInputTest) Fails on Python 3.7+

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

[jira] [Work logged] (BEAM-6988) TypeHints Py3 Error: test_non_function (apache_beam.typehints.typed_pipeline_test.MainInputTest) Fails on Python 3.7+

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[jira] [Closed] (BEAM-7331) Missing util function for late pane in java PAssert

[ https://issues.apache.org/jira/browse/BEAM-7331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik closed BEAM-7331. --- Resolution: Fixed Fix Version/s: 2.14.0 > Missing util function for late pane in java PAssert >

[jira] [Work logged] (BEAM-7331) Missing util function for late pane in java PAssert

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

[jira] [Work logged] (BEAM-7331) Missing util function for late pane in java PAssert

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

[jira] [Work logged] (BEAM-7283) Have javadoc offline link dependency versions bound to versions within BeamModulePlugin.groovy

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

[jira] [Work logged] (BEAM-7283) Have javadoc offline link dependency versions bound to versions within BeamModulePlugin.groovy

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

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

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

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

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

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

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

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

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

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

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

[jira] [Commented] (BEAM-7322) PubSubIO watermark does not advance for very low volumes

[ https://issues.apache.org/jira/browse/BEAM-7322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840834#comment-16840834 ] Tim Sell commented on BEAM-7322: Further explanation of the data.json I uploaded, I set it my job to have

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

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

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

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

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

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

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

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

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

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

[jira] [Created] (BEAM-7331) Missing util function for late pane in java PAssert

Ruoyun Huang created BEAM-7331: -- Summary: Missing util function for late pane in java PAssert Key: BEAM-7331 URL: https://issues.apache.org/jira/browse/BEAM-7331 Project: Beam Issue Type:

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

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

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

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

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

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

[jira] [Work logged] (BEAM-6988) TypeHints Py3 Error: test_non_function (apache_beam.typehints.typed_pipeline_test.MainInputTest) Fails on Python 3.7+

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

[jira] [Created] (BEAM-7330) Log4j conflict causes stuck job in Datafloiw

Anton Kedin created BEAM-7330: - Summary: Log4j conflict causes stuck job in Datafloiw Key: BEAM-7330 URL: https://issues.apache.org/jira/browse/BEAM-7330 Project: Beam Issue Type: Bug

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

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

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

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

[jira] [Commented] (BEAM-7261) Add support for BasicSessionCredentials for aws credentials.

[ https://issues.apache.org/jira/browse/BEAM-7261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840730#comment-16840730 ] David Brown commented on BEAM-7261: --- The problem isn't the provider it is the AwsModule that

[jira] [Commented] (BEAM-7327) Revise BQ integration tests to clearly communicate that BQ IO expects base64-encoded bytes. 

[ https://issues.apache.org/jira/browse/BEAM-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840700#comment-16840700 ] Valentyn Tymofieiev commented on BEAM-7327: --- As discussed in the mailing list should take

[jira] [Commented] (BEAM-7319) Multiple NeedsRunner tests break with Flink 'Cannot union streams of different types'

[ https://issues.apache.org/jira/browse/BEAM-7319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840699#comment-16840699 ] Maximilian Michels commented on BEAM-7319: -- This is blocked on BEAM-6523. > Multiple NeedsRunner

[jira] [Updated] (BEAM-7319) Multiple NeedsRunner tests break with Flink 'Cannot union streams of different types'

[ https://issues.apache.org/jira/browse/BEAM-7319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-7319: - Priority: Major (was: Critical) > Multiple NeedsRunner tests break with Flink 'Cannot

[jira] [Work logged] (BEAM-7154) Switch internal Go SDK error code to use new package

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

[jira] [Updated] (BEAM-7319) Multiple NeedsRunner tests break with Flink 'Cannot union streams of different types'

[ https://issues.apache.org/jira/browse/BEAM-7319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7319: --- Priority: Critical (was: Major) > Multiple NeedsRunner tests break with Flink 'Cannot union streams

[jira] [Created] (BEAM-7329) Update Avro to version 1.9.0 in Python SDK

Ismaël Mejía created BEAM-7329: -- Summary: Update Avro to version 1.9.0 in Python SDK Key: BEAM-7329 URL: https://issues.apache.org/jira/browse/BEAM-7329 Project: Beam Issue Type: Improvement

[jira] [Created] (BEAM-7328) Update Avro to version 1.9.0 in Java SDK

Ismaël Mejía created BEAM-7328: -- Summary: Update Avro to version 1.9.0 in Java SDK Key: BEAM-7328 URL: https://issues.apache.org/jira/browse/BEAM-7328 Project: Beam Issue Type: Improvement

[jira] [Updated] (BEAM-7315) GatherAllPanesTest.multiplePanesMultipleReifiedPane breaks on Spark runner

[ https://issues.apache.org/jira/browse/BEAM-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7315: --- Summary: GatherAllPanesTest.multiplePanesMultipleReifiedPane breaks on Spark runner (was:

[jira] [Updated] (BEAM-7319) Multiple NeedsRunner tests break with Flink 'Cannot union streams of different types'

[ https://issues.apache.org/jira/browse/BEAM-7319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7319: --- Summary: Multiple NeedsRunner tests break with Flink 'Cannot union streams of different types' (was:

[jira] [Updated] (BEAM-7327) Revise BQ integration tests to clearly communicate that BQ IO expects base64-encoded bytes. 

[ https://issues.apache.org/jira/browse/BEAM-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-7327: -- Status: Open (was: Triage Needed) > Revise BQ integration tests to clearly communicate

[jira] [Created] (BEAM-7327) Revise BQ integration tests to clearly communicate that BQ IO expects base64-encoded bytes. 

Valentyn Tymofieiev created BEAM-7327: - Summary: Revise BQ integration tests to clearly communicate that BQ IO expects base64-encoded bytes.  Key: BEAM-7327 URL:

[jira] [Created] (BEAM-7326) Document that Beam BigQuery IO expects users to pass base64-encoded bytes, and BQ IO serves base64-encoded bytes to the user.

Valentyn Tymofieiev created BEAM-7326: - Summary: Document that Beam BigQuery IO expects users to pass base64-encoded bytes, and BQ IO serves base64-encoded bytes to the user. Key: BEAM-7326 URL:

[jira] [Commented] (BEAM-7230) Using JdbcIO creates huge amount of connections

[ https://issues.apache.org/jira/browse/BEAM-7230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840666#comment-16840666 ] Brachi Packter commented on BEAM-7230: -- Hi again. Checking with the new snapshot. When I configure

[jira] [Work logged] (BEAM-5967) ProtoCoder doesn't support DynamicMessage

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

[jira] [Work logged] (BEAM-6693) ApproximateUnique transform for Python SDK

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

[jira] [Updated] (BEAM-7322) PubSubIO watermark does not advance for very low volumes

[ https://issues.apache.org/jira/browse/BEAM-7322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-7322: -- Description: I have identified an issue where the watermark does not advance when using the

[jira] [Work logged] (BEAM-6138) Add User Metric Support to Java SDK

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

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

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

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

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

[jira] [Work logged] (BEAM-7305) Add first version of Hazelcast Jet Runner

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

[jira] [Work logged] (BEAM-7305) Add first version of Hazelcast Jet Runner

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

[jira] [Work logged] (BEAM-6988) TypeHints Py3 Error: test_non_function (apache_beam.typehints.typed_pipeline_test.MainInputTest) Fails on Python 3.7+

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

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

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

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

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

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

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

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

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

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

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

[jira] [Work logged] (BEAM-7131) Spark portable runner appears to be repeating work (in TFX example)

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

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

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

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

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

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

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

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

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

[jira] [Work logged] (BEAM-7103) Adding AvroGenericCoder for simple dict type cross-language data transfer

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

[jira] [Work logged] (BEAM-7103) Adding AvroGenericCoder for simple dict type cross-language data transfer

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

[jira] [Resolved] (BEAM-7311) merge internal commits to beam open source trunk to prepare for the security patch

[ https://issues.apache.org/jira/browse/BEAM-7311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Lu resolved BEAM-7311. -- Resolution: Fixed Fix Version/s: 2.13.0 > merge internal commits to beam open source trunk to prepare

[jira] [Work logged] (BEAM-7311) merge internal commits to beam open source trunk to prepare for the security patch

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

[jira] [Work logged] (BEAM-7305) Add first version of Hazelcast Jet Runner

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

[jira] [Updated] (BEAM-7323) PartitionTest.testDroppedPartition breaks on Flink runner

[ https://issues.apache.org/jira/browse/BEAM-7323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7323: --- Status: Open (was: Triage Needed) > PartitionTest.testDroppedPartition breaks on Flink runner >

[jira] [Updated] (BEAM-7320) TextIOWriteTest.testWriteViaSink breaks on Flink runner

[ https://issues.apache.org/jira/browse/BEAM-7320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7320: --- Status: Open (was: Triage Needed) > TextIOWriteTest.testWriteViaSink breaks on Flink runner >

[jira] [Updated] (BEAM-7318) WriteFilesTest.testEmptyWrite breaks on Flink runner

[ https://issues.apache.org/jira/browse/BEAM-7318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7318: --- Status: Open (was: Triage Needed) > WriteFilesTest.testEmptyWrite breaks on Flink runner >

[jira] [Created] (BEAM-7325) PipelineTest.testEmptyPipeline breaks on Flink runner

Ismaël Mejía created BEAM-7325: -- Summary: PipelineTest.testEmptyPipeline breaks on Flink runner Key: BEAM-7325 URL: https://issues.apache.org/jira/browse/BEAM-7325 Project: Beam Issue Type: Bug

[jira] [Updated] (BEAM-7321) TestStreamTest breaks on Flink runner

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

[jira] [Updated] (BEAM-7323) PartitionTest.testDroppedPartition breaks on Flink runner

[ https://issues.apache.org/jira/browse/BEAM-7323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7323: --- Description: This happens too in GroupByKeyTest$WindowTests.testIdentityWindowFnPropagation {code}

[jira] [Created] (BEAM-7324) GroupByKeyTest$WindowTests.testWindowFnInvalidation breaks on Flink runner in batch mode

Ismaël Mejía created BEAM-7324: -- Summary: GroupByKeyTest$WindowTests.testWindowFnInvalidation breaks on Flink runner in batch mode Key: BEAM-7324 URL: https://issues.apache.org/jira/browse/BEAM-7324

[jira] [Updated] (BEAM-7319) Multple NeedsRunner tests break because of 'Cannot union streams of different types'

[ https://issues.apache.org/jira/browse/BEAM-7319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7319: --- Description: This happens in AvroIOTest for reference.This also breaks most of the Schema related

[jira] [Updated] (BEAM-7319) Multple NeedsRunner tests break because of 'Cannot union streams of different types'

[ https://issues.apache.org/jira/browse/BEAM-7319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7319: --- Description: This happens in AvroIOTest for reference.This also breaks most of the Schema related

[jira] [Updated] (BEAM-7319) Multple NeedsRunner tests break because of 'Cannot union streams of different types'

[ https://issues.apache.org/jira/browse/BEAM-7319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7319: --- Priority: Major (was: Minor) > Multple NeedsRunner tests break because of 'Cannot union streams of

[jira] [Updated] (BEAM-7319) Multple NeedsRunner tests break because of 'Cannot union streams of different types'

[ https://issues.apache.org/jira/browse/BEAM-7319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7319: --- Status: Open (was: Triage Needed) > Multple NeedsRunner tests break because of 'Cannot union streams

[jira] [Work logged] (BEAM-6829) Duplicate metric warnings clutter log

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

[jira] [Created] (BEAM-7323) PartitionTest.testDroppedPartition

Ismaël Mejía created BEAM-7323: -- Summary: PartitionTest.testDroppedPartition Key: BEAM-7323 URL: https://issues.apache.org/jira/browse/BEAM-7323 Project: Beam Issue Type: Sub-task

[jira] [Updated] (BEAM-7323) PartitionTest.testDroppedPartition breaks on Flink runner

[ https://issues.apache.org/jira/browse/BEAM-7323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-7323: --- Summary: PartitionTest.testDroppedPartition breaks on Flink runner (was:

[jira] [Assigned] (BEAM-6829) Duplicate metric warnings clutter log

[ https://issues.apache.org/jira/browse/BEAM-6829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-6829: Assignee: Maximilian Michels > Duplicate metric warnings clutter log >

[jira] [Commented] (BEAM-7322) PubSubIO watermark does not advance for very low volumes

[ https://issues.apache.org/jira/browse/BEAM-7322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840472#comment-16840472 ] Tim Sell commented on BEAM-7322: In my example code, I have a job that produces events per pane with their

[jira] [Updated] (BEAM-7322) PubSubIO watermark does not advance for very low volumes

[ https://issues.apache.org/jira/browse/BEAM-7322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tim Sell updated BEAM-7322: --- Attachment: data.json > PubSubIO watermark does not advance for very low volumes >

[jira] [Created] (BEAM-7322) PubSubIO watermark does not advance for very low volumes

Tim Sell created BEAM-7322: -- Summary: PubSubIO watermark does not advance for very low volumes Key: BEAM-7322 URL: https://issues.apache.org/jira/browse/BEAM-7322 Project: Beam Issue Type: Bug

[jira] [Commented] (BEAM-7302) Dependencies are broken in SNAPSHOT pom files

[ https://issues.apache.org/jira/browse/BEAM-7302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840452#comment-16840452 ] Michael Luckey commented on BEAM-7302: -- After short investigating, it seems neither components.java

  1   2   >