[
https://issues.apache.org/jira/browse/BEAM-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16761774#comment-16761774
]
Maximilian Michels commented on BEAM-6608:
------------------------------------------
This does not affect execution through the {{bin/flink}} utility where one
provides a packaged jar, but native execution via Beam directly.
> Flink Runner prepares to-be-staged file too late
> -------------------------------------------------
>
> Key: BEAM-6608
> URL: https://issues.apache.org/jira/browse/BEAM-6608
> Project: Beam
> Issue Type: Bug
> Components: runner-flink
> Affects Versions: 2.10.0
> Reporter: Maximilian Michels
> Assignee: Maximilian Michels
> Priority: Major
> Fix For: 2.11.0
>
>
> Before execution, the Flink Runner prepares all necessary files, in order for
> them to be shipped to the remote cluster.
> Due to a recent regression via BEAM-2873, the preparation is performed after
> the execution environment has been initialized. This skips the preparation
> phase and results in invalid files being shipped.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
