ops / yoho-trace-analyzer · Commits

Go to a project

Authored by gemingdan
Commit 0cb39fc6db5376375835aa462df0bfc359e3cd32 1 parent aadff2ff

EventTime

Inline Side-by-side
Showing 1 changed file with 1 additions and 1 deletions
@@ -20,7 +20,7 @@ public class TraceFlinkExecutor { @@ -20,7 +20,7 @@ public class TraceFlinkExecutor {
20 20
21 public static void main(String[] args) throws Exception{ 21 public static void main(String[] args) throws Exception{
22 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); 22 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
23 - env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime); 23 + env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
24 24
25 FlinkKafkaConsumerBase<String> kafkaConsumer = KafkaUtils.finkKafkaConsumer(PropertiesFactory.kafka().getBrokers(), PropertiesFactory.kafka().getGroup(), PropertiesFactory.kafka().getTopic()); 25 FlinkKafkaConsumerBase<String> kafkaConsumer = KafkaUtils.finkKafkaConsumer(PropertiesFactory.kafka().getBrokers(), PropertiesFactory.kafka().getGroup(), PropertiesFactory.kafka().getTopic());
26 SingleOutputStreamOperator<Spans> clickStream = env.addSource(kafkaConsumer) 26 SingleOutputStreamOperator<Spans> clickStream = env.addSource(kafkaConsumer)