[
https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xymaqingxiang updated FLINK-12909:
----------------------------------
Description:
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.
was:
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.
> 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
> 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)
