"Fossies" - the Fresh Open Source Software Archive  

Source code changes report for "flink" between the packages
flink-1.10.0-src.tgz and flink-1.10.1-src.tgz

About: Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams.

Summary:

The "flink" source code changed by about 1.0% and now consists of 13622 regular files (+30) and 4474 directories (+14).

Related Informations:

See docs/release-notes/flink-1.10.md and docs/monitoring/historyserver.md (flink 1.10.1).

Changes In Files (According File Type):

File TypeTotalAddedRemovedChanged
C program 130 1 2 0
Assembler program 6 0 0 0
Java program 8878 23 2 244
Python program 111 6 0 18
Shell program 141 1 0 17
Ruby program 7 0 0 0
Configuration file 5 0 0 0
Executable file 11 0 0 0
Initialization file 1 0 0 0
JavaScript file 4 0 0 0
JSON file 16 0 0 0
Makefile 1 0 0 0
Man page 1 0 0 0
SGML document 367 16 0 49
XML document 392 0 0 190
CSS style sheet 6 0 0 0
CSV file 5 0 0 0
DOS Batch file 3 0 2 0
Font file 23 0 0 0
Git file 1 0 0 0
HTML page 163 2 0 13
Log file 2 0 0 0
Property file 104 1 0 0
Protocol Buffer file 1 0 0 0
Qt Translation or MS TypeScript file 107 0 0 1
RST file 6 0 0 0
SQL file 107 0 0 0
YAML file 50 0 0 2
Data file 662 0 0 0
Icon 2 0 0 0
Image file 63 0 0 0
Vector Image file 50 2 0 0
Directory 4477 17 3 0
Archive 2 0 0 0
Information file 37 0 1 35
License 87 0 17 0
Readme file 21 0 0 0
Text file 2049 2 0 35
Other 24 0 0 0
Total Files181237127604



C Programs (3 of 130):

NameStatusDeltaVisual Diff
docs/dev/best_practices.md removed
docs/dev/best_practices.zh.md removed
flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/functions/sink/filesystem
/StreamingFileSinkTest.scala
added

Java Programs (269 of 8878):

NameStatusDeltaVisual Diff
docs/dev/connectors/streamfile_sink.md changed 0.4% diff
docs/dev/connectors/streamfile_sink.zh.md changed 0.4% diff
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java changed 2.9% diff
flink-clients/src/main/java/org/apache/flink/client/deployment/executors/LocalExecutor.java changed 46.3% diff
flink-clients/src/main/java/org/apache/flink/client/deployment/executors/LocalExecutorFactory.java changed 2.9% diff
flink-clients/src/main/java/org/apache/flink/client/program/OptimizerPlanEnvironment.java changed 3.6% diff
flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgramUtils.java changed 14.3% diff
flink-clients/src/main/java/org/apache/flink/client/program/PerJobMiniClusterFactory.java added
flink-clients/src/test/java/org/apache/flink/client/cli/CliFrontendPackageProgramTest.java changed 0.7% diff
flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java changed 0.7% diff
flink-clients/src/test/java/org/apache/flink/client/program/ExecutionPlanCreationTest.java changed 2.3% diff
flink-clients/src/test/java/org/apache/flink/client/program/OptimizerPlanEnvironmentTest.java changed 5.1% diff
flink-clients/src/test/java/org/apache/flink/client/program/PackagedProgramUtilsTest.java added
flink-clients/src/test/java/org/apache/flink/client/program/PerJobMiniClusterFactoryTest.java added
flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors
/elasticsearch5/Elasticsearch5ApiCallBridge.java
changed 1.3% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveOutputForm
atFactory.java
changed 5.9% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableParti
tion.java
changed 25.0% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.
java
changed 14.5% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSourc
e.java
changed 6.1% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveMapre
dSplitReader.java
changed 4.1% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/Hive
Shim.java
changed 4.4% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/Hive
ShimV100.java
changed 5.8% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/Hive
ShimV110.java
changed 26.4% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog
.java
changed 2.7% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveSt
atsUtil.java
changed 4.7% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveTa
bleUtil.java
changed 15.1% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/conversio
n/HiveInspectors.java
changed 12.3% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGener
icUDF.java
changed 9.2% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveSimpl
eUDF.java
changed 4.8% diff
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveOutputForm
atFactoryTest.java
changed 3.4% diff
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourc
eTest.java
changed 8.2% diff
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveCo
nnectorTest.java
changed 9.7% diff
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/factories/H
iveCatalogFactoryTest.java
changed 15.0% diff
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalog
HiveMetadataTest.java
changed 22.4% diff
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/functions/hive/HiveSimpl
eUDFTest.java
changed 21.1% diff
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/module/hive/HiveModuleTe
st.java
changed 7.6% diff
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kaf
ka/FlinkKafkaConsumerBase.java
changed 2.9% diff
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/table/descriptors/KafkaV
alidator.java
changed 2.7% diff
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kaf
ka/FlinkKafkaConsumerBaseTest.java
changed 3.7% diff
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kaf
ka/KafkaTableSourceSinkFactoryTestBase.java
changed 29.5% diff
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/Fl
inkKafkaProducer.java
changed 1.7% diff
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/util/RecordEmitter.java
changed 2.7% diff
flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/u
tils/HadoopUtils.java
changed 34.8% diff
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUpsertOutputFormat.
java
changed 3.9% diff
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/writer/AppendOnlyWriter
.java
changed 19.0% diff
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/writer/JDBCWriter.java changed 4.1% diff
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/writer/UpsertWriter.jav
a
changed 10.7% diff
flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCAppenOnlyWriterTest
.java
added
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/NullableSerializer.java changed 0.4% diff
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java changed 0.1% diff
flink-core/src/main/java/org/apache/flink/configuration/Configuration.java changed 1.9% diff
flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java changed 1.9% diff
flink-core/src/main/java/org/apache/flink/configuration/MemorySize.java changed 0.1% diff
flink-core/src/main/java/org/apache/flink/configuration/ReadableConfigToConfigurationAdapter.java changed 21.5% diff
flink-core/src/main/java/org/apache/flink/configuration/StructuredOptionsSplitter.java changed 18.8% diff
flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java changed 0.2% diff
flink-core/src/main/java/org/apache/flink/configuration/WebOptions.java changed 0.5% diff
flink-core/src/main/java/org/apache/flink/core/execution/PipelineExecutor.java changed 6.6% diff
flink-core/src/main/java/org/apache/flink/core/fs/EntropyInjector.java changed 6.0% diff
flink-core/src/main/java/org/apache/flink/core/fs/PluginFileSystemFactory.java changed 2.1% diff
flink-core/src/main/java/org/apache/flink/core/memory/HybridMemorySegment.java changed 12.2% diff
flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentFactory.java changed 18.7% diff
flink-core/src/main/java/org/apache/flink/core/memory/MemoryUtils.java changed 49.5% diff
flink-core/src/main/java/org/apache/flink/util/ExceptionUtils.java changed 26.3% diff
flink-core/src/main/java/org/apache/flink/util/FileUtils.java changed 1.7% diff
flink-core/src/test/java/org/apache/flink/api/java/typeutils/LambdaExtractionTest.java changed 1.8% diff
flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/NullableSerializerTest.java changed 1.6% diff
flink-core/src/test/java/org/apache/flink/configuration/ConfigurationTest.java changed 14.9% diff
flink-core/src/test/java/org/apache/flink/configuration/ReadableConfigToConfigurationAdapterTest.ja
va
added
flink-core/src/test/java/org/apache/flink/configuration/StructuredOptionsSplitterEscapeTest.java added
flink-core/src/test/java/org/apache/flink/core/fs/AbstractCloseableRegistryTest.java changed 0.9% diff
flink-core/src/test/java/org/apache/flink/core/fs/EntropyInjectorTest.java changed 21.6% diff
flink-core/src/test/java/org/apache/flink/util/ExceptionUtilsTest.java changed 15.4% diff
flink-dist/src/test/java/org/apache/flink/dist/BashJavaUtilsITCase.java changed 46.3% diff
flink-docs/src/main/java/org/apache/flink/docs/rest/NoOpTransientBlobService.java moved 15.3% diff
flink-runtime/src/test/java/org/apache/flink/runtime/blob/NoOpTransientBlobService.java
flink-docs/src/main/java/org/apache/flink/docs/rest/RestAPIDocGenerator.java changed 10.8% diff
flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/cach
e/AbstractDownloadCache.java
changed 1.4% diff
flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/src/test/java/org/apache/flink/metric
s/prometheus/tests/PrometheusReporterEndToEndITCase.java
changed 3.4% diff
flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/StreamWindow
SQLExample.java
changed 2.2% diff
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java changed 10.1% diff
flink-filesystems/flink-hadoop-fs/src/test/java/org/apache/flink/runtime/fs/hdfs/AbstractHadoopFile
SystemITTest.java
changed 8.7% diff
flink-filesystems/flink-s3-fs-base/src/main/java/com/amazonaws/services/s3/model/transform/XmlRespo
nsesSaxParser.java
added
flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/CompressWriterFactory.
java
changed 100.0% diff
flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/writers/HadoopCompress
ionBulkWriter.java
changed 35.7% diff
flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/writers/NoCompressionB
ulkWriter.java
changed 12.9% diff
flink-formats/flink-compress/src/test/java/org/apache/flink/formats/compress/CompressionFactoryITCa
se.java
added
flink-formats/flink-compress/src/test/java/org/apache/flink/formats/compress/CompressWriterFactoryT
est.java
changed 34.0% diff
flink-formats/flink-compress/src/test/java/org/apache/flink/formats/compress/CustomCompressionCodec
.java
added
flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.jav
a
changed 1.4% diff
flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowSerializationSchemaTest
.java
changed 19.8% diff
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcInputFormat.java changed 1.0% diff
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcSplitReaderUtil.java changed 4.8% diff
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcTableSource.java changed 0.5% diff
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/AbstractOrcColumnVector.java changed 2.4% diff
flink-formats/flink-orc/src/test/java/org/apache/flink/orc/OrcRowInputFormatTest.java changed 2.2% diff
flink-formats/flink-orc/src/test/java/org/apache/flink/orc/OrcSplitReaderUtilTest.java changed 7.2% diff
flink-formats/flink-orc/src/test/java/org/apache/flink/orc/OrcTableSourceTest.java changed 7.8% diff
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java changed 0.1% diff
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java changed 1.2% diff
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesResourceManagerC
onfiguration.java
added
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/entrypoint/KubernetesResourceManagerFact
ory.java
changed 20.4% diff
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/decorators/ServiceDecorator.j
ava
changed 10.0% diff
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java changed 26.4% diff
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/FlinkKubeClient.java changed 22.3% diff
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/KubeClientFactory.java changed 17.4% diff
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java changed 7.9% diff
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java changed 12.8% diff
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/Fabric8ClientTest.java changed 9.3% diff
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesResourceManagerTest.java changed 27.0% diff
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesTestBase.java changed 2.3% diff
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/input/KeyedStat
eInputFormat.java
changed 1.7% diff
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/input/operator/
StateReaderOperator.java
changed 6.2% diff
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/operator
s/LazyTimerService.java
changed 5.8% diff
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/output/KeyedSta
teBootstrapOperatorTest.java
changed 98.4% diff
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameter
s.java
changed 0.9% diff
flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameter
sTest.java
changed 1.5% diff
flink-metrics/flink-metrics-jmx/src/main/java/org/apache/flink/metrics/jmx/JMXReporter.java changed 16.7% diff
flink-python/src/main/java/org/apache/flink/python/AbstractPythonFunctionRunner.java changed 4.0% diff
flink-python/src/main/java/org/apache/flink/python/env/ProcessPythonEnvironmentManager.java changed 8.0% diff
flink-python/src/main/java/org/apache/flink/python/env/PythonEnvironmentManager.java changed 5.7% diff
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractPythonFunctionOp
erator.java
changed 3.3% diff
flink-python/src/test/java/org/apache/flink/python/env/ProcessPythonEnvironmentManagerTest.java changed 2.9% diff
flink-python/src/test/java/org/apache/flink/table/functions/python/BaseRowPythonScalarFunctionRunne
rTest.java
changed 0.3% diff
flink-python/src/test/java/org/apache/flink/table/functions/python/PythonScalarFunctionRunnerTest.j
ava
changed 0.2% diff
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/n
etwork/KvStateServerHandlerTest.java
changed 0.8% diff
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerTest.java changed 2.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java changed 4.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java changed 0.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/TaskExecutorProcessUtils.java changed 1.3% diff
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java changed 0.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherRestEndpoint.java changed 4.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherServices.java changed 1.8% diff
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/HistoryServerArchivist.java changed 12.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JsonResponseHistoryServerArchivist.
java
changed 25.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/PartialDispatcherServices.java changed 2.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/PartialDispatcherServicesWithJobGra
phStore.java
changed 2.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/DefaultDispatcherResource
ManagerComponentFactory.java
changed 2.7% diff
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/MiniDispatcherRestEndpoint.java changed 9.0% diff
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java changed 1.0% diff
flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java changed 0.8% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java changed 6.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/AsynchronousOperationResult
.java
changed 2.8% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/AsynchronousOperationStatus
MessageHeaders.java
changed 2.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/rescaling/RescalingStatusHead
ers.java
changed 2.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.
java
changed 0.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/DefaultExecutionGraphCache
.java
added
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCache.java changed 68.9% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/JobRestEndpointFactory.java changed 6.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/savepoints/SavepointDisposal
StatusHeaders.java
changed 2.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/savepoints/SavepointStatusHe
aders.java
changed 2.0% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestEndpointFactory.java changed 28.3% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java changed 2.3% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/SessionRestEndpointFactory.java changed 6.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java changed 5.6% diff
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java changed 1.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/HadoopModule.java changed 9.7% diff
flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryStateHandle.java changed 29.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapRestoreOperation.java changed 2.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateHandle.java changed 14.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupsStateHandle.java changed 5.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java changed 15.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/JobLeaderService.java changed 19.6% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java changed 0.6% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java changed 3.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java changed 0.7% diff
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java changed 4.5% diff
flink-runtime/src/test/java/org/apache/flink/runtime/clusterframework/BootstrapToolsTest.java changed 14.5% diff
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java changed 3.1% diff
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/AbstractByteBufTest.java changed 0.1% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/async/AbstractAsynchronousOperati
onHandlersTest.java
changed 0.4% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/JobConfigHandlerTest.java changed 3.9% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/JobExceptionsHandlerTest.java changed 2.6% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/metrics/JobVertexWatermarksHa
ndlerTest.java
changed 1.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/SubtaskCurrentAttemptDetailsH
andlerTest.java
changed 1.9% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/SubtaskExecutionAttemptAccumu
latorsHandlerTest.java
changed 2.4% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/SubtaskExecutionAttemptDetail
sHandlerTest.java
changed 1.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCacheTest.ja
va
renamed 6.2% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/legacy/DefaultExecutionGraphCacheTest.java
flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestServerEndpointITCase.java changed 2.1% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/util/DocumentingDispatcherRestEndpoint.ja
va
changed 26.5% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/util/NoOpExecutionGraphCache.java added
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java changed 10.2% diff
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java changed 5.4% diff
flink-runtime/src/test/java/org/apache/flink/runtime/state/KeyGroupsStateHandleTest.java added
flink-runtime/src/test/java/org/apache/flink/runtime/state/SnapshotDirectoryTest.java changed 18.2% diff
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java changed 4.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateSnapshotTransformerTest.java changed 1.3% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/JobLeaderServiceTest.java added
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorPartitionLifecycleTes
t.java
changed 5.5% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorSubmissionTest.java changed 4.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorTest.java changed 10.5% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskSubmissionTestEnvironment.jav
a
changed 3.5% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TestingTaskExecutor.java changed 3.2% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java changed 2.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TestingTaskManagerActions.java added
flink-runtime/src/test/java/org/apache/flink/runtime/webmonitor/TestingExecutionGraphCache.java added
flink-runtime/src/test/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpointTest.java added
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/st
ate/restore/RocksDBIncrementalRestoreOperation.java
changed 6.9% diff
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/st
ate/RocksDBOperationUtils.java
changed 8.7% diff
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/st
ate/RocksDBStateBackend.java
changed 2.5% diff
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/st
ate/RocksDBStateDownloader.java
changed 7.5% diff
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/st
ate/RocksDBStateUploader.java
changed 5.4% diff
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/st
ate/snapshot/RocksIncrementalSnapshotStrategy.java
changed 3.0% diff
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/st
ate/RocksDBAsyncSnapshotTest.java
changed 0.8% diff
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/st
ate/RocksDBOperationsUtilsTest.java
added
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/st
ate/RocksDBStateBackendConfigTest.java
changed 4.6% diff
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/st
ate/RocksDBStateDownloaderTest.java
changed 4.8% diff
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/st
ate/RocksDBStateUploaderTest.java
changed 7.2% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSource.java changed 3.4% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnviro
nment.java
changed 0.1% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamPlanEnvironment
.java
changed 1.6% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/OutputF
ileConfig.java
changed 2.6% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/Streami
ngFileSink.java
changed 6.9% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.
java
changed 0.1% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java changed 5.9% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java changed 0.9% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/functions/sink/filesystem/BulkWri
terTest.java
changed 1.3% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorT
est.java
changed 4.7% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/StreamSourceOperato
rWatermarksTest.java
changed 2.3% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTaskTest.ja
va
changed 1.1% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/AbstractStreamOperatorTestHarnes
s.java
changed 1.4% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/PackagedProgramUtilsTest.java added
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionCon
text.java
changed 2.4% diff
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/LocalExecuto
r.java
changed 1.9% diff
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ProgramDeplo
yer.java
changed 3.5% diff
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/Colle
ctStreamResult.java
changed 5.9% diff
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/Dynam
icResult.java
changed 11.8% diff
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/Mater
ializedCollectBatchResult.java
changed 5.1% diff
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/LocalExecuto
rITCase.java
changed 3.2% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOpt
ions.java
changed 1.8% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironment
Impl.java
changed 0.3% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java changed 1.2% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/functions/FunctionDefinitionU
til.java
changed 14.2% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/module/ModuleManager.java changed 4.0% diff
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/functions/FunctionDefinitionU
tilTest.java
changed 72.8% diff
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/transforms/Lega
cyRawTypeTransformation.java
added
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/TypeTransformat
ions.java
changed 12.1% diff
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TypeMappingUtils.java changed 25.2% diff
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/TypeTransformat
ionsTest.java
changed 25.9% diff
flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/TypeMappingUtilsTest.java changed 20.8% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/calcite/CalciteP
arser.java
changed 3.1% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/calcite/SqlExprT
oRexConverter.java
changed 22.8% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlTo
OperationConverter.java
changed 3.6% diff
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/utils/Ja
vaPojos.java
changed 100.0% diff
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/calcite/CalciteParser.java changed 3.1% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOut
putFormat.java
changed 8.9% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/PartitionTemp
FileManager.java
changed 11.6% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/SqlDat
eTimeUtils.java
changed 4.1% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggreg
ate/GroupAggFunction.java
changed 3.9% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/BaseRo
wSerializer.java
changed 2.6% diff
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils/BaseRo
wSerializerTest.java
changed 14.5% diff
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/util/BaseRowHarn
essAssertor.java
changed 8.5% diff
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/util/StreamRecor
dUtils.java
changed 5.5% diff
flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/Common
TestUtils.java
changed 13.1% diff
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestProcessBuilde
r.java
changed 15.7% diff
flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterStopWithSavepointIT.java changed 1.7% diff
flink-tests/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTriggerSavepointITCase.java changed 1.1% diff
flink-tests/src/test/java/org/apache/flink/runtime/util/ExceptionUtilsITCases.java added
flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java changed 0.9% diff
flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java changed 1.1% diff
flink-tests/src/test/java/org/apache/flink/test/example/client/LocalExecutorITCase.java changed 65.3% diff
flink-tests/src/test/java/org/apache/flink/test/optimizer/jsonplan/DumpCompiledPlanTest.java changed 4.3% diff
flink-tests/src/test/java/org/apache/flink/test/optimizer/jsonplan/PreviewPlanDumpTest.java changed 4.2% diff
flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractTaskManagerProcessFailureRecoveryT
est.java
changed 0.5% diff
flink-tests/src/test/java/org/apache/flink/test/recovery/ProcessFailureCancelingITCase.java changed 1.3% diff
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java changed 0.6% diff
flink-yarn/src/test/java/org/apache/flink/yarn/FlinkYarnSessionCliTest.java changed 8.6% diff
flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java changed 8.7% diff

Python Programs (24 of 111):

NameStatusDeltaVisual Diff
docs/dev/table/functions/udfs.md changed 10.2% diff
docs/dev/table/functions/udfs.zh.md changed 10.2% diff
docs/dev/table/python/common_questions.md added
docs/dev/table/python/common_questions.zh.md added
docs/dev/table/python/dependency_management.md added
docs/dev/table/python/dependency_management.zh.md added
docs/dev/table/python/python_udfs.md added
docs/dev/table/python/python_udfs.zh.md added
docs/tutorials/python_table_api.md changed 16.6% diff
docs/tutorials/python_table_api.zh.md changed 9.6% diff
flink-python/pyflink/__init__.py changed 31.1% diff
flink-python/pyflink/fn_execution/coders.py changed 0.6% diff
flink-python/pyflink/fn_execution/tests/test_process_mode_boot.py changed 0.7% diff
flink-python/pyflink/java_gateway.py changed 11.3% diff
flink-python/pyflink/table/catalog.py changed 0.2% diff
flink-python/pyflink/table/examples/batch/word_count.py changed 17.0% diff
flink-python/pyflink/table/table_config.py changed 0.5% diff
flink-python/pyflink/table/table_environment.py changed 2.0% diff
flink-python/pyflink/table/tests/test_dependency.py changed 10.1% diff
flink-python/pyflink/table/tests/test_table_environment_api.py changed 16.7% diff
flink-python/pyflink/table/types.py changed 3.2% diff
flink-python/pyflink/util/utils.py changed 74.2% diff
flink-python/pyflink/version.py changed 2.2% diff
flink-python/setup.py changed 3.1% diff

