Hi!
这种文件用于在 task 之间交换数据。我对 windows
的行为不太了解,但看起来是这个临时文件被清理了。是否有设置什么自动清理策略?另外这样的错误如果只是偶发,Flink 的 failover
机制会让作业从 checkpoint 重新运行,不必担心作业的可用性和正确性。
陈卓宇 <2572805...@qq.com.invalid> 于2021年11月17日周三 下午7:44写道:
> 场景:将table表转为streaming流进行一个关联维表操作后发生异常
>
> 异常内容:
> 2021-11-17
>
场景:将table表转为streaming流进行一个关联维表操作后发生异常
异常内容:
2021-11-17
19:39:53.056|ERROR|org.apache.flink.runtime.io.network.partition.BufferWritingResultPartition|flink-taskexecutor-io-thread-4|releaseInternal|233|Error
during release of result subpartition: