801?focusedCommentId=16807691&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-16807691
>
> Best,
> Tao Yang
>
> 在 2019年4月5日，上午5:22，Yan Yan 写道：
>
> Hi,
>
> I am running issues when trying to move from HDFS to S3 using Flink 1.6.
>
> I am getting an exception from Hadoop code:
Hi,
I am running issues when trying to move from HDFS to S3 using Flink 1.6.
I am getting an exception from Hadoop code:
IOException("Resource " + sCopy +
" changed on src filesystem (expected " + resource.getTimestamp() +
", was " + sStat.getModificationTime());
Digging into this, I f
looping in Stephan and Stefan how
> have worked on this the most in the past. Maybe they have some valuable
> input.
>
> Best,
> Aljoscha
>
>
> On 4. Oct 2018, at 01:18, Yan Yan wrote:
>
> Hi,
>
> We recently bumped to Flink 1.4 from 1.3.2, and found out an issue on
Hi,
We recently bumped to Flink 1.4 from 1.3.2, and found out an issue on HDFS
configuration.
We are using *FlinkYarnSessionCli* to start the cluster and submit job.
In 1.3.2, we set below Flink properties when using checkpoints:
state.backend.fs.checkpointdir = hdfs://nameservice0/.../..
state.
