You are viewing a plain text version of this content. The canonical link for it is here.
Posted to github@beam.apache.org by GitBox <gi...@apache.org> on 2022/11/17 15:25:02 UTC
[GitHub] [beam] damccorm opened a new pull request, #24228: WIP: Attempt to fix flink XVR tests
damccorm opened a new pull request, #24228:
URL: https://github.com/apache/beam/pull/24228
**Please** add a meaningful description for your change here
------------------------
Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:
- [ ] [**Choose reviewer(s)**](https://beam.apache.org/contribute/#make-your-change) and mention them in a comment (`R: @username`).
- [ ] Mention the appropriate issue in your description (for example: `addresses #123`), if applicable. This will automatically add a link to the pull request in the issue. If you would like the issue to automatically close on merging the pull request, comment `fixes #<ISSUE NUMBER>` instead.
- [ ] Update `CHANGES.md` with noteworthy changes.
- [ ] If this contribution is large, please file an Apache [Individual Contributor License Agreement](https://www.apache.org/licenses/icla.pdf).
See the [Contributor Guide](https://beam.apache.org/contribute) for more tips on [how to make review process smoother](https://beam.apache.org/contribute/get-started-contributing/#make-the-reviewers-job-easier).
To check the build health, please visit [https://github.com/apache/beam/blob/master/.test-infra/BUILD_STATUS.md](https://github.com/apache/beam/blob/master/.test-infra/BUILD_STATUS.md)
GitHub Actions Tests Status (on master branch)
------------------------------------------------------------------------------------------------
[](https://github.com/apache/beam/actions?query=workflow%3A%22Build+python+source+distribution+and+wheels%22+branch%3Amaster+event%3Aschedule)
[](https://github.com/apache/beam/actions?query=workflow%3A%22Python+Tests%22+branch%3Amaster+event%3Aschedule)
[](https://github.com/apache/beam/actions?query=workflow%3A%22Java+Tests%22+branch%3Amaster+event%3Aschedule)
[](https://github.com/apache/beam/actions?query=workflow%3A%22Go+tests%22+branch%3Amaster+event%3Aschedule)
See [CI.md](https://github.com/apache/beam/blob/master/CI.md) for more information about GitHub Actions CI.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1318886317
Run Seed Job
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319034458
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319904292
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1320215352
R: @Abacn
I think this should fix flink postcommits on Go across the board. I'll add a follow up PR to reenable Go tests and remove some of the changes from https://github.com/apache/beam/pull/24159/files once this in in (anything else I'm missing?)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1318897598
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319322468
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319476173
Run Seed Job
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319109714
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319222297
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319386734
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319189879
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1318838600
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1320102163
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm merged pull request #24228: Fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm merged PR #24228:
URL: https://github.com/apache/beam/pull/24228
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] codecov[bot] commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
codecov[bot] commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319256856
# [Codecov](https://codecov.io/gh/apache/beam/pull/24228?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) Report
> Merging [#24228](https://codecov.io/gh/apache/beam/pull/24228?src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) (ba6c872) into [master](https://codecov.io/gh/apache/beam/commit/755b9c9d3e89061ec2076df13f23d671cf53a32a?el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) (755b9c9) will **decrease** coverage by `0.00%`.
> The diff coverage is `n/a`.
```diff
@@ Coverage Diff @@
## master #24228 +/- ##
==========================================
- Coverage 73.45% 73.45% -0.01%
==========================================
Files 714 714
Lines 96496 96497 +1
==========================================
- Hits 70885 70882 -3
- Misses 24288 24292 +4
Partials 1323 1323
```
| Flag | Coverage Δ | |
|---|---|---|
| python | `83.16% <ø> (-0.01%)` | :arrow_down: |
Flags with carried forward coverage won't be shown. [Click here](https://docs.codecov.io/docs/carryforward-flags?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#carryforward-flags-in-the-pull-request-comment) to find out more.
| [Impacted Files](https://codecov.io/gh/apache/beam/pull/24228?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) | Coverage Δ | |
|---|---|---|
| [sdks/python/apache\_beam/transforms/core.py](https://codecov.io/gh/apache/beam/pull/24228/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-c2Rrcy9weXRob24vYXBhY2hlX2JlYW0vdHJhbnNmb3Jtcy9jb3JlLnB5) | `92.54% <0.00%> (-0.37%)` | :arrow_down: |
| [...hon/apache\_beam/runners/worker/bundle\_processor.py](https://codecov.io/gh/apache/beam/pull/24228/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-c2Rrcy9weXRob24vYXBhY2hlX2JlYW0vcnVubmVycy93b3JrZXIvYnVuZGxlX3Byb2Nlc3Nvci5weQ==) | `93.67% <0.00%> (+0.12%)` | :arrow_up: |
:mega: We’re building smart automated test selection to slash your CI/CD build times. [Learn more](https://about.codecov.io/iterative-testing/?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319897078
Run Seed Job
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1318800538
Run Seed Job
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1318819018
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319100701
Run Seed Job
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319272876
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319999091
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] github-actions[bot] commented on pull request #24228: Fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
github-actions[bot] commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1320216790
Stopping reviewer notifications for this pull request: review requested by someone other than the bot, ceding control
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319024803
Run Seed Job
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1318860383
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319094534
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319480258
Run XVR_Flink PostCommit
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] damccorm commented on pull request #24228: WIP: Attempt to fix flink XVR tests
Posted by GitBox <gi...@apache.org>.
damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319995187
(this version worked, though a different test failed for seemingly unrelated reasons)
```
FAIL: TestKafkaIO_BasicReadWrite (0.01s)
08:02:41 panic: tried cross-language for beam:transform:org.apache.beam:kafka_write:v1 against localhost:44319 and failed
08:02:41 expanding external transform
08:02:41 expanding transform with ExpansionRequest: components:{pcollections:{key:"n4" value:{unique_name:"n4" coder_id:"c1@ErKwBRUxvv" is_bounded:BOUNDED windowing_strategy_id:"w0@ErKwBRUxvv"}} windowing_strategies:{key:"w0@ErKwBRUxvv" value:{window_fn:{urn:"beam:window_fn:global_windows:v1"} merge_status:NON_MERGING window_coder_id:"c2@ErKwBRUxvv" trigger:{default:{}} accumulation_mode:DISCARDING output_time:END_OF_WINDOW closing_behavior:EMIT_IF_NONEMPTY on_time_behavior:FIRE_IF_NONEMPTY environment_id:"go"}} coders:{key:"c0@ErKwBRUxvv" value:{spec:{urn:"beam:coder:bytes:v1"}}} coders:{key:"c1@ErKwBRUxvv" value:{spec:{urn:"beam:coder:kv:v1"} component_coder_ids:"c0@ErKwBRUxvv" component_coder_ids:"c0@ErKwBRUxvv"}} coders:{key:"c2@ErKwBRUxvv" value:{spec:{urn:"beam:coder:global_window:v1"}}}} transform:{unique_name:"External" spec:{urn:"beam:transform:org.apache.beam:kafka_write:v1" payload:"\n}\n\x1c\n\x0eProducerConfig\x1a\n*\x08\n\x02\x10\x07\x12\x02
\x10\x07\n\x0b\n\x05Topic\x1a\x02\x10\x07\n\x13\n\rKeySerializer\x1a\x02\x10\x07\n\x15\n\x0fValueSerializer\x1a\x02\x10\x07\x12$d97fbd8d-dde2-46d8-babd-f5372b6ab5e6\x12\xda\x01\x04\x00\x00\x00\x00\x01\x11bootstrap.servers\x0flocalhost:37919=xlang_kafkaio_basic_test_364cd506-46f5-49dc-aeb4-4f84e1ea3e739org.apache.kafka.common.serialization.ByteArraySerializer9org.apache.kafka.common.serialization.ByteArraySerializer"} inputs:{key:"i0" value:"n4"} environment_id:"go"} namespace:"ErKwBRUxvv"
08:02:41 expansion failed
08:02:41 caused by:
08:02:41 rpc error: code = Unavailable desc = connection error: desc = "transport: Error while dialing dial tcp 127.0.0.1:44319: connect: connection refused" [recovered]
08:02:41 panic: tried cross-language for beam:transform:org.apache.beam:kafka_write:v1 against localhost:44319 and failed
08:02:41 expanding external transform
08:02:41 expanding transform with ExpansionRequest: components:{pcollections:{key:"n4" value:{unique_name:"n4" coder_id:"c1@ErKwBRUxvv" is_bounded:BOUNDED windowing_strategy_id:"w0@ErKwBRUxvv"}} windowing_strategies:{key:"w0@ErKwBRUxvv" value:{window_fn:{urn:"beam:window_fn:global_windows:v1"} merge_status:NON_MERGING window_coder_id:"c2@ErKwBRUxvv" trigger:{default:{}} accumulation_mode:DISCARDING output_time:END_OF_WINDOW closing_behavior:EMIT_IF_NONEMPTY on_time_behavior:FIRE_IF_NONEMPTY environment_id:"go"}} coders:{key:"c0@ErKwBRUxvv" value:{spec:{urn:"beam:coder:bytes:v1"}}} coders:{key:"c1@ErKwBRUxvv" value:{spec:{urn:"beam:coder:kv:v1"} component_coder_ids:"c0@ErKwBRUxvv" component_coder_ids:"c0@ErKwBRUxvv"}} coders:{key:"c2@ErKwBRUxvv" value:{spec:{urn:"beam:coder:global_window:v1"}}}} transform:{unique_name:"External" spec:{urn:"beam:transform:org.apache.beam:kafka_write:v1" payload:"\n}\n\x1c\n\x0eProducerConfig\x1a\n*\x08\n\x02\x10\x07\x12\x02
\x10\x07\n\x0b\n\x05Topic\x1a\x02\x10\x07\n\x13\n\rKeySerializer\x1a\x02\x10\x07\n\x15\n\x0fValueSerializer\x1a\x02\x10\x07\x12$d97fbd8d-dde2-46d8-babd-f5372b6ab5e6\x12\xda\x01\x04\x00\x00\x00\x00\x01\x11bootstrap.servers\x0flocalhost:37919=xlang_kafkaio_basic_test_364cd506-46f5-49dc-aeb4-4f84e1ea3e739org.apache.kafka.common.serialization.ByteArraySerializer9org.apache.kafka.common.serialization.ByteArraySerializer"} inputs:{key:"i0" value:"n4"} environment_id:"go"} namespace:"ErKwBRUxvv"
08:02:41 expansion failed
08:02:41 caused by:
08:02:41 rpc error: code = Unavailable desc = connection error: desc = "transport: Error while dialing dial tcp 127.0.0.1:44319: connect: connection refused"
08:02:41
08:02:41 goroutine 11 [running]:
08:02:41 testing.tRunner.func1.2({0xda55a0, 0xc00069ca40})
08:02:41 /home/jenkins/sdk/go1.19.3/src/testing/testing.go:1396 +0x24e
08:02:41 testing.tRunner.func1()
08:02:41 /home/jenkins/sdk/go1.19.3/src/testing/testing.go:1399 +0x39f
08:02:41 panic({0xda55a0, 0xc00069ca40})
08:02:41 /home/jenkins/sdk/go1.19.3/src/runtime/panic.go:884 +0x212
08:02:41 github.com/apache/beam/sdks/v2/go/pkg/beam.CrossLanguage({0xc000489680?, 0xc0004b9c70?}, {0xee06b4, 0x2d}, {0xc00013c6e0?, 0xcfaf20?, 0xc0001b54c0?}, {0xc00048b310, 0xf}, 0xc000169c60, ...)
08:02:41 /home/jenkins/jenkins-slave/workspace/beam_PostCommit_XVR_Flink_PR/src/sdks/go/pkg/beam/xlang.go:162 +0x136
08:02:41 github.com/apache/beam/sdks/v2/go/pkg/beam/io/xlang/kafkaio.Write({0xc000489420?, 0xc0004b9c70?}, {0xc00048b310, 0xf}, {0xc00048b2d0, 0xf}, {0xc0004b6e80, 0x3d}, {0xc000169e60?}, {0x0, ...})
08:02:41 /home/jenkins/jenkins-slave/workspace/beam_PostCommit_XVR_Flink_PR/src/sdks/go/pkg/beam/io/xlang/kafkaio/kafka.go:278 +0x4cb
08:02:41 github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/kafka.writeInts({0xc000489400?, 0xc0004b9c70?}, {0xc00048b310, 0xf}, {0xc00048b2d0, 0xf}, {0xc0004b6e80, 0x3d}, {0xc0000f8000, 0x3e8, ...})
08:02:41 /home/jenkins/jenkins-slave/workspace/beam_PostCommit_XVR_Flink_PR/src/sdks/go/test/integration/io/xlang/kafka/kafka.go:48 +0x24d
08:02:41 github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/kafka.WritePipeline({0xc00048b310, 0xf}, {0xc00048b2d0, 0xf}, {0xc0004b6e80, 0x3d}, {0xc0000f8000, 0x3e8, 0x3e8})
08:02:41 /home/jenkins/jenkins-slave/workspace/beam_PostCommit_XVR_Flink_PR/src/sdks/go/test/integration/io/xlang/kafka/kafka.go:70 +0x157
08:02:41 github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/kafka.TestKafkaIO_BasicReadWrite(0xc000491860)
08:02:41 /home/jenkins/jenkins-slave/workspace/beam_PostCommit_XVR_Flink_PR/src/sdks/go/test/integration/io/xlang/kafka/kafka_test.go:61 +0xed
08:02:41 testing.tRunner(0xc000491860, 0xf18ff0)
08:02:41 /home/jenkins/sdk/go1.19.3/src/testing/testing.go:1446 +0x10b
08:02:41 created by testing.(*T).Run
08:02:41 /home/jenkins/sdk/go1.19.3/src/testing/testing.go:1493 +0x35f
08:02:41 FAIL github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/kafka 6.051s
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org