[
https://issues.apache.org/jira/browse/BEAM-8372?focusedWorklogId=334612&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-334612
]
ASF GitHub Bot logged work on BEAM-8372:
----------------------------------------
Author: ASF GitHub Bot
Created on: 27/Oct/19 06:31
Start Date: 27/Oct/19 06:31
Worklog Time Spent: 10m
Work Description: robertwb commented on issue #9844: [BEAM-8372] Support
both flink_master and flink_master_url parameter
URL: https://github.com/apache/beam/pull/9844#issuecomment-546666058
I'm not sure what you mean by "a job run by Flink CLI." What does that mean
for a Python job? (I was trying to read the docs and code for [auto] but
wasn't able to figure it out.)
As for re-using flink master for the REST client, this is to have the same
behavior as when using the automatically started job server (e.g. for py <
3.6).
+1 to bringing this to the list. It's be good to just enumerate all the
modes we have and how they should work.
On Sat, Oct 26, 2019, 3:04 PM Thomas Weise <[email protected]> wrote:
> [auto] is the correct default value, it will result in local execution
> except when a job is run by Flink CLI or REST API. The use case here is a
> Flink REST client. In that context there is no Flink config, the REST API
> is fully described here:
>
https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/rest_api.html
>
> I don't see why flink_master has to serve as endpoint URL necessarily.
> Why can there not be a separate property for just for the REST client?
>
> It would be good to separate the more general discussion from this PR and
> surface it on the mailing list. That new job submission mode and related
> changes need to become more visible to others interested in Flink.
>
> —
> You are receiving this because your review was requested.
> Reply to this email directly, view it on GitHub
>
<https://github.com/apache/beam/pull/9844?email_source=notifications&email_token=AADWVAIE6CF4D7WB2IKQFZTQQS5HXA5CNFSM4JC4BD4KYY3PNVWWK3TUL52HS4DFVREXG43VMVBW63LNMVXHJKTDN5WW2ZLOORPWSZGOECKR2FQ#issuecomment-546643222>,
> or unsubscribe
>
<https://github.com/notifications/unsubscribe-auth/AADWVAOZHFZEVGELH3R43ODQQS5HXANCNFSM4JC4BD4A>
> .
>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 334612)
Time Spent: 8h 10m (was: 8h)
> Allow submission of Flink UberJar directly to flink cluster.
> ------------------------------------------------------------
>
> Key: BEAM-8372
> URL: https://issues.apache.org/jira/browse/BEAM-8372
> Project: Beam
> Issue Type: New Feature
> Components: sdk-py-core
> Reporter: Robert Bradshaw
> Assignee: Robert Bradshaw
> Priority: Major
> Time Spent: 8h 10m
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
