Skip to content

Commit 604430c

Browse files
JNSimbaclaude
andcommitted
[Feature] disable gz compression for json format IT cases
Doris 2.1 does not support json compression, so explicitly set compress_type to empty for json format test cases. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
1 parent 31cdf59 commit 604430c

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

flink-doris-connector/flink-doris-connector-it/src/test/java/org/apache/doris/flink/sink/DorisSinkITCase.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -139,6 +139,7 @@ public void testSinkJsonFormat() throws Exception {
139139
Properties properties = new Properties();
140140
properties.setProperty("read_json_by_line", "true");
141141
properties.setProperty("format", "json");
142+
properties.setProperty("compress_type", "");
142143

143144
// mock data
144145
Map<String, Object> row1 = new HashMap<>();
@@ -225,6 +226,7 @@ public void testTableSinkJsonFormat() throws Exception {
225226
+ " 'sink.ignore.update-before' = 'true',"
226227
+ " 'sink.properties.format' = 'json',"
227228
+ " 'sink.properties.read_json_by_line' = 'true',"
229+
+ " 'sink.properties.compress_type' = '',"
228230
+ " 'sink.label-prefix' = 'doris_sink"
229231
+ UUID.randomUUID()
230232
+ "'"
@@ -874,6 +876,7 @@ public void testSinkUnicodeColumn() throws Exception {
874876
Properties properties = new Properties();
875877
properties.setProperty("read_json_by_line", "true");
876878
properties.setProperty("format", "json");
879+
properties.setProperty("compress_type", "");
877880

878881
// mock data
879882
Map<String, Object> row1 = new HashMap<>();

0 commit comments

Comments
 (0)