Shell Programs (18 of 141):

NameStatusDeltaVisual Diff
docs/downloads/setup-pyflink-virtual-env.sh added
flink-dist/src/main/flink-bin/bin/config.sh changed 3.2% diff
flink-dist/src/main/flink-bin/bin/flink changed 13.5% diff
flink-dist/src/main/flink-bin/bin/taskmanager.sh changed 10.5% diff
flink-dist/src/test/bin/runBashJavaUtilsCmd.sh changed 23.6% diff
flink-end-to-end-tests/run-nightly-tests.sh changed 3.2% diff
flink-end-to-end-tests/test-scripts/common.sh changed 0.7% diff
flink-end-to-end-tests/test-scripts/common_kubernetes.sh changed 3.4% diff
flink-end-to-end-tests/test-scripts/common_mesos_docker.sh changed 3.1% diff
flink-end-to-end-tests/test-scripts/common_s3_operations.sh changed 2.6% diff
flink-end-to-end-tests/test-scripts/elasticsearch-common.sh changed 8.0% diff
flink-end-to-end-tests/test-scripts/test_batch_wordcount.sh changed 3.3% diff
flink-end-to-end-tests/test-scripts/test_quickstarts.sh changed 2.1% diff
flink-end-to-end-tests/test-scripts/test_rocksdb_state_memory_control.sh changed 1.2% diff
flink-end-to-end-tests/test-scripts/test_sql_client.sh changed 25.0% diff
flink-python/bin/pyflink-udf-runner.sh changed 14.9% diff
tools/travis/splits/split_checkpoints.sh changed 2.0% diff
tools/travis/splits/split_misc.sh changed 9.1% diff

SGML Documents (65 of 367):

NameStatusDeltaVisual Diff
docs/concepts/glossary.md changed 4.6% diff
docs/dev/stream/state/state.zh.md changed 5.0% diff
docs/dev/table/config.md changed 1.9% diff
docs/dev/table/connect.md changed 2.9% diff
docs/dev/table/connect.zh.md changed 2.6% diff
docs/dev/table/hive/hive_catalog.md changed 77.2% diff
docs/dev/table/hive/hive_catalog.zh.md changed 77.2% diff
docs/dev/table/hive/index.md changed 18.8% diff
docs/dev/table/hive/index.zh.md changed 18.8% diff
docs/dev/table/python/index.md added
docs/dev/table/python/index.zh.md added
docs/dev/table/python/installation.md added
docs/dev/table/python/installation.zh.md added
docs/dev/table/python/python_config.md added
docs/dev/table/python/python_config.zh.md added
docs/dev/table/sql/queries.md changed 0.5% diff
docs/dev/table/sql/queries.zh.md changed 1.4% diff
docs/dev/table/streaming/query_configuration.md changed 18.4% diff
docs/dev/table/streaming/query_configuration.zh.md changed 18.4% diff
docs/flinkDev/building.md changed 2.1% diff
docs/flinkDev/building.zh.md changed 2.2% diff
docs/getting-started/tutorials/flink_on_windows.md changed 32.8% diff
docs/getting-started/tutorials/flink_on_windows.zh.md changed 32.8% diff
docs/monitoring/application_profiling.md changed 65.8% diff
docs/monitoring/application_profiling.zh.md changed 64.1% diff
docs/ops/cli.md changed 2.5% diff
docs/ops/cli.zh.md changed 2.4% diff
docs/ops/config.md changed 0.9% diff
docs/ops/config.zh.md changed 0.9% diff
docs/ops/deployment/cluster_setup.md changed 3.2% diff
docs/ops/deployment/cluster_setup.zh.md changed 3.2% diff
docs/ops/deployment/docker.md changed 39.1% diff
docs/ops/deployment/docker.zh.md changed 39.2% diff
docs/ops/deployment/kubernetes.md changed 7.0% diff
docs/ops/deployment/kubernetes.zh.md changed 7.2% diff
docs/ops/deployment/native_kubernetes.md changed 17.2% diff
docs/ops/deployment/native_kubernetes.zh.md changed 17.3% diff
docs/ops/filesystems/s3.md changed 2.6% diff
docs/ops/filesystems/s3.zh.md changed 80.5% diff
docs/ops/memory/index.md added
docs/ops/memory/index.zh.md added
docs/ops/memory/mem_detail.md added
docs/ops/memory/mem_detail.zh.md added
docs/ops/memory/mem_setup.md added
docs/ops/memory/mem_setup.zh.md added
docs/ops/memory/mem_trouble.md added
docs/ops/memory/mem_trouble.zh.md added
docs/ops/memory/mem_tuning.md added
docs/ops/memory/mem_tuning.zh.md added
docs/ops/plugins.md changed 2.2% diff
docs/ops/plugins.zh.md changed 2.2% diff
docs/ops/production_ready.md changed 0.3% diff
docs/ops/production_ready.zh.md changed 0.3% diff
docs/ops/python_shell.md changed 13.8% diff
docs/ops/python_shell.zh.md changed 11.9% diff
docs/ops/scala_shell.md changed 0.1% diff
docs/ops/scala_shell.zh.md changed 0.1% diff
docs/ops/security-ssl.md changed 0.1% diff
docs/ops/security-ssl.zh.md changed 0.1% diff
docs/ops/state/state_backends.md changed 2.4% diff
docs/ops/state/state_backends.zh.md changed 2.2% diff
docs/ops/upgrading.md changed 0.1% diff
docs/ops/upgrading.zh.md changed 0.1% diff
docs/release-notes/flink-1.10.md changed 33.6% diff
docs/release-notes/flink-1.10.zh.md changed 33.6% diff

