flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore
Date Thu, 06 Dec 2018 06:04:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-11048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711005#comment-16711005
] 

ASF GitHub Bot commented on FLINK-11048:
----------------------------------------

tweise opened a new pull request #7249: [FLINK-11048] Ability to programmatically execute
streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249
 
 
   ## What is the purpose of the change
   
   Adds the ability to programmatically execute a job with savepoint restore option.
   
   https://lists.apache.org/thread.html/6fff05d4a8444d1c6fa139d63605d51f610caff46605a4cdbb35cd50@%3Cdev.flink.apache.org%3E
   
   The number of parameters to *executeRemotely* is a bit higher than what we might have expected.
The change to ScalaShellRemoteStreamEnvironment needs a closer look. It needs to override
the jar file list, but do we really need the *ProgramInvocationException* there?
   
   ## Brief change log
     -  executeRemotely changed to static method that can be used with any StreamExecutionEnvironment
   
   ## Verifying this change
   
   No added test coverage.
   
   ## Does this pull request potentially affect one of the following parts:
   
     - Dependencies (does it add or upgrade a dependency): (yes / **no**)
     - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (**yes**
/ no)
     - The serializers: (yes / **no** / don't know)
     - The runtime per-record code paths (performance sensitive): (yes / **no** / don't know)
     - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing,
Yarn/Mesos, ZooKeeper: (**yes** / no / don't know)
     - The S3 file system connector: (yes / **no** / don't know)
   
   ## Documentation
   
     - Does this pull request introduce a new feature? (**yes** / no)
     - If yes, how is the feature documented? (not applicable / docs / JavaDocs / **not documented**)
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


> Ability to programmatically execute streaming pipeline with savepoint restore  
> -------------------------------------------------------------------------------
>
>                 Key: FLINK-11048
>                 URL: https://issues.apache.org/jira/browse/FLINK-11048
>             Project: Flink
>          Issue Type: Improvement
>          Components: DataStream API
>    Affects Versions: 1.7.0
>            Reporter: Thomas Weise
>            Assignee: Thomas Weise
>            Priority: Minor
>              Labels: pull-request-available
>
> RemoteStreamEnvironment.execute doesn't support restore from savepoint, though the underlying
ClusterClient does. Add an explicit "execute remotely" that can be used by downstream projects.
> [https://lists.apache.org/thread.html/6fff05d4a8444d1c6fa139d63605d51f610caff46605a4cdbb35cd50@%3Cdev.flink.apache.org%3E]
>  
>   



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message