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

[Caizhi Weng]

Hi！

这种文件用于在 task 之间交换数据。我对 windows
的行为不太了解，但看起来是这个临时文件被清理了。是否有设置什么自动清理策略？另外这样的错误如果只是偶发，Flink 的 failover
机制会让作业从 checkpoint 重新运行，不必担心作业的可用性和正确性。

陈卓宇 <2572805...@qq.com.invalid> 于2021年11月17日周三 下午7:44写道：

> 场景:将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:
> C:\Users\monster\AppData\Local\Temp\flink-netty-shuffle-76964c7f-ffc6-490f-82bc-a3091412955b\0be871a1d3b522377ffd8f565bb3b81f.channel
> java.nio.file.NoSuchFileException:
> C:\Users\monster\AppData\Local\Temp\flink-netty-shuffle-76964c7f-ffc6-490f-82bc-a3091412955b\0be871a1d3b522377ffd8f565bb3b81f.channel
> &nbsp;&nbsp; &nbsp;at
> sun.nio.fs.WindowsException.translateToIOException(WindowsException.java:79)
> &nbsp;&nbsp; &nbsp;at
> sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:97)
> &nbsp;&nbsp; &nbsp;at
> sun.nio.fs.WindowsException.rethrowAsIOException(WindowsException.java:102)
> &nbsp;&nbsp; &nbsp;at
> sun.nio.fs.WindowsFileSystemProvider.implDelete(WindowsFileSystemProvider.java:269)
> &nbsp;&nbsp; &nbsp;at
> sun.nio.fs.AbstractFileSystemProvider.delete(AbstractFileSystemProvider.java:103)
> &nbsp;&nbsp; &nbsp;at java.nio.file.Files.delete(Files.java:1126)
> &nbsp;&nbsp; &nbsp;at org.apache.flink.runtime.io
> .network.partition.FileChannelBoundedData.close(FileChannelBoundedData.java:97)
> &nbsp;&nbsp; &nbsp;at org.apache.flink.runtime.io
> .network.partition.BoundedBlockingSubpartition.checkReaderReferencesAndDispose(BoundedBlockingSubpartition.java:253)
> &nbsp;&nbsp; &nbsp;at org.apache.flink.runtime.io
> .network.partition.BoundedBlockingSubpartition.release(BoundedBlockingSubpartition.java:205)
> &nbsp;&nbsp; &nbsp;at org.apache.flink.runtime.io
> .network.partition.BufferWritingResultPartition.releaseInternal(BufferWritingResultPartition.java:229)
> &nbsp;&nbsp; &nbsp;at org.apache.flink.runtime.io
> .network.partition.ResultPartition.release(ResultPartition.java:246)
> &nbsp;&nbsp; &nbsp;at org.apache.flink.runtime.io
> .network.partition.ResultPartitionManager.releasePartition(ResultPartitionManager.java:86)
> &nbsp;&nbsp; &nbsp;at org.apache.flink.runtime.io
> .network.NettyShuffleEnvironment.lambda$releasePartitionsLocally$0(NettyShuffleEnvironment.java:181)
> &nbsp;&nbsp; &nbsp;at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> &nbsp;&nbsp; &nbsp;at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> &nbsp;&nbsp; &nbsp;at java.lang.Thread.run(Thread.java:748)
>
>
> 陈
>
>
> &nbsp;