Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Failing Test]: Java IO Precommit failing due to KafkaIOTranslation being out of sync #30941

Closed
2 of 16 tasks
ahmedabu98 opened this issue Apr 12, 2024 · 2 comments
Closed
2 of 16 tasks

Comments

@ahmedabu98
Copy link
Contributor

What happened?

Error:

java.lang.AssertionError: Method getConsumerPollingTimeout will not be tracked when upgrading the 'KafkaIO.Read' transform. Please update 'KafkaIOTranslation.KafkaIOReadWithMetadataTranslator' to track the new method and update this test.
	at org.junit.Assert.fail(Assert.java:89)
	at org.junit.Assert.assertTrue(Assert.java:42)
	at org.apache.beam.sdk.io.kafka.upgrade.KafkaIOTranslationTest.testReadTransformRowIncludesAllFields(KafkaIOTranslationTest.java:170)

A new builder method was added for KafkaIO in #30877, which now needs to be added in KafkaIOTranslation.

Issue Failure

Failure: Test is continually failing

Issue Priority

Priority: 2 (backlog / disabled test but we think the product is healthy)

Issue Components

  • Component: Python SDK
  • Component: Java SDK
  • Component: Go SDK
  • Component: Typescript SDK
  • Component: IO connector
  • Component: Beam YAML
  • Component: Beam examples
  • Component: Beam playground
  • Component: Beam katas
  • Component: Website
  • Component: Spark Runner
  • Component: Flink Runner
  • Component: Samza Runner
  • Component: Twister2 Runner
  • Component: Hazelcast Jet Runner
  • Component: Google Cloud Dataflow Runner
@Abacn
Copy link
Contributor

Abacn commented Apr 15, 2024

This affects PreCommit so bump to P1

xianhualiu added a commit to xianhualiu/beam that referenced this issue Apr 16, 2024
xianhualiu added a commit to xianhualiu/beam that referenced this issue Apr 16, 2024
xianhualiu added a commit to xianhualiu/beam that referenced this issue Apr 16, 2024
xianhualiu added a commit to xianhualiu/beam that referenced this issue Apr 16, 2024
xianhualiu added a commit to xianhualiu/beam that referenced this issue Apr 16, 2024
damccorm pushed a commit that referenced this issue Apr 17, 2024
…30998)

* [#30941]fix upgrade test deu to  missed config ConsumerPollingTimeout in  KafkaIOTranslation

* [#30941]fix upgrade test due to  missed config ConsumerPollingTimeout in KafkaIOTranslation

* [#30941]fix upgrade test due to  missed config ConsumerPollingTimeout in KafkaIOTranslation

* [#30941]fix upgrade test due to  missed config ConsumerPollingTimeout in KafkaIOTranslation

* [#30941]fix upgrade test due to  missed config ConsumerPollingTimeout in KafkaIOTranslation

* fixed upgrade test and changed consumer timeout to long

* fixed spotless issues

* fixed test
@chamikaramj
Copy link
Contributor

Fixed by #30877.

@github-actions github-actions bot added this to the 2.57.0 Release milestone Apr 23, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging a pull request may close this issue.

3 participants