You can increase the state ttl to avoid this. 这个已经明确了方法了，增加ttl的时长。
段晓雄 <macd...@gmail.com> 于2022年4月11日周一 09:52写道： > > 各位老大， > > 现在是 Flink 1.14.4 集群，通过 pyflink执行 sql 做流处理， > > taskmanager日志大量 The state is cleared because of state ttl. This will result > in incorrect result. You can increase the state ttl to avoid this. 为什么出现？如何解决？ > > > 2022-04-09 17:08:54,672 INFO > org.apache.flink.streaming.runtime.operators.sink.AbstractStreamingCommitterHandler > [] - Committing the state for checkpoint 284 > 2022-04-09 17:08:54,672 INFO > org.apache.flink.streaming.runtime.operators.sink.AbstractStreamingCommitterHandler > [] - Committing the state for checkpoint 284 > 2022-04-09 17:08:54,852 INFO > org.apache.flink.table.runtime.operators.sink.SinkUpsertMaterializer [] - The > state is cleared because of state ttl. This will result in incorrect result. > You can increase the state ttl to avoid this. > 2022-04-09 17:08:54,852 INFO > org.apache.flink.table.runtime.operators.sink.SinkUpsertMaterializer [] - The > state is cleared because of state ttl. This will result in incorrect result. > You can increase the state ttl to avoid this. > 2022-04-09 17:08:54,852 INFO > org.apache.flink.table.runtime.operators.sink.SinkUpsertMaterializer [] - The > state is cleared because of state ttl. This will result in incorrect result. > You can increase the state ttl to avoid this. > 2022-04-09 17:08:54,922 INFO > org.apache.flink.streaming.runtime.operators.sink.AbstractStreamingCommitterHandler > [] - Committing the state for checkpoint 277 > 2022-04-09 17:08:54,922 INFO > org.apache.flink.streaming.runtime.operators.sink.AbstractStreamingCommitterHandler > [] - Committing the state for checkpoint 277 > 2022-04-09 17:08:54,952 INFO > org.apache.flink.table.runtime.operators.sink.SinkUpsertMaterializer [] - The > state is cleared because of state ttl. This will result in incorrect result. > You can increase the state ttl to avoid this. > 2022-04-09 17:08:54,952 INFO > org.apache.flink.table.runtime.operators.sink.SinkUpsertMaterializer [] - The > state is cleared because of state ttl. This will result in incorrect result. > You can increase the state ttl to avoid this. > 2022-04-09 17:08:54,952 INFO > org.apache.flink.table.runtime.operators.sink.SinkUpsertMaterializer [] - The > state is cleared because of state ttl. This will result in incorrect result. > You can increase the state ttl to avoid this. > 2022-04-09 17:08:54,952 INFO > org.apache.flink.table.runtime.operators.sink.SinkUpsertMaterializer [] - The > state is cleared because of state ttl. This will result in incorrect result. > You can increase the state ttl to avoid this. > 2022-04-09 17:08:54,952 INFO > org.apache.flink.table.runtime.operators.sink.SinkUpsertMaterializer [] - The > state is cleared because of state ttl. This will result in incorrect result. > You can increase the state ttl to avoid this. > 2022-04-09 17:08:54,952 INFO > org.apache.flink.table.runtime.operators.sink.SinkUpsertMaterializer [] - The > state is cleared because of state ttl. This will result in incorrect result. > You can increase the state ttl to avoid this. > 2022-04-09 17:08:55,052 INFO > org.apache.flink.table.runtime.operators.sink.SinkUpsertMaterializer [] - The > state is cleared because of state ttl. This will result in incorrect result. > You can increase the state ttl to avoid this. > 2022-04-09 17:08:55,052 INFO > org.apache.flink.table.runtime.operators.sink.SinkUpsertMaterializer [] - The > state is cleared because of state ttl. This will result in incorrect result. > You can increase the state ttl to avoid this. > 2022-04-09 17:08:55,152 INFO > org.apache.flink.table.runtime.operators.sink.SinkUpsertMaterializer [] - The > state is cleared because of state ttl. This will result in incorrect result. > You can increase the state ttl to avoid this. > 2022-04-09 17:08:55,330 INFO > org.apache.flink.streaming.runtime.operators.sink.AbstractStreamingCommitterHandler > [] - Committing the state for checkpoint 282 > 2022-04-09 17:08:55,330 INFO > org.apache.flink.streaming.runtime.operators.sink.AbstractStreamingCommitterHandler > [] - Committing the state for checkpoint 282 >
