Path	Lines of Code
flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java	154
flink-clients/src/main/java/org/apache/flink/client/FlinkPipelineTranslationUtil.java	59
flink-clients/src/main/java/org/apache/flink/client/FlinkPipelineTranslator.java	10
flink-clients/src/main/java/org/apache/flink/client/StreamGraphTranslator.java	35
flink-clients/src/main/java/org/apache/flink/client/cli/AbstractCustomCommandLine.java	63
flink-clients/src/main/java/org/apache/flink/client/cli/ApplicationDeployer.java	11
flink-clients/src/main/java/org/apache/flink/client/cli/ArtifactFetchOptions.java	35
flink-clients/src/main/java/org/apache/flink/client/cli/CancelOptions.java	38
flink-clients/src/main/java/org/apache/flink/client/cli/CheckpointOptions.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	1069
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java	560
flink-clients/src/main/java/org/apache/flink/client/cli/ClientOptions.java	53
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	19
flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java	57
flink-clients/src/main/java/org/apache/flink/client/cli/DynamicPropertiesUtil.java	31
flink-clients/src/main/java/org/apache/flink/client/cli/ExecutionConfigAccessor.java	55
flink-clients/src/main/java/org/apache/flink/client/cli/GenericCLI.java	100
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	141
flink-clients/src/main/java/org/apache/flink/client/cli/ProgramOptionsUtils.java	97
flink-clients/src/main/java/org/apache/flink/client/cli/SavepointOptions.java	50
flink-clients/src/main/java/org/apache/flink/client/cli/StopOptions.java	50
flink-clients/src/main/java/org/apache/flink/client/deployment/AbstractContainerizedClusterClientFactory.java	29
flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientFactory.java	16
flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientJobClientAdapter.java	122
flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientServiceLoader.java	8
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	17
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	53
flink-clients/src/main/java/org/apache/flink/client/deployment/DefaultClusterClientServiceLoader.java	78
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	50
flink-clients/src/main/java/org/apache/flink/client/deployment/StandaloneClusterId.java	12
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationClusterEntryPoint.java	85
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationConfiguration.java	50
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java	309
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherGatewayServiceFactory.java	80
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherLeaderProcessFactoryFactory.java	56
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	14
flink-clients/src/main/java/org/apache/flink/client/deployment/application/DetachedApplicationRunner.java	53
flink-clients/src/main/java/org/apache/flink/client/deployment/application/EmbeddedJobClient.java	121
flink-clients/src/main/java/org/apache/flink/client/deployment/application/EntryClassInformationProvider.java	7
flink-clients/src/main/java/org/apache/flink/client/deployment/application/FromClasspathEntryClassInformationProvider.java	86
flink-clients/src/main/java/org/apache/flink/client/deployment/application/FromJarEntryClassInformationProvider.java	31
flink-clients/src/main/java/org/apache/flink/client/deployment/application/JarManifestParser.java	83
flink-clients/src/main/java/org/apache/flink/client/deployment/application/JobStatusPollingUtils.java	82
flink-clients/src/main/java/org/apache/flink/client/deployment/application/UnsuccessfulExecutionException.java	41
flink-clients/src/main/java/org/apache/flink/client/deployment/application/WebSubmissionJobClient.java	57
flink-clients/src/main/java/org/apache/flink/client/deployment/application/cli/ApplicationClusterDeployer.java	39
flink-clients/src/main/java/org/apache/flink/client/deployment/application/executors/EmbeddedExecutor.java	155
flink-clients/src/main/java/org/apache/flink/client/deployment/application/executors/EmbeddedExecutorFactory.java	48
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	28
flink-clients/src/main/java/org/apache/flink/client/deployment/executors/AbstractSessionClusterExecutor.java	130
flink-clients/src/main/java/org/apache/flink/client/deployment/executors/LocalExecutor.java	79
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	100
flink-clients/src/main/java/org/apache/flink/client/deployment/executors/RemoteExecutor.java	14
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	67
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClientProvider.java	6
flink-clients/src/main/java/org/apache/flink/client/program/DefaultPackagedProgramRetriever.java	197
flink-clients/src/main/java/org/apache/flink/client/program/MiniClusterClient.java	176
flink-clients/src/main/java/org/apache/flink/client/program/MutatedConfigurationException.java	19
flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java	514
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	202
flink-clients/src/main/java/org/apache/flink/client/program/PerJobMiniClusterFactory.java	123
flink-clients/src/main/java/org/apache/flink/client/program/ProgramAbortException.java	10
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	254
flink-clients/src/main/java/org/apache/flink/client/program/StreamPlanEnvironment.java	38
flink-clients/src/main/java/org/apache/flink/client/program/artifact/ArtifactFetchManager.java	122
flink-clients/src/main/java/org/apache/flink/client/program/artifact/ArtifactFetcher.java	7
flink-clients/src/main/java/org/apache/flink/client/program/artifact/ArtifactUtils.java	26
flink-clients/src/main/java/org/apache/flink/client/program/artifact/FsArtifactFetcher.java	30
flink-clients/src/main/java/org/apache/flink/client/program/artifact/HttpArtifactFetcher.java	39
flink-clients/src/main/java/org/apache/flink/client/program/artifact/LocalArtifactFetcher.java	17
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java	1002
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClientConfiguration.java	49
flink-clients/src/main/java/org/apache/flink/client/program/rest/UrlPrefixDecorator.java	68
flink-clients/src/main/java/org/apache/flink/client/program/rest/retry/ExponentialWaitStrategy.java	24
flink-clients/src/main/java/org/apache/flink/client/program/rest/retry/WaitStrategy.java	5