Re: 在进行table转streaming后报一个异常

2021-11-17 文章 Caizhi Weng
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 文章 陈卓宇
场景:将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: