You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Valentyn Tymofieiev (Jira)" <ji...@apache.org> on 2021/09/03 22:49:00 UTC
[jira] [Created] (BEAM-12842)
StreamingDataflowWorkerTest.testHotKeyLogging tests are flaky
Valentyn Tymofieiev created BEAM-12842:
------------------------------------------
Summary: StreamingDataflowWorkerTest.testHotKeyLogging tests are flaky
Key: BEAM-12842
URL: https://issues.apache.org/jira/browse/BEAM-12842
Project: Beam
Issue Type: New Feature
Components: runner-dataflow
Reporter: Valentyn Tymofieiev
Assignee: Sam Rohde
Hi Sam, would you be able to please help take a look at these test failures:
https://ci-beam.apache.org/job/beam_PreCommit_Java_Cron/4455/testReport/junit/org.apache.beam.runners.dataflow.worker/StreamingDataflowWorkerTest/testHotKeyLogging_1___streamingEngine_true___2/
{noformat}
org.apache.beam.runners.dataflow.worker.StreamingDataflowWorkerTest.testHotKeyLogging[1: [streamingEngine=true]]
Failing for the past 1 build (Since #4455 )
Took 15 sec.
Error Message
java.lang.AssertionError: Should have received 2000 more commits beyond 0 commits already seen, but after 10s have only seen {0=key: "key"
work_token: 0
output_messages {
bundles {
key: "key"
messages {
timestamp: 0
data: "data0"
metadata: "\017\000\000\000\001\200\000\000\000\000\000\b\272\350\a"
}
messages_ids: ""
}
destination_stream_id: "out"
}
sharding_key: 12345
cache_token: 3
, 1=key: "key"
work_token: 1
output_messages {
bundles {
key: "key"
messages {
timestamp: 0
data: "data1"
metadata: "\017\000\000\000\001\200\000\000\000\000\000\b\272\350\a"
}
messages_ids: ""
}
destination_stream_id: "out"
}
sharding_key: 12345
cache_token: 3
, 2=key: "key"
work_token: 2
output_messages {
bundles {
key: "key"
messages {
timestamp: 0
data: "data2"
metadata: "\017\000\000\000\001\200\000\000\000\000\000\b\272\350\a"
}
messages_ids: ""
}
destination_stream_id: "out"
}
...
{noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)