"Fossies" - the Fresh Open Source Software Archive  

Source code changes report for "flink" between the packages
flink-1.11.1-src.tgz and flink-1.11.2-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 15055 regular files (+79) and 4966 directories (+4).

Related Informations:

See docs/release-notes/flink-1.11.md and docs/monitoring/historyserver.md (flink 1.11.2).

Changes In Files (According File Type):

File TypeTotalAddedRemovedChanged
Header file 1 0 0 0
C program 131 0 0 8
Assembler program 6 0 0 0
Java program 10099 9 6 141
Python program 174 16 10 3
Shell program 135 1 2 4
Ruby program 8 1 0 0
Configuration file 5 0 0 0
Executable file 13 0 0 0
Initialization file 1 0 0 0
JavaScript file 4 0 0 1
JSON file 16 0 0 0
Makefile 1 0 0 0
Man page 1 0 0 0
SGML document 431 16 8 53
XML document 417 0 6 188
CSS style sheet 6 0 0 0
CSV file 5 0 0 0
DOS Batch file 1 0 0 0
Font file 9 0 0 0
Git file 1 0 0 0
HTML page 194 1 0 11
Log file 2 0 0 0
MS Windows file 4 0 0 0
Property file 93 0 2 0
Protocol Buffer file 1 0 0 0
Qt Translation or MS TypeScript file 113 0 0 0
RST file 8 0 0 0
SQL file 108 0 0 0
YAML file 53 1 0 3
Data file 567 64 0 0
Icon 2 0 0 0
Image file 75 2 0 0
Vector Image file 59 0 0 0
Directory 4990 28 24 0
Archive 3 0 0 0
Information file 41 0 0 0
License 84 0 0 0
Readme file 18 0 0 0
Text file 2181 3 1 20
Other 19 0 0 0
Total Files2008014259432



C Programs (8 of 131):

NameStatusDeltaVisual Diff
docs/dev/batch/connectors.md changed 6.1% diff
docs/dev/batch/connectors.zh.md changed 6.2% diff
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/tw
itter/TwitterExample.scala
changed 0.5% diff
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/wi
ndowing/GroupedProcessingTimeWindowExample.scala
changed 0.7% diff
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/wi
ndowing/SessionWindowing.scala
changed 0.6% diff
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/wi
ndowing/TopSpeedWindowing.scala
changed 0.5% diff
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/wi
ndowing/WindowWordCount.scala
changed 0.7% diff
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/wo
rdcount/WordCount.scala
changed 0.7% diff

Java Programs (156 of 10099):

NameStatusDeltaVisual Diff
docs/dev/stream/operators/process_function.md changed 0.3% diff
docs/dev/stream/operators/process_function.zh.md changed 0.3% diff
docs/dev/table/common.md changed 0.9% diff
docs/dev/table/common.zh.md changed 0.9% diff
docs/dev/table/functions/udfs.md changed 1.3% diff
docs/dev/table/functions/udfs.zh.md changed 1.3% diff
docs/learn-flink/etl.md changed 0.5% diff
docs/learn-flink/etl.zh.md changed 0.5% diff
flink-annotations/src/main/java/org/apache/flink/annotation/docs/Documentation.java changed 1.2% diff
flink-connectors/flink-connector-elasticsearch-base/src/test/java/org/apache/flink/streaming/connec
tors/elasticsearch/testutils/ElasticsearchResource.java
changed 42.7% diff
flink-connectors/flink-connector-filesystem/src/test/java/org/apache/flink/streaming/connectors/fs/
bucketing/BucketingSinkMigrationTest.java
changed 4.6% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.
java
changed 11.1% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveBulk
WriterFactory.java
changed 7.7% diff
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog
.java
changed 3.0% diff
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectITC
ase.java
changed 1.2% diff
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSinkI
TCase.java
changed 5.6% diff
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveCo
nnectorITCase.java
changed 1.4% diff
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalog
GenericMetadataTest.java
changed 100.0% diff
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalog
HiveMetadataTest.java
changed 1.5% diff
flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kaf
ka/FlinkKafkaProducer011MigrationTest.java
changed 2.7% diff
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kaf
ka/internals/KafkaSerializationSchemaWrapper.java
changed 15.1% diff
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kaf
ka/FlinkKafkaConsumerBaseMigrationTest.java
changed 0.5% diff
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/Fl
inkKafkaProducer.java
changed 1.0% diff
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/Fl
inkKafkaProducerMigrationOperatorTest.java
changed 3.7% diff
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/Fl
inkKafkaProducerMigrationTest.java
changed 2.7% diff
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/Fl
inkKafkaProducerTest.java
changed 34.7% diff
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/ta
ble/KafkaChangelogTableITCase.java
changed 19.5% diff
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/FlinkKinesisConsumerMigrationTest.java
changed 0.4% diff
flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategy.java changed 1.3% diff
flink-core/src/main/java/org/apache/flink/configuration/ClusterOptions.java changed 19.5% diff
flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java changed 5.7% diff
flink-core/src/main/java/org/apache/flink/core/fs/SafetyNetCloseableRegistry.java changed 6.2% diff
flink-core/src/main/java/org/apache/flink/util/AbstractCloseableRegistry.java changed 2.3% diff
flink-core/src/main/java/org/apache/flink/util/JavaGcCleanerWrapper.java changed 5.9% diff
flink-core/src/test/java/org/apache/flink/core/fs/AbstractCloseableRegistryTest.java changed 0.4% diff
flink-core/src/test/java/org/apache/flink/core/fs/local/LocalFileSystemTest.java changed 4.4% diff
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/Asy
ncIOExample.java
changed 0.4% diff
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/sideoutpu
t/SideOutputExample.java
changed 0.6% diff
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/So
cketWindowWordCount.java
changed 0.9% diff
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/twitter/T
witterExample.java
changed 0.7% diff
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing
/GroupedProcessingTimeWindowExample.java
changed 0.7% diff
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing
/SessionWindowing.java
changed 0.9% diff
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing
/TopSpeedWindowing.java
changed 0.5% diff
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing
/WindowWordCount.java
changed 0.9% diff
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/wordcount
/WordCount.java
changed 0.9% diff
flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeseriali
zationSchema.java
changed 8.4% diff
flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeseriali
zationSchemaTest.java
changed 21.0% diff
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcSplitReaderUtil.java changed 1.1% diff
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/TimestampUtil.java added
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/AbstractOrcColumnVector.java changed 14.8% diff
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/OrcLegacyTimestampColumnVector.ja
va
added
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/OrcTimestampColumnVector.java changed 39.1% diff
flink-fs-tests/src/test/java/org/apache/flink/hdfstests/ContinuousFileProcessingMigrationTest.java changed 1.1% diff
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPMigrationTest.java changed 0.3% diff
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/Savepoi
ntEnvironment.java
changed 1.6% diff
flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosTaskExecutorRunner.java changed 28.7% diff
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java changed 3.9% diff
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java changed 29.6% diff
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java changed 1.0% diff
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherRestEndpoint.java changed 8.7% diff
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MiniDispatcher.java changed 14.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java changed 0.9% diff
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory
.java
changed 5.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.ja
va
changed 4.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalServic
e.java
changed 15.0% diff
flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java changed 4.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/memory/UnsafeMemoryBudget.java changed 39.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.ja
va
changed 0.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java changed 7.8% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/InFlightRequestTracker.java changed 10.6% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ResourceProfileInfo.java changed 3.6% diff
flink-runtime/src/main/java/org/apache/flink/runtime/security/ExitTrappingSecurityManager.java added
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlot.java changed 11.3% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTableImpl.java changed 2.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorResourceUtils.java changed 12.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java changed 4.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java changed 1.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/jobmanager/JobManagerFlinkM
emoryUtils.java
changed 1.6% diff
flink-runtime/src/main/java/org/apache/flink/runtime/util/FatalExitExceptionHandler.java changed 7.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java changed 1.5% diff
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java changed 40.2% diff
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTestingUtils.j
ava
changed 12.9% diff
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDeciderTest.java changed 19.5% diff
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/MiniDispatcherTest.java changed 13.4% diff
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphNotEnoughResource
Test.java
changed 0.7% diff
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory
Test.java
changed 17.0% diff
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerProcessUtilsTest.java changed 5.6% diff
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionConnecti
onHandlingTest.java
added
flink-runtime/src/test/java/org/apache/flink/runtime/memory/MemoryManagerBuilder.java changed 6.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/memory/MemoryManagerSharedResourcesTest.java changed 1.1% diff
flink-runtime/src/test/java/org/apache/flink/runtime/memory/MemoryManagerTest.java changed 3.4% diff
flink-runtime/src/test/java/org/apache/flink/runtime/memory/UnsafeMemoryBudgetTest.java changed 21.3% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/InFlightRequestTrackerTest.java changed 10.9% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestServerEndpointITCase.java changed 4.4% diff
flink-runtime/src/test/java/org/apache/flink/runtime/security/ExitTrappingSecurityManagerTest.java added
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTest.java changed 8.2% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotUtils.java changed 3.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorITCase.java changed 2.3% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorTest.java changed 0.5% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnviro
nment.java
changed 0.2% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java changed 5.2% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java changed 34.6% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java changed 0.7% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.
java
changed 2.2% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java changed 0.3% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext
.java
changed 2.0% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/AlternatingCheckpointBarri
erHandler.java
changed 2.6% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnaligner
.java
changed 0.4% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxExecutor
Impl.java
changed 5.1% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java changed 10.6% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java changed 4.6% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorT
est.java
changed 2.2% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorTest.java changed 30.8% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/AlternatingCheckpointBarri
erHandlerTest.java
changed 21.7% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnaligner
Test.java
changed 5.5% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOpe
ratorMigrationTest.java
changed 0.2% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxExecutor
ImplTest.java
changed 11.1% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask
Test.java
changed 3.7% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask
TestHarnessBuilder.java
removed
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceOperatorStreamTas
kTest.java
changed 2.3% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTaskTest.ja
va
changed 13.0% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamConfigChainer.jav
a
changed 3.0% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskMailboxTestHa
rnessBuilder.java
changed 24.3% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskMultipleInput
SelectiveReadingTest.java
changed 1.6% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java changed 0.7% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.j
ava
changed 3.3% diff
flink-table/flink-sql-parser-hive/src/main/java/org/apache/flink/sql/parser/hive/ddl/SqlCreateHiveT
able.java
changed 2.6% diff
flink-table/flink-sql-parser-hive/src/test/java/org/apache/flink/sql/parser/hive/FlinkHiveSqlParser
ImplTest.java
changed 0.9% diff
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateTable.java changed 6.5% diff
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Table.java changed 0.3% diff
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/TypeInferenceUt
il.java
changed 0.6% diff
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/InputTypeStrate
giesTest.java
changed 1.7% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/conv
erter/CustomizedConvertRule.java
changed 1.8% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfun
ctions/ListAggWithRetractAggFunction.java
changed 21.5% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfun
ctions/ListAggWsWithRetractAggFunction.java
changed 21.9% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlTo
OperationConverter.java
changed 4.4% diff
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/Expander.j
ava
added
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestVa
luesRuntimeFunctions.java
changed 5.8% diff
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/t
able/ValuesITCase.java
changed 4.3% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTab
leFactory.java
changed 4.8% diff
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/Stream
ingFileWriter.java
changed 5.2% diff
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/filesystem/stream/Stream
ingFileWriterTest.java
added
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationIT
Case.java
changed 2.9% diff
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigra
tionITCase.java
changed 2.5% diff
flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.jav
a
changed 3.7% diff
flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorR
estoreTestBase.java
changed 2.9% diff
flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOper
atorRestoreTestBase.java
changed 2.3% diff
flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/DataStreamWithSharedPartit
ionNodeITCase.java
added
flink-tests/src/test/java/org/apache/flink/test/streaming/api/FileReadingWatermarkITCase.java added
flink-walkthroughs/flink-walkthrough-common/src/main/java/org/apache/flink/walkthrough/common/table
/BoundedTransactionTableSource.java
removed
flink-walkthroughs/flink-walkthrough-common/src/main/java/org/apache/flink/walkthrough/common/table
/SpendReportTableSink.java
removed
flink-walkthroughs/flink-walkthrough-common/src/main/java/org/apache/flink/walkthrough/common/table
/TruncateDateToHour.java
removed
flink-walkthroughs/flink-walkthrough-common/src/main/java/org/apache/flink/walkthrough/common/table
/UnboundedTransactionTableSource.java
removed
flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/archetype-resources/src/main/jav
a/SpendReport.java
removed
flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskExecutorRunner.java changed 14.6% diff
flink-yarn/src/test/java/org/apache/flink/yarn/YarnTaskExecutorRunnerTest.java changed 10.6% diff

Python Programs (29 of 174):

NameStatusDeltaVisual Diff
docs/dev/python/faq.md added
docs/dev/python/faq.zh.md added
docs/dev/python/table-api-users-guide/intro_to_table_api.md added
docs/dev/python/table-api-users-guide/intro_to_table_api.zh.md added
docs/dev/python/table-api-users-guide/table_environment.md added
docs/dev/python/table-api-users-guide/table_environment.zh.md added
docs/dev/python/table_api_tutorial.md added
docs/dev/python/table_api_tutorial.zh.md added
docs/dev/table/python/common_questions.md removed
docs/dev/table/python/common_questions.zh.md removed
docs/dev/table/python/dependency_management.md moved 13.6% diff
docs/dev/python/table-api-users-guide/dependency_management.md
docs/dev/table/python/dependency_management.zh.md moved 13.7% diff
docs/dev/python/table-api-users-guide/dependency_management.zh.md
docs/dev/table/python/metrics.md moved 20.4% diff
docs/dev/python/table-api-users-guide/metrics.md
docs/dev/table/python/metrics.zh.md moved 50.5% diff
docs/dev/python/table-api-users-guide/metrics.zh.md
docs/dev/table/python/python_udfs.md moved 0.9% diff
docs/dev/python/table-api-users-guide/udfs/python_udfs.md
docs/dev/table/python/python_udfs.zh.md moved 50.7% diff
docs/dev/python/table-api-users-guide/udfs/python_udfs.zh.md
docs/dev/table/python/vectorized_python_udfs.md moved 9.4% diff
docs/dev/python/table-api-users-guide/udfs/vectorized_python_udfs.md
docs/dev/table/python/vectorized_python_udfs.zh.md moved 61.9% diff
docs/dev/python/table-api-users-guide/udfs/vectorized_python_udfs.zh.md
docs/dev/table/tableApi.md changed 16.2% diff
docs/dev/table/tableApi.zh.md changed 16.2% diff
flink-python/pyflink/version.py changed 2.2% diff

Shell Programs (7 of 135):

NameStatusDeltaVisual Diff
flink-dist/src/main/flink-bin/bin/config.sh changed 0.4% diff
flink-dist/src/main/flink-bin/bin/taskmanager.sh changed 2.5% diff
flink-end-to-end-tests/run-nightly-tests.sh changed 1.3% diff
tools/azure-pipelines/setup_docker.sh removed
tools/ci/deploy_nightly_to_s3.sh added
tools/deploy_to_maven.sh removed
tools/releasing/deploy_staging_jars.sh changed 9.6% diff

Ruby Programs (1 of 8):

NameStatusDeltaVisual Diff
docs/_plugins/include_without_header.rb added

JavaScript Files (1 of 4):

NameStatusDeltaVisual Diff
docs/page/js/flink.js changed 46.1% diff

SGML Documents (77 of 431):

NameStatusDeltaVisual Diff
docs/concepts/flink-architecture.md changed 0.6% diff
docs/concepts/flink-architecture.zh.md changed 0.6% diff
docs/concepts/timely-stream-processing.md changed 0.8% diff
docs/dev/connectors/cassandra.md changed 0.7% diff
docs/dev/connectors/cassandra.zh.md changed 0.7% diff
docs/dev/datastream_api.md changed 0.2% diff
docs/dev/datastream_api.zh.md changed 0.2% diff
docs/dev/parallel.md changed 1.0% diff
docs/dev/parallel.zh.md changed 1.0% diff
docs/dev/python/table-api-users-guide/built_in_functions.md added
docs/dev/python/table-api-users-guide/built_in_functions.zh.md added
docs/dev/python/table-api-users-guide/index.md added
docs/dev/python/table-api-users-guide/index.zh.md added
docs/dev/python/table-api-users-guide/python_types.md added
docs/dev/python/table-api-users-guide/python_types.zh.md added
docs/dev/python/table-api-users-guide/udfs/index.md added
docs/dev/python/table-api-users-guide/udfs/index.zh.md added
docs/dev/stream/state/queryable_state.md changed 0.4% diff
docs/dev/stream/state/queryable_state.zh.md changed 0.4% diff
docs/dev/stream/state/state.md changed 0.1% diff
docs/dev/stream/state/state.zh.md changed 0.1% diff
docs/dev/table/connectors/filesystem.md changed 0.6% diff
docs/dev/table/connectors/filesystem.zh.md changed 0.6% diff
docs/dev/table/connectors/formats/debezium.md changed 13.6% diff
docs/dev/table/connectors/formats/debezium.zh.md changed 13.3% diff
docs/dev/table/connectors/jdbc.md changed 4.9% diff
docs/dev/table/connectors/jdbc.zh.md changed 4.9% diff
docs/dev/table/connectors/kafka.md changed 8.0% diff
docs/dev/table/connectors/kafka.zh.md changed 8.0% diff
docs/dev/table/hive/index.md changed 8.0% diff
docs/dev/table/hive/index.zh.md changed 7.9% diff
docs/dev/table/python/conversion_of_pandas.md moved 13.0% diff
docs/dev/python/table-api-users-guide/conversion_of_pandas.md
docs/dev/table/python/conversion_of_pandas.zh.md moved 50.5% diff
docs/dev/python/table-api-users-guide/conversion_of_pandas.zh.md
docs/dev/table/python/index.md moved 65.3% diff
docs/dev/python/index.md
docs/dev/table/python/index.zh.md moved 64.9% diff
docs/dev/python/index.zh.md
docs/dev/table/python/installation.md moved 10.6% diff
docs/dev/python/installation.md
docs/dev/table/python/installation.zh.md moved 36.8% diff
docs/dev/python/installation.zh.md
docs/dev/table/python/python_config.md moved 12.7% diff
docs/dev/python/table-api-users-guide/python_config.md
docs/dev/table/python/python_config.zh.md moved 13.0% diff
docs/dev/python/table-api-users-guide/python_config.zh.md
docs/dev/table/sql/alter.md changed 4.7% diff
docs/dev/table/sql/alter.zh.md changed 4.3% diff
docs/dev/table/sql/create.md changed 2.9% diff
docs/dev/table/sql/create.zh.md changed 2.9% diff
docs/dev/table/sql/queries.md changed 0.2% diff
docs/dev/table/sql/queries.zh.md changed 0.2% diff
docs/dev/table/streaming/match_recognize.zh.md changed 63.6% diff
docs/dev/table/streaming/time_attributes.zh.md changed 0.2% diff
docs/dev/types_serialization.md changed 2.1% diff
docs/dev/types_serialization.zh.md changed 2.4% diff
docs/learn-flink/streaming_analytics.md changed 3.6% diff
docs/learn-flink/streaming_analytics.zh.md changed 3.6% diff
docs/monitoring/metrics.md changed 0.8% diff
docs/monitoring/metrics.zh.md changed 0.8% diff
docs/ops/config.md changed 2.3% diff
docs/ops/config.zh.md changed 2.3% diff
docs/ops/external_resources.md changed 3.4% diff
docs/ops/external_resources.zh.md changed 78.0% diff
docs/ops/memory/mem_setup_jobmanager.zh.md changed 1.3% diff
docs/ops/memory/mem_setup_tm.zh.md changed 4.2% diff
docs/ops/python_shell.md changed 5.0% diff
docs/ops/python_shell.zh.md changed 3.2% diff
docs/ops/scala_shell.md changed 0.4% diff
docs/ops/scala_shell.zh.md changed 0.4% diff
docs/ops/security-kerberos.md changed 6.8% diff
docs/ops/security-kerberos.zh.md changed 6.8% diff
docs/ops/state/state_backends.md changed 0.5% diff
docs/ops/state/state_backends.zh.md changed 0.5% diff
docs/ops/upgrading.md changed 4.3% diff
docs/ops/upgrading.zh.md changed 4.3% diff

XML Documents (194 of 417):

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.4% 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-elasticsearch5/pom.xml changed 0.3% diff
flink-connectors/flink-connector-elasticsearch6/pom.xml changed 0.6% diff
flink-connectors/flink-connector-elasticsearch7/pom.xml changed 0.6% diff
flink-connectors/flink-connector-filesystem/pom.xml changed 0.5% diff
flink-connectors/flink-connector-gcp-pubsub/pom.xml changed 1.0% diff
flink-connectors/flink-connector-hbase/pom.xml changed 0.3% diff
flink-connectors/flink-connector-hive/pom.xml changed 0.5% diff
flink-connectors/flink-connector-jdbc/pom.xml changed 0.6% diff
flink-connectors/flink-connector-kafka-0.10/pom.xml changed 0.3% diff
flink-connectors/flink-connector-kafka-0.11/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 0.4% 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-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-hive-1.2.2/pom.xml changed 0.7% 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.1% diff
flink-connectors/flink-sql-connector-hive-3.1.2/pom.xml changed 1.1% 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 1.0% diff
flink-connectors/flink-sql-connector-kafka/pom.xml changed 1.0% 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.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 0.8% 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-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.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-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.4% 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.2% 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 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 0.3% 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 0.4% diff
flink-filesystems/flink-fs-hadoop-shaded/pom.xml changed 0.4% 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 0.6% diff
flink-filesystems/flink-s3-fs-base/pom.xml changed 0.4% diff
flink-filesystems/flink-s3-fs-hadoop/pom.xml changed 0.4% diff
flink-filesystems/flink-s3-fs-presto/pom.xml changed 0.2% 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.4% diff
flink-formats/flink-compress/pom.xml changed 1.1% diff
flink-formats/flink-csv/pom.xml changed 0.8% diff
flink-formats/flink-hadoop-bulk/pom.xml changed 0.8% diff
flink-formats/flink-json/pom.xml changed 0.7% 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.5% diff
flink-formats/flink-sequence-file/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.2% diff
flink-fs-tests/pom.xml changed 0.6% diff
flink-java/pom.xml changed 1.2% diff
flink-kubernetes/pom.xml changed 3.8% 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 1.0% 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.9% 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-ml-parent/flink-ml-api/pom.xml changed 1.9% diff
flink-ml-parent/flink-ml-lib/pom.xml changed 1.1% diff
flink-ml-parent/flink-ml-uber/pom.xml changed 1.2% diff
flink-ml-parent/pom.xml changed 2.1% diff
flink-optimizer/pom.xml changed 1.0% diff
flink-python/pom.xml changed 0.2% 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-scala/pom.xml changed 2.2% diff
flink-quickstart/pom.xml changed 1.0% diff
flink-runtime-web/pom.xml changed 0.3% diff
flink-runtime/pom.xml changed 0.6% diff
flink-scala-shell/pom.xml changed 0.4% diff
flink-scala/pom.xml changed 0.4% diff
flink-state-backends/flink-statebackend-heap-spillable/pom.xml changed 1.6% 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.8% diff
flink-streaming-scala/pom.xml changed 0.3% 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 3.4% 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.1% 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/common
/ViewsExpandingTest.xml
changed 42.4% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream
/sql/join/LookupJoinTest.xml
changed 8.0% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream
/sql/MiniBatchIntervalInferTest.xml
changed 40.4% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream
/sql/SortTest.xml
changed 4.2% diff
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream
/table/ValuesTest.xml
changed 37.5% 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-test-utils-junit/pom.xml changed 1.5% 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.2% diff
flink-walkthroughs/flink-walkthrough-common/pom.xml changed 21.7% 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 removed
flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/archetype-resources/pom.xml removed
flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/META-INF/maven/archetype-metadat
a.xml
removed
flink-walkthroughs/flink-walkthrough-table-scala/pom.xml removed
flink-walkthroughs/flink-walkthrough-table-scala/src/main/resources/archetype-resources/pom.xml removed
flink-walkthroughs/flink-walkthrough-table-scala/src/main/resources/META-INF/maven/archetype-metada
ta.xml
removed
flink-walkthroughs/pom.xml changed 4.3% 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

HTML Pages (12 of 194):

NameStatusDeltaVisual Diff
docs/_includes/generated/cluster_configuration.html changed 19.2%
docs/_includes/generated/expert_cluster_section.html added
docs/_layouts/base.html changed 1.8%
docs/dev/stream/operators/index.md changed 0.1%
docs/dev/stream/operators/index.zh.md changed 0.1%
docs/dev/table/connectors/formats/csv.md changed 0.1%
docs/dev/table/connectors/formats/csv.zh.md changed 0.1%
docs/dev/table/connectors/index.md changed 0.1%
docs/dev/table/connectors/index.zh.md changed 0.1%
docs/dev/table/sqlClient.md changed 0.003%
docs/dev/table/sqlClient.zh.md changed 0.003%
docs/dev/table/streaming/dynamic_tables.zh.md changed 0.3%

Property Files (2 of 93):

NameStatusDeltaVisual Diff
flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/archetype-resources/src/main/res
ources/log4j2.properties
removed
flink-walkthroughs/flink-walkthrough-table-scala/src/main/resources/archetype-resources/src/main/re
sources/log4j2.properties
removed

YAML Files (4 of 53):

NameStatusDeltaVisual Diff
docs/_config.yml changed 0.4% diff
tools/azure-pipelines/build-apache-repo.yml changed 3.8% diff
tools/azure-pipelines/build-nightly-dist.yml added
tools/azure-pipelines/jobs-template.yml changed 1.1% diff

Data Files (64 of 567):

NameStatusDeltaVisual Diff
flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1
.10-snapshot
added
flink-connectors/flink-connector-filesystem/src/test/resources/bucketing-sink-migration-test-flink1
.11-snapshot
added
flink-connectors/flink-connector-kafka-0.11/src/test/resources/kafka-migration-kafka-producer-flink
-1.10-snapshot
added
flink-connectors/flink-connector-kafka-0.11/src/test/resources/kafka-migration-kafka-producer-flink
-1.11-snapshot
added
flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1
.10-empty-state-snapshot
added
flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1
.10-snapshot
added
flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1
.11-empty-state-snapshot
added
flink-connectors/flink-connector-kafka-base/src/test/resources/kafka-consumer-migration-test-flink1
.11-snapshot
added
flink-connectors/flink-connector-kafka/src/test/resources/kafka-0.11-migration-kafka-producer-flink
-1.10-snapshot
added
flink-connectors/flink-connector-kafka/src/test/resources/kafka-0.11-migration-kafka-producer-flink
-1.11-snapshot
added
flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.
10-empty-snapshot
added
flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.
10-snapshot
added
flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.
11-empty-snapshot
added
flink-connectors/flink-connector-kinesis/src/test/resources/kinesis-consumer-migration-test-flink1.
11-snapshot
added
flink-fs-tests/src/test/resources/monitoring-function-migration-test-1594559333000-flink1.10-snapsh
ot
added
flink-fs-tests/src/test/resources/monitoring-function-migration-test-1594561663000-flink1.11-snapsh
ot
added
flink-fs-tests/src/test/resources/reader-migration-test-flink1.10-snapshot added
flink-fs-tests/src/test/resources/reader-migration-test-flink1.11-snapshot added
flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.10-snapshot added
flink-libraries/flink-cep/src/test/resources/cep-migration-after-branching-flink1.11-snapshot added
flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.10-snapshot added
flink-libraries/flink-cep/src/test/resources/cep-migration-conditions-flink1.11-snapshot added
flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.10-snap
shot
added
flink-libraries/flink-cep/src/test/resources/cep-migration-single-pattern-afterwards-flink1.11-snap
shot
added
flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.10-snapshot added
flink-libraries/flink-cep/src/test/resources/cep-migration-starting-new-pattern-flink1.11-snapshot added
flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.10-snapshot added
flink-streaming-java/src/test/resources/win-op-migration-test-apply-event-time-flink1.11-snapshot added
flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.10-snaps
hot
added
flink-streaming-java/src/test/resources/win-op-migration-test-apply-processing-time-flink1.11-snaps
hot
added
flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.10-snapsho
t
added
flink-streaming-java/src/test/resources/win-op-migration-test-kryo-serialized-key-flink1.11-snapsho
t
added
flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.10-snapshot added
flink-streaming-java/src/test/resources/win-op-migration-test-reduce-event-time-flink1.11-snapshot added
flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.10-snap
shot
added
flink-streaming-java/src/test/resources/win-op-migration-test-reduce-processing-time-flink1.11-snap
shot
added
flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.
10-snapshot
added
flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-flink1.
11-snapshot
added
flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-fl
ink1.10-snapshot
added
flink-streaming-java/src/test/resources/win-op-migration-test-session-with-stateful-trigger-mint-fl
ink1.11-snapshot
added
flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.10-rocksdb-savepo
int/_metadata
added
flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.10-savepoint/_met
adata
added
flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.11-rocksdb-savepo
int/_metadata
added
flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.11-savepoint/_met
adata
added
flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.10-rocksdb-savepoint/_metad
ata
added
flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.10-savepoint/_metadata added
flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metad
ata
added
flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.11-savepoint/_metadata added
flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.10/_metadata added
flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.11/_metadata added
flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.10/_metadata added
flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.11/_metadata added
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.10-jobmanager-savepoint/_
metadata
added
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.10-rocksdb-savepoint/_met
adata
added
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.11-jobmanager-savepoint/_
metadata
added
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.11-rocksdb-savepoint/_met
adata
added
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.10-jobmana
ger-savepoint/_metadata
added
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.10-rocksdb
-savepoint/_metadata
added
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.11-jobmana
ger-savepoint/_metadata
added
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.11-rocksdb
-savepoint/_metadata
added
flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.10-rocksdb-savepoin
t/_metadata
added
flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.10-savepoint/_metad
ata
added
flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.11-rocksdb-savepoin
t/_metadata
added
flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.11-savepoint/_metad
ata
added

Image Files (2 of 75):

NameStatusDeltaVisual Diff
flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.10
-snapshot
added
flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.11
-snapshot
added

Directories (52 of 4990):

NameStatus
docs/dev/python/table-api-users-guide added
docs/dev/python/table-api-users-guide/udfs added
docs/dev/table/python moved
docs/dev/python
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/filesystem/stream added
flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.10-rocksdb-savepo
int
added
flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.10-savepoint added
flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.11-rocksdb-savepo
int
added
flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.11-savepoint added
flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.10-rocksdb-savepoint added
flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.10-savepoint added
flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.11-rocksdb-savepoint added
flink-tests/src/test/resources/new-stateful-udf-migration-itcase-flink1.11-savepoint added
flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.10 added
flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.11 added
flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.10 added
flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.11 added
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.10-jobmanager-savepoint added
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.10-rocksdb-savepoint added
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.11-jobmanager-savepoint added
flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.11-rocksdb-savepoint added
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.10-jobmana
ger-savepoint
added
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.10-rocksdb
-savepoint
added
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.11-jobmana
ger-savepoint
added
flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.11-rocksdb
-savepoint
added
flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.10-rocksdb-savepoin
t
added
flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.10-savepoint added
flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.11-rocksdb-savepoin
t
added
flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.11-savepoint added
flink-walkthroughs/flink-walkthrough-common/src/main/java/org/apache/flink/walkthrough/common/table removed
flink-walkthroughs/flink-walkthrough-table-java removed
flink-walkthroughs/flink-walkthrough-table-java/src removed
flink-walkthroughs/flink-walkthrough-table-java/src/main removed
flink-walkthroughs/flink-walkthrough-table-java/src/main/resources removed
flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/archetype-resources removed
flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/archetype-resources/src removed
flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/archetype-resources/src/main removed
flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/archetype-resources/src/main/jav
a
removed
flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/archetype-resources/src/main/res
ources
removed
flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/META-INF removed
flink-walkthroughs/flink-walkthrough-table-java/src/main/resources/META-INF/maven removed
flink-walkthroughs/flink-walkthrough-table-scala removed
flink-walkthroughs/flink-walkthrough-table-scala/src removed
flink-walkthroughs/flink-walkthrough-table-scala/src/main removed
flink-walkthroughs/flink-walkthrough-table-scala/src/main/resources removed
flink-walkthroughs/flink-walkthrough-table-scala/src/main/resources/archetype-resources removed
flink-walkthroughs/flink-walkthrough-table-scala/src/main/resources/archetype-resources/src removed
flink-walkthroughs/flink-walkthrough-table-scala/src/main/resources/archetype-resources/src/main removed
flink-walkthroughs/flink-walkthrough-table-scala/src/main/resources/archetype-resources/src/main/re
sources
removed
flink-walkthroughs/flink-walkthrough-table-scala/src/main/resources/archetype-resources/src/main/sc
ala
removed
flink-walkthroughs/flink-walkthrough-table-scala/src/main/resources/META-INF removed
flink-walkthroughs/flink-walkthrough-table-scala/src/main/resources/META-INF/maven removed

Text Files (24 of 2181):

NameStatusDeltaVisual Diff
flink-end-to-end-tests/test-scripts/docker-hadoop-secure-cluster/Dockerfile changed 7.6% diff
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/so
cket/SocketWindowWordCount.scala
changed 0.9% diff
flink-formats/flink-json/src/test/resources/debezium-postgres-data-replica-identity.txt added
flink-formats/flink-json/src/test/resources/debezium-postgres-data-schema-exclude.txt added
flink-formats/flink-json/src/test/resources/debezium-postgres-data-schema-include.txt added
flink-table/flink-sql-parser-hive/src/main/codegen/includes/parserImpls.ftl changed 0.5% diff
flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/bridge/scala/Str
eamTableEnvironment.scala
changed 2.1% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/SinkCod
eGenerator.scala
changed 1.2% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/functions/utils
/UserDefinedFunctionUtils.scala
changed 0.01% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/comm
on/CommonLookupJoin.scala
changed 0.2% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logi
cal/WindowPropertiesRule.scala
changed 0.6% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/phys
ical/stream/MiniBatchIntervalInferRule.scala
changed 5.9% diff
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/phys
ical/stream/StreamExecTemporalSortRule.scala
changed 14.4% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/common/Vie
wsExpandingTest.scala
changed 83.1% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql
/join/LookupJoinTest.scala
changed 1.5% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/stream/sql
/MiniBatchIntervalInferTest.scala
changed 18.9% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/FileSys
temITCaseBase.scala
changed 3.7% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/
sql/AggregateITCase.scala
changed 3.3% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/
sql/LookupJoinITCase.scala
changed 3.9% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/
sql/StreamTableEnvironmentITCase.scala
changed 21.0% diff
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/
sql/TemporalSortITCase.scala
changed 25.1% diff
flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase
.scala
changed 3.0% diff
flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigration
ITCase.scala
changed 2.1% diff
flink-walkthroughs/flink-walkthrough-table-scala/src/main/resources/archetype-resources/src/main/sc
ala/SpendReport.scala
removed

Packages Compared:

flink-1.11.1-src.tgz
flink-1.11.2-src.tgz


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