[jira] [Assigned] (BEAM-9932) Add documentation describing cross-language test pipelines

[ https://issues.apache.org/jira/browse/BEAM-9932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-9932: --- Assignee: Kevin Sijo Puthusseri (was: Chamikara Madhusanka

[jira] [Assigned] (BEAM-7163) Godoc for passert.Sum seems wrong

[ https://issues.apache.org/jira/browse/BEAM-7163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-7163: --- Assignee: Kevin Sijo Puthusseri > Godoc for passert.Sum

[jira] [Assigned] (BEAM-10186) Send error response to runner when split or progress requests are received out of order

[ https://issues.apache.org/jira/browse/BEAM-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-10186: Assignee: Chamikara Madhusanka Jayalath > Send error

[jira] [Created] (BEAM-10186) Send error response to runner when split or progress requests are received out of order

Chamikara Madhusanka Jayalath created BEAM-10186: Summary: Send error response to runner when split or progress requests are received out of order Key: BEAM-10186 URL:

[jira] [Updated] (BEAM-10151) Document how to run a Java (xlang) pipeline on the Spark portable runner

[ https://issues.apache.org/jira/browse/BEAM-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-10151: - Component/s: cross-language > Document how to run a Java (xlang)

[jira] [Updated] (BEAM-3083) BigQueryIO.write() with DynamicDestinations should not call getSchema() on every element

[ https://issues.apache.org/jira/browse/BEAM-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-3083: Labels: testlabel (was: ) > BigQueryIO.write() with

[jira] [Updated] (BEAM-9921) Add Go SDK tests to cross-language Flink ValidatesRunner test suite

[ https://issues.apache.org/jira/browse/BEAM-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9921: Description: Test suite is here: 

[jira] [Updated] (BEAM-9921) Add Go SDK tests to cross-language Flink ValidatesRunner test suite

[ https://issues.apache.org/jira/browse/BEAM-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9921: Summary: Add Go SDK tests to cross-language Flink ValidatesRunner

[jira] [Updated] (BEAM-9922) Add Go SDK tests to cross-language Spark ValidatesRunner test suite

[ https://issues.apache.org/jira/browse/BEAM-9922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9922: Description: Test suite is here: 

[jira] [Updated] (BEAM-9922) Add Go SDK tests to cross-language Spark ValidatesRunner test suite

[ https://issues.apache.org/jira/browse/BEAM-9922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9922: Summary: Add Go SDK tests to cross-language Spark ValidatesRunner

[jira] [Updated] (BEAM-9919) Add an External transform API to Go SDK

[ https://issues.apache.org/jira/browse/BEAM-9919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9919: Summary: Add an External transform API to Go SDK (was: Add an

[jira] [Updated] (BEAM-9923) Add an expansion service to Go SDK

[ https://issues.apache.org/jira/browse/BEAM-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9923: Parent: BEAM-9918 Issue Type: Sub-task (was: Bug) > Add an

[jira] [Updated] (BEAM-9918) Cross-language transforms support for Go SDK

[ https://issues.apache.org/jira/browse/BEAM-9918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9918: Component/s: cross-language > Cross-language transforms support for

[jira] [Updated] (BEAM-9348) Enable CrossLanguageValidateRunner test for direct runner

[ https://issues.apache.org/jira/browse/BEAM-9348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9348: Component/s: cross-language > Enable CrossLanguageValidateRunner

[jira] [Updated] (BEAM-10078) uniquify Dataflow specific jars when staging

[ https://issues.apache.org/jira/browse/BEAM-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-10078: - Issue Type: Improvement (was: Bug) > uniquify Dataflow specific

[jira] [Updated] (BEAM-9238) Cross-language pipeline dependency management

[ https://issues.apache.org/jira/browse/BEAM-9238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9238: Component/s: cross-language > Cross-language pipeline dependency

[jira] [Updated] (BEAM-10125) adding cross-language KafkaIO integration test

[ https://issues.apache.org/jira/browse/BEAM-10125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-10125: - Component/s: cross-language > adding cross-language KafkaIO

[jira] [Resolved] (BEAM-9719) Cross-language test suites failing due to mossing nose plugin

[ https://issues.apache.org/jira/browse/BEAM-9719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath resolved BEAM-9719. - Fix Version/s: Not applicable Resolution: Fixed >

[jira] [Updated] (BEAM-10078) uniquify Dataflow specific jars when staging

[ https://issues.apache.org/jira/browse/BEAM-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-10078: - Component/s: cross-language > uniquify Dataflow specific jars

[jira] [Updated] (BEAM-10134) Add Cross-language wrappers for Java IOs

[ https://issues.apache.org/jira/browse/BEAM-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-10134: - Component/s: cross-language > Add Cross-language wrappers for

[jira] [Updated] (BEAM-9932) Add documentation describing cross-language test pipelines

[ https://issues.apache.org/jira/browse/BEAM-9932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9932: Component/s: (was: testing) website

[jira] [Assigned] (BEAM-9932) Add documentation describing cross-language test pipelines

[ https://issues.apache.org/jira/browse/BEAM-9932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-9932: --- Assignee: (was: Chamikara Madhusanka Jayalath) > Add

[jira] [Updated] (BEAM-9932) Add documentation describing cross-language test pipelines

[ https://issues.apache.org/jira/browse/BEAM-9932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9932: Component/s: (was: website) > Add documentation describing

[jira] [Assigned] (BEAM-9932) Add documentation describing cross-language test pipelines

[ https://issues.apache.org/jira/browse/BEAM-9932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-9932: --- Assignee: Chamikara Madhusanka Jayalath > Add documentation

[jira] [Resolved] (BEAM-3557) Converting to runner api protos and back results in parent pointers being dropped

[ https://issues.apache.org/jira/browse/BEAM-3557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath resolved BEAM-3557. - Fix Version/s: Not applicable Resolution: Fixed >

[jira] [Resolved] (BEAM-6486) Cross-language transform API

[ https://issues.apache.org/jira/browse/BEAM-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath resolved BEAM-6486. - Fix Version/s: Not applicable Resolution: Fixed >

[jira] [Commented] (BEAM-6486) Cross-language transform API

[ https://issues.apache.org/jira/browse/BEAM-6486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119808#comment-17119808 ] Chamikara Madhusanka Jayalath commented on BEAM-6486: - This is already available.

[jira] [Updated] (BEAM-6683) Add an integration test suite for cross-language transforms for Flink runner

[ https://issues.apache.org/jira/browse/BEAM-6683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-6683: Component/s: cross-language > Add an integration test suite for

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-8019: Component/s: cross-language > Support cross-language transforms for

[jira] [Updated] (BEAM-8603) Add Python SqlTransform MVP

[ https://issues.apache.org/jira/browse/BEAM-8603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-8603: Component/s: cross-language > Add Python SqlTransform MVP >

[jira] [Updated] (BEAM-7738) Support PubSubIO to be configured externally for use with other SDKs

[ https://issues.apache.org/jira/browse/BEAM-7738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-7738: Component/s: cross-language > Support PubSubIO to be configured

[jira] [Updated] (BEAM-7029) Support KafkaIO to be configured externally for use with other SDKs

[ https://issues.apache.org/jira/browse/BEAM-7029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-7029: Component/s: cross-language > Support KafkaIO to be configured

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

[ https://issues.apache.org/jira/browse/BEAM-7886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-7886: Component/s: cross-language > Make row coder a standard coder and

[jira] [Commented] (BEAM-7029) Support KafkaIO to be configured externally for use with other SDKs

[ https://issues.apache.org/jira/browse/BEAM-7029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118975#comment-17118975 ] Chamikara Madhusanka Jayalath commented on BEAM-7029: - Will do. Thanks. > Support

[jira] [Resolved] (BEAM-10077) using filename + hash instead of UUID for staging name

[ https://issues.apache.org/jira/browse/BEAM-10077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath resolved BEAM-10077. -- Resolution: Fixed > using filename + hash instead of UUID for

[jira] [Commented] (BEAM-7029) Support KafkaIO to be configured externally for use with other SDKs

[ https://issues.apache.org/jira/browse/BEAM-7029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118945#comment-17118945 ] Chamikara Madhusanka Jayalath commented on BEAM-7029: - Dataflow will support

[jira] [Reopened] (BEAM-10077) using filename + hash instead of UUID for staging name

[ https://issues.apache.org/jira/browse/BEAM-10077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reopened BEAM-10077: -- > using filename + hash instead of UUID for staging name >

[jira] [Commented] (BEAM-10077) using filename + hash instead of UUID for staging name

[ https://issues.apache.org/jira/browse/BEAM-10077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118176#comment-17118176 ] Chamikara Madhusanka Jayalath commented on BEAM-10077: -- Seems like 

[jira] [Commented] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117906#comment-17117906 ] Chamikara Madhusanka Jayalath commented on BEAM-3788: - KafkaIO is expected to be

[jira] [Resolved] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath resolved BEAM-3788. - Resolution: Fixed > Implement a Kafka IO for Python SDK >

[jira] [Updated] (BEAM-3788) Implement a Kafka IO for Python SDK

[ https://issues.apache.org/jira/browse/BEAM-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-3788: Fix Version/s: 2.22.0 > Implement a Kafka IO for Python SDK >

[jira] [Commented] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116875#comment-17116875 ] Chamikara Madhusanka Jayalath commented on BEAM-9383: - Steve, why would two workers

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113628#comment-17113628 ] Chamikara Madhusanka Jayalath commented on BEAM-8019: - Marking this as fixed since the

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-8019: Priority: P2 (was: P1) > Support cross-language transforms for

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath resolved BEAM-8019. - Resolution: Fixed > Support cross-language transforms for

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-8019: Fix Version/s: 2.22.0 > Support cross-language transforms for

[jira] [Updated] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9383: Fix Version/s: 2.22.0 > Staging Dataflow artifacts from environment

[jira] [Resolved] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath resolved BEAM-9383. - Resolution: Fixed > Staging Dataflow artifacts from environment >

[jira] [Updated] (BEAM-10057) Failure when getting watermark "getWatermark is never meant to be invoked."

[ https://issues.apache.org/jira/browse/BEAM-10057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-10057: - Priority: P1 (was: P0) > Failure when getting watermark

[jira] [Commented] (BEAM-10057) Failure when getting watermark "getWatermark is never meant to be invoked."

[ https://issues.apache.org/jira/browse/BEAM-10057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113479#comment-17113479 ] Chamikara Madhusanka Jayalath commented on BEAM-10057: -- Not sure. Hit this when

[jira] [Commented] (BEAM-10057) Failure when getting watermark "getWatermark is never meant to be invoked."

[ https://issues.apache.org/jira/browse/BEAM-10057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113473#comment-17113473 ] Chamikara Madhusanka Jayalath commented on BEAM-10057: -- cc: [~bhulette] > Failure

[jira] [Created] (BEAM-10057) Failure when getting watermark "getWatermark is never meant to be invoked."

Chamikara Madhusanka Jayalath created BEAM-10057: Summary: Failure when getting watermark "getWatermark is never meant to be invoked." Key: BEAM-10057 URL:

[jira] [Updated] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9383: Fix Version/s: (was: 2.22.0) > Staging Dataflow artifacts from

[jira] [Commented] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113468#comment-17113468 ] Chamikara Madhusanka Jayalath commented on BEAM-9383: - Removing this from the blockers

[jira] [Updated] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9383: Priority: P2 (was: P0) > Staging Dataflow artifacts from

[jira] [Commented] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112678#comment-17112678 ] Chamikara Madhusanka Jayalath commented on BEAM-9383: - Seems like it's picking up jars

[jira] [Commented] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112649#comment-17112649 ] Chamikara Madhusanka Jayalath commented on BEAM-9383: - Note that I'm running from Beam

[jira] [Comment Edited] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112645#comment-17112645 ] Chamikara Madhusanka Jayalath edited comment on BEAM-9383 at 5/20/20, 10:51 PM:

[jira] [Reopened] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reopened BEAM-9383: - > Staging Dataflow artifacts from environment >

[jira] [Commented] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112645#comment-17112645 ] Chamikara Madhusanka Jayalath commented on BEAM-9383: - I tried running a Kafka

[jira] [Assigned] (BEAM-10045) Reduce logging related to ratelimitExceeded error for BQ sink when performing streaming inserts

[ https://issues.apache.org/jira/browse/BEAM-10045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-10045: Assignee: Chamikara Madhusanka Jayalath > Reduce logging

[jira] [Created] (BEAM-10045) Reduce logging related to ratelimitExceeded error for BQ sink when performing streaming inserts

Chamikara Madhusanka Jayalath created BEAM-10045: Summary: Reduce logging related to ratelimitExceeded error for BQ sink when performing streaming inserts Key: BEAM-10045 URL:

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-8019: Fix Version/s: (was: 2.22.0) > Support cross-language

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111546#comment-17111546 ] Chamikara Madhusanka Jayalath commented on BEAM-8019: - Yeah, removing from the

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111376#comment-17111376 ] Chamikara Madhusanka Jayalath commented on BEAM-8019: - Temporarily making this a

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-8019: Fix Version/s: 2.22.0 > Support cross-language transforms for

[jira] [Commented] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110523#comment-17110523 ] Chamikara Madhusanka Jayalath commented on BEAM-9383: - Work after 

[jira] [Commented] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110521#comment-17110521 ] Chamikara Madhusanka Jayalath commented on BEAM-9383: - Changing to a blocker to get 

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-8019: Priority: P1 (was: P0) > Support cross-language transforms for

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-8019: Fix Version/s: (was: 2.22.0) > Support cross-language

[jira] [Updated] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9383: Priority: P0 (was: P2) > Staging Dataflow artifacts from

[jira] [Updated] (BEAM-9383) Staging Dataflow artifacts from environment

[ https://issues.apache.org/jira/browse/BEAM-9383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9383: Fix Version/s: 2.22.0 > Staging Dataflow artifacts from environment

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-8019: --- Assignee: Chamikara Madhusanka Jayalath (was: Heejong Lee)

[jira] [Issue Comment Deleted] (BEAM-8019) Support cross-language transforms for DataflowRunner

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-8019: Comment: was deleted (was: Changing to a blocker to get 

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-8019: Fix Version/s: 2.22.0 > Support cross-language transforms for

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-8019: Priority: P0 (was: P2) > Support cross-language transforms for

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110386#comment-17110386 ] Chamikara Madhusanka Jayalath commented on BEAM-8019: - Changing to a blocker to get 

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

[ https://issues.apache.org/jira/browse/BEAM-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-8019: --- Assignee: Heejong Lee (was: Chamikara Madhusanka Jayalath)

[jira] [Updated] (BEAM-9745) [beam_PostCommit_Java_PortabilityApi] Various GCP IO tests failing, unable to deserialize Custom DoFns and Custom Coders.

[ https://issues.apache.org/jira/browse/BEAM-9745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9745: Fix Version/s: 2.22.0 > [beam_PostCommit_Java_PortabilityApi]

[jira] [Comment Edited] (BEAM-9745) [beam_PostCommit_Java_PortabilityApi] Various GCP IO tests failing, unable to deserialize Custom DoFns and Custom Coders.

[ https://issues.apache.org/jira/browse/BEAM-9745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109176#comment-17109176 ] Chamikara Madhusanka Jayalath edited comment on BEAM-9745 at 5/16/20, 7:04 PM:

[jira] [Commented] (BEAM-9745) [beam_PostCommit_Java_PortabilityApi] Various GCP IO tests failing, unable to deserialize Custom DoFns and Custom Coders.

[ https://issues.apache.org/jira/browse/BEAM-9745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109176#comment-17109176 ] Chamikara Madhusanka Jayalath commented on BEAM-9745: - I noticed that we add harness

[jira] [Updated] (BEAM-9745) [beam_PostCommit_Java_PortabilityApi] Various GCP IO tests failing, unable to deserialize Custom DoFns and Custom Coders.

[ https://issues.apache.org/jira/browse/BEAM-9745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9745: Priority: P0 (was: P2) > [beam_PostCommit_Java_PortabilityApi]

[jira] [Commented] (BEAM-9745) [beam_PostCommit_Java_PortabilityApi] Various GCP IO tests failing, unable to deserialize Custom DoFns and Custom Coders.

[ https://issues.apache.org/jira/browse/BEAM-9745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109113#comment-17109113 ] Chamikara Madhusanka Jayalath commented on BEAM-9745: - I've seen this when running

[jira] [Assigned] (BEAM-9745) [beam_PostCommit_Java_PortabilityApi] Various GCP IO tests failing, unable to deserialize Custom DoFns and Custom Coders.

[ https://issues.apache.org/jira/browse/BEAM-9745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-9745: --- Assignee: Kenneth Knowles (was: Pablo Estrada) >

[jira] [Created] (BEAM-10012) Update Python SDK to construct Dataflow job requests from Beam runner API protos

Chamikara Madhusanka Jayalath created BEAM-10012: Summary: Update Python SDK to construct Dataflow job requests from Beam runner API protos Key: BEAM-10012 URL:

[jira] [Created] (BEAM-9932) Add documentation describing cross-language test pipelines

Chamikara Madhusanka Jayalath created BEAM-9932: --- Summary: Add documentation describing cross-language test pipelines Key: BEAM-9932 URL: https://issues.apache.org/jira/browse/BEAM-9932

[jira] [Commented] (BEAM-9907) apache_beam.transforms.external_test.ExternalTransformTest.test_nested flaky

[ https://issues.apache.org/jira/browse/BEAM-9907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101938#comment-17101938 ] Chamikara Madhusanka Jayalath commented on BEAM-9907: - Thanks Brian. Assigning to Jira

[jira] [Assigned] (BEAM-9907) apache_beam.transforms.external_test.ExternalTransformTest.test_nested flaky

[ https://issues.apache.org/jira/browse/BEAM-9907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-9907: --- Assignee: Brian Hulette (was: Chamikara Madhusanka Jayalath)

[jira] [Commented] (BEAM-9907) apache_beam.transforms.external_test.ExternalTransformTest.test_nested flaky

[ https://issues.apache.org/jira/browse/BEAM-9907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101912#comment-17101912 ] Chamikara Madhusanka Jayalath commented on BEAM-9907: - Looking into this. >

[jira] [Created] (BEAM-9923) Add an expansion service to Go SDK

Chamikara Madhusanka Jayalath created BEAM-9923: --- Summary: Add an expansion service to Go SDK Key: BEAM-9923 URL: https://issues.apache.org/jira/browse/BEAM-9923 Project: Beam

[jira] [Created] (BEAM-9922) Go SDK supports executing cross-language transforms on Spark runner

Chamikara Madhusanka Jayalath created BEAM-9922: --- Summary: Go SDK supports executing cross-language transforms on Spark runner Key: BEAM-9922 URL: https://issues.apache.org/jira/browse/BEAM-9922

[jira] [Created] (BEAM-9921) Go SDK supports executing cross-language transforms on Flink runner

Chamikara Madhusanka Jayalath created BEAM-9921: --- Summary: Go SDK supports executing cross-language transforms on Flink runner Key: BEAM-9921 URL: https://issues.apache.org/jira/browse/BEAM-9921

[jira] [Created] (BEAM-9920) Add support for identifying and staging artifacts received through transform expansion protocol

Chamikara Madhusanka Jayalath created BEAM-9920: --- Summary: Add support for identifying and staging artifacts received through transform expansion protocol Key: BEAM-9920 URL:

[jira] [Created] (BEAM-9919) Add an External transform to Go SDK

Chamikara Madhusanka Jayalath created BEAM-9919: --- Summary: Add an External transform to Go SDK Key: BEAM-9919 URL: https://issues.apache.org/jira/browse/BEAM-9919 Project: Beam

[jira] [Created] (BEAM-9918) Cross-language transforms support for Go SDK

Chamikara Madhusanka Jayalath created BEAM-9918: --- Summary: Cross-language transforms support for Go SDK Key: BEAM-9918 URL: https://issues.apache.org/jira/browse/BEAM-9918 Project: Beam

[jira] [Commented] (BEAM-9913) Cross-language ValidatesRunner tests are failing due to failure of ':sdks:java:container:pullLicenses'

[ https://issues.apache.org/jira/browse/BEAM-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101288#comment-17101288 ] Chamikara Madhusanka Jayalath commented on BEAM-9913: - cc: [~robertwb] >

[jira] [Created] (BEAM-9913) Cross-language ValidatesRunner tests are failing due to failure of ':sdks:java:container:pullLicenses'

Chamikara Madhusanka Jayalath created BEAM-9913: --- Summary: Cross-language ValidatesRunner tests are failing due to failure of ':sdks:java:container:pullLicenses' Key: BEAM-9913 URL:

[jira] [Commented] (BEAM-9482) beam_PerformanceTests_Kafka_IO failing due to " provided port is already allocated"

[ https://issues.apache.org/jira/browse/BEAM-9482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17100309#comment-17100309 ] Chamikara Madhusanka Jayalath commented on BEAM-9482: - Haven't been able to look into

[jira] [Assigned] (BEAM-9482) beam_PerformanceTests_Kafka_IO failing due to " provided port is already allocated"

[ https://issues.apache.org/jira/browse/BEAM-9482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-9482: --- Assignee: (was: Chamikara Madhusanka Jayalath) >

[jira] [Commented] (BEAM-9779) HL7v2IOWriteIT is flaky

[ https://issues.apache.org/jira/browse/BEAM-9779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17099986#comment-17099986 ] Chamikara Madhusanka Jayalath commented on BEAM-9779: - I think so. Test suite looks

  1   2   3   >