[jira] [Created] (BEAM-9635) Make Python side input tags always key, value pairs instead of depending in index suffixed tag names

Chamikara Madhusanka Jayalath created BEAM-9635: --- Summary: Make Python side input tags always key, value pairs instead of depending in index suffixed tag names Key: BEAM-9635 URL:

[jira] [Commented] (BEAM-9832) KeyError: 'No such coder: ' in fn_runner_test

[ https://issues.apache.org/jira/browse/BEAM-9832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094572#comment-17094572 ] Chamikara Madhusanka Jayalath commented on BEAM-9832: - Interactive_runner_test failed

[jira] [Created] (BEAM-9842) interactive_runner_test test_streaming_wordcount failing due to 'ValueError: PCollection not available'

Chamikara Madhusanka Jayalath created BEAM-9842: --- Summary: interactive_runner_test test_streaming_wordcount failing due to 'ValueError: PCollection not available' Key: BEAM-9842 URL:

[jira] [Updated] (BEAM-9767) test_streaming_wordcount flaky timeouts

[ https://issues.apache.org/jira/browse/BEAM-9767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9767: Priority: Critical (was: Major) > test_streaming_wordcount flaky

[jira] [Commented] (BEAM-9843) Flink UnboundedSourceWrapperTest flaky due to a timeout

[ https://issues.apache.org/jira/browse/BEAM-9843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094658#comment-17094658 ] Chamikara Madhusanka Jayalath commented on BEAM-9843: - Test is timing out here: 

[jira] [Commented] (BEAM-9843) Flink UnboundedSourceWrapperTest flaky due to a timeout

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

[jira] [Created] (BEAM-9844) ParDoTest.KeyTests failing for Spark

Chamikara Madhusanka Jayalath created BEAM-9844: --- Summary: ParDoTest.KeyTests failing for Spark Key: BEAM-9844 URL: https://issues.apache.org/jira/browse/BEAM-9844 Project: Beam

[jira] [Created] (BEAM-9843) Flink UnboundedSourceWrapperTest flaky due to a timeout

Chamikara Madhusanka Jayalath created BEAM-9843: --- Summary: Flink UnboundedSourceWrapperTest flaky due to a timeout Key: BEAM-9843 URL: https://issues.apache.org/jira/browse/BEAM-9843

[jira] [Commented] (BEAM-9842) interactive_runner_test test_streaming_wordcount failing due to 'ValueError: PCollection not available'

[ https://issues.apache.org/jira/browse/BEAM-9842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094706#comment-17094706 ] Chamikara Madhusanka Jayalath commented on BEAM-9842: - Thanks. Missed the existing

[jira] [Comment Edited] (BEAM-9767) test_streaming_wordcount flaky timeouts

[ https://issues.apache.org/jira/browse/BEAM-9767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094709#comment-17094709 ] Chamikara Madhusanka Jayalath edited comment on BEAM-9767 at 4/28/20, 5:24 PM:

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

[ https://issues.apache.org/jira/browse/BEAM-9779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093641#comment-17093641 ] Chamikara Madhusanka Jayalath commented on BEAM-9779: - Can we please remove/sickbay

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

[ https://issues.apache.org/jira/browse/BEAM-9779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9779: Priority: Critical (was: Minor) > HL7v2IOWriteIT is flaky >

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

[ https://issues.apache.org/jira/browse/BEAM-9779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9779: Component/s: test-failures > HL7v2IOWriteIT is flaky >

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

[ https://issues.apache.org/jira/browse/BEAM-9779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093646#comment-17093646 ] Chamikara Madhusanka Jayalath commented on BEAM-9779: - More occurrences

[jira] [Updated] (BEAM-9832) KeyError: 'No such coder: ' in fn_runner_test

[ https://issues.apache.org/jira/browse/BEAM-9832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath updated BEAM-9832: Priority: Critical (was: Major) > KeyError: 'No such coder: ' in

[jira] [Assigned] (BEAM-9832) KeyError: 'No such coder: ' in fn_runner_test

[ https://issues.apache.org/jira/browse/BEAM-9832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-9832: --- Assignee: Pablo Estrada > KeyError: 'No such coder: ' in

[jira] [Commented] (BEAM-9832) KeyError: 'No such coder: ' in fn_runner_test

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

[jira] [Work stopped] (BEAM-9117) Clustering coder does not get used for BQ multi-partitioned tables

[ https://issues.apache.org/jira/browse/BEAM-9117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-9117 stopped by Chamikara Madhusanka Jayalath. --- > Clustering coder does not get used for BQ

[jira] [Work started] (BEAM-9117) Clustering coder does not get used for BQ multi-partitioned tables

[ https://issues.apache.org/jira/browse/BEAM-9117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on BEAM-9117 started by Chamikara Madhusanka Jayalath. --- > Clustering coder does not get used for BQ

[jira] [Commented] (BEAM-9459) Go Postcommit failing at GBK

[ https://issues.apache.org/jira/browse/BEAM-9459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091069#comment-17091069 ] Chamikara Madhusanka Jayalath commented on BEAM-9459: - Seems like a number of test

[jira] [Created] (BEAM-9815) beam_PostCommit_Go perma red due to failing to start container

Chamikara Madhusanka Jayalath created BEAM-9815: --- Summary: beam_PostCommit_Go perma red due to failing to start container Key: BEAM-9815 URL: https://issues.apache.org/jira/browse/BEAM-9815

[jira] [Commented] (BEAM-9459) Go Postcommit failing at GBK

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

[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=17091876#comment-17091876 ] Chamikara Madhusanka Jayalath commented on BEAM-8121: - I think there are some users

[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: Pablo Estrada (was: Chamikara Madhusanka Jayalath)

[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=17090111#comment-17090111 ] Chamikara Madhusanka Jayalath commented on BEAM-9745: - Thanks Pablo. Do you know if

[jira] [Created] (BEAM-9834) Spanner IT tests are flaky due to "io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED"

Chamikara Madhusanka Jayalath created BEAM-9834: --- Summary: Spanner IT tests are flaky due to "io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED" Key: BEAM-9834 URL:

[jira] [Commented] (BEAM-9834) Spanner IT tests are flaky due to "io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED"

[ https://issues.apache.org/jira/browse/BEAM-9834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093989#comment-17093989 ] Chamikara Madhusanka Jayalath commented on BEAM-9834: - Project: apache-beam-testing

[jira] [Commented] (BEAM-9834) Spanner IT tests are flaky due to "io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED"

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

[jira] [Assigned] (BEAM-9834) Spanner IT tests are flaky due to "io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED"

[ https://issues.apache.org/jira/browse/BEAM-9834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chamikara Madhusanka Jayalath reassigned BEAM-9834: --- Assignee: Allen Pradeep Xavier > Spanner IT tests are flaky

[jira] [Commented] (BEAM-9832) KeyError: 'No such coder: ' in fn_runner_test

[ https://issues.apache.org/jira/browse/BEAM-9832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094033#comment-17094033 ] Chamikara Madhusanka Jayalath commented on BEAM-9832: - Should we consider a rollback

[jira] [Commented] (BEAM-9811) beam_Release_NightlySnapshot failing due to "Failed to publish publication 'mavenJava'"

[ https://issues.apache.org/jira/browse/BEAM-9811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090830#comment-17090830 ] Chamikara Madhusanka Jayalath commented on BEAM-9811: - Thanks Tomo.   Ismael, seems

[jira] [Created] (BEAM-9811) beam_Release_NightlySnapshot failing due to "Failed to publish publication 'mavenJava'"

Chamikara Madhusanka Jayalath created BEAM-9811: --- Summary: beam_Release_NightlySnapshot failing due to "Failed to publish publication 'mavenJava'" Key: BEAM-9811 URL:

[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=17090856#comment-17090856 ] Chamikara Madhusanka Jayalath commented on BEAM-8121: - Alexey and TJ, I think we might

[jira] [Commented] (BEAM-9811) beam_Release_NightlySnapshot failing due to "Failed to publish publication 'mavenJava'"

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

[jira] [Assigned] (BEAM-9811) beam_Release_NightlySnapshot failing due to "Failed to publish publication 'mavenJava'"

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

[jira] [Created] (BEAM-9807) PostRelease_NightlySnapshot failing due to missing "region" flag

Chamikara Madhusanka Jayalath created BEAM-9807: --- Summary: PostRelease_NightlySnapshot failing due to missing "region" flag Key: BEAM-9807 URL: https://issues.apache.org/jira/browse/BEAM-9807

[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] [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] [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] [Resolved] (BEAM-9779) HL7v2IOWriteIT is flaky

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

[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

[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-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] [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-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] [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] [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] [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] [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: 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: Fix Version/s: 2.22.0 > Staging Dataflow artifacts from environment

[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] [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] [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: Priority: P0 (was: P2) > 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] [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] [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-9484) apache_beam.io.gcp.bigquery_write_it_test.BigQueryWriteIntegrationTests is flaky in DirectRunner Postcommits

[ https://issues.apache.org/jira/browse/BEAM-9484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061263#comment-17061263 ] Chamikara Madhusanka Jayalath commented on BEAM-9484: - Haven't been looking into this

[jira] [Assigned] (BEAM-9484) apache_beam.io.gcp.bigquery_write_it_test.BigQueryWriteIntegrationTests is flaky in DirectRunner Postcommits

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

[jira] [Commented] (BEAM-5422) Update BigQueryIO DynamicDestinations documentation to clarify usage of getDestination() and getTable()

[ https://issues.apache.org/jira/browse/BEAM-5422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065111#comment-17065111 ] Chamikara Madhusanka Jayalath commented on BEAM-5422: - Udi, will you be able to look

[jira] [Commented] (BEAM-5422) Update BigQueryIO DynamicDestinations documentation to clarify usage of getDestination() and getTable()

[ https://issues.apache.org/jira/browse/BEAM-5422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065185#comment-17065185 ] Chamikara Madhusanka Jayalath commented on BEAM-5422: - Ok. I don't remember what else

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

Chamikara Madhusanka Jayalath created BEAM-9482: --- Summary: beam_PerformanceTests_Kafka_IO failing due to " provided port is already allocated" Key: BEAM-9482 URL:

[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: Michał Walenia > beam_PerformanceTests_Kafka_IO

[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=17056313#comment-17056313 ] Chamikara Madhusanka Jayalath commented on BEAM-9482: - cc: [~lgajowy] >

[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=17056310#comment-17056310 ] Chamikara Madhusanka Jayalath commented on BEAM-9482: - (since seems like you updated

[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=17056309#comment-17056309 ] Chamikara Madhusanka Jayalath commented on BEAM-9482: - Seems like this test has been

[jira] [Commented] (BEAM-8732) Add support for additional structured types to Schemas/RowCoders

[ https://issues.apache.org/jira/browse/BEAM-8732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056414#comment-17056414 ] Chamikara Madhusanka Jayalath commented on BEAM-8732: - [~chadrik] and [~bhulette] are

[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-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-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-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-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-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-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] [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] [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: 2.22.0 > 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=17111376#comment-17111376 ] Chamikara Madhusanka Jayalath commented on BEAM-8019: - Temporarily making this a

[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] [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=17112649#comment-17112649 ] Chamikara Madhusanka Jayalath commented on BEAM-9383: - Note that I'm running from Beam

[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-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] [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] [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] [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] [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-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

<    1   2   3   >