Path Lines of Code flink-annotations/pom.xml 14 flink-clients/pom.xml 160 flink-connectors/flink-connector-base/pom.xml 35 flink-connectors/flink-connector-cassandra/pom.xml 192 flink-connectors/flink-connector-elasticsearch-base/pom.xml 116 flink-connectors/flink-connector-elasticsearch5/pom.xml 231 flink-connectors/flink-connector-elasticsearch6/pom.xml 122 flink-connectors/flink-connector-elasticsearch7/pom.xml 117 flink-connectors/flink-connector-filesystem/pom.xml 146 flink-connectors/flink-connector-gcp-pubsub/pom.xml 63 flink-connectors/flink-connector-hbase/pom.xml 329 flink-connectors/flink-connector-hive/pom.xml 1053 flink-connectors/flink-connector-jdbc/pom.xml 101 flink-connectors/flink-connector-kafka-0.10/pom.xml 253 flink-connectors/flink-connector-kafka-0.11/pom.xml 232 flink-connectors/flink-connector-kafka-base/pom.xml 231 flink-connectors/flink-connector-kafka/pom.xml 210 flink-connectors/flink-connector-kinesis/pom.xml 195 flink-connectors/flink-connector-nifi/pom.xml 55 flink-connectors/flink-connector-rabbitmq/pom.xml 45 flink-connectors/flink-connector-twitter/pom.xml 75 flink-connectors/flink-hadoop-compatibility/pom.xml 158 flink-connectors/flink-hcatalog/pom.xml 160 flink-connectors/flink-sql-connector-elasticsearch6/pom.xml 117 flink-connectors/flink-sql-connector-elasticsearch7/pom.xml 124 flink-connectors/flink-sql-connector-hbase/pom.xml 121 flink-connectors/flink-sql-connector-hive-1.2.2/pom.xml 129 flink-connectors/flink-sql-connector-hive-2.2.0/pom.xml 92 flink-connectors/flink-sql-connector-hive-2.3.6/pom.xml 66 flink-connectors/flink-sql-connector-hive-3.1.2/pom.xml 68 flink-connectors/flink-sql-connector-kafka-0.10/pom.xml 64 flink-connectors/flink-sql-connector-kafka-0.11/pom.xml 65 flink-connectors/flink-sql-connector-kafka/pom.xml 66 flink-connectors/pom.xml 95 flink-container/pom.xml 38 flink-contrib/flink-connector-wikiedits/pom.xml 30 flink-contrib/pom.xml 24 flink-core/pom.xml 141 flink-dist/pom.xml 676 flink-dist/src/main/flink-bin/kubernetes-bin/kubernetes-entry.sh 7 flink-dist/src/main/flink-bin/kubernetes-bin/kubernetes-session.sh 12 flink-dist/src/main/flink-bin/mesos-bin/mesos-appmaster-job.sh 3 flink-dist/src/main/flink-bin/mesos-bin/mesos-appmaster.sh 3 flink-dist/src/main/flink-bin/mesos-bin/mesos-jobmanager.sh 18 flink-dist/src/main/flink-bin/mesos-bin/mesos-taskmanager.sh 13 flink-dist/src/main/flink-bin/yarn-bin/yarn-session.sh 11 flink-docs/pom.xml 238 flink-examples/flink-examples-batch/pom.xml 306 flink-examples/flink-examples-build-helper/flink-examples-streaming-gcp-pubsub/pom.xml 85 flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/pom.xml 78 flink-examples/flink-examples-build-helper/flink-examples-streaming-twitter/pom.xml 70 flink-examples/flink-examples-build-helper/pom.xml 20 flink-examples/flink-examples-streaming/pom.xml 450 flink-examples/flink-examples-table/pom.xml 225 flink-examples/pom.xml 82 flink-external-resources/flink-external-resource-gpu/pom.xml 28 flink-external-resources/flink-external-resource-gpu/src/main/resources/gpu-discovery-common.sh 62 flink-external-resources/flink-external-resource-gpu/src/main/resources/nvidia-gpu-discovery.sh 35 flink-external-resources/pom.xml 17 flink-filesystems/flink-azure-fs-hadoop/pom.xml 163 flink-filesystems/flink-fs-hadoop-shaded/pom.xml 231 flink-filesystems/flink-hadoop-fs/pom.xml 92 flink-filesystems/flink-mapr-fs/pom.xml 43 flink-filesystems/flink-oss-fs-hadoop/pom.xml 133 flink-filesystems/flink-s3-fs-base/pom.xml 204 flink-filesystems/flink-s3-fs-hadoop/pom.xml 196 flink-filesystems/flink-s3-fs-presto/pom.xml 355 flink-filesystems/flink-swift-fs-hadoop/pom.xml 249 flink-filesystems/pom.xml 64 flink-formats/flink-avro-confluent-registry/pom.xml 144 flink-formats/flink-avro/pom.xml 218 flink-formats/flink-compress/pom.xml 64 flink-formats/flink-csv/pom.xml 88 flink-formats/flink-hadoop-bulk/pom.xml 102 flink-formats/flink-json/pom.xml 93 flink-formats/flink-orc-nohive/pom.xml 84 flink-formats/flink-orc/pom.xml 153 flink-formats/flink-parquet/pom.xml 159 flink-formats/flink-sequence-file/pom.xml 69 flink-formats/flink-sql-orc/pom.xml 66 flink-formats/flink-sql-parquet/pom.xml 70 flink-formats/pom.xml 55 flink-java/pom.xml 52 flink-jepsen/docker/run-tests.sh 26 flink-jepsen/docker/up.sh 9 flink-kubernetes/pom.xml 149 flink-libraries/flink-cep-scala/pom.xml 124 flink-libraries/flink-cep/pom.xml 81 flink-libraries/flink-gelly-examples/pom.xml 195 flink-libraries/flink-gelly-scala/pom.xml 180 flink-libraries/flink-gelly/pom.xml 53 flink-libraries/flink-state-processing-api/pom.xml 70 flink-libraries/pom.xml 38 flink-mesos/pom.xml 227 flink-metrics/flink-metrics-core/pom.xml 39 flink-metrics/flink-metrics-datadog/pom.xml 76 flink-metrics/flink-metrics-dropwizard/pom.xml 55 flink-metrics/flink-metrics-graphite/pom.xml 80 flink-metrics/flink-metrics-influxdb/pom.xml 89 flink-metrics/flink-metrics-jmx/pom.xml 63 flink-metrics/flink-metrics-prometheus/pom.xml 95 flink-metrics/flink-metrics-slf4j/pom.xml 50 flink-metrics/flink-metrics-statsd/pom.xml 50 flink-metrics/pom.xml 40 flink-ml-parent/flink-ml-api/pom.xml 26 flink-ml-parent/flink-ml-lib/pom.xml 65 flink-ml-parent/flink-ml-uber/pom.xml 54 flink-ml-parent/pom.xml 20 flink-optimizer/pom.xml 65 flink-python/dev/build-wheels.sh 24 flink-python/dev/install_command.sh 11 flink-python/dev/lint-python.sh 565 flink-python/pom.xml 418 flink-queryable-state/flink-queryable-state-client-java/pom.xml 57 flink-queryable-state/flink-queryable-state-runtime/pom.xml 86 flink-queryable-state/pom.xml 35 flink-quickstart/flink-quickstart-java/pom.xml 16 flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/pom.xml 162 flink-quickstart/flink-quickstart-scala/pom.xml 16 flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/pom.xml 201 flink-quickstart/pom.xml 70 flink-runtime-web/pom.xml 251 flink-runtime/pom.xml 461 flink-scala-shell/pom.xml 170 flink-scala-shell/start-script/start-scala-shell.sh 60 flink-scala/pom.xml 211 flink-state-backends/flink-statebackend-heap-spillable/pom.xml 27 flink-state-backends/flink-statebackend-rocksdb/pom.xml 73 flink-state-backends/pom.xml 19 flink-streaming-java/pom.xml 91 flink-streaming-scala/pom.xml 229 flink-table/flink-sql-client/pom.xml 494 flink-table/flink-sql-parser-hive/pom.xml 181 flink-table/flink-sql-parser/pom.xml 269 flink-table/flink-table-api-java-bridge/pom.xml 67 flink-table/flink-table-api-java/pom.xml 51 flink-table/flink-table-api-scala-bridge/pom.xml 73 flink-table/flink-table-api-scala/pom.xml 91 flink-table/flink-table-common/pom.xml 62 flink-table/flink-table-planner-blink/pom.xml 349 flink-table/flink-table-planner/pom.xml 318 flink-table/flink-table-runtime-blink/pom.xml 131 flink-table/flink-table-uber-blink/pom.xml 109 flink-table/flink-table-uber/pom.xml 97 flink-table/pom.xml 53 flink-walkthroughs/flink-walkthrough-common/pom.xml 23 flink-walkthroughs/flink-walkthrough-datastream-java/pom.xml 16 flink-walkthroughs/flink-walkthrough-datastream-java/src/main/resources/archetype-resources/pom.xml 162 flink-walkthroughs/flink-walkthrough-datastream-scala/pom.xml 16 flink-walkthroughs/flink-walkthrough-datastream-scala/src/main/resources/archetype-resources/pom.xml 195 flink-walkthroughs/pom.xml 70 flink-yarn/pom.xml 179 pom.xml 1687 tools/azure-pipelines/build_properties.sh 25 tools/azure-pipelines/create_build_artifact.sh 6 tools/azure-pipelines/debug_files_utils.sh 14 tools/azure-pipelines/free_disk_space.sh 18 tools/azure-pipelines/unpack_build_artifact.sh 12 tools/change-version.sh 9 tools/ci/compile.sh 58 tools/ci/controller_utils.sh 32 tools/ci/docs.sh 11 tools/ci/maven-utils.sh 65 tools/ci/shade.sh 140 tools/ci/stage.sh 172 tools/ci/verify_scala_suffixes.sh 72 tools/ci/watchdog.sh 44 tools/deploy_to_maven.sh 50 tools/force-shading/pom.xml 77 tools/releasing/collect_license_files.sh 29 tools/releasing/create_binary_release.sh 100 tools/releasing/create_release_branch.sh 40 tools/releasing/create_snapshot_branch.sh 29 tools/releasing/create_source_release.sh 42 tools/releasing/deploy_staging_jars.sh 16 tools/releasing/update_branch_version.sh 29 tools/releasing/update_japicmp_configuration.sh 35 tools/update_notice_year.sh 14