XML Documents (190 of 392):

NameStatusDeltaVisual Diff
flink-annotations/pom.xml changed 2.3% diff
flink-clients/pom.xml changed 0.5% diff
flink-connectors/flink-connector-cassandra/pom.xml changed 0.4% diff
flink-connectors/flink-connector-elasticsearch-base/pom.xml changed 0.6% diff
flink-connectors/flink-connector-elasticsearch2/pom.xml changed 0.4% diff
flink-connectors/flink-connector-elasticsearch5/pom.xml changed 0.3% diff
flink-connectors/flink-connector-elasticsearch6/pom.xml changed 0.5% diff
flink-connectors/flink-connector-elasticsearch7/pom.xml changed 0.5% diff
flink-connectors/flink-connector-filesystem/pom.xml changed 0.6% diff
flink-connectors/flink-connector-gcp-pubsub/pom.xml changed 1.0% diff
flink-connectors/flink-connector-hive/pom.xml changed 3.0% diff
flink-connectors/flink-connector-kafka-0.10/pom.xml changed 0.9% diff
flink-connectors/flink-connector-kafka-0.11/pom.xml changed 0.4% diff
flink-connectors/flink-connector-kafka-0.8/pom.xml changed 0.4% diff
flink-connectors/flink-connector-kafka-0.9/pom.xml changed 0.4% diff
flink-connectors/flink-connector-kafka-base/pom.xml changed 0.4% diff
flink-connectors/flink-connector-kafka/pom.xml changed 0.4% diff
flink-connectors/flink-connector-kinesis/pom.xml changed 4.7% diff
flink-connectors/flink-connector-nifi/pom.xml changed 1.0% diff
flink-connectors/flink-connector-rabbitmq/pom.xml changed 1.3% diff
flink-connectors/flink-connector-twitter/pom.xml changed 0.9% diff
flink-connectors/flink-hadoop-compatibility/pom.xml changed 0.5% diff
flink-connectors/flink-hbase/pom.xml changed 0.3% diff
flink-connectors/flink-hcatalog/pom.xml changed 0.5% diff
flink-connectors/flink-jdbc/pom.xml changed 1.0% diff
flink-connectors/flink-sql-connector-elasticsearch6/pom.xml changed 0.6% diff
flink-connectors/flink-sql-connector-elasticsearch7/pom.xml changed 9.4% diff
flink-connectors/flink-sql-connector-kafka-0.10/pom.xml changed 1.0% diff
flink-connectors/flink-sql-connector-kafka-0.11/pom.xml changed 0.9% diff
flink-connectors/flink-sql-connector-kafka-0.9/pom.xml changed 1.0% diff
flink-connectors/flink-sql-connector-kafka/pom.xml changed 1.0% diff
flink-connectors/pom.xml changed 2.0% diff
flink-container/pom.xml changed 0.6% diff
flink-contrib/flink-connector-wikiedits/pom.xml changed 1.6% diff
flink-contrib/pom.xml changed 1.9% diff
flink-core/pom.xml changed 0.4% diff
flink-dist/pom.xml changed 0.1% diff
flink-docs/pom.xml changed 0.4% diff
flink-end-to-end-tests/flink-batch-sql-test/pom.xml changed 1.3% diff
flink-end-to-end-tests/flink-bucketing-sink-test/pom.xml changed 1.0% diff
flink-end-to-end-tests/flink-cli-test/pom.xml changed 1.3% diff
flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml changed 0.7% diff
flink-end-to-end-tests/flink-connector-gcp-pubsub-emulator-tests/pom.xml changed 0.8% diff
flink-end-to-end-tests/flink-dataset-allround-test/pom.xml changed 1.3% diff
flink-end-to-end-tests/flink-dataset-fine-grained-recovery-test/pom.xml changed 1.1% diff
flink-end-to-end-tests/flink-datastream-allround-test/pom.xml changed 0.7% diff
flink-end-to-end-tests/flink-distributed-cache-via-blob-test/pom.xml changed 1.2% diff
flink-end-to-end-tests/flink-elasticsearch2-test/pom.xml changed 1.2% diff
flink-end-to-end-tests/flink-elasticsearch5-test/pom.xml changed 1.2% diff
flink-end-to-end-tests/flink-elasticsearch6-test/pom.xml changed 1.0% diff
flink-end-to-end-tests/flink-elasticsearch7-test/pom.xml changed 1.0% diff
flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/pom.xml changed 0.6% diff
flink-end-to-end-tests/flink-end-to-end-tests-common/pom.xml changed 1.2% diff
flink-end-to-end-tests/flink-heavy-deployment-stress-test/pom.xml changed 1.1% diff
flink-end-to-end-tests/flink-high-parallelism-iterations-test/pom.xml changed 1.0% diff
flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml changed 1.2% diff
flink-end-to-end-tests/flink-metrics-availability-test/pom.xml changed 1.4% diff
flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/pom.xml changed 1.3% diff
flink-end-to-end-tests/flink-parent-child-classloading-test-lib-package/pom.xml changed 1.5% diff
flink-end-to-end-tests/flink-parent-child-classloading-test-program/pom.xml changed 1.2% diff
flink-end-to-end-tests/flink-plugins-test/another-dummy-fs/pom.xml changed 1.3% diff
flink-end-to-end-tests/flink-plugins-test/dummy-fs/pom.xml changed 1.3% diff
flink-end-to-end-tests/flink-plugins-test/pom.xml changed 2.0% diff
flink-end-to-end-tests/flink-queryable-state-test/pom.xml changed 0.7% diff
flink-end-to-end-tests/flink-quickstart-test/pom.xml changed 1.3% diff
flink-end-to-end-tests/flink-rocksdb-state-memory-control-test/pom.xml changed 4.3% diff
flink-end-to-end-tests/flink-sql-client-test/pom.xml changed 7.3% diff
flink-end-to-end-tests/flink-state-evolution-test/pom.xml changed 0.8% diff
flink-end-to-end-tests/flink-stream-sql-test/pom.xml changed 1.1% diff
flink-end-to-end-tests/flink-stream-state-ttl-test/pom.xml changed 1.1% diff
flink-end-to-end-tests/flink-stream-stateful-job-upgrade-test/pom.xml changed 1.2% diff
flink-end-to-end-tests/flink-streaming-file-sink-test/pom.xml changed 1.4% diff
flink-end-to-end-tests/flink-streaming-kafka-test-base/pom.xml changed 1.9% diff
flink-end-to-end-tests/flink-streaming-kafka-test/pom.xml changed 1.0% diff
flink-end-to-end-tests/flink-streaming-kafka010-test/pom.xml changed 1.0% diff
flink-end-to-end-tests/flink-streaming-kafka011-test/pom.xml changed 1.0% diff
flink-end-to-end-tests/flink-streaming-kinesis-test/pom.xml changed 0.9% diff
flink-end-to-end-tests/flink-tpcds-test/pom.xml changed 1.1% diff
flink-end-to-end-tests/flink-tpch-test/pom.xml changed 1.3% diff
flink-end-to-end-tests/pom.xml changed 0.6% diff
flink-examples/flink-examples-batch/pom.xml changed 0.2% diff
flink-examples/flink-examples-build-helper/flink-examples-streaming-gcp-pubsub/pom.xml changed 0.8% diff
flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/pom.xml changed 0.8% diff
flink-examples/flink-examples-build-helper/flink-examples-streaming-twitter/pom.xml changed 1.0% diff
flink-examples/flink-examples-build-helper/pom.xml changed 1.9% diff
flink-examples/flink-examples-streaming/pom.xml changed 0.2% diff
flink-examples/flink-examples-table/pom.xml changed 3.0% diff
flink-examples/pom.xml changed 1.0% diff
flink-filesystems/flink-azure-fs-hadoop/pom.xml changed 0.4% diff
flink-filesystems/flink-fs-hadoop-shaded/pom.xml changed 0.4% diff
flink-filesystems/flink-hadoop-fs/pom.xml changed 1.0% diff
flink-filesystems/flink-mapr-fs/pom.xml changed 1.4% diff
flink-filesystems/flink-oss-fs-hadoop/pom.xml changed 12.8% diff
flink-filesystems/flink-s3-fs-base/pom.xml changed 0.4% diff
flink-filesystems/flink-s3-fs-hadoop/pom.xml changed 7.9% diff
flink-filesystems/flink-s3-fs-presto/pom.xml changed 4.5% diff
flink-filesystems/flink-swift-fs-hadoop/pom.xml changed 0.3% diff
flink-filesystems/pom.xml changed 1.1% diff
flink-formats/flink-avro-confluent-registry/pom.xml changed 0.8% diff
flink-formats/flink-avro/pom.xml changed 0.3% diff
flink-formats/flink-compress/pom.xml changed 1.1% diff
flink-formats/flink-csv/pom.xml changed 1.1% diff
flink-formats/flink-json/pom.xml changed 0.9% diff
flink-formats/flink-orc/pom.xml changed 0.7% diff
flink-formats/flink-parquet/pom.xml changed 0.6% diff
flink-formats/flink-sequence-file/pom.xml changed 1.0% diff
flink-formats/pom.xml changed 1.4% diff
flink-fs-tests/pom.xml changed 0.7% diff
flink-java/pom.xml changed 1.2% diff
flink-kubernetes/pom.xml changed 0.5% diff
flink-libraries/flink-cep-scala/pom.xml changed 0.6% diff
flink-libraries/flink-cep/pom.xml changed 0.9% diff
flink-libraries/flink-gelly-examples/pom.xml changed 0.4% diff
flink-libraries/flink-gelly-scala/pom.xml changed 0.4% diff
flink-libraries/flink-gelly/pom.xml changed 1.2% diff
flink-libraries/flink-state-processing-api/pom.xml changed 0.9% diff
flink-libraries/pom.xml changed 1.4% diff
flink-mesos/pom.xml changed 0.3% diff
flink-metrics/flink-metrics-core/pom.xml changed 1.5% diff
flink-metrics/flink-metrics-datadog/pom.xml changed 1.1% diff
flink-metrics/flink-metrics-dropwizard/pom.xml changed 1.1% diff
flink-metrics/flink-metrics-graphite/pom.xml changed 1.0% diff
flink-metrics/flink-metrics-influxdb/pom.xml changed 9.1% diff
flink-metrics/flink-metrics-jmx/pom.xml changed 1.0% diff
flink-metrics/flink-metrics-prometheus/pom.xml changed 0.8% diff
flink-metrics/flink-metrics-slf4j/pom.xml changed 1.2% diff
flink-metrics/flink-metrics-statsd/pom.xml changed 1.2% diff
flink-metrics/pom.xml changed 1.4% diff
flink-ml-parent/flink-ml-api/pom.xml changed 1.9% diff
flink-ml-parent/flink-ml-lib/pom.xml changed 1.4% diff
flink-ml-parent/pom.xml changed 2.2% diff
flink-optimizer/pom.xml changed 1.0% diff
flink-python/pom.xml changed 0.3% diff
flink-queryable-state/flink-queryable-state-client-java/pom.xml changed 1.2% diff
flink-queryable-state/flink-queryable-state-runtime/pom.xml changed 0.8% diff
flink-queryable-state/pom.xml changed 1.5% diff
flink-quickstart/flink-quickstart-java/pom.xml changed 2.2% diff
flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/pom.xml changed 0.7% diff
flink-quickstart/flink-quickstart-scala/pom.xml changed 2.2% diff
flink-quickstart/flink-quickstart-scala/src/main/resources/archetype-resources/pom.xml changed 0.6% diff
flink-quickstart/pom.xml changed 1.0% diff
flink-runtime-web/pom.xml changed 0.4% diff
flink-runtime/pom.xml changed 0.2% diff
flink-scala-shell/pom.xml changed 0.4% diff
flink-scala/pom.xml changed 0.4% diff
flink-shaded-curator/pom.xml changed 1.1% diff
flink-state-backends/flink-statebackend-heap-spillable/pom.xml changed 1.5% diff
flink-state-backends/flink-statebackend-rocksdb/pom.xml changed 0.9% diff
flink-state-backends/pom.xml changed 2.0% diff
flink-streaming-java/pom.xml changed 0.9% diff
flink-streaming-scala/pom.xml changed 0.4% diff
flink-table/flink-sql-client/pom.xml changed 0.2% diff
flink-table/flink-sql-parser/pom.xml changed 0.4% diff
flink-table/flink-table-api-java-bridge/pom.xml changed 1.2% diff
flink-table/flink-table-api-java/pom.xml changed 1.3% diff
flink-table/flink-table-api-scala-bridge/pom.xml changed 0.8% diff
flink-table/flink-table-api-scala/pom.xml changed 0.8% diff
flink-table/flink-table-common/pom.xml changed 1.2% diff
flink-table/flink-table-planner-blink/pom.xml changed 0.2% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/batch/
sql/agg/HashAggregateTest.xml
changed 3.8% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/batch/
sql/agg/SortAggregateTest.xml
changed 3.5% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/rules/
logical/PythonCalcSplitRuleTest.xml
changed 65.4% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream
/sql/agg/AggregateTest.xml
changed 3.3% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream
/sql/agg/TwoStageAggregateTest.xml
changed 2.6% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream
/sql/CalcTest.xml
changed 7.0% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream
/sql/join/SemiAntiJoinTest.xml
changed 1.5% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream
/sql/RankTest.xml
changed 15.4% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream
/sql/TableScanTest.xml
changed 62.6% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream
/table/AggregateTest.xml
changed 2.0% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream
/table/TwoStageAggregateTest.xml
changed 6.7% diff
flink-table/flink-table-planner/pom.xml changed 0.2% diff
flink-table/flink-table-runtime-blink/pom.xml changed 0.6% diff
flink-table/flink-table-uber-blink/pom.xml changed 0.6% diff
flink-table/flink-table-uber/pom.xml changed 0.7% diff
flink-table/pom.xml changed 1.5% diff
flink-test-utils-parent/flink-test-utils-junit/pom.xml changed 2.0% diff
flink-test-utils-parent/flink-test-utils/pom.xml changed 0.6% diff
flink-test-utils-parent/pom.xml changed 2.1% diff
flink-tests/pom.xml changed 0.1% diff
flink-walkthroughs/flink-walkthrough-common/pom.xml changed 1.5% diff
flink-walkthroughs/flink-walkthrough-datastream-java/pom.xml changed 2.2% diff
flink-walkthroughs/flink-walkthrough-datastream-scala/pom.xml changed 2.2% diff
flink-walkthroughs/flink-walkthrough-table-java/pom.xml changed 2.2% diff
flink-walkthroughs/flink-walkthrough-table-scala/pom.xml changed 2.2% diff
flink-walkthroughs/pom.xml changed 1.0% diff
flink-yarn-tests/pom.xml changed 0.2% diff
flink-yarn/pom.xml changed 0.5% diff
pom.xml changed 0.2% diff
tools/force-shading/pom.xml changed 0.9% diff
tools/maven/suppressions.xml changed 5.0% diff

DOS Batch Files (2 of 3):

NameStatusDeltaVisual Diff
flink-dist/src/main/flink-bin/bin/flink.bat removed
flink-dist/src/main/flink-bin/bin/start-cluster.bat removed

HTML Pages (15 of 163):

NameStatusDeltaVisual Diff
docs/_includes/generated/common_memory_section.html changed 0.02%
docs/_includes/generated/environment_configuration.html changed 8.3%
docs/_includes/generated/execution_config_configuration.html changed 0.04%
docs/_includes/generated/rest_v1_dispatcher.html changed 0.6%
docs/_includes/generated/task_manager_memory_configuration.html changed 0.02%
docs/_includes/generated/web_configuration.html changed 0.1%
docs/dev/connectors/elasticsearch.md changed 0.5%
docs/dev/connectors/elasticsearch.zh.md changed 0.5%
docs/dev/table/modules.md changed 0.03%
docs/dev/table/modules.zh.md changed 0.03%
docs/getting-started/tutorials/local_setup.md changed 0.01%
docs/getting-started/tutorials/local_setup.zh.md changed 0.01%
docs/ops/memory/mem_migration.md added
docs/ops/memory/mem_migration.zh.md added
flink-runtime-web/web-dashboard/src/app/pages/job-manager/configuration/job-manager-configuration.c
omponent.html
changed 1.3%

Property Files (1 of 104):

NameStatusDeltaVisual Diff
flink-test-utils-parent/flink-test-utils-junit/src/main/resources/org/powermock/extensions/configur
ation.properties
added

Qt Translation Or MS TypeScript Files (1 of 107):

NameStatusDeltaVisual Diff
flink-runtime-web/web-dashboard/src/app/app.config.ts changed 4.2% diff

YAML Files (2 of 50):

NameStatusDeltaVisual Diff
docs/_config.yml changed 0.5% diff
flink-dist/src/main/resources/flink-conf.yaml changed 0.4% diff

Vector Image Files (2 of 50):

NameStatusDeltaVisual Diff
docs/fig/detailed-mem-model.svg added
docs/fig/simple_mem_model.svg added

Directories (20 of 4477):

NameStatus
docs/dev/table/python added
docs/downloads added
docs/ops/memory added
flink-filesystems/flink-s3-fs-base/src/main/java/com added
flink-filesystems/flink-s3-fs-base/src/main/java/com/amazonaws added
flink-filesystems/flink-s3-fs-base/src/main/java/com/amazonaws/services added
flink-filesystems/flink-s3-fs-base/src/main/java/com/amazonaws/services/s3 added
flink-filesystems/flink-s3-fs-base/src/main/java/com/amazonaws/services/s3/model added
flink-filesystems/flink-s3-fs-base/src/main/java/com/amazonaws/services/s3/model/transform added
flink-ml-parent/flink-ml-lib/src/main/resources moved
flink-test-utils-parent/flink-test-utils-junit/src/main/resources
flink-ml-parent/flink-ml-lib/src/main/resources/META-INF removed
flink-ml-parent/flink-ml-lib/src/main/resources/META-INF/licenses removed
flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/functions added
flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/functions/sink added
flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/functions/sink/filesystem added
flink-test-utils-parent/flink-test-utils-junit/src/main/resources/org added
flink-test-utils-parent/flink-test-utils-junit/src/main/resources/org/powermock added
flink-test-utils-parent/flink-test-utils-junit/src/main/resources/org/powermock/extensions added
flink-tests/src/test/java/org/apache/flink/runtime/util added

Information Files (36 of 37):

NameStatusDeltaVisual Diff
flink-connectors/flink-connector-cassandra/src/main/resources/META-INF/NOTICE changed 8.2% diff
flink-connectors/flink-connector-elasticsearch2/src/main/resources/META-INF/NOTICE changed 1.7% diff
flink-connectors/flink-connector-elasticsearch5/src/main/resources/META-INF/NOTICE changed 1.3% diff
flink-connectors/flink-connector-kinesis/src/main/resources/META-INF/NOTICE changed 100.0% diff
flink-connectors/flink-connector-twitter/src/main/resources/META-INF/NOTICE changed 10.8% diff
flink-connectors/flink-sql-connector-elasticsearch6/src/main/resources/META-INF/NOTICE changed 2.5% diff
flink-connectors/flink-sql-connector-elasticsearch7/src/main/resources/META-INF/NOTICE changed 11.1% diff
flink-connectors/flink-sql-connector-kafka-0.10/src/main/resources/META-INF/NOTICE changed 26.4% diff
flink-connectors/flink-sql-connector-kafka-0.11/src/main/resources/META-INF/NOTICE changed 14.6% diff
flink-connectors/flink-sql-connector-kafka-0.9/src/main/resources/META-INF/NOTICE changed 14.6% diff
flink-connectors/flink-sql-connector-kafka/src/main/resources/META-INF/NOTICE changed 14.9% diff
flink-dist/src/main/resources/META-INF/NOTICE changed 2.1% diff
flink-examples/flink-examples-build-helper/flink-examples-streaming-state-machine/src/main/resource
s/META-INF/NOTICE
changed 14.2% diff
flink-filesystems/flink-azure-fs-hadoop/src/main/resources/META-INF/NOTICE changed 5.9% diff
flink-filesystems/flink-fs-hadoop-shaded/src/main/resources/META-INF/NOTICE changed 0.04% diff
flink-filesystems/flink-oss-fs-hadoop/src/main/resources/META-INF/NOTICE changed 1.1% diff
flink-filesystems/flink-s3-fs-hadoop/src/main/resources/META-INF/NOTICE changed 2.6% diff
flink-filesystems/flink-s3-fs-presto/src/main/resources/META-INF/NOTICE changed 2.0% diff
flink-filesystems/flink-swift-fs-hadoop/src/main/resources/META-INF/NOTICE changed 0.1% diff
flink-formats/flink-avro-confluent-registry/src/main/resources/META-INF/NOTICE changed 8.4% diff
flink-mesos/src/main/resources/META-INF/NOTICE changed 7.7% diff
flink-metrics/flink-metrics-datadog/src/main/resources/META-INF/NOTICE changed 13.9% diff
flink-metrics/flink-metrics-graphite/src/main/resources/META-INF/NOTICE changed 13.1% diff
flink-metrics/flink-metrics-influxdb/src/main/resources/META-INF/NOTICE changed 47.7% diff
flink-metrics/flink-metrics-prometheus/src/main/resources/META-INF/NOTICE changed 10.9% diff
flink-ml-parent/flink-ml-lib/src/main/resources/META-INF/NOTICE removed
flink-python/src/main/resources/META-INF/NOTICE changed 2.1% diff
flink-runtime-web/src/main/resources/META-INF/NOTICE changed 0.1% diff
flink-runtime/src/main/resources/META-INF/NOTICE changed 3.2% diff
flink-shaded-curator/src/main/resources/META-INF/NOTICE changed 11.1% diff
flink-table/flink-sql-client/src/main/resources/META-INF/NOTICE changed 15.3% diff
flink-table/flink-table-planner-blink/src/main/resources/META-INF/NOTICE changed 5.7% diff
flink-table/flink-table-planner/src/main/resources/META-INF/NOTICE changed 5.7% diff
flink-table/flink-table-runtime-blink/src/main/resources/META-INF/NOTICE changed 14.5% diff
flink-test-utils-parent/flink-test-utils/src/main/resources/META-INF/NOTICE changed 3.5% diff
NOTICE changed 3.5% diff

Licenses (17 of 87):

NameStatusDeltaVisual Diff
flink-ml-parent/flink-ml-lib/src/main/resources/META-INF/licenses/LICENSE.core removed
licenses/LICENSE.angular removed
licenses/LICENSE.angular-drag-and-drop-list removed
licenses/LICENSE.angular-moment removed
licenses/LICENSE.angular-ui-router removed
licenses/LICENSE.bootstrap removed
licenses/LICENSE.d3 removed
licenses/LICENSE.dagre removed
licenses/LICENSE.dagre-d3 removed
licenses/LICENSE.ev-emitter removed
licenses/LICENSE.graphlib removed
licenses/LICENSE.imagesloaded removed
licenses/LICENSE.lodash removed
licenses/LICENSE.moment removed
licenses/LICENSE.moment-duration-format removed
licenses/LICENSE.qtip2 removed
licenses/LICENSE.split removed

Text Files (37 of 2049):

NameStatusDeltaVisual Diff
flink-python/MANIFEST.in changed 3.9% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkPl
annerImpl.scala
changed 0.4% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/S
calarFunctionCallGen.scala
changed 5.5% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/Express
ionReducer.scala
changed 1.4% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/Generat
eUtils.scala
changed 0.6% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/SinkCod
eGenerator.scala
changed 6.6% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/cal
l.scala
changed 0.2% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/functions/utils
/ScalarSqlFunction.scala
changed 7.2% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/functions/utils
/UserDefinedFunctionUtils.scala
changed 0.1% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/Flin
kBatchRuleSets.scala
changed 0.3% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/Flin
kStreamRuleSets.scala
changed 1.0% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logi
cal/PythonCalcSplitRule.scala
changed 21.8% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/schema/Cat
alogSourceTable.scala
changed 30.7% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/sinks/TableSink
Utils.scala
changed 31.4% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentITC
ase.scala
changed 14.7% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/catalog/Catalog
TableITCase.scala
changed 9.6% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/Dec
imalTypeTest.scala
changed 0.4% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/Tem
poralTypesTest.scala
changed 1.5% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/Use
rDefinedScalarFunctionTest.scala
changed 9.2% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/
agg/AggregateTestBase.scala
changed 3.6% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/
TableScanTest.scala
changed 18.0% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/rules/logi
cal/PythonCalcSplitRuleTest.scala
changed 9.9% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql
/agg/AggregateTest.scala
changed 2.6% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql
/CalcTest.scala
changed 3.7% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql
/TableScanTest.scala
changed 40.1% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/batch/s
ql/PartitionableSinkITCase.scala
changed 8.7% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/harness
/GroupAggregateHarnessTest.scala
added
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/
sql/AggregateITCase.scala
changed 2.9% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/
sql/StreamTableEnvironmentITCase.scala
added
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/utils/S
treamTestSink.scala
changed 1.1% diff
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/FlinkRuleSets.scal
a
changed 0.4% diff
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/PythonCalc
SplitRule.scala
changed 21.8% diff
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/DataStreamConversions
.scala
changed 2.0% diff
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/sinks/TableSinkUtils.scala changed 4.3% diff
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/batch/sql/validation/Inse
rtIntoValidationTest.scala
changed 24.3% diff
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/plan/PythonCalcSplitRuleTest.
scala
changed 19.3% diff
tools/releasing/NOTICE-binary_PREAMBLE.txt changed 8.4% diff

Packages Compared:

flink-1.10.0-src.tgz
flink-1.10.1-src.tgz


Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)