"Fossies" - the Fresh Open Source Software Archive  

Source code changes report for "flink" between the packages
flink-1.13.0-src.tgz and flink-1.13.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.2% and now consists of 17579 regular files (+35) and 5480 directories (-3).

Related Informations:

None found by Fossies.

Changes In Files (According File Type):

File TypeTotalAddedRemovedChanged
Header file 1 0 0 0
C program 133 0 0 2
Assembler program 6 0 0 2
Java program 11959 22 7 277
Python program 241 10 4 37
Shell program 140 1 0 8
Configuration file 6 0 0 0
Executable file 17 0 0 0
Initialization file 1 0 0 0
JavaScript file 5 0 0 0
JSON file 17 0 0 0
Makefile 1 0 0 0
Man page 1 0 0 0
SGML document 448 12 2 52
XML document 453 0 0 186
CSS style sheet 4 0 0 0
CSV file 5 0 0 0
DOS Batch file 1 0 0 0
Font file 10 0 0 0
Git file 3 0 0 0
HTML page 232 0 0 9
Log file 2 0 0 0
MS Windows file 5 0 0 0
Property file 98 1 0 1
Protocol Buffer file 2 0 0 0
Qt Translation or MS TypeScript file 120 0 0 1
RST file 7 0 0 0
Sass CSS style sheet 2 0 0 0
SQL file 111 1 1 0
YAML file 54 1 0 1
Data file 866 1 0 0
Icon 1 0 0 0
Image file 81 3 4 0
Vector Image file 72 0 0 0
Directory 5488 5 8 0
Archive 4 0 0 0
Information file 40 0 0 1
License 91 0 0 0
Readme file 20 0 0 0
Text file 2310 1 0 25
Other 27 0 0 0
Total Files230855826602



C Programs (2 of 133):

NameStatusDeltaVisual Diff
docs/content.zh/docs/learn-flink/datastream_api.md changed 1.8% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/metadata/F
linkRelMdHandlerTestBase.scala
changed 0.2% diff

Assembler Programs (2 of 6):

NameStatusDeltaVisual Diff
docs/content.zh/docs/libs/gelly/graph_api.md changed 1.5% diff
docs/content/docs/libs/gelly/graph_api.md changed 1.5% diff

Java Programs (306 of 11959):

NameStatusDeltaVisual Diff
docs/content.zh/docs/dev/datastream/operators/process_function.md changed 26.6% diff
docs/content.zh/docs/dev/table/common.md changed 35.5% diff
docs/content.zh/docs/dev/table/data_stream_api.md added
docs/content/docs/dev/datastream/operators/process_function.md changed 26.6% diff
docs/content/docs/dev/table/data_stream_api.md added
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java changed 2.4% diff
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java changed 5.9% diff
flink-clients/src/test/java/org/apache/flink/client/program/PerJobMiniClusterFactoryTest.java changed 3.2% diff
flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java changed 8.2% diff
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cass
andra/CassandraConnectorITCase.java
changed 1.4% diff
flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connec
tors/elasticsearch/table/ElasticsearchOptions.java
changed 9.1% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveSourceFile
Enumerator.java
changed 2.2% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveInput
FormatPartitionReader.java
changed 13.3% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTable
InputFormat.java
changed 6.2% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/
HiveParser.java
changed 1.3% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/
HiveParserFactory.java
changed 13.6% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/
SqlFunctionConverter.java
changed 2.9% diff
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkI
TCase.java
changed 51.4% diff
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/read/HiveInput
FormatPartitionReaderITCase.java
added
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynam
icTableFactory.java
changed 11.5% diff
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/ta
ble/KafkaOptions.java
changed 15.3% diff
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/ta
ble/KafkaTableTestBase.java
changed 2.8% diff
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/config/ConsumerConfigConstants.java
changed 1.6% diff
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/FlinkKinesisConsumer.java
changed 0.6% diff
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/internals/KinesisDataFetcher.java
changed 2.5% diff
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/internals/publisher/fanout/FanOutRecordPublisher.java
changed 1.6% diff
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/internals/publisher/fanout/FanOutRecordPublisherConfiguration.java
changed 3.3% diff
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/internals/publisher/fanout/FanOutShardSubscriber.java
changed 22.9% diff
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/table/KinesisOptions.java
changed 14.9% diff
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/FlinkKinesisITCase.java
added
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/FlinkKinesisProducerTest.java
changed 0.4% diff
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/internals/KinesisDataFetcherTest.java
changed 5.4% diff
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/internals/publisher/fanout/FanOutRecordPublisherConfigurationTest.java
changed 20.8% diff
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/internals/publisher/fanout/FanOutShardSubscriberTest.java
changed 60.0% diff
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/KinesisConsumerTest.java
changed 3.2% diff
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/testutils/FakeKinesisFanOutBehavioursFactory.java
changed 3.3% diff
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/testutils/KinesaliteContainer.java
added
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/testutils/TestableKinesisDataFetcher.java
changed 12.0% diff
flink-core/src/main/java/org/apache/flink/configuration/DeploymentOptions.java changed 19.9% diff
flink-end-to-end-tests/flink-streaming-kinesis-test/src/test/java/org/apache/flink/streaming/kinesi
s/test/containers/KinesaliteContainer.java
removed
flink-end-to-end-tests/flink-streaming-kinesis-test/src/test/java/org/apache/flink/streaming/kinesi
s/test/KinesisTableApiITCase.java
changed 26.2% diff
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesHaServices.ja
va
changed 2.6% diff
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleSt
ore.java
changed 13.5% diff
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java changed 4.8% diff
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/FlinkKubeClient.java changed 7.4% diff
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesLeaderEle
ctor.java
changed 8.5% diff
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesHaServicesTes
t.java
changed 52.2% diff
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesHighAvailabil
ityTestBase.java
changed 0.3% diff
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesLeaderElectio
nAndRetrievalITCase.java
changed 4.1% diff
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleSt
oreITCase.java
changed 7.9% diff
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleSt
oreTest.java
changed 74.4% diff
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClientTest.ja
va
changed 11.0% diff
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesClientTestBase.java changed 24.9% diff
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/MixedKubernetesServer.java changed 6.3% diff
flink-python/src/main/java/org/apache/flink/python/PythonOptions.java changed 2.0% diff
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/WebFrontendITCase.java changed 2.3% diff
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java changed 1.0% diff
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetaData.java changed 34.0% diff
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java changed 47.8% diff
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsSnapshot.java changed 8.3% diff
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCompletedCheckpointStore.jav
a
changed 20.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java changed 3.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobMasterServiceLeadershipRunnerFac
tory.java
changed 1.0% diff
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MiniDispatcher.java changed 8.6% diff
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ArchivedExecutionGraph.java changed 3.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java changed 0.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractHaServices.java changed 6.3% diff
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/HighAvailabilityServices.java changed 3.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperHaServices
.java
changed 15.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferPool.java changed 2.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java changed 0.8% diff
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalRecoveredIn
putChannel.java
changed 1.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.
java
changed 3.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedResultPartition.
java
changed 15.9% diff
flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/AbstractIterativeTask.java changed 2.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationHeadTask.java changed 0.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationIntermediateTask.java changed 28.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationSynchronizationSinkTas
k.java
changed 2.7% diff
flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationTailTask.java changed 29.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/Terminable.java changed 3.3% diff
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointRestoreSettings.java changed 5.8% diff
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/AbstractInvokable.java changed 2.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/factories/DefaultJobMasterServicePro
cessFactory.java
changed 14.7% diff
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.jav
a
changed 3.3% diff
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobResult.java changed 1.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java changed 0.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/SubtaskGatewayImpl.java changed 2.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSinkTask.java changed 1.6% diff
flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSourceTask.java changed 1.8% diff
flink-runtime/src/main/java/org/apache/flink/runtime/persistence/PossibleInconsistentStateException
.java
added
flink-runtime/src/main/java/org/apache/flink/runtime/persistence/StateHandleStore.java changed 10.8% diff
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotMan
ager.java
changed 0.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobExceptionsHandler.java changed 1.7% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java changed 1.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java changed 1.3% diff
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Canceling.java changed 5.6% diff
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java changed 8.7% diff
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Failing.java changed 4.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Finished.java changed 8.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/JobGraphJobInformation.java changed 5.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Restarting.java changed 3.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.jav
a
changed 1.0% diff
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StopWithSavepoint.java changed 3.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/exceptionhistory/ExceptionHistoryEnt
ry.java
changed 3.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java changed 2.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/util/StateHandleStoreUtils.java added
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java changed 24.5% diff
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorFailureTest.ja
va
changed 47.5% diff
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTestingUtils.j
ava
changed 0.6% diff
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/DefaultCompletedCheckpointStoreTest
.java
changed 10.0% diff
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStoreMo
ckitoTest.java
changed 8.7% diff
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java changed 6.7% diff
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java changed 13.0% diff
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/TestingDispatcher.java changed 2.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ArchivedExecutionGraphTest.java changed 4.6% diff
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/AbstractHaServicesTest.java changed 19.9% diff
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/TestingHighAvailabilityServic
es.java
changed 3.6% diff
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperHaServices
Test.java
changed 37.2% diff
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NoOpBufferPool.java changed 5.5% diff
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/UnpooledBufferPool.java added
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PipelinedResultPartitionR
eleaseOnConsumptionTest.java
changed 28.0% diff
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionWith
ReadViewTest.java
changed 0.1% diff
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionFactoryTes
t.java
changed 5.0% diff
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/DefaultJobMasterServiceProcessTest.j
ava
changed 0.9% diff
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/factories/TestingJobMasterServicePro
cessFactory.java
changed 2.1% diff
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/factories/TestingJobMasterServicePro
cessFactoryOld.java
changed 2.4% diff
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunnerTest
.java
changed 1.9% diff
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/TestingAbstractInvokables.java changed 3.2% diff
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/TestingJobManagerRunner.java changed 8.1% diff
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/LeaderChangeClusterComponentsTe
st.java
changed 7.1% diff
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/TestingLeaderElectionEventHandl
er.java
changed 56.2% diff
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionTest.jav
a
changed 0.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/CoordinatorEventsExactl
yOnceITCase.java
changed 14.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/persistence/TestingLongStateHandleHelper.java changed 100.0% diff
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotMan
agerTest.java
changed 12.1% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/JobExceptionsHandlerTest.java changed 5.1% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java changed 12.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java changed 39.6% diff
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerSimpleITCa
se.java
changed 28.4% diff
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java changed 1.6% diff
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/CancelingTest.java changed 2.6% diff
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/CreatedTest.java changed 1.6% diff
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraphTest.
java
changed 0.7% diff
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/ExecutingTest.java changed 17.5% diff
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/FailingTest.java changed 6.2% diff
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/RestartingTest.java changed 4.7% diff
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/StopWithSavepointTest.java changed 8.6% diff
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java changed 2.9% diff
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/exceptionhistory/ExceptionHistoryEnt
ryTest.java
changed 24.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorOperatorEventHandling
Test.java
changed 1.2% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java changed 1.0% diff
flink-runtime/src/test/java/org/apache/flink/runtime/testtasks/OnceBlockingNoOpInvokable.java changed 7.1% diff
flink-runtime/src/test/java/org/apache/flink/runtime/testutils/CancelableInvokable.java changed 34.6% diff
flink-runtime/src/test/java/org/apache/flink/runtime/util/StateHandleStoreUtilsTest.java added
flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStoreTest.java changed 66.7% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java changed 0.5% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator
.java
changed 8.0% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/AbstractAlte
rnatingAlignedBarrierHandlerState.java
changed 7.3% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/AlternatingC
ollectingBarriers.java
changed 9.0% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/AlternatingW
aitingForFirstBarrier.java
changed 16.9% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/ChannelState
.java
changed 11.0% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/CheckpointBa
rrierHandler.java
changed 2.8% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/CollectingBa
rriers.java
changed 8.4% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/CollectingBa
rriersUnaligned.java
renamed 36.5% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/AlternatingCollectingBarriersUnaligned.java
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/SingleCheckp
ointBarrierHandler.java
changed 1.4% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/WaitingForFi
rstBarrier.java
changed 6.3% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/WaitingForFi
rstBarrierUnaligned.java
renamed 38.9% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/checkpointing/AlternatingWaitingForFirstBarrierUnaligned.java
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask
.java
changed 3.7% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java changed 0.7% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceOperatorStreamTas
k.java
changed 1.0% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java changed 0.8% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java changed 3.5% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordi
natorImpl.java
changed 1.9% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamGraphGeneratorTest.ja
va
changed 5.3% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator
Test.java
changed 19.0% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/checkpointing/AlternatingC
heckpointsTest.java
changed 6.6% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/TimeWindo
wTest.java
changed 0.8% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask
Test.java
changed 3.8% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskMailboxTestHa
rness.java
changed 1.6% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskMailboxTestHa
rnessBuilder.java
changed 1.8% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java changed 9.5% diff
flink-table/flink-sql-parser-hive/src/test/java/org/apache/flink/sql/parser/hive/FlinkHiveSqlParser
ImplTest.java
changed 2.5% diff
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateTable.java changed 0.8% diff
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlDropPartitions.java changed 4.4% diff
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java changed 3.9% diff
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/datagen/Rand
omGeneratorVisitor.java
changed 5.5% diff
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/datagen/Sequ
enceGeneratorVisitor.java
changed 5.0% diff
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/DataGenOptio
ns.java
added
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/DataGenTable
SourceFactory.java
changed 25.4% diff
flink-table/flink-table-api-java-bridge/src/test/java/org/apache/flink/table/factories/DataGenTable
SourceFactoryTest.java
changed 15.4% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/TableConfigOptions
.java
changed 2.1% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Expressions.java changed 3.3% 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/TableConfig.java changed 0.8% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/DefaultSchemaResolver
.java
changed 6.3% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/QueryOperationCatalog
View.java
changed 52.3% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/delegation/Parser.java changed 13.6% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver/Expressi
onResolver.java
changed 2.9% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver/rules/Re
solveCallByArgumentsRule.java
changed 5.7% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver/rules/Re
solverRule.java
changed 4.2% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver/rules/Re
solveSqlCallRule.java
changed 58.5% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver/SqlExpre
ssionResolver.java
changed 20.3% diff
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/api/TableConfigTest.java changed 20.4% diff
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/CatalogBaseTableResol
utionTest.java
changed 1.9% diff
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/SchemaResolutionTest.
java
changed 17.9% diff
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/expressions/resolver/Expressi
onResolverTest.java
changed 0.4% diff
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/operations/utils/ValuesOperat
ionTreeBuilderTest.java
changed 0.2% diff
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/utils/ExpressionResolverMocks
.java
changed 2.5% diff
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/utils/ParserMock.java changed 16.4% diff
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/DynamicTableSink
.java
changed 2.8% diff
flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/Factory.java changed 5.0% diff
flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FactoryUtil.java changed 1.3% diff
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefini
tions.java
changed 0.1% diff
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/ExtractionUtil
s.java
changed 0.2% diff
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/ArgumentCount.j
ava
changed 1.8% diff
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/ConstantArgumen
tCount.java
changed 2.1% diff
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/TypeInferenceUt
il.java
changed 9.8% diff
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/TypeStrategies.
java
changed 3.9% diff
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalType
Casts.java
changed 11.5% diff
flink-table/flink-table-common/src/test/java/org/apache/flink/table/factories/FactoryUtilTest.java changed 3.2% diff
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/InputTypeStrate
giesTestBase.java
changed 0.6% diff
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/LogicalTypeCastAvoidanceT
est.java
changed 17.5% diff
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/LogicalTypeCastsTest.java changed 17.5% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/calcite/FlinkCal
citeSqlValidator.java
changed 13.2% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/calcite/SqlExprT
oRexConverter.java
changed 3.2% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/calcite/SqlExprT
oRexConverterFactory.java
changed 56.9% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/calcite/SqlExprT
oRexConverterImpl.java
changed 16.6% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/catalog/CatalogS
chemaTable.java
changed 24.1% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/connectors/Dynam
icSinkUtils.java
changed 11.4% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/connectors/Dynam
icSourceUtils.java
changed 1.8% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/delegation/Defau
ltParserFactory.java
changed 14.3% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/delegation/Parse
rImpl.java
changed 9.5% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/delegation/Plann
erContext.java
changed 13.4% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/Call
ExpressionResolver.java
changed 2.7% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/conv
erter/ExpressionConverter.java
changed 4.7% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfun
ctions/LagAggFunction.java
added
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/infere
nce/TypeInferenceOperandInference.java
changed 3.0% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/infere
nce/TypeInferenceReturnInference.java
changed 23.2% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/sql/Sq
lCumulateTableFunction.java
changed 8.1% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/sql/Sq
lHopTableFunction.java
changed 8.0% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/sql/Sq
lTumbleTableFunction.java
changed 9.1% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlTo
OperationConverter.java
changed 0.2% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/abilities/s
ource/FilterPushDownSpec.java
changed 1.4% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/logical/Win
dowAttachedWindowingStrategy.java
changed 1.7% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/
common/CommonExecSink.java
changed 11.8% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/
stream/StreamExecGlobalWindowAggregate.java
changed 1.1% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/
stream/StreamExecLocalWindowAggregate.java
changed 11.1% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/
stream/StreamExecWindowAggregate.java
changed 0.7% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/ShortcutUt
ils.java
changed 7.4% diff
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/delegation/Parse
rImplTest.java
changed 2.8% diff
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestVa
luesTableFactory.java
changed 5.9% diff
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/functions/aggfun
ctions/LagAggFunctionTest.java
added
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/functions/MiscFu
nctionsITCase.java
changed 3.3% diff
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/operations/SqlTo
OperationConverterTest.java
changed 1.0% diff
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/
stream/WindowAggregateJsonPlanTest.java
changed 19.3% diff
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/j
sonplan/WindowAggregateJsonITCase.java
changed 25.3% diff
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/s
ql/DataStreamJavaITCase.java
changed 17.0% diff
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/utils/PlannerMoc
ks.java
changed 5.7% diff
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/ParserImpl.java changed 5.2% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/conversion/Structur
edObjectConverter.java
changed 10.8% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOpt
ions.java
changed 55.6% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTab
leFactory.java
changed 10.3% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/Partit
ionTimeCommitTrigger.java
changed 17.2% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggreg
ate/window/buffers/RecordsWindowBuffer.java
changed 56.9% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggreg
ate/window/buffers/WindowBuffer.java
changed 51.3% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggreg
ate/window/combines/AggRecordsCombiner.java
renamed 29.7% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/combines/AggCombiner.java
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggreg
ate/window/combines/GlobalAggAccCombiner.java
renamed 26.5% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/combines/GlobalAggCombiner.java
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggreg
ate/window/combines/LocalAggRecordsCombiner.java
renamed 23.8% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/combines/LocalAggCombiner.java
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggreg
ate/window/LocalSlicingWindowAggOperator.java
changed 19.3% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggreg
ate/window/processors/AbstractWindowAggProcessor.java
changed 5.9% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggreg
ate/window/processors/SliceSharedWindowAggProcessor.java
changed 4.6% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggreg
ate/window/processors/SliceUnsharedWindowAggProcessor.java
changed 13.5% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggreg
ate/window/SlicingWindowAggOperatorBuilder.java
changed 16.0% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/w
indow/combines/TopNRecordsCombiner.java
changed 17.3% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/w
indow/processors/WindowRankProcessor.java
changed 6.6% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/w
indow/WindowRankOperatorBuilder.java
changed 8.3% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sink/O
utputConversionOperator.java
changed 2.5% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window
/combines/RecordsCombiner.java
added
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window
/combines/WindowCombineFunction.java
removed
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/Linked
ListSerializer.java
added
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/MapDat
aSerializer.java
changed 1.3% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/collections
/binary/AbstractBytesHashMap.java
changed 4.3% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/collections
/binary/AbstractBytesMultiMap.java
changed 5.2% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/collections
/binary/BytesMap.java
changed 0.1% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/TimeWindowU
til.java
changed 1.6% diff
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/filesystem/FileSystemTab
leFactoryTest.java
changed 16.5% diff
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/aggreg
ate/SumHashAggTestOperator.java
changed 1.2% diff
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/aggreg
ate/window/SlicingWindowAggOperatorTest.java
changed 0.5% diff
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils/Linked
ListSerializerTest.java
added
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/typeutils/MapDat
aSerializerTest.java
changed 28.4% diff
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/util/collections
/binary/BytesHashMapTestBase.java
changed 0.5% diff
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/util/collections
/binary/BytesMultiMapTestBase.java
changed 1.5% diff
flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/Retry
OnException.java
changed 30.0% diff
flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/Retry
OnFailure.java
changed 31.4% diff
flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/Retry
Rule.java
changed 40.2% diff
flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/testutils/junit/Retry
RuleTest.java
added
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/AbstractTestBase.
java
changed 8.8% diff
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterWithCl
ientResource.java
changed 37.3% diff
flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointStoreITCase.java added
flink-tests/src/test/java/org/apache/flink/test/scheduling/AdaptiveSchedulerITCase.java changed 6.2% diff
flink-tests/src/test/java/org/apache/flink/test/scheduling/ReactiveModeITCase.java changed 37.6% diff

Python Programs (51 of 241):

NameStatusDeltaVisual Diff
docs/content.zh/docs/connectors/table/hive/hive_dialect.md changed 37.0% diff
docs/content.zh/docs/dev/python/datastream/data_types.md changed 5.1% diff
docs/content.zh/docs/dev/python/datastream/dependency_management.md removed
docs/content.zh/docs/dev/python/datastream/intro_to_datastream_api.md added
docs/content.zh/docs/dev/python/datastream/operators/overview.md changed 100.0% diff
docs/content.zh/docs/dev/python/datastream_tutorial.md changed 7.7% diff
docs/content.zh/docs/dev/python/debugging.md added
docs/content.zh/docs/dev/python/dependency_management.md added
docs/content.zh/docs/dev/python/faq.md changed 8.4% diff
docs/content.zh/docs/dev/python/table/dependency_management.md removed
docs/content.zh/docs/dev/python/table/intro_to_table_api.md changed 3.0% diff
docs/content.zh/docs/dev/python/table/metrics.md changed 39.6% diff
docs/content.zh/docs/dev/python/table/operations/row_based_operations.md added
docs/content.zh/docs/dev/python/table/python_table_api_connectors.md changed 17.7% diff
docs/content.zh/docs/dev/python/table/table_environment.md changed 0.9% diff
docs/content.zh/docs/dev/python/table/udfs/overview.md added
docs/content.zh/docs/dev/python/table/udfs/python_udfs.md changed 21.0% diff
docs/content.zh/docs/dev/python/table/udfs/vectorized_python_udfs.md changed 41.3% diff
docs/content.zh/docs/dev/python/table_api_tutorial.md changed 1.3% diff
docs/content.zh/docs/dev/table/tableApi.md changed 0.3% diff
docs/content/docs/connectors/table/hive/hive_dialect.md changed 37.0% diff
docs/content/docs/dev/python/datastream/data_types.md changed 3.6% diff
docs/content/docs/dev/python/datastream/dependency_management.md removed
docs/content/docs/dev/python/datastream/intro_to_datastream_api.md added
docs/content/docs/dev/python/datastream/operators/overview.md changed 100.0% diff
docs/content/docs/dev/python/datastream_tutorial.md changed 9.1% diff
docs/content/docs/dev/python/debugging.md added
docs/content/docs/dev/python/dependency_management.md added
docs/content/docs/dev/python/faq.md changed 7.8% diff
docs/content/docs/dev/python/table/dependency_management.md removed
docs/content/docs/dev/python/table/intro_to_table_api.md changed 3.5% diff
docs/content/docs/dev/python/table/metrics.md changed 26.2% diff
docs/content/docs/dev/python/table/operations/row_based_operations.md added
docs/content/docs/dev/python/table/python_table_api_connectors.md changed 25.3% diff
docs/content/docs/dev/python/table/table_environment.md changed 1.1% diff
docs/content/docs/dev/python/table/udfs/overview.md added
docs/content/docs/dev/python/table/udfs/python_udfs.md changed 4.5% diff
docs/content/docs/dev/python/table/udfs/vectorized_python_udfs.md changed 0.2% diff
docs/content/docs/dev/python/table_api_tutorial.md changed 2.2% diff
docs/content/docs/dev/table/common.md changed 37.4% diff
docs/content/docs/dev/table/tableApi.md changed 0.3% diff
flink-python/pyflink/datastream/connectors.py changed 0.2% diff
flink-python/pyflink/datastream/data_stream.py changed 0.3% diff
flink-python/pyflink/datastream/tests/test_data_stream.py changed 1.4% diff
flink-python/pyflink/fn_execution/table/aggregate_fast.pyx changed 1.7% diff
flink-python/pyflink/fn_execution/table/aggregate_slow.py changed 1.2% diff
flink-python/pyflink/table/expressions.py changed 2.8% diff
flink-python/pyflink/table/table_config.py changed 0.4% diff
flink-python/pyflink/table/tests/test_row_based_operation.py changed 1.2% diff
flink-python/pyflink/util/exceptions.py changed 12.6% diff
flink-python/pyflink/version.py changed 2.2% diff

Shell Programs (9 of 140):

NameStatusDeltaVisual Diff
flink-end-to-end-tests/run-nightly-tests.sh changed 6.0% diff
flink-end-to-end-tests/test-scripts/common.sh changed 0.4% diff
flink-end-to-end-tests/test-scripts/common_kubernetes.sh changed 21.7% diff
flink-end-to-end-tests/test-scripts/common_yarn_docker.sh changed 17.8% diff
flink-end-to-end-tests/test-scripts/test_kubernetes_application.sh changed 3.6% diff
flink-end-to-end-tests/test-scripts/test_kubernetes_application_ha.sh added
flink-end-to-end-tests/test-scripts/test_kubernetes_itcases.sh changed 57.5% diff
flink-end-to-end-tests/test-scripts/test_kubernetes_pyflink_application.sh changed 2.1% diff
flink-end-to-end-tests/test-scripts/test_local_recovery_and_scheduling.sh changed 4.8% diff

SGML Documents (66 of 448):

NameStatusDeltaVisual Diff
docs/content.zh/docs/concepts/flink-architecture.md changed 3.0% diff
docs/content.zh/docs/connectors/table/filesystem.md changed 12.4% diff
docs/content.zh/docs/connectors/table/hive/overview.md changed 4.9% diff
docs/content.zh/docs/deployment/cli.md changed 25.0% diff
docs/content.zh/docs/deployment/config.md changed 4.5% diff
docs/content.zh/docs/deployment/elastic_scaling.md changed 4.6% diff
docs/content.zh/docs/deployment/resource-providers/native_kubernetes.md changed 0.7% diff
docs/content.zh/docs/deployment/resource-providers/standalone/kubernetes.md changed 14.8% diff
docs/content.zh/docs/dev/datastream/operators/overview.md changed 0.8% diff
docs/content.zh/docs/dev/datastream/sources.md changed 78.8% diff
docs/content.zh/docs/dev/python/datastream/_index.md changed 4.3% diff
docs/content.zh/docs/dev/python/datastream/operators/process_function.md added
docs/content.zh/docs/dev/python/installation.md changed 60.3% diff
docs/content.zh/docs/dev/python/table/_index.md changed 3.7% diff
docs/content.zh/docs/dev/python/table/conversion_of_pandas.md changed 40.3% diff
docs/content.zh/docs/dev/python/table/operations.md removed
docs/content.zh/docs/dev/python/table/operations/_index.md added
docs/content.zh/docs/dev/python/table/operations/operations.md added
docs/content.zh/docs/dev/python/table/python_types.md changed 0.4% diff
docs/content.zh/docs/dev/table/concepts/timezone.md changed 25.0% diff
docs/content.zh/docs/dev/table/config.md changed 6.7% diff
docs/content.zh/docs/dev/table/sql/create.md changed 1.0% diff
docs/content.zh/docs/dev/table/sql/queries/overview.md changed 11.5% diff
docs/content.zh/docs/dev/table/sqlClient.md changed 1.1% diff
docs/content.zh/docs/libs/gelly/bipartite_graph.md changed 1.5% diff
docs/content.zh/docs/libs/state_processor_api.md changed 1.1% diff
docs/content.zh/docs/ops/batch/_index.md added
docs/content.zh/docs/ops/batch/blocking_shuffle.md added
docs/content.zh/docs/ops/monitoring/checkpoint_monitoring.md changed 1.7% diff
docs/content.zh/docs/ops/state/state_backends.md changed 22.1% diff
docs/content.zh/docs/ops/upgrading.md changed 5.1% diff
docs/content.zh/docs/try-flink/table_api.md changed 0.7% diff
docs/content.zh/release-notes/flink-1.13.md added
docs/content/_index.md changed 11.5% diff
docs/content/docs/connectors/table/filesystem.md changed 11.9% diff
docs/content/docs/connectors/table/hive/overview.md changed 4.8% diff
docs/content/docs/deployment/cli.md changed 25.0% diff
docs/content/docs/deployment/config.md changed 4.5% diff
docs/content/docs/deployment/elastic_scaling.md changed 4.6% diff
docs/content/docs/deployment/memory/mem_setup_tm.md changed 0.8% diff
docs/content/docs/deployment/resource-providers/native_kubernetes.md changed 0.7% diff
docs/content/docs/deployment/resource-providers/standalone/kubernetes.md changed 14.8% diff
docs/content/docs/dev/datastream/operators/overview.md changed 0.7% diff
docs/content/docs/dev/datastream/sources.md changed 1.4% diff
docs/content/docs/dev/python/datastream/operators/process_function.md added
docs/content/docs/dev/python/installation.md changed 25.2% diff
docs/content/docs/dev/python/overview.md changed 6.7% diff
docs/content/docs/dev/python/table/operations.md removed
docs/content/docs/dev/python/table/operations/_index.md added
docs/content/docs/dev/python/table/operations/operations.md added
docs/content/docs/dev/python/table/python_types.md changed 0.4% diff
docs/content/docs/dev/table/concepts/timezone.md changed 0.9% diff
docs/content/docs/dev/table/config.md changed 6.4% diff
docs/content/docs/dev/table/sql/create.md changed 1.0% diff
docs/content/docs/dev/table/sql/queries/overview.md changed 11.5% diff
docs/content/docs/dev/table/sqlClient.md changed 1.1% diff
docs/content/docs/libs/gelly/bipartite_graph.md changed 1.5% diff
docs/content/docs/libs/state_processor_api.md changed 1.1% diff
docs/content/docs/ops/batch/_index.md added
docs/content/docs/ops/batch/blocking_shuffle.md added
docs/content/docs/ops/monitoring/back_pressure.md changed 59.3% diff
docs/content/docs/ops/state/checkpoints.md changed 8.0% diff
docs/content/docs/ops/state/state_backends.md changed 23.8% diff
docs/content/docs/ops/upgrading.md changed 5.1% diff
docs/content/docs/try-flink/table_api.md changed 0.7% diff
docs/content/release-notes/flink-1.13.md added

XML Documents (186 of 453):

NameStatusDeltaVisual Diff
flink-annotations/pom.xml changed 2.3% diff
flink-clients/pom.xml changed 0.5% diff
flink-connectors/flink-connector-base/pom.xml changed 1.3% diff
flink-connectors/flink-connector-cassandra/pom.xml changed 3.0% diff
flink-connectors/flink-connector-elasticsearch-base/pom.xml changed 0.6% diff
flink-connectors/flink-connector-elasticsearch5/pom.xml changed 8.1% 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-files/pom.xml changed 0.9% diff
flink-connectors/flink-connector-gcp-pubsub/pom.xml changed 0.9% diff
flink-connectors/flink-connector-hbase-1.4/pom.xml changed 0.3% diff
flink-connectors/flink-connector-hbase-2.2/pom.xml changed 0.2% diff
flink-connectors/flink-connector-hbase-base/pom.xml changed 0.5% diff
flink-connectors/flink-connector-hive/pom.xml changed 0.1% diff
flink-connectors/flink-connector-jdbc/pom.xml changed 0.5% diff
flink-connectors/flink-connector-kafka/pom.xml changed 2.9% diff
flink-connectors/flink-connector-kinesis/pom.xml changed 5.6% diff
flink-connectors/flink-connector-nifi/pom.xml changed 1.1% 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-file-sink-common/pom.xml changed 2.0% diff
flink-connectors/flink-hadoop-compatibility/pom.xml changed 0.5% diff
flink-connectors/flink-hcatalog/pom.xml changed 0.5% diff
flink-connectors/flink-sql-connector-elasticsearch6/pom.xml changed 0.6% diff
flink-connectors/flink-sql-connector-elasticsearch7/pom.xml changed 0.5% diff
flink-connectors/flink-sql-connector-hbase-1.4/pom.xml changed 0.5% diff
flink-connectors/flink-sql-connector-hbase-2.2/pom.xml changed 0.5% diff
flink-connectors/flink-sql-connector-hive-1.2.2/pom.xml changed 0.6% diff
flink-connectors/flink-sql-connector-hive-2.2.0/pom.xml changed 0.8% diff
flink-connectors/flink-sql-connector-hive-2.3.6/pom.xml changed 1.0% diff
flink-connectors/flink-sql-connector-hive-3.1.2/pom.xml changed 1.0% diff
flink-connectors/flink-sql-connector-kafka/pom.xml changed 1.0% diff
flink-connectors/flink-sql-connector-kinesis/pom.xml changed 0.8% diff
flink-connectors/pom.xml changed 0.7% diff
flink-container/pom.xml changed 1.3% 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.3% diff
flink-dist/pom.xml changed 6.2% 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-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-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.4% diff
flink-end-to-end-tests/flink-end-to-end-tests-common/pom.xml changed 0.7% diff
flink-end-to-end-tests/flink-end-to-end-tests-hbase/pom.xml changed 0.4% diff
flink-end-to-end-tests/flink-file-sink-test/pom.xml changed 1.3% diff
flink-end-to-end-tests/flink-glue-schema-registry-test/pom.xml changed 0.4% 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.5% diff
flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/pom.xml changed 1.3% diff
flink-end-to-end-tests/flink-netty-shuffle-memory-control-test/pom.xml changed 1.3% diff
flink-end-to-end-tests/flink-parent-child-classloading-test-lib-package/pom.xml changed 1.4% 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-python-test/pom.xml changed 1.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 1.1% diff
flink-end-to-end-tests/flink-sql-client-test/pom.xml changed 0.5% 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-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-kinesis-test/pom.xml changed 20.6% 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.3% 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 0.9% diff
flink-examples/flink-examples-build-helper/pom.xml changed 1.8% diff
flink-examples/flink-examples-streaming/pom.xml changed 0.2% diff
flink-examples/flink-examples-table/pom.xml changed 0.2% diff
flink-examples/pom.xml changed 0.9% diff
flink-external-resources/flink-external-resource-gpu/pom.xml changed 1.7% diff
flink-external-resources/pom.xml changed 2.1% diff
flink-filesystems/flink-azure-fs-hadoop/pom.xml changed 1.1% diff
flink-filesystems/flink-fs-hadoop-shaded/pom.xml changed 0.9% diff
flink-filesystems/flink-hadoop-fs/pom.xml changed 0.8% diff
flink-filesystems/flink-mapr-fs/pom.xml changed 1.4% diff
flink-filesystems/flink-oss-fs-hadoop/pom.xml changed 1.5% diff
flink-filesystems/flink-s3-fs-base/pom.xml changed 0.4% diff
flink-filesystems/flink-s3-fs-hadoop/pom.xml changed 3.5% diff
flink-filesystems/flink-s3-fs-presto/pom.xml changed 3.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-glue-schema-registry/pom.xml changed 0.6% diff
flink-formats/flink-avro/pom.xml changed 0.4% diff
flink-formats/flink-compress/pom.xml changed 1.1% diff
flink-formats/flink-csv/pom.xml changed 0.7% diff
flink-formats/flink-format-common/pom.xml changed 2.1% diff
flink-formats/flink-hadoop-bulk/pom.xml changed 0.8% diff
flink-formats/flink-json/pom.xml changed 0.6% diff
flink-formats/flink-orc-nohive/pom.xml changed 0.9% diff
flink-formats/flink-orc/pom.xml changed 0.5% diff
flink-formats/flink-parquet/pom.xml changed 0.3% diff
flink-formats/flink-sequence-file/pom.xml changed 1.0% diff
flink-formats/flink-sql-avro-confluent-registry/pom.xml changed 0.6% diff
flink-formats/flink-sql-avro/pom.xml changed 1.0% diff
flink-formats/flink-sql-orc/pom.xml changed 1.0% diff
flink-formats/flink-sql-parquet/pom.xml changed 0.9% diff
flink-formats/pom.xml changed 1.1% diff
flink-fs-tests/pom.xml changed 0.6% diff
flink-java/pom.xml changed 1.2% diff
flink-kubernetes/pom.xml changed 1.9% 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 3.1% 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.0% diff
flink-metrics/flink-metrics-dropwizard/pom.xml changed 1.1% diff
flink-metrics/flink-metrics-graphite/pom.xml changed 0.9% diff
flink-metrics/flink-metrics-influxdb/pom.xml changed 0.8% 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.3% diff
flink-optimizer/pom.xml changed 1.0% diff
flink-python/pom.xml changed 0.6% 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.1% diff
flink-quickstart/flink-quickstart-scala/pom.xml changed 2.1% diff
flink-quickstart/pom.xml changed 1.0% diff
flink-runtime-web/pom.xml changed 0.3% diff
flink-runtime/pom.xml changed 1.1% diff
flink-scala-shell/pom.xml changed 0.4% diff
flink-scala/pom.xml changed 0.4% diff
flink-state-backends/flink-statebackend-changelog/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.5% diff
flink-streaming-scala/pom.xml changed 0.2% diff
flink-table/flink-sql-client/pom.xml changed 0.2% diff
flink-table/flink-sql-parser-hive/pom.xml changed 0.4% diff
flink-table/flink-sql-parser/pom.xml changed 0.3% diff
flink-table/flink-table-api-java-bridge/pom.xml changed 1.0% 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.7% diff
flink-table/flink-table-common/pom.xml changed 1.0% 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/rules/
logical/SplitAggregateRuleTest.xml
changed 7.0% diff
flink-table/flink-table-planner/pom.xml changed 0.2% diff
flink-table/flink-table-runtime-blink/pom.xml changed 0.5% 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.1% diff
flink-test-utils-parent/flink-connector-test-utils/pom.xml changed 1.4% diff
flink-test-utils-parent/flink-test-utils-junit/pom.xml changed 1.5% diff
flink-test-utils-parent/flink-test-utils/pom.xml changed 1.7% diff
flink-test-utils-parent/pom.xml changed 2.0% diff
flink-tests/pom.xml changed 0.2% diff
flink-walkthroughs/flink-walkthrough-common/pom.xml changed 1.9% diff
flink-walkthroughs/flink-walkthrough-datastream-java/pom.xml changed 2.1% diff
flink-walkthroughs/flink-walkthrough-datastream-scala/pom.xml changed 2.1% diff
flink-walkthroughs/pom.xml changed 1.0% diff
flink-yarn-tests/pom.xml changed 0.2% diff
flink-yarn/pom.xml changed 0.4% diff
pom.xml changed 3.7% diff
tools/ci/java-ci-tools/pom.xml changed 2.4% diff
tools/force-shading/pom.xml changed 0.7% diff

HTML Pages (9 of 232):

NameStatusDeltaVisual Diff
docs/content.zh/docs/connectors/table/hive/hive_read_write.md changed 7.2%
docs/content.zh/docs/dev/table/concepts/dynamic_tables.md changed 0.01%
docs/content/docs/connectors/table/hive/hive_read_write.md changed 7.2%
docs/content/docs/dev/table/concepts/dynamic_tables.md changed 0.01%
docs/layouts/shortcodes/generated/deployment_configuration.html changed 13.8%
docs/layouts/shortcodes/generated/python_configuration.html changed 0.01%
docs/layouts/shortcodes/generated/table_config_configuration.html changed 0.1%
flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.html changed 1.9%
flink-runtime-web/web-dashboard/src/app/pages/job/overview/backpressure/job-overview-drawer-backpre
ssure.component.html
changed 0.04%

Property Files (2 of 98):

NameStatusDeltaVisual Diff
flink-end-to-end-tests/flink-streaming-kinesis-test/src/test/resources/log4j2-test.properties added
flink-table/flink-sql-parser/src/main/resources/org.apache.flink.sql.parser.utils/ParserResource.pr
operties
changed 18.9% diff

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

NameStatusDeltaVisual Diff
flink-runtime-web/web-dashboard/src/app/interfaces/job-checkpoint.ts changed 1.1% diff

SQL Files (2 of 111):

NameStatusDeltaVisual Diff
flink-end-to-end-tests/flink-streaming-kinesis-test/src/main/resources/org/apache/flink/streaming/k
inesis/test/filter-large-orders.sql
moved 0.0%
flink-end-to-end-tests/flink-streaming-kinesis-test/src/test/resources/filter-large-orders.sql

YAML Files (2 of 54):

NameStatusDeltaVisual Diff
docs/data/sql_functions.yml changed 1.4% diff
flink-end-to-end-tests/test-scripts/container-scripts/kubernetes-pod-template.yaml added

Data Files (1 of 866):

NameStatusDeltaVisual Diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/nodes/
exec/stream/WindowAggregateJsonPlanTest_jsonplan/testDistinctSplitEnabled.out
added

Image Files (7 of 81):

NameStatusDeltaVisual Diff
docs/static/fig/back_pressure_job_graph.png added
docs/static/fig/back_pressure_sampling.png removed
docs/static/fig/back_pressure_sampling_high.png removed
docs/static/fig/back_pressure_sampling_in_progress.png removed
docs/static/fig/back_pressure_sampling_ok.png removed
docs/static/fig/back_pressure_subtasks.png added
docs/static/fig/udtagg-mechanism-python.png added

Directories (13 of 5488):

NameStatus
docs/content.zh/docs/dev/python/table/operations added
docs/content.zh/docs/ops/batch added
docs/content/docs/dev/python/table/operations added
docs/content/docs/ops/batch added
flink-end-to-end-tests/flink-streaming-kinesis-test/src/main/resources moved
flink-end-to-end-tests/flink-streaming-kinesis-test/src/test/resources
flink-end-to-end-tests/flink-streaming-kinesis-test/src/main/resources/org removed
flink-end-to-end-tests/flink-streaming-kinesis-test/src/main/resources/org/apache removed
flink-end-to-end-tests/flink-streaming-kinesis-test/src/main/resources/org/apache/flink removed
flink-end-to-end-tests/flink-streaming-kinesis-test/src/main/resources/org/apache/flink/streaming removed
flink-end-to-end-tests/flink-streaming-kinesis-test/src/main/resources/org/apache/flink/streaming/k
inesis
removed
flink-end-to-end-tests/flink-streaming-kinesis-test/src/main/resources/org/apache/flink/streaming/k
inesis/test
removed
flink-end-to-end-tests/flink-streaming-kinesis-test/src/test/java/org/apache/flink/streaming/kinesi
s/test/containers
removed

Information Files (1 of 40):

NameStatusDeltaVisual Diff
NOTICE changed 27.0% diff

Text Files (26 of 2310):

NameStatusDeltaVisual Diff
docs/config.toml changed 0.6% diff
flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/PatternStream.scala changed 0.8% diff
flink-python/pyflink/fn_execution/table/aggregate_fast.pxd changed 1.3% diff
flink-table/flink-table-api-scala/src/main/scala/org/apache/flink/table/api/ImplicitExpressionConve
rsions.scala
changed 3.8% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkPl
annerImpl.scala
changed 9.1% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkTy
peFactory.scala
changed 2.6% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/bat
ch/HashAggCodeGenHelper.scala
changed 0.3% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/bat
ch/HashWindowCodeGenerator.scala
changed 0.3% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/delegation/Plan
nerBase.scala
changed 2.1% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/F
linkRelMdColumnInterval.scala
changed 2.9% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/phys
ical/stream/StreamPhysicalGlobalWindowAggregate.scala
changed 1.6% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/phys
ical/stream/StreamPhysicalLocalWindowAggregate.scala
changed 1.6% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/phys
ical/stream/StreamPhysicalWindowAggregate.scala
changed 2.1% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logi
cal/SplitAggregateRule.scala
changed 5.9% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/schema/Leg
acyCatalogSourceTable.scala
changed 2.1% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/AggF
unctionFactory.scala
changed 4.9% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/Aggr
egateUtil.scala
changed 1.5% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/sinks/TableSink
Utils.scala
changed 3.3% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/codegen/Waterma
rkGeneratorCodeGenTest.scala
changed 12.8% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/rules/logi
cal/SplitAggregateRuleTest.scala
changed 9.4% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql
/WindowTableFunctionTest.scala
changed 37.4% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/
sql/CalcITCase.scala
changed 13.1% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/
sql/DataStreamScalaITCase.scala
added
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/
sql/OverAggregateITCase.scala
changed 6.8% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/
sql/SplitAggregateITCase.scala
changed 4.7% diff
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/TableEnvImpl.sca
la
changed 0.4% diff

Packages Compared:

flink-1.13.0-src.tgz
flink-1.13.1-src.tgz


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