diff options
| author | doufenghu <[email protected]> | 2024-05-13 17:40:20 +0800 |
|---|---|---|
| committer | doufenghu <[email protected]> | 2024-05-13 17:40:20 +0800 |
| commit | df696e2f65227b950fcde0a51b7ca0f717b2becd (patch) | |
| tree | 60632303c95e43001e9b3e9b4b14c59938bfc7ae /src/test | |
| parent | fc650bb9e525adc737058896f7c372597586d8f0 (diff) | |
[fix] 修复自定义kafka配置被默认配置覆盖的问题
Diffstat (limited to 'src/test')
| -rw-r--r-- | src/test/java/com/zdjizhi/ConfigTest.java | 6 | ||||
| -rw-r--r-- | src/test/java/com/zdjizhi/FastJsonTest.java | 2 |
2 files changed, 4 insertions, 4 deletions
diff --git a/src/test/java/com/zdjizhi/ConfigTest.java b/src/test/java/com/zdjizhi/ConfigTest.java index 7a2b5d3..53cc764 100644 --- a/src/test/java/com/zdjizhi/ConfigTest.java +++ b/src/test/java/com/zdjizhi/ConfigTest.java @@ -19,15 +19,15 @@ public class ConfigTest { final ParameterTool tool; try { - tool = ParameterTool.fromPropertiesFile("D:\\workerspace\\flink\\test.properties"); + tool = ParameterTool.fromPropertiesFile("/Users/darnell/IdeaProjects/app-protocol-stat-traffic-merge/properties/application.properties"); final Configuration config = tool.getConfiguration(); environment.getConfig().setGlobalJobParameters(config); final FusionConfiguration fusionConfiguration = new FusionConfiguration(config); System.out.println(config.get(SOURCE_KAFKA_TOPIC)); System.out.println(config.get(SINK_KAFKA_TOPIC)); - System.out.println(fusionConfiguration.getProperties(SOURCE_KAFKA_PROPERTIES_PREFIX)); - System.out.println(fusionConfiguration.getProperties(SINK_KAFKA_PROPERTIES_PREFIX)); + System.out.println("#####"+ fusionConfiguration.getProperties( SOURCE_KAFKA_PROPERTIES_PREFIX)); + System.out.println("#####"+ fusionConfiguration.getProperties(SINK_KAFKA_PROPERTIES_PREFIX)); final FlinkKafkaConsumer<String> kafkaConsumer = new FlinkKafkaConsumer<>( diff --git a/src/test/java/com/zdjizhi/FastJsonTest.java b/src/test/java/com/zdjizhi/FastJsonTest.java index 3a6df5c..bf04b83 100644 --- a/src/test/java/com/zdjizhi/FastJsonTest.java +++ b/src/test/java/com/zdjizhi/FastJsonTest.java @@ -77,7 +77,7 @@ public class FastJsonTest { } - @Test + @Test(expected=JSONException.class) public void errorJsonTest() { String message = "{\"fields\":{\"c2s_bytes\":2292,\"c2s_fragments\":0,\"c2s_pkts\":13,\"c2s_tcp_lost_bytes\":0,\"c2s_tcp_ooorder_pkts\":0,\"c2s_tcp_retransmitted_bytes\":0,\"c2s_tcp_retransmitted_pkts\":0,\"ytes\":2292,\"out_pkts\":13,\"s2c_bytes\":4695,\"s2c_fragments\":0,\"s2c_pkts\":12,\"s2c_tcp_lost_bytes\":0,\"s2c_tcp_ooorder_pkts\":0,\"s2c_tcp_retransmitted_bytes\":0,\"s2c_tcp_retransmitraffic_application_protocol_stat\",\"tags\":{\"app_full_path\":\"ssl.https.qq_web.wecom\",\"app_name\":\"app_metric\",\"data_center\":\"center-xxg-7400\",\"device_group\":\"group-xxg-7400\",dc-161\",\"protocol_label\":\"ETHERNET.IPv4.TCP\",\"table_name\":\"traffic_application_protocol_stat\",\"vsys_id\":\"1\"},\"timestamp\":1688708725000}"; JSONObject originalLog = JSON.parseObject(message); |