You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 6 Current »

Status

Current stateImplemented

Discussion threadhttps://lists.apache.org/thread.html/0dbd0a4adf9ad00d6ad869dffc8820f6ce4c1969e1ea4aafb1dd0aa4@%3Cdev.flink.apache.org%3E

JIRA Unable to render Jira issues macro, execution error.

Released: -


In the early days of Flink, the Program interface was the only way to submit a job.
The user code should implement this interface and return the Plan of the job to Flink.

This way of submitting jobs is now outdated but the code paths to support this type
of job submission are still there, complicating the code of other components, such as
the ClusterClient.

Given that this interface is not used anymore (as discussed in [1]), this FLIP proposes the removal of
the interface and the related code.


Proposed changes


This change includes the following changes:

  1. removal of the

if (Program.class.isAssignableFrom(this.mainClass)) {

   ...

 } 

branches in the PackagedProgram  class

2. the program  and plan  fields in the same class

3. all the code in the project that is executed when the PackagedProgram.isUsingProgramEntryPoint() is true

4. the related documentation

[1] https://lists.apache.org/x/thread.html/7ffc9936a384b891dbcf0a481d26c6d13b2125607c200577780d1e18@%3Cdev.flink.apache.org%3E

  • No labels