This is an automated email from the ASF dual-hosted git repository.
gian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new a21bf3e2f22 Fix flipped logic in KinesisFaultToleranceTest. (#19153)
a21bf3e2f22 is described below
commit a21bf3e2f22f6575d2b1826ec752f63880cd1b82
Author: Gian Merlino <[email protected]>
AuthorDate: Sun Mar 15 12:33:41 2026 -0700
Fix flipped logic in KinesisFaultToleranceTest. (#19153)
The "publishToSingleShard" boolean was being used backwards: when
true we would publish to all shards, when false we'd publish only
to shard "0". Fixing this will possibly help with flakiness for this
test.
---
.../druid/testing/embedded/kinesis/KinesisFaultToleranceTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/kinesis/KinesisFaultToleranceTest.java
b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/kinesis/KinesisFaultToleranceTest.java
index 645af768294..4725db58890 100644
---
a/embedded-tests/src/test/java/org/apache/druid/testing/embedded/kinesis/KinesisFaultToleranceTest.java
+++
b/embedded-tests/src/test/java/org/apache/druid/testing/embedded/kinesis/KinesisFaultToleranceTest.java
@@ -38,9 +38,9 @@ public class KinesisFaultToleranceTest extends
StreamIndexFaultToleranceTest
public void publishRecordsToTopicWithoutTransaction(String topic,
List<byte[]> records)
{
if (publishToSingleShard.get()) {
- super.publishRecordsToTopicWithoutTransaction(topic, records);
- } else {
super.publishRecordsToTopicPartition(topic, "O", records);
+ } else {
+ super.publishRecordsToTopicWithoutTransaction(topic, records);
}
}
};
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
