This is an automated email from the ASF dual-hosted git repository.
kgyrtkirk 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 d342a10300c Fix CompactionRunSimulatorTest after conflicting merged
patches (#18814)
d342a10300c is described below
commit d342a10300cdf26002f3a0ceb1944caa955a596a
Author: Kashif Faraz <[email protected]>
AuthorDate: Fri Dec 5 16:18:59 2025 +0530
Fix CompactionRunSimulatorTest after conflicting merged patches (#18814)
---
.../server/compaction/CompactionRunSimulatorTest.java | 16 +++++++++-------
1 file changed, 9 insertions(+), 7 deletions(-)
diff --git
a/server/src/test/java/org/apache/druid/server/compaction/CompactionRunSimulatorTest.java
b/server/src/test/java/org/apache/druid/server/compaction/CompactionRunSimulatorTest.java
index 34b61144e2b..7a68424db9f 100644
---
a/server/src/test/java/org/apache/druid/server/compaction/CompactionRunSimulatorTest.java
+++
b/server/src/test/java/org/apache/druid/server/compaction/CompactionRunSimulatorTest.java
@@ -177,15 +177,17 @@ public class CompactionRunSimulatorTest
List.of("dataSource", "interval", "numSegments", "bytes",
"reasonToSkip"),
skippedTable.getColumnNames()
);
+ final String rejectedMessage
+ = "Rejected by search policy: Datasource/Interval is not in the list
of 'eligibleCandidates'";
Assert.assertEquals(
List.of(
- List.of("wiki", Intervals.of("2013-01-02/P1D"), 10,
1_000_000_000L, 1, "Rejected by search policy"),
- List.of("wiki", Intervals.of("2013-01-03/P1D"), 10,
1_000_000_000L, 1, "Rejected by search policy"),
- List.of("wiki", Intervals.of("2013-01-07/P1D"), 10,
1_000_000_000L, 1, "Rejected by search policy"),
- List.of("wiki", Intervals.of("2013-01-05/P1D"), 10,
1_000_000_000L, 1, "Rejected by search policy"),
- List.of("wiki", Intervals.of("2013-01-06/P1D"), 10,
1_000_000_000L, 1, "Rejected by search policy"),
- List.of("wiki", Intervals.of("2013-01-01/P1D"), 10,
1_000_000_000L, 1, "Rejected by search policy"),
- List.of("wiki", Intervals.of("2013-01-09/P1D"), 10,
1_000_000_000L, 1, "Rejected by search policy"),
+ List.of("wiki", Intervals.of("2013-01-02/P1D"), 10,
1_000_000_000L, 1, rejectedMessage),
+ List.of("wiki", Intervals.of("2013-01-03/P1D"), 10,
1_000_000_000L, 1, rejectedMessage),
+ List.of("wiki", Intervals.of("2013-01-07/P1D"), 10,
1_000_000_000L, 1, rejectedMessage),
+ List.of("wiki", Intervals.of("2013-01-05/P1D"), 10,
1_000_000_000L, 1, rejectedMessage),
+ List.of("wiki", Intervals.of("2013-01-06/P1D"), 10,
1_000_000_000L, 1, rejectedMessage),
+ List.of("wiki", Intervals.of("2013-01-01/P1D"), 10,
1_000_000_000L, 1, rejectedMessage),
+ List.of("wiki", Intervals.of("2013-01-09/P1D"), 10,
1_000_000_000L, 1, rejectedMessage),
List.of("wiki", Intervals.of("2013-01-10/P1D"), 10,
1_000_000_000L, 1, "skip offset from latest[P1D]")
),
skippedTable.getRows()
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
