[jira] [Work logged] (BEAM-8382) Add polling interval to KinesisIO.Read

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

[jira] [Work logged] (BEAM-8382) Add polling interval to KinesisIO.Read

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

[jira] [Work logged] (BEAM-8382) Add polling interval to KinesisIO.Read

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

[jira] [Work logged] (BEAM-8382) Add polling interval to KinesisIO.Read

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

[jira] [Work logged] (BEAM-8382) Add polling interval to KinesisIO.Read

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

[jira] [Work logged] (BEAM-8382) Add polling interval to KinesisIO.Read

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

[jira] [Work logged] (BEAM-8382) Add polling interval to KinesisIO.Read

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

[jira] [Work logged] (BEAM-8382) Add polling interval to KinesisIO.Read

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

[jira] [Work logged] (BEAM-8550) @RequiresTimeSortedInput DoFn annotation

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

[jira] [Assigned] (BEAM-8095) pytest Py3.7 crashes on test_remote_runner_display_data

[ https://issues.apache.org/jira/browse/BEAM-8095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Udi Meiri reassigned BEAM-8095: --- Assignee: Udi Meiri > pytest Py3.7 crashes on test_remote_runner_display_data >

[jira] [Work logged] (BEAM-8396) Default to LOOPBACK mode for local flink (spark, ...) runner.

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

[jira] [Commented] (BEAM-8542) Add async write to AWS SNS IO & remove retry logic

[ https://issues.apache.org/jira/browse/BEAM-8542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966803#comment-16966803 ] Ankit Jhalaria commented on BEAM-8542: -- I will take a look today [~kenn] > Add async write to AWS

[jira] [Work logged] (BEAM-7303) Move Portable Runner and other of reference runner.

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

[jira] [Work logged] (BEAM-4420) Add KafkaIO Integration Tests

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

[jira] [Work logged] (BEAM-3713) Consider moving away from nose to nose2 or pytest.

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

[jira] [Work logged] (BEAM-3713) Consider moving away from nose to nose2 or pytest.

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

[jira] [Work logged] (BEAM-8382) Add polling interval to KinesisIO.Read

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

[jira] [Work logged] (BEAM-4420) Add KafkaIO Integration Tests

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

[jira] [Updated] (BEAM-8549) Buffered state during checkpointing may be keyed incorrectly

[ https://issues.apache.org/jira/browse/BEAM-8549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8549: - Status: Open (was: Triage Needed) > Buffered state during checkpointing may be keyed

[jira] [Work logged] (BEAM-8368) [Python] libprotobuf-generated exception when importing apache_beam

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

[jira] [Work logged] (BEAM-8550) @RequiresTimeSortedInput DoFn annotation

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

[jira] [Work logged] (BEAM-8550) @RequiresTimeSortedInput DoFn annotation

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

[jira] [Work logged] (BEAM-8352) Reading records in background may lead to OOM errors

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

[jira] [Created] (BEAM-8551) Beam Python containers should include all Beam SDK dependencies, and do not have conflicting dependencies

Valentyn Tymofieiev created BEAM-8551: - Summary: Beam Python containers should include all Beam SDK dependencies, and do not have conflicting dependencies Key: BEAM-8551 URL:

[jira] [Commented] (BEAM-8095) pytest Py3.7 crashes on test_remote_runner_display_data

[ https://issues.apache.org/jira/browse/BEAM-8095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966848#comment-16966848 ] Udi Meiri commented on BEAM-8095: - Fixed in https://issues.apache.org/jira/browse/BEAM-8397 Leaving this

[jira] [Work logged] (BEAM-4420) Add KafkaIO Integration Tests

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

[jira] [Work logged] (BEAM-4420) Add KafkaIO Integration Tests

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

[jira] [Work logged] (BEAM-8382) Add polling interval to KinesisIO.Read

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

[jira] [Work logged] (BEAM-7013) A new count distinct transform based on BigQuery compatible HyperLogLog++ implementation

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

[jira] [Work logged] (BEAM-7434) RabbitMqIO uses a deprecated API

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

[jira] [Work logged] (BEAM-7303) Move Portable Runner and other of reference runner.

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

[jira] [Work logged] (BEAM-4420) Add KafkaIO Integration Tests

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

[jira] [Work logged] (BEAM-4420) Add KafkaIO Integration Tests

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

[jira] [Created] (BEAM-8552) Spark runner should not used STOPPED state as a terminal state

Chad Dombrova created BEAM-8552: --- Summary: Spark runner should not used STOPPED state as a terminal state Key: BEAM-8552 URL: https://issues.apache.org/jira/browse/BEAM-8552 Project: Beam

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

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-2572) Implement an S3 filesystem for Python SDK

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

[jira] [Work logged] (BEAM-8511) Support for enhanced fan-out in KinesisIO

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

[jira] [Work logged] (BEAM-8368) [Python] libprotobuf-generated exception when importing apache_beam

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

[jira] [Work logged] (BEAM-8539) Clearly define the valid job state transitions

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Commented] (BEAM-8536) Migrate usage of DelayedBundleApplication.requested_execution_time to time duration

[ https://issues.apache.org/jira/browse/BEAM-8536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966931#comment-16966931 ] Boyuan Zhang commented on BEAM-8536: No, this only affects Java. Currently we only have Java and

[jira] [Work logged] (BEAM-7434) RabbitMqIO uses a deprecated API

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

[jira] [Commented] (BEAM-8504) BigQueryIO DIRECT_READ is broken

[ https://issues.apache.org/jira/browse/BEAM-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966982#comment-16966982 ] Aryan Naraghi commented on BEAM-8504: - Gleb, do you want to send me a PR with your change that relaxes

[jira] [Work logged] (BEAM-8511) Support for enhanced fan-out in KinesisIO

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

[jira] [Work logged] (BEAM-8432) Parametrize source & target compatibility for beam Java modules

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

[jira] [Work logged] (BEAM-8432) Parametrize source & target compatibility for beam Java modules

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

[jira] [Work logged] (BEAM-8254) (Java SDK) Add workerRegion and workerZone options

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

[jira] [Work logged] (BEAM-4420) Add KafkaIO Integration Tests

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Comment Edited] (BEAM-8504) BigQueryIO DIRECT_READ is broken

[ https://issues.apache.org/jira/browse/BEAM-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967032#comment-16967032 ] Aryan Naraghi edited comment on BEAM-8504 at 11/4/19 10:00 PM: --- Okay, I just

[jira] [Work logged] (BEAM-8504) BigQueryIO DIRECT_READ is broken

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

[jira] [Work logged] (BEAM-8504) BigQueryIO DIRECT_READ is broken

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

[jira] [Work logged] (BEAM-8504) BigQueryIO DIRECT_READ is broken

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

[jira] [Commented] (BEAM-8504) BigQueryIO DIRECT_READ is broken

[ https://issues.apache.org/jira/browse/BEAM-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967082#comment-16967082 ] Aryan Naraghi commented on BEAM-8504: - Fix: [https://github.com/apache/beam/pull/9987] > BigQueryIO

[jira] [Work logged] (BEAM-7886) Make row coder a standard coder and implement in python

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Commented] (BEAM-8434) Allow trigger transcript tests to be run as ValidatesRunner tests.

[ https://issues.apache.org/jira/browse/BEAM-8434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966897#comment-16966897 ] Robert Bradshaw commented on BEAM-8434: --- The original intent was to allow these to be executed in

[jira] [Work logged] (BEAM-8532) Beam Python trigger driver sets incorrect timestamp for output windows.

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

[jira] [Work logged] (BEAM-8368) [Python] libprotobuf-generated exception when importing apache_beam

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

[jira] [Work logged] (BEAM-8504) BigQueryIO DIRECT_READ is broken

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

[jira] [Work logged] (BEAM-8504) BigQueryIO DIRECT_READ is broken

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

[jira] [Work logged] (BEAM-8544) Install Beam SDK with ccache for faster re-install.

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

[jira] [Work logged] (BEAM-8544) Install Beam SDK with ccache for faster re-install.

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

[jira] [Assigned] (BEAM-8504) BigQueryIO DIRECT_READ is broken

[ https://issues.apache.org/jira/browse/BEAM-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-8504: --- Assignee: Aryan Naraghi > BigQueryIO DIRECT_READ is broken >

[jira] [Work logged] (BEAM-2572) Implement an S3 filesystem for Python SDK

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Commented] (BEAM-8432) Parametrize source & target compatibility for beam Java modules

[ https://issues.apache.org/jira/browse/BEAM-8432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966883#comment-16966883 ] Lukasz Gajowy commented on BEAM-8432: - I think you're right - I missed this one. Submitting PR... >

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8526) Turn on metrics publishing in load tests on Flink

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

[jira] [Work logged] (BEAM-8526) Turn on metrics publishing in load tests on Flink

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-7013) A new count distinct transform based on BigQuery compatible HyperLogLog++ implementation

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

[jira] [Updated] (BEAM-8537) Provide WatermarkEstimatorProvider for different types of WatermarkEstimator

[ https://issues.apache.org/jira/browse/BEAM-8537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyuan Zhang updated BEAM-8537: --- Description: This is a follow up for in-progress PR: https://github.com/apache/beam/pull/9794.

[jira] [Updated] (BEAM-8537) Provide WatermarkEstimatorProvider for different types of WatermarkEstimator

[ https://issues.apache.org/jira/browse/BEAM-8537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyuan Zhang updated BEAM-8537: --- Description: This is a follow up for in-progress PR: https://github.com/apache/beam/pull/9794.

[jira] [Commented] (BEAM-8504) BigQueryIO DIRECT_READ is broken

[ https://issues.apache.org/jira/browse/BEAM-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16966996#comment-16966996 ] Gleb Kanterov commented on BEAM-8504: - [~aryann] yes, it looks like a backend or floating-point

[jira] [Work logged] (BEAM-8545) don't docker pull before docker run

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

[jira] [Work logged] (BEAM-8545) don't docker pull before docker run

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

[jira] [Commented] (BEAM-8504) BigQueryIO DIRECT_READ is broken

[ https://issues.apache.org/jira/browse/BEAM-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967032#comment-16967032 ] Aryan Naraghi commented on BEAM-8504: - Okay, I just confirmed with a colleague that there is a case

[jira] [Comment Edited] (BEAM-8504) BigQueryIO DIRECT_READ is broken

[ https://issues.apache.org/jira/browse/BEAM-8504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16967032#comment-16967032 ] Aryan Naraghi edited comment on BEAM-8504 at 11/4/19 10:00 PM: --- Okay, I just

[jira] [Created] (BEAM-8554) Use WorkItemCommitRequest protobuf fields to signal that a WorkItem needs to be broken up

Steve Koonce created BEAM-8554: -- Summary: Use WorkItemCommitRequest protobuf fields to signal that a WorkItem needs to be broken up Key: BEAM-8554 URL: https://issues.apache.org/jira/browse/BEAM-8554

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8500) PR Trigger Phrase of beam_PreCommit_Website_Stage_GCS listed in README is incorrect

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

[jira] [Work logged] (BEAM-8368) [Python] libprotobuf-generated exception when importing apache_beam

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

[jira] [Work logged] (BEAM-8544) Install Beam SDK with ccache for faster re-install.

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

[jira] [Work logged] (BEAM-8532) Beam Python trigger driver sets incorrect timestamp for output windows.

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

[jira] [Work logged] (BEAM-8532) Beam Python trigger driver sets incorrect timestamp for output windows.

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

[jira] [Work logged] (BEAM-4420) Add KafkaIO Integration Tests

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

[jira] [Work logged] (BEAM-8335) Add streaming support to Interactive Beam

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

[jira] [Work logged] (BEAM-8516) sdist build fails when artifacts from different versions are present

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

  1   2   >