flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From XW Marvin <marvin....@gmail.com>
Subject flink reduce becoming increasingly over time
Date Sun, 26 Apr 2020 12:42:31 GMT
Hi All

This My Coding:

statDataStream
  .map(new InnerStatMap(logType))
    .uid("InnerStatMap").name("InnerStatMap")
  .keyBy(new InnerKeySelector)
  .timeWindow(Time.seconds(statTimeWindow))
  .reduce(new InnerStatReduce)
    .uid("InnerReduce").name("InnerReduce")
  .addSink(innerStatProducer)
    .uid("InnerSink").name("InnerSink")
  .setParallelism(sinkParallelism)


I find checkpoint state is becoming increasingly over time

best wishes

Mime
View raw message