[
https://issues.apache.org/jira/browse/BEAM-4615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16610895#comment-16610895
]
Maximilian Michels edited comment on BEAM-4615 at 9/11/18 4:29 PM:
-------------------------------------------------------------------
bq. A gradle wrapper that can execute the Flink job server driver so that it
can be easily run locally for testing/debugging.
The first part of this is done.
bq. A shadow ("uber") target that packages all portable Flink runner
dependencies into a runnable jar. This jar can then be submitted to Flink
clusters via `flink run`.
[~bsidhom] What exactly is the second task? Should this be a bundled pipeline
which uses a local JobServer which is spawned during job execution?
was (Author: mxm):
bq. A gradle wrapper that can execute the Flink job server driver so that it
can be easily run locally for testing/debugging.
The first part of this is done.
bq. A shadow ("uber") target that packages all portable Flink runner
dependencies into a runnable jar. This jar can then be submitted to Flink
clusters via `flink run`.
[~bsidhom] What exactly is the second task? Should this be a bundled pipeline
which uses a local JobServer?
> Flink job server driver wrapper
> -------------------------------
>
> Key: BEAM-4615
> URL: https://issues.apache.org/jira/browse/BEAM-4615
> Project: Beam
> Issue Type: New Feature
> Components: runner-flink
> Reporter: Ben Sidhom
> Assignee: Ben Sidhom
> Priority: Major
> Time Spent: 5h 50m
> Remaining Estimate: 0h
>
> This includes:
> * A gradle wrapper that can execute the Flink job server driver so that it
> can be easily run locally for testing/debugging.
> * A shadow ("uber") target that packages all portable Flink runner
> dependencies into a runnable jar. This jar can then be submitted to Flink
> clusters via `flink run`.
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
