- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Documentation path like ".*/docs/.*" 668 files: flink-python/docs/index.rst flink-python/docs/pyflink.common.rst flink-python/docs/pyflink.metrics.rst flink-python/docs/pyflink.ml.rst flink-python/docs/_templates/layout.html flink-python/docs/conf.py flink-python/docs/_static/pyflink.js flink-python/docs/_static/pyflink.css flink-python/docs/pyflink.table.rst flink-python/docs/pyflink.dataset.rst flink-python/docs/pyflink.rst flink-python/docs/pyflink.datastream.rst docs/_includes/generated/security_auth_zk_section.html docs/_includes/generated/netty_shuffle_environment_configuration.html docs/_includes/generated/execution_config_configuration.html docs/_includes/generated/blob_server_configuration.html docs/_includes/generated/rest_v1_dispatcher.html docs/_includes/generated/task_manager_memory_configuration.html docs/_includes/generated/deployment_configuration.html docs/_includes/generated/mesos_configuration.html docs/_includes/generated/expert_state_backends_section.html docs/_includes/generated/environment_configuration.html docs/_includes/generated/common_state_backends_section.html docs/_includes/generated/expert_rest_section.html docs/_includes/generated/optimizer_config_configuration.html docs/_includes/generated/expert_high_availability_section.html docs/_includes/generated/failure_rate_restart_strategy_configuration.html docs/_includes/generated/expert_high_availability_zk_section.html docs/_includes/generated/table_config_configuration.html docs/_includes/generated/common_high_availability_section.html docs/_includes/generated/resource_manager_configuration.html docs/_includes/generated/queryable_state_configuration.html docs/_includes/generated/expert_class_loading_section.html docs/_includes/generated/task_manager_configuration.html docs/_includes/generated/common_host_port_section.html docs/_includes/generated/high_availability_configuration.html docs/_includes/generated/heartbeat_manager_configuration.html docs/_includes/generated/mesos_task_manager_configuration.html docs/_includes/generated/yarn_config_configuration.html docs/_includes/generated/web_configuration.html docs/_includes/generated/akka_configuration.html docs/_includes/generated/security_auth_kerberos_section.html docs/_includes/generated/execution_configuration.html docs/_includes/generated/python_configuration.html docs/_includes/generated/all_jobmanager_section.html docs/_includes/generated/stream_pipeline_configuration.html docs/_includes/generated/state_backend_rocksdb_section.html docs/_includes/generated/savepoint_config_configuration.html docs/_includes/generated/all_taskmanager_section.html docs/_includes/generated/rest_configuration.html docs/_includes/generated/rocksdb_native_metric_configuration.html docs/_includes/generated/checkpointing_configuration.html docs/_includes/generated/execution_checkpointing_configuration.html docs/_includes/generated/common_high_availability_zk_section.html docs/_includes/generated/client_configuration.html docs/_includes/generated/security_ssl_section.html docs/_includes/generated/expert_debugging_and_tuning_section.html docs/_includes/generated/expert_fault_tolerance_section.html docs/_includes/generated/metric_configuration.html docs/_includes/generated/rocksdb_configuration.html docs/_includes/generated/influxdb_reporter_configuration.html docs/_includes/generated/deprecated_file_sinks_section.html docs/_includes/generated/cluster_configuration.html docs/_includes/generated/optimizer_configuration.html docs/_includes/generated/external_resource_configuration.html docs/_includes/generated/history_server_configuration.html docs/_includes/generated/pipeline_configuration.html docs/_includes/generated/all_taskmanager_network_section.html docs/_includes/generated/expert_cluster_section.html docs/_includes/generated/job_manager_configuration.html docs/_includes/generated/shuffle_service_configuration.html docs/_includes/generated/core_configuration.html docs/_includes/generated/common_miscellaneous_section.html docs/_includes/generated/algorithm_configuration.html docs/_includes/generated/expert_scheduling_section.html docs/_includes/generated/fixed_delay_restart_strategy_configuration.html docs/_includes/generated/common_memory_section.html docs/_includes/generated/prometheus_push_gateway_reporter_configuration.html docs/_includes/generated/expert_rocksdb_section.html docs/_includes/generated/kubernetes_config_configuration.html docs/_includes/generated/rocksdb_configurable_configuration.html docs/_includes/sidenav.html docs/_includes/latex_commands.html docs/connectors/index.md docs/connectors/index.zh.md docs/try-flink/flink-operations-playground.md docs/try-flink/table_api.md docs/try-flink/datastream_api.md docs/try-flink/local_installation.zh.md docs/try-flink/table_api.zh.md docs/try-flink/python_table_api.zh.md docs/try-flink/local_installation.md docs/try-flink/python_table_api.md docs/try-flink/index.md docs/try-flink/index.zh.md docs/try-flink/datastream_api.zh.md docs/try-flink/flink-operations-playground.zh.md docs/page/css/flink.css docs/page/css/codetabs.css docs/page/css/syntax.css docs/page/js/flink.js docs/page/img/LICENSE.txt docs/page/font-awesome/css/font-awesome.css docs/annotations.xml docs/docker/run.sh docs/fig/FlinkOnYarn.svg docs/fig/interval-join.svg docs/fig/slots.svg docs/fig/transformation.svg docs/fig/window-assigners.svg docs/fig/connected-streams.svg docs/fig/FlinkOnK8s.svg docs/fig/stream_watermark_out_of_order.svg docs/fig/sliding-window-join.svg docs/fig/tumbling-window-join.svg docs/fig/job_status.svg docs/fig/parallel_streams_watermarks.svg docs/fig/windows.svg docs/fig/stream_watermark_in_order.svg docs/fig/session-window-join.svg docs/fig/program_dataflow.svg docs/fig/LICENSE.txt docs/fig/levels_of_abstraction.svg docs/fig/stream_barriers.svg docs/fig/rescale.svg docs/fig/checkpoint_tuning.svg docs/search-results.md docs/learn-flink/streaming_analytics.zh.md docs/learn-flink/event_driven.zh.md docs/learn-flink/datastream_api.md docs/learn-flink/streaming_analytics.md docs/learn-flink/event_driven.md docs/learn-flink/etl.zh.md docs/learn-flink/index.md docs/learn-flink/etl.md docs/learn-flink/fault_tolerance.md docs/learn-flink/index.zh.md docs/learn-flink/fault_tolerance.zh.md docs/learn-flink/datastream_api.zh.md docs/release-notes/flink-1.9.md docs/release-notes/flink-1.6.zh.md docs/release-notes/flink-1.8.md docs/release-notes/flink-1.7.zh.md docs/release-notes/flink-1.5.zh.md docs/release-notes/flink-1.7.md docs/release-notes/flink-1.6.md docs/release-notes/flink-1.10.zh.md docs/release-notes/flink-1.5.md docs/release-notes/flink-1.9.zh.md docs/release-notes/flink-1.11.zh.md docs/release-notes/flink-1.11.md docs/release-notes/flink-1.10.md docs/release-notes/flink-1.8.zh.md docs/_layouts/redirect.html docs/_layouts/base.html docs/_layouts/404_base.html docs/_layouts/plain.html docs/README.md docs/internals/task_lifecycle.zh.md docs/internals/filesystems.zh.md docs/internals/index.md docs/internals/index.zh.md docs/internals/job_scheduling.zh.md docs/internals/filesystems.md docs/internals/job_scheduling.md docs/internals/task_lifecycle.md docs/redirects/kafka.md docs/redirects/tutorials_overview.md docs/redirects/examples.md docs/redirects/java-quickstart.md docs/redirects/projectsetup_scala_api_quickstart.zh.md docs/redirects/restart_strategies.zh.md docs/redirects/savepoints.md docs/redirects/examples_index.md docs/redirects/flink-operations-playground.md docs/redirects/linking_with_optional_modules.md docs/redirects/table_api.md docs/redirects/projectsetup_dependencies.md docs/redirects/als.md docs/redirects/filesystem_sink.md docs/redirects/projectsetup_dependencies.zh.md docs/redirects/datastream_api.md docs/redirects/ml.md docs/redirects/datastream-walkthrough.md docs/redirects/contribution_guide.md docs/redirects/java_quickstart.md docs/redirects/projectsetup_scala_api_quickstart.md docs/redirects/oss.md docs/redirects/local_setup_tutorial.md docs/redirects/cli.md docs/redirects/projectsetup_java_api_quickstart.md docs/redirects/basic_api_concepts.md docs/redirects/training.md docs/redirects/basic_api_concepts2.md docs/redirects/local_execution.md docs/redirects/pipelines.md docs/redirects/tutorials_flink_on_windows.md docs/redirects/rest_api.md docs/redirects/concepts.md docs/redirects/setup_quickstart.md docs/redirects/cross_validation.md docs/redirects/knn.md docs/redirects/sos.md docs/redirects/scala-quickstart.md docs/redirects/dependencies.md docs/redirects/state.md docs/redirects/ide_setup.md docs/redirects/gelly.md docs/redirects/sql.md docs/redirects/scala_quickstart.md docs/redirects/windows.md docs/redirects/getting-started-dependencies.md docs/redirects/table.md docs/redirects/streaming_guide.md docs/redirects/python_table_tutorial.md docs/redirects/svm.md docs/redirects/programming_guide.md docs/redirects/getting-started.md docs/redirects/event_timestamp_extractors.md docs/redirects/scala_shell.md docs/redirects/tutorials_local_setup.md docs/redirects/table-walkthrough.md docs/redirects/mapr.md docs/redirects/event_timestamps_watermarks.md docs/redirects/connectors.md docs/redirects/multiple_linear_regression.md docs/redirects/event_time.md docs/redirects/standard_scaler.md docs/redirects/cluster_execution.md docs/redirects/polynomial_features.md docs/redirects/batch_fault_tolerance.zh.md docs/redirects/types_serialization.md docs/redirects/fault_tolerance.md docs/redirects/python_shell.md docs/redirects/cassandra.md docs/redirects/elasticsearch2.md docs/redirects/linking_with_flink.md docs/redirects/projectsetup_java_api_quickstart.zh.md docs/redirects/filesystems.md docs/redirects/elasticsearch.md docs/redirects/metrics.md docs/redirects/state_backends.md docs/redirects/windows_local_setup.md docs/redirects/back_pressure.md docs/redirects/kinesis.md docs/redirects/restart_strategies.md docs/redirects/cep.md docs/redirects/gce_setup.md docs/redirects/optimization.md docs/redirects/distance_metrics.md docs/redirects/scala_api_extensions.md docs/redirects/aws.md docs/redirects/min_max_scaler.md docs/redirects/batch_fault_tolerance.md docs/redirects/flinkml_quickstart.md docs/redirects/building.md docs/redirects/elasticsearch2_2.md docs/redirects/best_practices.md docs/redirects/python_table_walkthrough.md docs/redirects/example_quickstart.md docs/index.md docs/_plugins/removeDuplicateLicenseHeaders.rb docs/_plugins/gh_link.rb docs/_plugins/panel.rb docs/_plugins/info.rb docs/_plugins/warn.rb docs/_plugins/top.rb docs/_plugins/build_time.rb docs/index.zh.md docs/concepts/timely-stream-processing.zh.md docs/concepts/stateful-stream-processing.md docs/concepts/glossary.zh.md docs/concepts/stateful-stream-processing.zh.md docs/concepts/timely-stream-processing.md docs/concepts/glossary.md docs/concepts/flink-architecture.zh.md docs/concepts/index.md docs/concepts/index.zh.md docs/concepts/flink-architecture.md docs/404.md docs/dev/types_serialization.zh.md docs/dev/connectors/kafka.md docs/dev/connectors/twitter.zh.md docs/dev/connectors/pubsub.zh.md docs/dev/connectors/rabbitmq.md docs/dev/connectors/nifi.zh.md docs/dev/connectors/pubsub.md docs/dev/connectors/filesystem_sink.md docs/dev/connectors/streamfile_sink.zh.md docs/dev/connectors/twitter.md docs/dev/connectors/kinesis.zh.md docs/dev/connectors/elasticsearch.zh.md docs/dev/connectors/filesystem_sink.zh.md docs/dev/connectors/rabbitmq.zh.md docs/dev/connectors/guarantees.md docs/dev/connectors/index.md docs/dev/connectors/cassandra.zh.md docs/dev/connectors/index.zh.md docs/dev/connectors/nifi.md docs/dev/connectors/kafka.zh.md docs/dev/connectors/cassandra.md docs/dev/connectors/jdbc.zh.md docs/dev/connectors/guarantees.zh.md docs/dev/connectors/elasticsearch.md docs/dev/connectors/jdbc.md docs/dev/connectors/streamfile_sink.md docs/dev/connectors/kinesis.md docs/dev/project-configuration.zh.md docs/dev/parallel.zh.md docs/dev/cluster_execution.zh.md docs/dev/local_execution.zh.md docs/dev/datastream_api.md docs/dev/packaging.md docs/dev/local_execution.md docs/dev/java_lambdas.zh.md docs/dev/migration.zh.md docs/dev/user_defined_functions.zh.md docs/dev/stream/testing.zh.md docs/dev/stream/operators/process_function.md docs/dev/stream/operators/process_function.zh.md docs/dev/stream/operators/joining.md docs/dev/stream/operators/windows.zh.md docs/dev/stream/operators/windows.md docs/dev/stream/operators/joining.zh.md docs/dev/stream/operators/index.md docs/dev/stream/operators/index.zh.md docs/dev/stream/operators/asyncio.zh.md docs/dev/stream/operators/asyncio.md docs/dev/stream/sources.md docs/dev/stream/testing.md docs/dev/stream/state/custom_serialization.md docs/dev/stream/state/broadcast_state.zh.md docs/dev/stream/state/checkpointing.md docs/dev/stream/state/queryable_state.zh.md docs/dev/stream/state/state.md docs/dev/stream/state/index.md docs/dev/stream/state/checkpointing.zh.md docs/dev/stream/state/index.zh.md docs/dev/stream/state/state_backends.md docs/dev/stream/state/state_backends.zh.md docs/dev/stream/state/queryable_state.md docs/dev/stream/state/custom_serialization.zh.md docs/dev/stream/state/schema_evolution.md docs/dev/stream/state/schema_evolution.zh.md docs/dev/stream/state/state.zh.md docs/dev/stream/state/broadcast_state.md docs/dev/stream/side_output.zh.md docs/dev/stream/experimental.md docs/dev/stream/sources.zh.md docs/dev/stream/side_output.md docs/dev/stream/experimental.zh.md docs/dev/event_timestamps_watermarks.zh.md docs/dev/scala_api_extensions.zh.md docs/dev/task_failure_recovery.zh.md docs/dev/execution_plans.md docs/dev/migration.md docs/dev/parallel.md docs/dev/event_timestamp_extractors.md docs/dev/libs/gelly/graph_api.md docs/dev/libs/gelly/library_methods.md docs/dev/libs/gelly/bipartite_graph.md docs/dev/libs/gelly/graph_generators.md docs/dev/libs/gelly/bipartite_graph.zh.md docs/dev/libs/gelly/iterative_graph_processing.md docs/dev/libs/gelly/iterative_graph_processing.zh.md docs/dev/libs/gelly/library_methods.zh.md docs/dev/libs/gelly/index.md docs/dev/libs/gelly/graph_api.zh.md docs/dev/libs/gelly/index.zh.md docs/dev/libs/gelly/graph_algorithms.zh.md docs/dev/libs/gelly/graph_generators.zh.md docs/dev/libs/gelly/graph_algorithms.md docs/dev/libs/cep.zh.md docs/dev/libs/state_processor_api.zh.md docs/dev/libs/cep.md docs/dev/libs/state_processor_api.md docs/dev/libraries.zh.md docs/dev/event_timestamps_watermarks.md docs/dev/execution.md docs/dev/project-configuration.md docs/dev/execution.zh.md docs/dev/custom_serializers.zh.md docs/dev/event_time.md docs/dev/index.md docs/dev/task_failure_recovery.md docs/dev/table/connectors/kafka.md docs/dev/table/connectors/print.md docs/dev/table/connectors/formats/csv.md docs/dev/table/connectors/formats/orc.zh.md docs/dev/table/connectors/formats/json.md docs/dev/table/connectors/formats/debezium.md docs/dev/table/connectors/formats/parquet.md docs/dev/table/connectors/formats/canal.md docs/dev/table/connectors/formats/avro.md docs/dev/table/connectors/formats/canal.zh.md docs/dev/table/connectors/formats/index.md docs/dev/table/connectors/formats/avro.zh.md docs/dev/table/connectors/formats/orc.md docs/dev/table/connectors/formats/index.zh.md docs/dev/table/connectors/formats/csv.zh.md docs/dev/table/connectors/formats/parquet.zh.md docs/dev/table/connectors/formats/debezium.zh.md docs/dev/table/connectors/formats/json.zh.md docs/dev/table/connectors/blackhole.zh.md docs/dev/table/connectors/datagen.zh.md docs/dev/table/connectors/hbase.zh.md docs/dev/table/connectors/hbase.md docs/dev/table/connectors/blackhole.md docs/dev/table/connectors/elasticsearch.zh.md docs/dev/table/connectors/print.zh.md docs/dev/table/connectors/index.md docs/dev/table/connectors/index.zh.md docs/dev/table/connectors/kafka.zh.md docs/dev/table/connectors/jdbc.zh.md docs/dev/table/connectors/elasticsearch.md docs/dev/table/connectors/jdbc.md docs/dev/table/connectors/datagen.md docs/dev/table/connectors/filesystem.md docs/dev/table/connectors/filesystem.zh.md docs/dev/table/modules.zh.md docs/dev/table/common.md docs/dev/table/tableApi.md docs/dev/table/python/common_questions.md docs/dev/table/python/vectorized_python_udfs.md docs/dev/table/python/metrics.zh.md docs/dev/table/python/conversion_of_pandas.zh.md docs/dev/table/python/installation.zh.md docs/dev/table/python/dependency_management.md docs/dev/table/python/python_config.md docs/dev/table/python/python_udfs.zh.md docs/dev/table/python/python_types.md docs/dev/table/python/python_types.zh.md docs/dev/table/python/index.md docs/dev/table/python/index.zh.md docs/dev/table/python/python_udfs.md docs/dev/table/python/vectorized_python_udfs.zh.md docs/dev/table/python/dependency_management.zh.md docs/dev/table/python/python_config.zh.md docs/dev/table/python/metrics.md docs/dev/table/python/common_questions.zh.md docs/dev/table/python/installation.md docs/dev/table/python/conversion_of_pandas.md docs/dev/table/connect.zh.md docs/dev/table/legacySourceSinks.md docs/dev/table/modules.md docs/dev/table/types.zh.md docs/dev/table/sourceSinks.zh.md docs/dev/table/streaming/time_attributes.zh.md docs/dev/table/streaming/query_configuration.zh.md docs/dev/table/streaming/match_recognize.md docs/dev/table/streaming/query_configuration.md docs/dev/table/streaming/time_attributes.md docs/dev/table/streaming/temporal_tables.md docs/dev/table/streaming/dynamic_tables.md docs/dev/table/streaming/index.md docs/dev/table/streaming/temporal_tables.zh.md docs/dev/table/streaming/dynamic_tables.zh.md docs/dev/table/streaming/index.zh.md docs/dev/table/streaming/match_recognize.zh.md docs/dev/table/streaming/joins.md docs/dev/table/streaming/joins.zh.md docs/dev/table/config.md docs/dev/table/connect.md docs/dev/table/index.md docs/dev/table/legacySourceSinks.zh.md docs/dev/table/index.zh.md docs/dev/table/tableApi.zh.md docs/dev/table/tuning/streaming_aggregation_optimization.md docs/dev/table/tuning/index.md docs/dev/table/tuning/index.zh.md docs/dev/table/tuning/streaming_aggregation_optimization.zh.md docs/dev/table/hive/hive_read_write.md docs/dev/table/hive/hive_streaming.zh.md docs/dev/table/hive/hive_functions.md docs/dev/table/hive/hive_functions.zh.md docs/dev/table/hive/hive_read_write.zh.md docs/dev/table/hive/hive_streaming.md docs/dev/table/hive/hive_dialect.zh.md docs/dev/table/hive/index.md docs/dev/table/hive/hive_dialect.md docs/dev/table/hive/index.zh.md docs/dev/table/hive/hive_catalog.zh.md docs/dev/table/hive/hive_catalog.md docs/dev/table/functions/udfs.md docs/dev/table/functions/udfs.zh.md docs/dev/table/functions/index.md docs/dev/table/functions/index.zh.md docs/dev/table/functions/systemFunctions.zh.md docs/dev/table/functions/systemFunctions.md docs/dev/table/sqlClient.md docs/dev/table/catalogs.zh.md docs/dev/table/types.md docs/dev/table/catalogs.md docs/dev/table/sqlClient.zh.md docs/dev/table/common.zh.md docs/dev/table/sourceSinks.md docs/dev/table/config.zh.md docs/dev/table/sql/insert.md docs/dev/table/sql/alter.md docs/dev/table/sql/queries.md docs/dev/table/sql/show.zh.md docs/dev/table/sql/queries.zh.md docs/dev/table/sql/use.zh.md docs/dev/table/sql/explain.md docs/dev/table/sql/drop.md docs/dev/table/sql/hints.md docs/dev/table/sql/describe.zh.md docs/dev/table/sql/insert.zh.md docs/dev/table/sql/create.zh.md docs/dev/table/sql/drop.zh.md docs/dev/table/sql/use.md docs/dev/table/sql/create.md docs/dev/table/sql/describe.md docs/dev/table/sql/show.md docs/dev/table/sql/hints.zh.md docs/dev/table/sql/explain.zh.md docs/dev/table/sql/alter.zh.md docs/dev/cluster_execution.md docs/dev/batch/examples.md docs/dev/batch/hadoop_compatibility.md docs/dev/batch/dataset_transformations.zh.md docs/dev/batch/iterations.zh.md docs/dev/batch/zip_elements_guide.zh.md docs/dev/batch/dataset_transformations.md docs/dev/batch/connectors.md docs/dev/batch/hadoop_compatibility.zh.md docs/dev/batch/index.md docs/dev/batch/zip_elements_guide.md docs/dev/batch/index.zh.md docs/dev/batch/examples.zh.md docs/dev/batch/connectors.zh.md docs/dev/batch/iterations.md docs/dev/types_serialization.md docs/dev/index.zh.md docs/dev/user_defined_functions.md docs/dev/application_parameters.zh.md docs/dev/java_lambdas.md docs/dev/event_timestamp_extractors.zh.md docs/dev/scala_api_extensions.md docs/dev/packaging.zh.md docs/dev/event_time.zh.md docs/dev/application_parameters.md docs/dev/execution_configuration.md docs/dev/libraries.md docs/dev/execution_configuration.zh.md docs/dev/custom_serializers.md docs/dev/datastream_api.zh.md docs/dev/execution_plans.zh.md docs/ops/security-kerberos.md docs/ops/jobmanager_high_availability.zh.md docs/ops/security-ssl.md docs/ops/memory/mem_setup_jobmanager.zh.md docs/ops/memory/mem_setup.md docs/ops/memory/mem_trouble.md docs/ops/memory/mem_tuning.zh.md docs/ops/memory/mem_setup_jobmanager.md docs/ops/memory/mem_setup_tm.zh.md docs/ops/memory/mem_trouble.zh.md docs/ops/memory/index.md docs/ops/memory/index.zh.md docs/ops/memory/mem_setup_tm.md docs/ops/memory/mem_migration.md docs/ops/memory/mem_setup.zh.md docs/ops/memory/mem_migration.zh.md docs/ops/memory/mem_tuning.md docs/ops/cli.md docs/ops/cli.zh.md docs/ops/production_ready.zh.md docs/ops/state/savepoints.md docs/ops/state/checkpoints.zh.md docs/ops/state/large_state_tuning.zh.md docs/ops/state/large_state_tuning.md docs/ops/state/savepoints.zh.md docs/ops/state/index.md docs/ops/state/index.zh.md docs/ops/state/state_backends.md docs/ops/state/state_backends.zh.md docs/ops/state/checkpoints.md docs/ops/scala_shell.md docs/ops/config.md docs/ops/scala_shell.zh.md docs/ops/security-kerberos.zh.md docs/ops/index.md docs/ops/production_ready.md docs/ops/plugins.md docs/ops/deployment/cluster_setup.zh.md docs/ops/deployment/local.zh.md docs/ops/deployment/kubernetes.md docs/ops/deployment/yarn_setup.md docs/ops/deployment/native_kubernetes.zh.md docs/ops/deployment/mesos.md docs/ops/deployment/cluster_setup.md docs/ops/deployment/native_kubernetes.md docs/ops/deployment/hadoop.zh.md docs/ops/deployment/yarn_setup.zh.md docs/ops/deployment/index.md docs/ops/deployment/kubernetes.zh.md docs/ops/deployment/index.zh.md docs/ops/deployment/mesos.zh.md docs/ops/deployment/docker.zh.md docs/ops/deployment/docker.md docs/ops/deployment/hadoop.md docs/ops/deployment/local.md docs/ops/python_shell.md docs/ops/index.zh.md docs/ops/external_resources.zh.md docs/ops/external_resources.md docs/ops/python_shell.zh.md docs/ops/security-ssl.zh.md docs/ops/upgrading.zh.md docs/ops/upgrading.md docs/ops/jobmanager_high_availability.md docs/ops/plugins.zh.md docs/ops/filesystems/oss.zh.md docs/ops/filesystems/oss.md docs/ops/filesystems/common.md docs/ops/filesystems/azure.zh.md docs/ops/filesystems/s3.md docs/ops/filesystems/s3.zh.md docs/ops/filesystems/index.md docs/ops/filesystems/index.zh.md docs/ops/filesystems/common.zh.md docs/ops/filesystems/azure.md docs/ops/config.zh.md docs/check_links.sh docs/build_docs.sh docs/cse.xml docs/monitoring/historyserver.md docs/monitoring/historyserver.zh.md docs/monitoring/debugging_event_time.zh.md docs/monitoring/rest_api.md docs/monitoring/checkpoint_monitoring.zh.md docs/monitoring/metrics.zh.md docs/monitoring/debugging_classloading.zh.md docs/monitoring/debugging_event_time.md docs/monitoring/debugging_classloading.md docs/monitoring/application_profiling.zh.md docs/monitoring/README.md docs/monitoring/application_profiling.md docs/monitoring/checkpoint_monitoring.md docs/monitoring/index.md docs/monitoring/logging.md docs/monitoring/index.zh.md docs/monitoring/logging.zh.md docs/monitoring/metrics.md docs/monitoring/back_pressure.md docs/monitoring/back_pressure.zh.md docs/monitoring/rest_api.zh.md docs/flinkDev/ide_setup.zh.md docs/flinkDev/ide_setup.md docs/flinkDev/building.zh.md docs/flinkDev/index.md docs/flinkDev/index.zh.md docs/flinkDev/building.md docs/downloads/setup-pyflink-virtual-env.sh flink-docs/src/test/java/org/apache/flink/docs/configuration/ConfigOptionsDocsCompletenessITCase.java flink-docs/src/test/java/org/apache/flink/docs/configuration/ConfigOptionsDocGeneratorTest.java flink-docs/src/test/java/org/apache/flink/docs/configuration/data/TestCommonOptions.java flink-docs/src/test/java/org/apache/flink/docs/rest/RestAPIDocGeneratorTest.java flink-docs/src/test/java/org/apache/flink/docs/rest/data/TestExcludeMessageHeaders.java flink-docs/src/test/java/org/apache/flink/docs/rest/data/TestEmptyMessageHeaders.java flink-docs/src/main/java/org/apache/flink/docs/configuration/OptionsClassLocation.java flink-docs/src/main/java/org/apache/flink/docs/configuration/ConfigOptionsDocGenerator.java flink-docs/src/main/java/org/apache/flink/docs/util/Utils.java flink-docs/src/main/java/org/apache/flink/docs/rest/RestAPIDocGenerator.java flink-annotations/src/main/java/org/apache/flink/annotation/docs/Documentation.java flink-annotations/src/main/java/org/apache/flink/annotation/docs/ConfigGroup.java flink-annotations/src/main/java/org/apache/flink/annotation/docs/ConfigGroups.java - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Too long lines (1000+ characters) 56 files: flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/table/CalcTest.xml flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/table/OverWindowTest.xml flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/agg/OverAggregateTest.xml flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/WindowGroupReorderRuleTest.xml flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/subquery/FlinkRewriteSubQueryRuleTest.xml flink-jepsen/test/jepsen/flink/client_test.clj flink-connectors/flink-connector-nifi/src/test/resources/NiFi_Flink.xml flink-python/pyflink/fn_execution/flink_fn_execution_pb2.py docs/_includes/generated/restart_strategy_configuration.html docs/_includes/generated/security_configuration.html docs/_includes/generated/expert_security_ssl_section.html docs/page/js/jquery.min.js docs/page/font-awesome/css/font-awesome.min.css docs/page/font-awesome/fonts/fontawesome-webfont.svg docs/fig/simple_mem_model.svg docs/fig/stream_unaligning.svg docs/fig/parallel_dataflow.svg docs/fig/checkpointing.svg docs/fig/detailed-mem-model.svg docs/fig/state_partitioning.svg docs/fig/tasks_slots.svg docs/fig/source_reader.svg docs/fig/distributed-runtime.svg docs/fig/parallel_kafka_watermarks.svg docs/fig/checkpoints.svg docs/fig/tasks_chains.svg docs/fig/fraud-transactions.svg docs/fig/stream_aligning.svg docs/fig/slot_sharing.svg docs/fig/per_split_watermarks.svg docs/fig/async_io.svg docs/fig/process_model.svg docs/fig/job_and_execution_graph.svg docs/fig/source_components.svg docs/fig/process_mem_model.svg docs/fig/non-windowed.svg docs/fig/ClientJmTm.svg docs/fig/event_processing_time.svg docs/fig/processes.svg docs/fig/flink-docker-playground.svg docs/fig/projects_dependencies.svg docs/fig/stack.svg docs/fig/table_connectors.svg docs/fig/session-windows.svg docs/fig/state_machine.svg docs/fig/slots_parallelism.svg docs/fig/ssl_internal_external.svg docs/fig/sliding-windows.svg docs/fig/click-event-count-example.svg docs/fig/tumbling-windows.svg docs/dev/table/sql/index.md docs/dev/table/sql/index.zh.md flink-formats/flink-json/src/test/resources/debezium-postgres-data-schema-include.txt flink-formats/flink-json/src/test/resources/canal-data.txt flink-formats/flink-json/src/test/resources/debezium-data-schema-include.txt flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/twitter/util/TwitterExampleData.java - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Binaries for distribution path like ".*/bin/.*" 19 files: flink-table/flink-sql-client/bin/sql-client.sh flink-python/bin/pyflink-udf-runner.bat flink-python/bin/pyflink-shell.sh flink-python/bin/pyflink-udf-runner.sh flink-dist/src/test/bin/runBashJavaUtilsCmd.sh flink-dist/src/test/bin/runExtractLoggingOutputs.sh flink-dist/src/main/flink-bin/bin/stop-zookeeper-quorum.sh flink-dist/src/main/flink-bin/bin/historyserver.sh flink-dist/src/main/flink-bin/bin/flink-daemon.sh flink-dist/src/main/flink-bin/bin/jobmanager.sh flink-dist/src/main/flink-bin/bin/stop-cluster.sh flink-dist/src/main/flink-bin/bin/standalone-job.sh flink-dist/src/main/flink-bin/bin/flink-console.sh flink-dist/src/main/flink-bin/bin/start-zookeeper-quorum.sh flink-dist/src/main/flink-bin/bin/config.sh flink-dist/src/main/flink-bin/bin/zookeeper.sh flink-dist/src/main/flink-bin/bin/find-flink-home.sh flink-dist/src/main/flink-bin/bin/start-cluster.sh flink-dist/src/main/flink-bin/bin/taskmanager.sh - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Hidden files and folders path like ".*/[.][a-zA-Z0-9_]+.*" 13 files: .asf.yaml flink-jepsen/docker/.gitignore flink-jepsen/.gitignore tools/.gitignore docs/.gitignore .editorconfig .gitignore .github/PULL_REQUEST_TEMPLATE.md .github/CONTRIBUTING.md flink-runtime-web/web-dashboard/.prettierignore flink-end-to-end-tests/flink-confluent-schema-registry/.gitignore flink-end-to-end-tests/.gitignore flink-runtime/src/main/resources-filtered/.flink-runtime.version.properties - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Caches path like ".*/cache/.*" 10 files: flink-core/src/main/java/org/apache/flink/api/common/cache/DistributedCache.java flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/AbstractDownloadCache.java flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/PersistingDownloadCacheFactory.java flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/DownloadCacheFactory.java flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/DownloadCache.java flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/TravisDownloadCacheFactory.java flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/TravisDownloadCache.java flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/LolCache.java flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/LolCacheFactory.java flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cache/PersistingDownloadCache.java - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Test data path like ".*/testdata/.*" 8 files: flink-tests/src/test/resources/testdata/terainput.txt flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/testdata/WordCountData.java flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/testdata/ConnectedComponentsData.java flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/testdata/EnumTriangleData.java flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/testdata/TransitiveClosureData.java flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/testdata/KMeansData.java flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/testdata/WebLogAnalysisData.java flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/testdata/PageRankData.java - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Distributions path like ".*/dist/.*" 2 files: flink-dist/src/test/java/org/apache/flink/dist/JavaBashTestBase.java flink-dist/src/test/java/org/apache/flink/dist/BashJavaUtilsITCase.java - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Sokrates conventions and configurations path like ".*/sokrates_.*?[.]json" 1 files: sokrates_conventions.json - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Too many lines (10000) 1 files: flink-runtime-web/web-dashboard/package-lock.json - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - Too long file (1000000+ bytes) 1 files: git-history.txt - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -