Skip to content

Commit 3433689

Browse files
JNSimbaclaude
andcommitted
[Feature] fix DorisExecutionOptionsTest for default gz compression
Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
1 parent d88b74a commit 3433689

1 file changed

Lines changed: 4 additions & 1 deletion

File tree

flink-doris-connector/flink-doris-connector-base/src/test/java/org/apache/doris/flink/cfg/DorisExecutionOptionsTest.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,10 +36,13 @@ public void testBuild() {
3636
Properties expected = new Properties();
3737
expected.put("format", "json");
3838
expected.put("read_json_by_line", true);
39-
Assert.assertTrue(actual.size() == 2);
39+
expected.put("compress_type", "gz");
40+
Assert.assertTrue(actual.size() == 3);
4041
Assert.assertTrue(actual.get("format").equals(expected.get("format")));
4142
Assert.assertTrue(
4243
actual.get("read_json_by_line").equals(expected.get("read_json_by_line")));
44+
Assert.assertTrue(
45+
actual.get("compress_type").equals(expected.get("compress_type")));
4346
}
4447

4548
@Test

0 commit comments

Comments
 (0)