Path	Lines of Code
flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java	128
flink-clients/src/main/java/org/apache/flink/client/FlinkPipelineTranslationUtil.java	44
flink-clients/src/main/java/org/apache/flink/client/FlinkPipelineTranslator.java	12
flink-clients/src/main/java/org/apache/flink/client/PlanTranslator.java	61
flink-clients/src/main/java/org/apache/flink/client/StreamGraphTranslator.java	33
flink-clients/src/main/java/org/apache/flink/client/cli/AbstractCustomCommandLine.java	80
flink-clients/src/main/java/org/apache/flink/client/cli/ApplicationDeployer.java	10
flink-clients/src/main/java/org/apache/flink/client/cli/CancelOptions.java	23
flink-clients/src/main/java/org/apache/flink/client/cli/CliArgsException.java	10
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java	743
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java	370
flink-clients/src/main/java/org/apache/flink/client/cli/ClientOptions.java	20
flink-clients/src/main/java/org/apache/flink/client/cli/CommandLineOptions.java	12
flink-clients/src/main/java/org/apache/flink/client/cli/CustomCommandLine.java	18
flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java	22
flink-clients/src/main/java/org/apache/flink/client/cli/ExecutionConfigAccessor.java	52
flink-clients/src/main/java/org/apache/flink/client/cli/GenericCLI.java	99
flink-clients/src/main/java/org/apache/flink/client/cli/ListOptions.java	25
flink-clients/src/main/java/org/apache/flink/client/cli/ProgramOptions.java	127
flink-clients/src/main/java/org/apache/flink/client/cli/ProgramOptionsUtils.java	60
flink-clients/src/main/java/org/apache/flink/client/cli/SavepointOptions.java	29
flink-clients/src/main/java/org/apache/flink/client/cli/StopOptions.java	29
flink-clients/src/main/java/org/apache/flink/client/deployment/AbstractContainerizedClusterClientFactory.java	31
flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientFactory.java	12
flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientJobClientAdapter.java	102
flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientServiceLoader.java	5
flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterDeploymentException.java	14
flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterDescriptor.java	20
flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterRetrieveException.java	14
flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterSpecification.java	51
flink-clients/src/main/java/org/apache/flink/client/deployment/DefaultClusterClientServiceLoader.java	52
flink-clients/src/main/java/org/apache/flink/client/deployment/StandaloneClientFactory.java	31
flink-clients/src/main/java/org/apache/flink/client/deployment/StandaloneClusterDescriptor.java	55
flink-clients/src/main/java/org/apache/flink/client/deployment/StandaloneClusterId.java	8
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationClusterEntryPoint.java	63
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationConfiguration.java	52
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java	215
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherGatewayServiceFactory.java	58
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherLeaderProcessFactoryFactory.java	53
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationExecutionException.java	15
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationRunner.java	11
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ClassPathPackagedProgramRetriever.java	210
flink-clients/src/main/java/org/apache/flink/client/deployment/application/DetachedApplicationRunner.java	46
flink-clients/src/main/java/org/apache/flink/client/deployment/application/EmbeddedJobClient.java	98
flink-clients/src/main/java/org/apache/flink/client/deployment/application/JarManifestParser.java	78
flink-clients/src/main/java/org/apache/flink/client/deployment/application/JobStatusPollingUtils.java	62
flink-clients/src/main/java/org/apache/flink/client/deployment/application/WebSubmissionJobClient.java	46
flink-clients/src/main/java/org/apache/flink/client/deployment/application/cli/ApplicationClusterDeployer.java	32
flink-clients/src/main/java/org/apache/flink/client/deployment/application/executors/EmbeddedExecutor.java	93
flink-clients/src/main/java/org/apache/flink/client/deployment/application/executors/EmbeddedExecutorFactory.java	46
flink-clients/src/main/java/org/apache/flink/client/deployment/application/executors/EmbeddedExecutorServiceLoader.java	33
flink-clients/src/main/java/org/apache/flink/client/deployment/application/executors/EmbeddedJobClientCreator.java	8
flink-clients/src/main/java/org/apache/flink/client/deployment/application/executors/WebSubmissionExecutorFactory.java	37
flink-clients/src/main/java/org/apache/flink/client/deployment/application/executors/WebSubmissionExecutorServiceLoader.java	29
flink-clients/src/main/java/org/apache/flink/client/deployment/executors/AbstractJobClusterExecutor.java	39
flink-clients/src/main/java/org/apache/flink/client/deployment/executors/AbstractSessionClusterExecutor.java	39
flink-clients/src/main/java/org/apache/flink/client/deployment/executors/LocalExecutor.java	58
flink-clients/src/main/java/org/apache/flink/client/deployment/executors/LocalExecutorFactory.java	21
flink-clients/src/main/java/org/apache/flink/client/deployment/executors/PipelineExecutorUtils.java	27
flink-clients/src/main/java/org/apache/flink/client/deployment/executors/RemoteExecutor.java	12
flink-clients/src/main/java/org/apache/flink/client/deployment/executors/RemoteExecutorFactory.java	21
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java	38
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClientProvider.java	6
flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java	113
flink-clients/src/main/java/org/apache/flink/client/program/MiniClusterClient.java	133
flink-clients/src/main/java/org/apache/flink/client/program/OptimizerPlanEnvironment.java	30
flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java	390
flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgramRetriever.java	7
flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgramUtils.java	179
flink-clients/src/main/java/org/apache/flink/client/program/PerJobMiniClusterFactory.java	144
flink-clients/src/main/java/org/apache/flink/client/program/ProgramAbortException.java	4
flink-clients/src/main/java/org/apache/flink/client/program/ProgramInvocationException.java	20
flink-clients/src/main/java/org/apache/flink/client/program/ProgramMissingJobException.java	8
flink-clients/src/main/java/org/apache/flink/client/program/ProgramParametrizationException.java	8
flink-clients/src/main/java/org/apache/flink/client/program/StreamContextEnvironment.java	112
flink-clients/src/main/java/org/apache/flink/client/program/StreamPlanEnvironment.java	33
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java	575
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClientConfiguration.java	45
flink-clients/src/main/java/org/apache/flink/client/program/rest/retry/ExponentialWaitStrategy.java	19
flink-clients/src/main/java/org/apache/flink/client/program/rest/retry/WaitStrategy.java	5