[jira] [Work logged] (BEAM-5760) Portable Flink support for maxBundleSize/maxBundleMillis

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

[jira] [Work logged] (BEAM-3450) RemoteGrpcPorts should contain the wire format

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

[jira] [Commented] (BEAM-5779) Failure in beam_PostCommit_Python_Verify PubSubIntegrationTest on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656971#comment-16656971 ] Kenneth Knowles commented on BEAM-5779: --- This now occurred in the Cron of the Python precommit.

[jira] [Work logged] (BEAM-5299) Define max global window as a shared value in protos like URN enums.

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

[jira] [Work logged] (BEAM-5299) Define max global window as a shared value in protos like URN enums.

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

[jira] [Work logged] (BEAM-5299) Define max global window as a shared value in protos like URN enums.

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

[jira] [Work logged] (BEAM-5299) Define max global window as a shared value in protos like URN enums.

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

[jira] [Updated] (BEAM-5438) Add Gemfire IO

[ https://issues.apache.org/jira/browse/BEAM-5438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismaël Mejía updated BEAM-5438: --- Summary: Add Gemfire IO (was: why not add a Gemfire IO) > Add Gemfire IO > -- > >

[jira] [Commented] (BEAM-4042) Get rid of deprecated gradle API

[ https://issues.apache.org/jira/browse/BEAM-4042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656946#comment-16656946 ] Michael Luckey commented on BEAM-4042: -- Opened a [PR|https://github.com/apache/beam/pull/6753] which

[jira] [Issue Comment Deleted] (BEAM-5779) Failure in beam_PostCommit_Python_Verify PubSubIntegrationTest on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles updated BEAM-5779: -- Comment: was deleted (was: This now occurred in the Cron of the Python precommit. Checking the

[jira] [Work logged] (BEAM-5299) Define max global window as a shared value in protos like URN enums.

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

[jira] [Work logged] (BEAM-5637) Python support for custom dataflow worker jar

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

[jira] [Assigned] (BEAM-5779) Failure in beam_PostCommit_Python_Verify PubSubIntegrationTest on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kenneth Knowles reassigned BEAM-5779: - Assignee: Udi Meiri (was: Ahmet Altay) > Failure in beam_PostCommit_Python_Verify

[jira] [Work logged] (BEAM-5791) Bound the amount of data on the data plane by time.

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

[jira] [Work logged] (BEAM-5790) Euphoria: Remove Dataset abstraction

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

[jira] [Created] (BEAM-5791) Bound the amount of data on the data plane by time.

Robert Bradshaw created BEAM-5791: - Summary: Bound the amount of data on the data plane by time. Key: BEAM-5791 URL: https://issues.apache.org/jira/browse/BEAM-5791 Project: Beam Issue Type:

[jira] [Work logged] (BEAM-5790) Euphoria: Remove Dataset abstraction

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

[jira] [Commented] (BEAM-5439) StringUtf8Coder is slower than expected

[ https://issues.apache.org/jira/browse/BEAM-5439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656897#comment-16656897 ] Ismaël Mejía commented on BEAM-5439: This looks interesting, I don't have historic context on this

[jira] [Work logged] (BEAM-5779) Failure in beam_PostCommit_Python_Verify PubSubIntegrationTest on Dataflow

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

[jira] [Commented] (BEAM-5786) KafkaIO should support topic patterns

[ https://issues.apache.org/jira/browse/BEAM-5786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657085#comment-16657085 ] Raghu Angadi commented on BEAM-5786: It will cause reader to fail. Streaming runners typically keep

[jira] [Work logged] (BEAM-5781) Enable ValidatesRunner tests for portable Java

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

[jira] [Created] (BEAM-5793) Python sdk docs target fails in flink_streaming_impulse_source

Ruoyun Huang created BEAM-5793: -- Summary: Python sdk docs target fails in flink_streaming_impulse_source Key: BEAM-5793 URL: https://issues.apache.org/jira/browse/BEAM-5793 Project: Beam Issue

[jira] [Issue Comment Deleted] (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: -- Comment: was deleted (was: https://builds.apache.org/job/beam_PreCommit_Java_Cron/462/) >

[jira] [Comment Edited] (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:comment-tabpanel=16657060#comment-16657060 ] Kenneth Knowles edited comment on BEAM-5286 at 10/19/18 4:43 PM: -

[jira] [Commented] (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:comment-tabpanel=16657060#comment-16657060 ] Kenneth Knowles commented on BEAM-5286: --- https://builds.apache.org/job/beam_PreCommit_Java_Cron/462/

[jira] [Work logged] (BEAM-5795) Can SQL Query 5 be simplified?

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

[jira] [Work logged] (BEAM-5467) Python Flink ValidatesRunner job fixes

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

[jira] [Comment Edited] (BEAM-5786) KafkaIO should support topic patterns

[ https://issues.apache.org/jira/browse/BEAM-5786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657014#comment-16657014 ] Alexey Romanenko edited comment on BEAM-5786 at 10/19/18 4:19 PM: --

[jira] [Commented] (BEAM-5794) TestDirectRunner: poll matchers for wait_until_finish_duration, then cancel the pipeline

[ https://issues.apache.org/jira/browse/BEAM-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657097#comment-16657097 ] Udi Meiri commented on BEAM-5794: - Note that this would require reviewing all matchers to make sure they

[jira] [Work logged] (BEAM-5467) Python Flink ValidatesRunner job fixes

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

[jira] [Work logged] (BEAM-5467) Python Flink ValidatesRunner job fixes

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

[jira] [Work logged] (BEAM-5779) Failure in beam_PostCommit_Python_Verify PubSubIntegrationTest on Dataflow

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

[jira] [Commented] (BEAM-5779) Failure in beam_PostCommit_Python_Verify PubSubIntegrationTest on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657063#comment-16657063 ] Kenneth Knowles commented on BEAM-5779: ---

[jira] [Created] (BEAM-5794) TestDirectRunner: poll matchers for wait_until_finish_duration, then cancel the pipeline

Udi Meiri created BEAM-5794: --- Summary: TestDirectRunner: poll matchers for wait_until_finish_duration, then cancel the pipeline Key: BEAM-5794 URL: https://issues.apache.org/jira/browse/BEAM-5794 Project:

[jira] [Commented] (BEAM-5793) Python sdk docs target fails in flink_streaming_impulse_source

[ https://issues.apache.org/jira/browse/BEAM-5793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657200#comment-16657200 ] Ruoyun Huang commented on BEAM-5793: No, didn't do anything special.  Just synced to head, and then

[jira] [Commented] (BEAM-5786) KafkaIO should support topic patterns

[ https://issues.apache.org/jira/browse/BEAM-5786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657014#comment-16657014 ] Alexey Romanenko commented on BEAM-5786: [~rangadi] What is a current behaviour if topic gets

[jira] [Comment Edited] (BEAM-5779) Failure in beam_PostCommit_Python_Verify PubSubIntegrationTest on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657012#comment-16657012 ] Udi Meiri edited comment on BEAM-5779 at 10/19/18 4:16 PM: --- The log from 6317

[jira] [Commented] (BEAM-5779) Failure in beam_PostCommit_Python_Verify PubSubIntegrationTest on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657012#comment-16657012 ] Udi Meiri commented on BEAM-5779: - The log from 6317 shows TestDataflowRunner attempting to cancel the job

[jira] [Commented] (BEAM-5779) Failure in beam_PostCommit_Python_Verify PubSubIntegrationTest on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657103#comment-16657103 ] Udi Meiri commented on BEAM-5779: - I think the error in 6321 is similar in nature: the job was cancelled

[jira] [Work logged] (BEAM-5779) Failure in beam_PostCommit_Python_Verify PubSubIntegrationTest on Dataflow

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

[jira] [Created] (BEAM-5795) Can SQL Query 5 be simplified?

Kenneth Knowles created BEAM-5795: - Summary: Can SQL Query 5 be simplified? Key: BEAM-5795 URL: https://issues.apache.org/jira/browse/BEAM-5795 Project: Beam Issue Type: Improvement

[jira] [Work logged] (BEAM-5467) Python Flink ValidatesRunner job fixes

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

[jira] [Work logged] (BEAM-5763) Re-organize IntelliJ docs into workflow tasks

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

[jira] [Work logged] (BEAM-5763) Re-organize IntelliJ docs into workflow tasks

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

[jira] [Work logged] (BEAM-5763) Re-organize IntelliJ docs into workflow tasks

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

[jira] [Commented] (BEAM-5793) Python sdk docs target fails in flink_streaming_impulse_source

[ https://issues.apache.org/jira/browse/BEAM-5793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657182#comment-16657182 ] Micah Wylde commented on BEAM-5793: --- Interesting. I'm able to run ./gradlew :beam-sdks-python:docs

[jira] [Commented] (BEAM-5779) Failure in beam_PostCommit_Python_Verify PubSubIntegrationTest on Dataflow

[ https://issues.apache.org/jira/browse/BEAM-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657078#comment-16657078 ] Udi Meiri commented on BEAM-5779: - Sadly it doesn't. The on_success_matcher is only run after the

[jira] [Work logged] (BEAM-5467) Python Flink ValidatesRunner job fixes

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

[jira] [Work logged] (BEAM-5790) Euphoria: Remove Dataset abstraction

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

[jira] [Commented] (BEAM-5781) Enable ValidatesRunner tests for portable Java

[ https://issues.apache.org/jira/browse/BEAM-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657330#comment-16657330 ] Boyuan Zhang commented on BEAM-5781: Trying to run all googleCloudPlatfromIntegratinTest with fnapi

[jira] [Work started] (BEAM-5796) TEST window_end for TUMBLE, HOP, SESSION

[ https://issues.apache.org/jira/browse/BEAM-5796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-5796 started by Rui Wang. -- > TEST window_end for TUMBLE, HOP, SESSION > > >

[jira] [Created] (BEAM-5797) SDK workers are not always killed when Flink pipeline finishes

Micah Wylde created BEAM-5797: - Summary: SDK workers are not always killed when Flink pipeline finishes Key: BEAM-5797 URL: https://issues.apache.org/jira/browse/BEAM-5797 Project: Beam Issue

[jira] [Commented] (BEAM-5781) Enable ValidatesRunner tests for portable Java

[ https://issues.apache.org/jira/browse/BEAM-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657391#comment-16657391 ] Boyuan Zhang commented on BEAM-5781: Trying to run all coreSDKJavaIntegrationTest and all tests

[jira] [Assigned] (BEAM-5739) Contributor Story: "Submitting your first PR"

[ https://issues.apache.org/jira/browse/BEAM-5739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Myrvold reassigned BEAM-5739: -- Assignee: Alan Myrvold > Contributor Story: "Submitting your first PR" >

[jira] [Commented] (BEAM-5793) Python sdk docs target fails in flink_streaming_impulse_source

[ https://issues.apache.org/jira/browse/BEAM-5793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657495#comment-16657495 ] Ruoyun Huang commented on BEAM-5793: I tend to guess this is a real issue as well.  I tried several

[jira] [Assigned] (BEAM-5743) Move "works in progress" out of getting started guide

[ https://issues.apache.org/jira/browse/BEAM-5743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Myrvold reassigned BEAM-5743: -- Assignee: Alan Myrvold (was: Scott Wegner) > Move "works in progress" out of getting started

[jira] [Assigned] (BEAM-5742) Add expectations for code reviews

[ https://issues.apache.org/jira/browse/BEAM-5742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Myrvold reassigned BEAM-5742: -- Assignee: Alan Myrvold > Add expectations for code reviews > -

[jira] [Assigned] (BEAM-5738) Refactor Contributor Guide into "Stories"

[ https://issues.apache.org/jira/browse/BEAM-5738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alan Myrvold reassigned BEAM-5738: -- Assignee: Alan Myrvold > Refactor Contributor Guide into "Stories" >

[jira] [Commented] (BEAM-5797) SDK workers are not always killed when Flink pipeline finishes

[ https://issues.apache.org/jira/browse/BEAM-5797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657535#comment-16657535 ] Micah Wylde commented on BEAM-5797: --- The relevant stack trace appears to be: {code:java} 2018-10-19

[jira] [Created] (BEAM-5796) TEST window_end for TUMBLE, HOP, SESSION

Rui Wang created BEAM-5796: -- Summary: TEST window_end for TUMBLE, HOP, SESSION Key: BEAM-5796 URL: https://issues.apache.org/jira/browse/BEAM-5796 Project: Beam Issue Type: Bug

[jira] [Work logged] (BEAM-5637) Python support for custom dataflow worker jar

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

[jira] [Work logged] (BEAM-5467) Python Flink ValidatesRunner job fixes

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

[jira] [Created] (BEAM-5798) Add support for dynamic destinations when writing to Kafka

Luke Cwik created BEAM-5798: --- Summary: Add support for dynamic destinations when writing to Kafka Key: BEAM-5798 URL: https://issues.apache.org/jira/browse/BEAM-5798 Project: Beam Issue Type: New

[jira] [Assigned] (BEAM-5384) [SQL] Calcite optimizes away LogicalProject

[ https://issues.apache.org/jira/browse/BEAM-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Wang reassigned BEAM-5384: -- Assignee: Rui Wang > [SQL] Calcite optimizes away LogicalProject >

[jira] [Commented] (BEAM-5793) Python sdk docs target fails in flink_streaming_impulse_source

[ https://issues.apache.org/jira/browse/BEAM-5793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657525#comment-16657525 ] Ruoyun Huang commented on BEAM-5793: AFAIK, it is not on Jenkins.  (And I think it should be)   

[jira] [Commented] (BEAM-5397) Flink portable runner GRPC cleanup failure after user class loader was removed

[ https://issues.apache.org/jira/browse/BEAM-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657290#comment-16657290 ] Thomas Weise commented on BEAM-5397: Yes, this is still relevant with current master / 2.9.0-SNAPSHOT.

[jira] [Commented] (BEAM-5781) Enable ValidatesRunner tests for portable Java

[ https://issues.apache.org/jira/browse/BEAM-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657382#comment-16657382 ] Boyuan Zhang commented on BEAM-5781: Trying to run all examplesJavaIntegrationTest with fnapi worker,

[jira] [Work logged] (BEAM-5796) TEST window_end for TUMBLE, HOP, SESSION

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

[jira] [Work logged] (BEAM-5467) Python Flink ValidatesRunner job fixes

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

[jira] [Commented] (BEAM-5793) Python sdk docs target fails in flink_streaming_impulse_source

[ https://issues.apache.org/jira/browse/BEAM-5793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657509#comment-16657509 ] Micah Wylde commented on BEAM-5793: --- Interesting. Is this run in jenkins anywhere? If not, can we add

[jira] [Work logged] (BEAM-5796) TEST window_end for TUMBLE, HOP, SESSION

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

[jira] [Commented] (BEAM-5793) Python sdk docs target fails in flink_streaming_impulse_source

[ https://issues.apache.org/jira/browse/BEAM-5793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657342#comment-16657342 ] Scott Wegner commented on BEAM-5793: I get the same error from master HEAD on Linux:

[jira] [Commented] (BEAM-5781) Enable ValidatesRunner tests for portable Java

[ https://issues.apache.org/jira/browse/BEAM-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657487#comment-16657487 ] Boyuan Zhang commented on BEAM-5781: Trying to run all ValidatesRunner tests with fnapi worker, got

[jira] [Work started] (BEAM-5799) Investigate the root cause of session_end is always equal to session_start

[ https://issues.apache.org/jira/browse/BEAM-5799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-5799 started by Rui Wang. -- > Investigate the root cause of session_end is always equal to session_start >

[jira] [Created] (BEAM-5799) Investigate the root cause of session_end is always equal to session_start

Rui Wang created BEAM-5799: -- Summary: Investigate the root cause of session_end is always equal to session_start Key: BEAM-5799 URL: https://issues.apache.org/jira/browse/BEAM-5799 Project: Beam

[jira] [Comment Edited] (BEAM-5793) Python sdk docs target fails in flink_streaming_impulse_source

[ https://issues.apache.org/jira/browse/BEAM-5793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657525#comment-16657525 ] Ruoyun Huang edited comment on BEAM-5793 at 10/19/18 10:50 PM: ---   Weird

[jira] [Comment Edited] (BEAM-5439) StringUtf8Coder is slower than expected

[ https://issues.apache.org/jira/browse/BEAM-5439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657550#comment-16657550 ] Luke Cwik edited comment on BEAM-5439 at 10/19/18 11:18 PM: The decoding seems

[jira] [Comment Edited] (BEAM-5439) StringUtf8Coder is slower than expected

[ https://issues.apache.org/jira/browse/BEAM-5439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657550#comment-16657550 ] Luke Cwik edited comment on BEAM-5439 at 10/19/18 11:19 PM: The decoding seems

[jira] [Comment Edited] (BEAM-5439) StringUtf8Coder is slower than expected

[ https://issues.apache.org/jira/browse/BEAM-5439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657550#comment-16657550 ] Luke Cwik edited comment on BEAM-5439 at 10/19/18 11:18 PM: The decoding seems

[jira] [Commented] (BEAM-5439) StringUtf8Coder is slower than expected

[ https://issues.apache.org/jira/browse/BEAM-5439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657550#comment-16657550 ] Luke Cwik commented on BEAM-5439: - The decoding seems to have a bug, it needs to loop around the

[jira] [Comment Edited] (BEAM-5439) StringUtf8Coder is slower than expected

[ https://issues.apache.org/jira/browse/BEAM-5439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657550#comment-16657550 ] Luke Cwik edited comment on BEAM-5439 at 10/19/18 11:17 PM: The decoding seems

[jira] [Created] (BEAM-5802) Support ValidatesRunner using fn-api worker

Boyuan Zhang created BEAM-5802: -- Summary: Support ValidatesRunner using fn-api worker Key: BEAM-5802 URL: https://issues.apache.org/jira/browse/BEAM-5802 Project: Beam Issue Type: Sub-task

[jira] [Work logged] (BEAM-5801) Support postcommit ITs using fn-api worker

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

[jira] [Commented] (BEAM-3612) Make it easy to generate type-specialized Go SDK reflectx.Funcs

[ https://issues.apache.org/jira/browse/BEAM-3612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657601#comment-16657601 ] Robert Burke commented on BEAM-3612: The various registration functions need to be resilient to

[jira] [Work logged] (BEAM-5617) Several tests fail on Python 3 with failed assert: == []

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

[jira] [Work logged] (BEAM-5646) Equality is broken for Rows with BYTES field

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

[jira] [Commented] (BEAM-5793) Python sdk docs target fails in flink_streaming_impulse_source

[ https://issues.apache.org/jira/browse/BEAM-5793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657606#comment-16657606 ] Ruoyun Huang commented on BEAM-5793: Update: I created a testing PR,

[jira] [Work logged] (BEAM-5745) Util test on annotations fails

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

[jira] [Work logged] (BEAM-5781) Enable ValidatesRunner tests for portable Java

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

[jira] [Commented] (BEAM-5617) Several tests fail on Python 3 with failed assert: == []

[ https://issues.apache.org/jira/browse/BEAM-5617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657654#comment-16657654 ] Valentyn Tymofieiev commented on BEAM-5617: --- I've been examining the execution path for

[jira] [Updated] (BEAM-5798) Add support for dynamic destinations when writing to Kafka

[ https://issues.apache.org/jira/browse/BEAM-5798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Cwik updated BEAM-5798: Labels: newbie starter (was: ) > Add support for dynamic destinations when writing to Kafka >

[jira] [Work logged] (BEAM-4444) Parquet IO for Python SDK

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

[jira] [Work logged] (BEAM-5299) Define max global window as a shared value in protos like URN enums.

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

[jira] [Updated] (BEAM-5791) Bound the amount of data on the data plane by time.

[ https://issues.apache.org/jira/browse/BEAM-5791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Bradshaw updated BEAM-5791: -- Description: This is especially important for Fn API reads, where each element represents a

[jira] [Assigned] (BEAM-5760) Portable Flink support for maxBundleSize/maxBundleMillis

[ https://issues.apache.org/jira/browse/BEAM-5760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-5760: Assignee: Thomas Weise (was: Maximilian Michels) > Portable Flink support for

[jira] [Assigned] (BEAM-5760) Portable Flink support for maxBundleSize/maxBundleMillis

[ https://issues.apache.org/jira/browse/BEAM-5760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned BEAM-5760: Assignee: Maximilian Michels (was: Thomas Weise) > Portable Flink support for