You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Robert Burke (Jira)" <ji...@apache.org> on 2022/02/08 23:30:00 UTC

[jira] [Updated] (BEAM-13857) DebeziumIO expansion address flag in Go SDK

     [ https://issues.apache.org/jira/browse/BEAM-13857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Robert Burke updated BEAM-13857:
--------------------------------
    Description: 
Currently a separate debezium io expansion address flag needs to be passed to the runner when running cross-language debezium IO pipelines from Go SDK. Find a way to do this in a better way so that we could have it started along with java io expansion service while spinning up the test without bulking :sdks:java:io:expansion-service.

In particular, needing to add a flag per expansion service jar to our integration tests will eventually become quite cluttered, so we may wish to settle on some kind of KV map flag approach instead to reduce copypasta code overhead.

  was:Currently a separate debezium io expansion address flag needs to be passed to the runner when running cross-language debezium IO pipelines from Go SDK. Find a way to do this in a better way so that we could have it started along with java io expansion service while spinning up the test without bulking :sdks:java:io:expansion-service.


> DebeziumIO expansion address flag in Go SDK
> -------------------------------------------
>
>                 Key: BEAM-13857
>                 URL: https://issues.apache.org/jira/browse/BEAM-13857
>             Project: Beam
>          Issue Type: Bug
>          Components: sdk-go
>            Reporter: Ritesh Ghorse
>            Priority: P2
>
> Currently a separate debezium io expansion address flag needs to be passed to the runner when running cross-language debezium IO pipelines from Go SDK. Find a way to do this in a better way so that we could have it started along with java io expansion service while spinning up the test without bulking :sdks:java:io:expansion-service.
> In particular, needing to add a flag per expansion service jar to our integration tests will eventually become quite cluttered, so we may wish to settle on some kind of KV map flag approach instead to reduce copypasta code overhead.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)