[
https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872286#comment-16872286
]
Nico Kruber commented on FLINK-12909:
-------------------------------------
Thanks [~zjwang] for clarification - I also was not aware of the existing PR
which I now linked to this ticket ([~xymaqingxiang] it seems that simply
changing the title is not enough).
I think, with the past two messages, I seem to be getting the reason for this
change: if you have multiple {{tempDirs}} / {{io.tmp.dirs}} set up, if there is
a failure while creating a spilling channel on one of them (due to disk
failure), we could still continue with some other directory. With only one
temporary directory, the change doesn't provide too much.
I'll leave some comments on the PR as well.
> add try catch when find a unique file name for the spilling channel
> -------------------------------------------------------------------
>
> Key: FLINK-12909
> URL: https://issues.apache.org/jira/browse/FLINK-12909
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Network
> Reporter: xymaqingxiang
> Priority: Major
> Labels: pull-request-available
>
> h2. What is the purpose of the change
> Catch exceptions thrown due to disk loss, try to find a unique file name for
> the spilling channel again.
> Modify the createSpillingChannel() method of the
> org.apache.flink.runtime.io.network.api.serialization.SpillingAdaptiveSpanningRecordDeserializer
> class to solve this problem.
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
