[jira] [Work logged] (BEAM-7980) External environment with containerized worker pool

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

[jira] [Work logged] (BEAM-7730) Add Flink 1.9 build target and Make FlinkRunner compatible with Flink 1.9

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

[jira] [Work logged] (BEAM-7739) Add ValueState in Python sdk

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

[jira] [Work logged] (BEAM-7993) portable python precommit is flaky

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

[jira] [Work logged] (BEAM-8114) Chicago Taxi on Dataflow is failing

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

[jira] [Work logged] (BEAM-8114) Chicago Taxi on Dataflow is failing

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

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

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

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

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

[jira] [Work logged] (BEAM-8113) FlinkRunner: Stage files from context classloader

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

[jira] [Work logged] (BEAM-8114) Chicago Taxi on Dataflow is failing

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

[jira] [Work logged] (BEAM-8114) Chicago Taxi on Dataflow is failing

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

[jira] [Updated] (BEAM-5752) Beam Dependency Update Request: org.eclipse.jetty:jetty-server

[ https://issues.apache.org/jira/browse/BEAM-5752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-5752: Description: - 2018-10-15 12:13:17.575546 -

[jira] [Work logged] (BEAM-7520) DirectRunner timers are not strictly time ordered

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

[jira] [Updated] (BEAM-5748) Beam Dependency Update Request: org.conscrypt:conscrypt-openjdk

[ https://issues.apache.org/jira/browse/BEAM-5748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-5748: Description: - 2018-10-15 12:11:29.496210 -

[jira] [Updated] (BEAM-5753) Beam Dependency Update Request: org.eclipse.jetty:jetty-servlet

[ https://issues.apache.org/jira/browse/BEAM-5753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-5753: Description: - 2018-10-15 12:13:19.256622 -

[jira] [Updated] (BEAM-5750) Beam Dependency Update Request: javax.servlet:javax.servlet-api

[ https://issues.apache.org/jira/browse/BEAM-5750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-5750: Description: - 2018-10-15 12:13:14.253682 -

[jira] [Updated] (BEAM-8002) Beam Dependency Update Request: Gradle:

[ https://issues.apache.org/jira/browse/BEAM-8002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-8002: Description: - 2019-08-19 12:04:19.192688 -

[jira] [Updated] (BEAM-5539) Beam Dependency Update Request: google-cloud-pubsub

[ https://issues.apache.org/jira/browse/BEAM-5539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-5539: Description: - 2018-10-01 19:17:59.633423 -

[jira] [Created] (BEAM-8127) Beam Dependency Update Request: google-cloud-bigtable

Beam JIRA Bot created BEAM-8127: --- Summary: Beam Dependency Update Request: google-cloud-bigtable Key: BEAM-8127 URL: https://issues.apache.org/jira/browse/BEAM-8127 Project: Beam Issue Type:

[jira] [Updated] (BEAM-6089) Beam Dependency Update Request: oauth2client

[ https://issues.apache.org/jira/browse/BEAM-6089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6089: Description: - 2018-11-19 12:11:53.801885 -

[jira] [Updated] (BEAM-6645) Beam Dependency Update Request: com.github.ben-manes.versions:com.github.ben-manes.versions.gradle.plugin

[ https://issues.apache.org/jira/browse/BEAM-6645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6645: Description: - 2019-02-11 12:12:17.710870 -

[jira] [Updated] (BEAM-7792) Beam Dependency Update Request: com.github.spotbugs:spotbugs

[ https://issues.apache.org/jira/browse/BEAM-7792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7792: Description: - 2019-07-22 12:15:41.216793 -

[jira] [Updated] (BEAM-7370) Beam Dependency Update Request: Sphinx

[ https://issues.apache.org/jira/browse/BEAM-7370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7370: Description: - 2019-05-20 16:38:07.937770 -

[jira] [Updated] (BEAM-7369) Beam Dependency Update Request: mock

[ https://issues.apache.org/jira/browse/BEAM-7369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-7369: Description: - 2019-05-20 16:37:42.331317 -

[jira] [Updated] (BEAM-6951) Beam Dependency Update Request: com.github.spotbugs:spotbugs-annotations

[ https://issues.apache.org/jira/browse/BEAM-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Beam JIRA Bot updated BEAM-6951: Description: - 2019-04-01 12:15:05.460427 -

[jira] [Commented] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16920907#comment-16920907 ] Alexey Romanenko commented on BEAM-8121: Thank you for additional details. Could you also post a

[jira] [Updated] (BEAM-8115) Overwrite portable Flink application jar pipeline options at runtime

[ https://issues.apache.org/jira/browse/BEAM-8115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated BEAM-8115: - Status: Open (was: Triage Needed) > Overwrite portable Flink application jar pipeline

[jira] [Commented] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16920886#comment-16920886 ] TJ commented on BEAM-8121: -- I use Dataflow runner.  I tried Reshuffle.viaRandomKey(), it worked quite poorly and

[jira] [Updated] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexey Romanenko updated BEAM-8121: --- Status: Open (was: Triage Needed) > Messages are not distributed per machines when consuming

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

[ https://issues.apache.org/jira/browse/BEAM-8102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved BEAM-8102. -- Fix Version/s: Not applicable Assignee: Reuven Lax Resolution: Fixed >

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

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

[jira] [Work logged] (BEAM-7605) Provide a way for user code to read dataflow runner stats

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

[jira] [Work logged] (BEAM-7605) Provide a way for user code to read dataflow runner stats

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

[jira] [Work logged] (BEAM-7520) DirectRunner timers are not strictly time ordered

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

[jira] [Commented] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16920851#comment-16920851 ] Alexey Romanenko commented on BEAM-8121: I guess it could be caused by fusion when messages,

[jira] [Created] (BEAM-8128) Don't deprecate Read for Impulse

Romain Manni-Bucau created BEAM-8128: Summary: Don't deprecate Read for Impulse Key: BEAM-8128 URL: https://issues.apache.org/jira/browse/BEAM-8128 Project: Beam Issue Type: Bug

[jira] [Comment Edited] (BEAM-8121) Messages are not distributed per machines when consuming from Kafka topic with 1 partition

[ https://issues.apache.org/jira/browse/BEAM-8121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16920886#comment-16920886 ] TJ edited comment on BEAM-8121 at 9/2/19 2:03 PM: -- I use Dataflow runner.  I tried

[jira] [Work logged] (BEAM-4087) Gradle build does not allow to overwrite versions of provided dependencies

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

[jira] [Work logged] (BEAM-8019) Support cross-language transforms for DataflowRunner

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