[
https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16871199#comment-16871199
]
Nico Kruber commented on FLINK-12909:
-------------------------------------
[~xymaqingxiang] I'm not sure I understand the problem yet:
# What concrete problem are you facing and where?
# When is the disk lost?
** If you mean during the 10 attempts in {{createSpillingChannel()}}, then
there is very little time span to have a disk loss and immediately recover
during these attempts (we don't wait between attempts).
> 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
>
> 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)
