Provides client libraries for submitting and managing Apache Flink jobs.
Install & Compatibility
Where this runs
No compatibility data collected yet for this library.
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
org.apache.flink.client.program.ClusterClient
Create a Flink cluster client to submit jobs.
import org.apache.flink.client.program.ClusterClient;
import org.apache.flink.configuration.Configuration;
public class MyApp {
public static void main(String[] args) throws Exception {
Configuration config = new Configuration();
ClusterClient<?> client = ClusterClient.create(config);
// Submit a job
}
}
Upgrade
Version history
Breaking-change detection hasn't run for this library yet.
Audit
Security & dependencies
CVE tracking and dependency tree are planned for a later release.