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

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

[jira] [Commented] (BEAM-6257) Can we deprecate the side input paths through PAssert?

[ https://issues.apache.org/jira/browse/BEAM-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786367#comment-16786367 ] Kenneth Knowles commented on BEAM-6257: --- OK now I'm watching this issue :-) Generally, each PAssert

[jira] [Comment Edited] (BEAM-6765) Beam 2.10.0 for Python requires pyarrow 0.11.1, which is not installable in Google Cloud DataFlow

[ https://issues.apache.org/jira/browse/BEAM-6765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786351#comment-16786351 ] Barry Hart edited comment on BEAM-6765 at 3/7/19 3:56 AM: -- We have a

[jira] [Commented] (BEAM-6765) Beam 2.10.0 for Python requires pyarrow 0.11.1, which is not installable in Google Cloud DataFlow

[ https://issues.apache.org/jira/browse/BEAM-6765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786351#comment-16786351 ] Barry Hart commented on BEAM-6765: -- We have a {{requirements.txt}} used for setting up our development

[jira] [Updated] (BEAM-6765) Beam 2.10.0 for Python requires pyarrow 0.11.1, which is not installable in Google Cloud DataFlow

[ https://issues.apache.org/jira/browse/BEAM-6765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Barry Hart updated BEAM-6765: - Description: When trying to run a Beam 2.10.0 job in Google Cloud DataFlow, I get the following error:

[jira] [Updated] (BEAM-6765) Beam 2.10.0 for Python requires pyarrow 0.11.1, which is not installable in Google Cloud DataFlow

[ https://issues.apache.org/jira/browse/BEAM-6765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Barry Hart updated BEAM-6765: - Summary: Beam 2.10.0 for Python requires pyarrow 0.11.1, which is not installable in Google Cloud

[jira] [Comment Edited] (BEAM-6769) Write bytes to BigQuery in Python 3

[ https://issues.apache.org/jira/browse/BEAM-6769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786293#comment-16786293 ] Valentyn Tymofieiev edited comment on BEAM-6769 at 3/7/19 1:52 AM: --- 1.

[jira] [Updated] (BEAM-6769) BigQuery IO does not support bytes in Python 3

[ https://issues.apache.org/jira/browse/BEAM-6769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-6769: -- Summary: BigQuery IO does not support bytes in Python 3 (was: Write bytes to BigQuery

[jira] [Updated] (BEAM-6769) BigQuery IO does not support bytes in Python 3

[ https://issues.apache.org/jira/browse/BEAM-6769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Valentyn Tymofieiev updated BEAM-6769: -- Priority: Major (was: Minor) > BigQuery IO does not support bytes in Python 3 >

[jira] [Commented] (BEAM-6769) Write bytes to BigQuery in Python 3

[ https://issues.apache.org/jira/browse/BEAM-6769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786293#comment-16786293 ] Valentyn Tymofieiev commented on BEAM-6769: --- 1. Per

[jira] [Work logged] (BEAM-4775) JobService should support returning metrics

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

[jira] [Work logged] (BEAM-4775) JobService should support returning metrics

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

[jira] [Work logged] (BEAM-4775) JobService should support returning metrics

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

[jira] [Work logged] (BEAM-4775) JobService should support returning metrics

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

[jira] [Work logged] (BEAM-4775) JobService should support returning metrics

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

[jira] [Work logged] (BEAM-4775) JobService should support returning metrics

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

[jira] [Work logged] (BEAM-4775) JobService should support returning metrics

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

[jira] [Work logged] (BEAM-4775) JobService should support returning metrics

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

[jira] [Work logged] (BEAM-4775) JobService should support returning metrics

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

[jira] [Work logged] (BEAM-4775) JobService should support returning metrics

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

[jira] [Commented] (BEAM-6257) Can we deprecate the side input paths through PAssert?

[ https://issues.apache.org/jira/browse/BEAM-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786226#comment-16786226 ] Kyle Weaver commented on BEAM-6257: --- [~kenn] Thanks for the heads up. Looks like PCollectionViewAssert

[jira] [Work logged] (BEAM-6619) Add PostCommit suite for integration tests on DataflowRunner

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

[jira] [Work logged] (BEAM-6619) Add PostCommit suite for integration tests on DataflowRunner

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

[jira] [Work logged] (BEAM-6619) Add PostCommit suite for integration tests on DataflowRunner

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

[jira] [Work logged] (BEAM-6772) Select transform has non-intuitive semantics

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

[jira] [Work logged] (BEAM-6772) Select transform has non-intuitive semantics

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

[jira] [Created] (BEAM-6772) Select transform has non-intuitive semantics

Reuven Lax created BEAM-6772: Summary: Select transform has non-intuitive semantics Key: BEAM-6772 URL: https://issues.apache.org/jira/browse/BEAM-6772 Project: Beam Issue Type: Sub-task

[jira] [Commented] (BEAM-6771) Spark Runner Fails on Certain Versions of Spark 2.X

[ https://issues.apache.org/jira/browse/BEAM-6771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786167#comment-16786167 ] Kyle Winkelman commented on BEAM-6771: -- Correct I tried to run a production workflow that runs on

[jira] [Work logged] (BEAM-6619) Add PostCommit suite for integration tests on DataflowRunner

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

[jira] [Commented] (BEAM-6771) Spark Runner Fails on Certain Versions of Spark 2.X

[ https://issues.apache.org/jira/browse/BEAM-6771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786162#comment-16786162 ] Alex Amato commented on BEAM-6771: -- I noticed as well that equals was not implemented properly.

[jira] [Updated] (BEAM-6546) MetricsContainerStepMap equals() method not implemented properly

[ https://issues.apache.org/jira/browse/BEAM-6546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Amato updated BEAM-6546: - Description: This calls equals on the underlying collection of containers it uses, however the

[jira] [Updated] (BEAM-6546) MetricsContainerStepMap equals() method not implemented properly

[ https://issues.apache.org/jira/browse/BEAM-6546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Amato updated BEAM-6546: - Description: This calls equals on the underlying collection of containers it uses, however the containers

[jira] [Work logged] (BEAM-5663) Add tox suites for various Python 3 versions (3.5, 3.6, 3.7)

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

[jira] [Commented] (BEAM-6327) Don't attempt to fuse subtransforms of primitive/known transforms.

[ https://issues.apache.org/jira/browse/BEAM-6327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786151#comment-16786151 ] Daniel Oliveira commented on BEAM-6327: --- I don't see a problem with that, it sounds like a good

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Work logged] (BEAM-6762) Behavior requires documentation: Pipeline can't run before fusion

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

[jira] [Work logged] (BEAM-6754) Support multi core machines for python pipeline on flink for loopback environment

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

[jira] [Work logged] (BEAM-6762) Behavior requires documentation: Pipeline can't run before fusion

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

[jira] [Created] (BEAM-6771) Spark Runner Fails on Certain Versions of Spark 2.X

Kyle Winkelman created BEAM-6771: Summary: Spark Runner Fails on Certain Versions of Spark 2.X Key: BEAM-6771 URL: https://issues.apache.org/jira/browse/BEAM-6771 Project: Beam Issue Type:

[jira] [Updated] (BEAM-6771) Spark Runner Fails on Certain Versions of Spark 2.X

[ https://issues.apache.org/jira/browse/BEAM-6771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Winkelman updated BEAM-6771: - Description: When updating to Beam 2.11.0, I ran into the exception at the bottom of this issue

[jira] [Work logged] (BEAM-6751) KafkaIO's EOS mode does not work with FlinkRunner

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

[jira] [Work logged] (BEAM-6751) KafkaIO's EOS mode does not work with FlinkRunner

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

[jira] [Work logged] (BEAM-6751) KafkaIO's EOS mode does not work with FlinkRunner

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

[jira] [Work logged] (BEAM-6751) KafkaIO's EOS mode does not work with FlinkRunner

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

[jira] [Commented] (BEAM-6757) Random "IllegalStateException: TimestampCombiner moved element from X to Y" seen in running topology

[ https://issues.apache.org/jira/browse/BEAM-6757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785979#comment-16785979 ] Kenneth Knowles commented on BEAM-6757: --- I can explain the stack trace: this is part of a GroupByKey

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Work logged] (BEAM-6751) KafkaIO's EOS mode does not work with FlinkRunner

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

[jira] [Assigned] (BEAM-6757) Random "IllegalStateException: TimestampCombiner moved element from X to Y" seen in running topology

[ https://issues.apache.org/jira/browse/BEAM-6757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-6757: - Assignee: Kenneth Knowles > Random "IllegalStateException: TimestampCombiner moved

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Commented] (BEAM-6757) Random "IllegalStateException: TimestampCombiner moved element from X to Y" seen in running topology

[ https://issues.apache.org/jira/browse/BEAM-6757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785919#comment-16785919 ] Kenneth Knowles commented on BEAM-6757: --- It definitely looks like the element is in the wrong

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Updated] (BEAM-4582) Incorrectly translates apache_beam.runners.dataflow.native_io.streaming_create.DecodeAndEmitDoFn when creating the Dataflow pipeline json description

[ https://issues.apache.org/jira/browse/BEAM-4582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4582: -- Labels: portability triaged (was: portability) > Incorrectly translates >

[jira] [Updated] (BEAM-5286) [beam_PostCommit_Java_GradleBuild][org.apache.beam.examples.subprocess.ExampleEchoPipelineTest.testExampleEchoPipeline][Flake] .sh script: text file busy.

[ https://issues.apache.org/jira/browse/BEAM-5286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-5286: -- Labels: currently-failing flake triaged (was: currently-failing) >

[jira] [Commented] (BEAM-6257) Can we deprecate the side input paths through PAssert?

[ https://issues.apache.org/jira/browse/BEAM-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785884#comment-16785884 ] Kenneth Knowles commented on BEAM-6257: --- Note that I file enough bugs, I don't follow them by

[jira] [Updated] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

[ https://issues.apache.org/jira/browse/BEAM-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6722: -- Labels: flake flaky-test triaged (was: flaky-test) > :beam-sdks-java-io-cassandra:test is

[jira] [Commented] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

[ https://issues.apache.org/jira/browse/BEAM-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785878#comment-16785878 ] Kenneth Knowles commented on BEAM-6722: --- [~echauchot] is this resolved, or is there still more to

[jira] [Updated] (BEAM-4657) Python SDK harness should support user timers

[ https://issues.apache.org/jira/browse/BEAM-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4657: -- Labels: portability triaged (was: portability) > Python SDK harness should support user timers

[jira] [Updated] (BEAM-6257) Can we deprecate the side input paths through PAssert?

[ https://issues.apache.org/jira/browse/BEAM-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-6257: -- Labels: starter triaged (was: starter) > Can we deprecate the side input paths through

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Updated] (BEAM-4581) Python SDK does not correctly set the serialized_fn of WindowInto when translating to the Dataflow pipeline description

[ https://issues.apache.org/jira/browse/BEAM-4581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4581: -- Labels: portability triaged (was: portability) > Python SDK does not correctly set the

[jira] [Updated] (BEAM-4655) Update pipeline translation for timers inside Python SDK

[ https://issues.apache.org/jira/browse/BEAM-4655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-4655: -- Labels: portability triaged (was: portability) > Update pipeline translation for timers inside

[jira] [Commented] (BEAM-6257) Can we deprecate the side input paths through PAssert?

[ https://issues.apache.org/jira/browse/BEAM-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785883#comment-16785883 ] Kenneth Knowles commented on BEAM-6257: --- [~ibzib] yes, at that level of implementation detail it is

[jira] [Updated] (BEAM-2791) DirectRunner shuts down when there are pending event time timers

[ https://issues.apache.org/jira/browse/BEAM-2791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-2791: -- Labels: sickbay triaged (was: sickbay) > DirectRunner shuts down when there are pending event

[jira] [Updated] (BEAM-3583) Apex Local Cluster Creation fails in TestE2EWordCount

[ https://issues.apache.org/jira/browse/BEAM-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-3583: -- Labels: flake sickbay triaged (was: sickbay) > Apex Local Cluster Creation fails in

[jira] [Updated] (BEAM-1946) Add IO module for restful api

[ https://issues.apache.org/jira/browse/BEAM-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-1946: -- Labels: IO features restful triaged (was: IO features restful) > Add IO module for restful api

[jira] [Commented] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

[ https://issues.apache.org/jira/browse/BEAM-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785879#comment-16785879 ] Kenneth Knowles commented on BEAM-6722: --- [~aromanenko] [~echauchot] should this be assigned to one

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Comment Edited] (BEAM-6770) Correct zstd-jni dependency scope to optional

[ https://issues.apache.org/jira/browse/BEAM-6770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785823#comment-16785823 ] Michael Luckey edited comment on BEAM-6770 at 3/6/19 4:23 PM: -- Sure you could

[jira] [Commented] (BEAM-6770) Correct zstd-jni dependency scope to optional

[ https://issues.apache.org/jira/browse/BEAM-6770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785823#comment-16785823 ] Michael Luckey commented on BEAM-6770: -- Sure you could also add an explicit configuration. And do an

[jira] [Commented] (BEAM-6770) Correct zstd-jni dependency scope to optional

[ https://issues.apache.org/jira/browse/BEAM-6770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785805#comment-16785805 ] Romain Manni-Bucau commented on BEAM-6770: -- with gradle you can always create the configuration

[jira] [Work logged] (BEAM-6751) KafkaIO's EOS mode does not work with FlinkRunner

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

[jira] [Work logged] (BEAM-6751) KafkaIO's EOS mode does not work with FlinkRunner

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

[jira] [Work logged] (BEAM-6751) KafkaIO's EOS mode does not work with FlinkRunner

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

[jira] [Work logged] (BEAM-6751) KafkaIO's EOS mode does not work with FlinkRunner

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

[jira] [Work logged] (BEAM-6751) KafkaIO's EOS mode does not work with FlinkRunner

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

[jira] [Commented] (BEAM-6770) Correct zstd-jni dependency scope to optional

[ https://issues.apache.org/jira/browse/BEAM-6770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785798#comment-16785798 ] Ismaël Mejía commented on BEAM-6770: Yes it makes sense, if gradle does not suport optinal

[jira] [Work logged] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

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

[jira] [Commented] (BEAM-6770) Correct zstd-jni dependency scope to optional

[ https://issues.apache.org/jira/browse/BEAM-6770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785789#comment-16785789 ] Jeff Klukas commented on BEAM-6770: --- Correct that the dependency is not required to compile. The class

[jira] [Comment Edited] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

[ https://issues.apache.org/jira/browse/BEAM-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785757#comment-16785757 ] Etienne Chauchot edited comment on BEAM-6722 at 3/6/19 3:43 PM: It seems

[jira] [Comment Edited] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

[ https://issues.apache.org/jira/browse/BEAM-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785757#comment-16785757 ] Etienne Chauchot edited comment on BEAM-6722 at 3/6/19 3:39 PM: It seems

[jira] [Commented] (BEAM-6770) Correct zstd-jni dependency scope to optional

[ https://issues.apache.org/jira/browse/BEAM-6770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785769#comment-16785769 ] Michael Luckey commented on BEAM-6770: -- [~jeff.klu...@gmail.com] To put it into test runtime,

[jira] [Commented] (BEAM-6722) :beam-sdks-java-io-cassandra:test is flaky

[ https://issues.apache.org/jira/browse/BEAM-6722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16785757#comment-16785757 ] Etienne Chauchot commented on BEAM-6722: It seems that embedded cassandra did not start within

[jira] [Work logged] (BEAM-5964) Add ClickHouseIO.Write

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

[jira] [Work logged] (BEAM-6655) Support progress reporting over FnAPI

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

[jira] [Work logged] (BEAM-6655) Support progress reporting over FnAPI

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

[jira] [Work logged] (BEAM-6655) Support progress reporting over FnAPI

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

  1   2   >