我使用sql-client.sh 执行sql创建的任务，如何设置 ttl 的时长？
On 2022/04/11 11:14:36 yidan zhao wrote: > You can increase the state ttl to avoid this. > 这个已经明确了方法了，增加ttl的时长。 > > 段晓雄 <ma...@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 > > >
