Skip to content

F
flink_warehouse_rt
Commit 37058fe6 authored by 刘喆's avatar 刘喆
Browse files
Options

update PreciseExposureStreaming bug

parent 6e91cec6
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
ml_c_et_pe_preciseexposure_dimem_d_rt/src/main/java/com/gmei/streaming/PreciseExposureStreaming.java
View file @ 37058fe6
...@@ -119,7 +119,7 @@ public class PreciseExposureStreaming { ...@@ -119,7 +119,7 @@ public class PreciseExposureStreaming {
.addSource(myConsumer).uid("id_blmaidiandata_source").setParallelism(parallelism) .addSource(myConsumer).uid("id_blmaidiandata_source").setParallelism(parallelism)
.split(new BlMaiDianOutputSelector()); .split(new BlMaiDianOutputSelector());
OutputTag<BlPreciseExposureBean> outputTag = new OutputTag<BlPreciseExposureBean>("bl_late_data"); OutputTag<BlPreciseExposureBean> outputTag = new OutputTag<BlPreciseExposureBean>("bl_preciseexposure_late_data"){};
/* /*
BL层数据清洗、转换、去重 BL层数据清洗、转换、去重
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment