"Fossies" - the Fresh Open Source Software Archive  

Source code changes report for "Apache Flink" between the packages
flink-1.8.0-src.tgz and flink-1.8.1-src.tgz

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

Summary:

The "Apache Flink" source code changed by about 0.4% and now consists of 9668 regular files (+19) and 3397 directories.

Related Informations:

See docs/release-notes/flink-1.8.md and docs/monitoring/historyserver.md (flink 1.8.1).

Changes In Files (According File Type):

File TypeTotalAddedRemovedChanged
C program 98 0 0 1
Assembler program 3 0 0 0
Java program 6655 19 1 120
Python program 73 0 0 0
Shell program 123 2 1 9
Ruby program 7 0 0 0
CoffeeScript file 18 0 0 0
Configuration file 4 0 0 0
Executable file 2 0 0 0
JavaScript file 8 0 0 0
JSON file 7 0 0 0
Man page 1 0 0 0
SGML document 161 0 0 7
XML document 206 0 0 152
CSS style sheet 7 0 0 0
CSV file 1 0 0 0
DOS Batch file 4 0 0 0
Font file 28 0 0 0
Git file 1 0 0 0
HTML page 109 0 0 3
Property file 90 0 0 2
TeX document 1 0 0 0
YAML file 20 0 0 1
Data file 537 0 0 0
Icon 3 0 0 0
Image file 69 0 0 0
Vector Image file 45 0 0 0
Directory 3397 0 0 0
Information file 36 0 0 0
License 145 0 0 0
Readme file 19 0 0 2
Text file 1166 0 0 7
Other 23 0 0 0
Total Files13067212304



C Programs (1 of 98):

NameStatusDeltaVisual Diff
flink-scala/src/test/scala/org/apache/flink/api/scala/typeutils/ScalaCaseClassSerializerReflectionT
est.scala
changed 36.8% diff

Java Programs (140 of 6655):

NameStatusDeltaVisual Diff
docs/dev/stream/operators/process_function.md changed 10.1% diff
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cass
andra/CassandraCommitter.java
changed 2.8% diff
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cass
andra/CassandraRowWriteAheadSink.java
changed 2.6% diff
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cass
andra/CassandraSinkBase.java
changed 2.6% diff
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cass
andra/CassandraTupleWriteAheadSink.java
changed 2.6% diff
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kaf
ka/FlinkKafkaProducer011.java
changed 2.6% diff
flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kaf
ka/FlinkKafkaProducer011ITCase.java
changed 6.6% diff
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kaf
ka/FlinkKafkaConsumerBase.java
changed 0.5% diff
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kaf
ka/FlinkKafkaProducerBase.java
changed 1.0% diff
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/Fl
inkKafkaProducer.java
changed 2.5% diff
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/Fl
inkKafkaProducerITCase.java
changed 6.6% diff
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/config/ConsumerConfigConstants.java
changed 7.0% diff
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/FlinkKinesisConsumer.java
changed 4.9% diff
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/internals/DynamoDBStreamsDataFetcher.java
changed 0.3% diff
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/internals/KinesisDataFetcher.java
changed 24.6% diff
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/util/JobManagerWatermarkTracker.java
added
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/util/RecordEmitter.java
added
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesi
s/util/WatermarkTracker.java
added
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/FlinkKinesisConsumerMigrationTest.java
changed 0.6% diff
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/FlinkKinesisConsumerTest.java
changed 17.6% diff
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/internals/ShardConsumerTest.java
changed 3.6% diff
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/testutils/TestableKinesisDataFetcher.java
changed 0.2% diff
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/util/JobManagerWatermarkTrackerTest.java
added
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/util/RecordEmitterTest.java
added
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesi
s/util/WatermarkTrackerTest.java
added
flink-container/src/main/java/org/apache/flink/container/entrypoint/StandaloneJobClusterConfigurati
on.java
changed 4.2% diff
flink-container/src/main/java/org/apache/flink/container/entrypoint/StandaloneJobClusterConfigurati
onParserFactory.java
changed 1.8% diff
flink-container/src/main/java/org/apache/flink/container/entrypoint/StandaloneJobClusterEntryPoint.
java
changed 17.5% diff
flink-container/src/test/java/org/apache/flink/container/entrypoint/StandaloneJobClusterConfigurati
onParserFactoryTest.java
changed 21.1% diff
flink-container/src/test/java/org/apache/flink/container/entrypoint/StandaloneJobClusterEntryPointT
est.java
added
flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java changed 3.1% diff
flink-core/src/main/java/org/apache/flink/api/common/io/InputFormat.java changed 1.8% diff
flink-core/src/main/java/org/apache/flink/api/common/state/StateDescriptor.java changed 12.0% diff
flink-core/src/main/java/org/apache/flink/api/common/state/StateTtlConfig.java changed 17.8% diff
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/DataInputViewStream.java changed 11.4% diff
flink-core/src/main/java/org/apache/flink/configuration/BlobServerOptions.java changed 12.8% diff
flink-core/src/main/java/org/apache/flink/configuration/ResourceManagerOptions.java changed 24.9% diff
flink-core/src/test/java/org/apache/flink/api/common/state/StateDescriptorTest.java changed 15.2% diff
flink-core/src/test/java/org/apache/flink/api/common/state/StateTtlConfigTest.java added
flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/DataInputViewStreamTest.java added
flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/tests/D
ataStreamStateTTLTestProgram.java
changed 1.7% diff
flink-java/src/main/java/org/apache/flink/api/java/ClosureCleaner.java changed 30.1% diff
flink-java/src/main/java/org/apache/flink/api/java/DataSet.java changed 0.1% diff
flink-java/src/test/java/org/apache/flink/api/java/functions/ClosureCleanerTest.java changed 100.0% diff
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java changed 1.5% diff
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java changed 3.3% diff
flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerTest.
java
changed 1.0% diff
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFet
cher.java
changed 7.1% diff
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerTest.java changed 11.8% diff
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobClient.java changed 1.9% diff
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java changed 3.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java changed 2.7% diff
flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatListener.java changed 14.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerImpl.java changed 9.9% diff
flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerSenderImpl.java changed 40.6% diff
flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatServices.java changed 12.1% diff
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java changed 7.8% diff
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java changed 4.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartition.java changed 2.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionManager.ja
va
changed 5.0% diff
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/AllocatedSlotInfo.java added
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/AllocatedSlotReport.java added
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java changed 3.7% diff
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java changed 5.0% diff
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java changed 3.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java changed 7.7% diff
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerRuntimeServices
.java
changed 4.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java changed 3.6% diff
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerConfigu
ration.java
changed 15.7% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/checkpoints/TaskCheckpointSta
tisticDetailsHandler.java
changed 1.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/SubtaskExecutionAttemptAccumu
latorsHandler.java
changed 9.3% diff
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/SubtaskExecutionAttemptDetail
sHandler.java
changed 9.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java changed 5.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java changed 11.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/rpc/RpcGlobalAggregateManager.jav
a
changed 7.5% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlot.java changed 0.6% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTable.java changed 0.2% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java changed 13.9% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorGateway.java changed 5.4% diff
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java changed 0.3% diff
flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientSslTest.java changed 3.2% diff
flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientTest.java changed 11.7% diff
flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/FutureUtilsTest.java changed 9.9% diff
flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/ManuallyTriggeredScheduledExecutor.
java
changed 2.4% diff
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphSuspendTest.java changed 4.9% diff
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/InteractionsCountingTaskManager
Gateway.java
changed 23.4% diff
flink-runtime/src/test/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerTest.java changed 38.3% diff
flink-runtime/src/test/java/org/apache/flink/runtime/heartbeat/TestingHeartbeatListener.java added
flink-runtime/src/test/java/org/apache/flink/runtime/heartbeat/TestingHeartbeatListenerBuilder.java added
flink-runtime/src/test/java/org/apache/flink/runtime/heartbeat/TestingHeartbeatServices.java changed 56.2% diff
flink-runtime/src/test/java/org/apache/flink/runtime/heartbeat/TestingHeartbeatTarget.java added
flink-runtime/src/test/java/org/apache/flink/runtime/heartbeat/TestingHeartbeatTargetBuilder.java added
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionTest.java changed 0.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest
.java
changed 19.4% diff
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java changed 16.3% diff
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolTest.java renamed 15.5% diff
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImplTest.java
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerHATest.java changed 1.0% diff
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerJobMasterTest.j
ava
changed 2.4% diff
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerTaskExecutorTes
t.java
changed 25.4% diff
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/ResourceManagerTest.java changed 8.0% diff
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerBuilder
.java
added
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerTest.ja
va
changed 4.9% diff
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotProtocolTest.j
ava
changed 5.6% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestClientTest.java changed 0.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/rpc/TestingRpcService.java changed 18.9% diff
flink-runtime/src/test/java/org/apache/flink/runtime/state/CheckpointStreamWithResultProviderTest.j
ava
changed 0.7% diff
flink-runtime/src/test/java/org/apache/flink/runtime/state/SnapshotDirectoryTest.java changed 15.6% diff
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendLoadingTest.java changed 14.2% diff
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateSnapshotCompressionTest.java changed 0.6% diff
flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/mock/MockKeyedStateBackendBuilder.ja
va
changed 0.1% diff
flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/mock/MockStateBackend.java changed 1.1% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorTest.java changed 13.3% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TestingTaskExecutorGateway.java changed 10.8% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TestingTaskExecutorGatewayBuilder
.java
changed 12.4% diff
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/NoOpTaskActions.java added
flink-runtime/src/test/java/org/apache/flink/runtime/util/clock/ManualClock.java changed 5.7% diff
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/st
ate/RocksDBKeyedStateBackendBuilder.java
changed 0.1% diff
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/st
ate/snapshot/RocksIncrementalSnapshotStrategy.java
changed 3.5% diff
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/st
ate/RocksDBStateBackendTest.java
changed 1.1% diff
flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/st
ate/ttl/RocksDBTtlStateTestBase.java
changed 0.6% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnviro
nment.java
changed 0.1% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/Streami
ngFileSink.java
changed 0.7% diff
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowled
gingSourceBase.java
changed 3.3% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/benchmark/StreamNetworkBen
chmarkEnvironment.java
changed 6.4% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTaskTestH
arness.java
changed 39.6% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamConfigChainer.jav
a
changed 18.8% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamMockEnvironment.j
ava
changed 2.8% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.j
ava
changed 6.4% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/KeyedOneInputStreamOperatorTestH
arness.java
changed 6.5% diff
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/KeyedTwoInputStreamOperatorTestH
arness.java
changed 8.3% diff
flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractTaskManagerProcessFailureRecoveryT
est.java
changed 9.8% diff
flink-tests/src/test/java/org/apache/flink/test/state/StatefulOperatorChainedTaskTest.java added
flink-yarn-tests/src/test/java/org/apache/flink/yarn/UtilsTest.java changed 53.5% diff
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOSecuredITCase.java changed 18.2% diff
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java changed 5.6% diff
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java changed 16.3% diff
flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java changed 2.5% diff
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java changed 1.8% diff
flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java changed 2.0% diff

Shell Programs (12 of 123):

NameStatusDeltaVisual Diff
flink-container/docker/build.sh changed 81.3% diff
flink-contrib/docker-flink/build.sh changed 86.5% diff
flink-end-to-end-tests/run-pre-commit-tests.sh changed 3.0% diff
flink-scala-shell/start-script/start-scala-shell.sh changed 7.2% diff
tools/check_dependency_convergence.sh removed
tools/travis/nightly.sh changed 6.4% diff
tools/travis/setup_docker.sh added
tools/travis/setup_kubernetes.sh added
tools/travis/splits/split_container.sh changed 4.8% diff
tools/travis_controller.sh changed 14.9% diff
tools/travis_mvn_watchdog.sh changed 0.7% diff
tools/verify_scala_suffixes.sh changed 12.2% diff

SGML Documents (7 of 161):

NameStatusDeltaVisual Diff
docs/dev/connectors/kinesis.md changed 3.1% diff
docs/dev/execution_configuration.md changed 8.5% diff
docs/dev/stream/state/state.md changed 4.6% diff
docs/ops/config.md changed 5.0% diff
docs/ops/deployment/cluster_setup.md changed 0.9% diff
docs/ops/deployment/yarn_setup.md changed 15.4% diff
docs/ops/security-ssl.md changed 9.8% diff

XML Documents (152 of 206):

NameStatusDeltaVisual Diff
flink-annotations/pom.xml changed 2.2% diff
flink-clients/pom.xml changed 0.5% diff
flink-connectors/flink-connector-cassandra/pom.xml changed 0.4% diff
flink-connectors/flink-connector-elasticsearch-base/pom.xml changed 0.6% diff
flink-connectors/flink-connector-elasticsearch/pom.xml changed 0.5% diff
flink-connectors/flink-connector-elasticsearch2/pom.xml changed 0.4% diff
flink-connectors/flink-connector-elasticsearch5/pom.xml changed 0.3% diff
flink-connectors/flink-connector-elasticsearch6/pom.xml changed 0.4% diff
flink-connectors/flink-connector-filesystem/pom.xml changed 0.6% diff
flink-connectors/flink-connector-kafka-0.10/pom.xml changed 0.4% diff
flink-connectors/flink-connector-kafka-0.11/pom.xml changed 0.4% diff
flink-connectors/flink-connector-kafka-0.8/pom.xml changed 0.4% diff
flink-connectors/flink-connector-kafka-0.9/pom.xml changed 0.4% diff
flink-connectors/flink-connector-kafka-base/pom.xml changed 0.4% diff
flink-connectors/flink-connector-kafka/pom.xml changed 0.4% diff
flink-connectors/flink-connector-kinesis/pom.xml changed 0.4% diff
flink-connectors/flink-connector-nifi/pom.xml changed 1.0% diff
flink-connectors/flink-connector-rabbitmq/pom.xml changed 1.2% diff
flink-connectors/flink-connector-twitter/pom.xml changed 0.9% diff
flink-connectors/flink-hadoop-compatibility/pom.xml changed 0.5% diff
flink-connectors/flink-hbase/pom.xml changed 0.3% diff
flink-connectors/flink-hcatalog/pom.xml changed 0.5% diff
flink-connectors/flink-jdbc/pom.xml changed 1.2% diff
flink-connectors/flink-orc/pom.xml changed 0.8% diff
flink-connectors/flink-sql-connector-elasticsearch6/pom.xml changed 0.5% diff
flink-connectors/flink-sql-connector-kafka-0.10/pom.xml changed 0.9% diff
flink-connectors/flink-sql-connector-kafka-0.11/pom.xml changed 0.9% diff
flink-connectors/flink-sql-connector-kafka-0.9/pom.xml changed 1.0% diff
flink-connectors/flink-sql-connector-kafka/pom.xml changed 0.9% diff
flink-connectors/pom.xml changed 0.6% diff
flink-container/pom.xml changed 0.9% 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 0.1% diff
flink-docs/pom.xml changed 0.4% diff
flink-end-to-end-tests/flink-bucketing-sink-test/pom.xml changed 1.0% diff
flink-end-to-end-tests/flink-cli-test/pom.xml changed 1.2% diff
flink-end-to-end-tests/flink-confluent-schema-registry/pom.xml changed 1.9% diff
flink-end-to-end-tests/flink-dataset-allround-test/pom.xml changed 1.3% 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-e2e-test-utils/pom.xml changed 1.1% diff
flink-end-to-end-tests/flink-elasticsearch1-test/pom.xml changed 1.1% diff
flink-end-to-end-tests/flink-elasticsearch2-test/pom.xml changed 1.1% diff
flink-end-to-end-tests/flink-elasticsearch5-test/pom.xml changed 1.1% diff
flink-end-to-end-tests/flink-elasticsearch6-test/pom.xml changed 1.0% diff
flink-end-to-end-tests/flink-end-to-end-tests-common/pom.xml changed 2.6% 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 0.9% diff
flink-end-to-end-tests/flink-local-recovery-and-allocation-test/pom.xml changed 1.1% diff
flink-end-to-end-tests/flink-metrics-availability-test/pom.xml changed 1.0% diff
flink-end-to-end-tests/flink-metrics-reporter-prometheus-test/pom.xml changed 0.9% 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.1% 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-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.0% 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.3% diff
flink-end-to-end-tests/flink-streaming-kafka-test-base/pom.xml changed 1.8% 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/pom.xml changed 0.6% diff
flink-examples/flink-examples-batch/pom.xml changed 0.2% diff
flink-examples/flink-examples-build-helper/flink-examples-streaming-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.9% diff
flink-examples/flink-examples-streaming/pom.xml changed 0.2% diff
flink-examples/flink-examples-table/pom.xml changed 0.7% diff
flink-examples/pom.xml changed 1.1% diff
flink-filesystems/flink-fs-hadoop-shaded/pom.xml changed 0.3% diff
flink-filesystems/flink-hadoop-fs/pom.xml changed 1.0% diff
flink-filesystems/flink-mapr-fs/pom.xml changed 1.3% diff
flink-filesystems/flink-oss-fs-hadoop/pom.xml changed 0.6% diff
flink-filesystems/flink-s3-fs-base/pom.xml changed 0.5% diff
flink-filesystems/flink-s3-fs-hadoop/pom.xml changed 0.8% diff
flink-filesystems/flink-s3-fs-presto/pom.xml changed 0.3% 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 2.2% diff
flink-formats/flink-avro/pom.xml changed 0.3% diff
flink-formats/flink-csv/pom.xml changed 0.9% diff
flink-formats/flink-json/pom.xml changed 0.9% diff
flink-formats/flink-parquet/pom.xml changed 0.6% diff
flink-formats/flink-sequence-file/pom.xml changed 1.0% diff
flink-formats/pom.xml changed 1.4% diff
flink-fs-tests/pom.xml changed 0.7% diff
flink-java/pom.xml changed 1.1% 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.1% diff
flink-libraries/flink-ml-uber/pom.xml changed 0.9% diff
flink-libraries/flink-ml/pom.xml changed 0.5% diff
flink-libraries/flink-python/pom.xml changed 0.7% diff
flink-libraries/flink-streaming-python/pom.xml changed 0.9% diff
flink-libraries/pom.xml changed 1.3% diff
flink-mesos/pom.xml changed 0.3% diff
flink-metrics/flink-metrics-core/pom.xml changed 1.6% 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 1.0% diff
flink-metrics/flink-metrics-influxdb/pom.xml changed 0.5% diff
flink-metrics/flink-metrics-jmx/pom.xml changed 1.0% diff
flink-metrics/flink-metrics-prometheus/pom.xml changed 0.7% 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-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.4% diff
flink-runtime/pom.xml changed 0.2% diff
flink-scala-shell/pom.xml changed 0.4% diff
flink-scala/pom.xml changed 0.4% diff
flink-shaded-curator/pom.xml changed 1.1% diff
flink-shaded-hadoop/flink-shaded-hadoop2-uber/pom.xml changed 2.1% diff
flink-shaded-hadoop/flink-shaded-hadoop2/pom.xml changed 0.3% diff
flink-shaded-hadoop/flink-shaded-yarn-tests/pom.xml changed 1.2% diff
flink-shaded-hadoop/pom.xml changed 0.4% diff
flink-state-backends/flink-statebackend-rocksdb/pom.xml changed 1.0% diff
flink-state-backends/pom.xml changed 2.0% diff
flink-streaming-java/pom.xml changed 0.9% diff
flink-streaming-scala/pom.xml changed 0.3% diff
flink-table/flink-sql-client/pom.xml changed 0.5% diff
flink-table/flink-table-api-java-bridge/pom.xml changed 1.4% diff
flink-table/flink-table-api-java/pom.xml changed 1.7% diff
flink-table/flink-table-api-scala-bridge/pom.xml changed 1.4% diff
flink-table/flink-table-api-scala/pom.xml changed 1.6% diff
flink-table/flink-table-common/pom.xml changed 1.5% diff
flink-table/flink-table-planner/pom.xml changed 0.3% diff
flink-table/flink-table-uber/pom.xml changed 0.8% diff
flink-table/pom.xml changed 1.8% diff
flink-test-utils-parent/flink-test-utils-junit/pom.xml changed 1.9% diff
flink-test-utils-parent/flink-test-utils/pom.xml changed 0.6% diff
flink-test-utils-parent/pom.xml changed 2.0% diff
flink-tests/pom.xml changed 0.1% diff
flink-yarn-tests/pom.xml changed 0.2% diff
flink-yarn/pom.xml changed 0.4% diff
pom.xml changed 0.6% diff
tools/force-shading/pom.xml changed 0.8% diff

HTML Pages (3 of 109):

NameStatusDeltaVisual Diff
docs/_includes/generated/blob_server_configuration.html changed 20.2%
docs/_includes/generated/yarn_config_configuration.html changed 19.5%
docs/dev/table/functions.md changed 0.001%

Property Files (2 of 90):

NameStatusDeltaVisual Diff
flink-connectors/flink-connector-kafka-0.11/src/test/resources/log4j-test.properties changed 7.5% diff
flink-connectors/flink-connector-kafka/src/test/resources/log4j-test.properties changed 7.5% diff

YAML Files (1 of 20):

NameStatusDeltaVisual Diff
docs/_config.yml changed 5.3% diff

Readme Files (2 of 19):

NameStatusDeltaVisual Diff
flink-container/docker/README.md changed 3.7% diff
flink-contrib/docker-flink/README.md changed 4.9% diff

Text Files (7 of 1166):

NameStatusDeltaVisual Diff
flink-container/docker/Dockerfile changed 22.1% diff
flink-contrib/docker-flink/Dockerfile changed 13.7% diff
flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala changed 0.2% diff
flink-scala/src/main/scala/org/apache/flink/api/scala/ClosureCleaner.scala changed 1.3% diff
flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala changed 0.2% diff
flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/ScalaCaseClassSerializer.scala changed 34.4% diff
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironmen
t.scala
changed 0.2% diff

Packages Compared:

flink-1.8.0-src.tgz
flink-1.8.1-src.tgz


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