https://github.com/apache/flink

sort by:
Revision Author Date Message Commit Date
98997ea Commit for release 1.14.3 08 January 2022, 22:23:54 UTC
ae8a4b7 [FLINK-25307][test] Print the curl logs is querying dispatcher startup failed This closes #18298. 08 January 2022, 11:47:25 UTC
c50151b [FLINK-24880][python] Fix PeriodicThread to handle properly for negative wait timeout value This closes #18292. 07 January 2022, 06:03:45 UTC
69dc8ba [FLINK-25513][python] Handle properly for None result in flat_map and map of ConnectedStream This closes #18280. 06 January 2022, 11:29:25 UTC
fee5532 [FLINK-25464][python] Turn on output infos for package installation in tox This closes #18270. 06 January 2022, 02:16:40 UTC
24f1449 [hotfix][doc]Fixed an issue where clicking Window Assigner and Window Function in Windows documents could not jump correctly. 05 January 2022, 14:23:32 UTC
7263d97 [FLINK-25477][docs] Make the directory structure of the State Backends document display correctly 04 January 2022, 03:14:13 UTC
6525971 [FLINK-25294][python] Fix cloudpickle import This closes #18099. 31 December 2021, 06:22:00 UTC
19c3655 [FLINK-25418][python] Install dependencies offline if the cache dir is specified This closes #18186. 31 December 2021, 06:07:28 UTC
09a8d25 [FLINK-25472][core] Update to Log4j 2.17.1 This closes #18230. 30 December 2021, 13:30:51 UTC
a73d1b2 [hotfix][connectors][docs] Use big M letters for month in date format 30 December 2021, 07:59:12 UTC
95777d1 [FLINK-25415] Add retries to CasandraConnectorITCase Add 3 retrials to all tests and to startAndInitializeCassandra() methods in CassandraConnectorITCase upon NoHostAvailableException which happens under load when cluster.connect() is called. 29 December 2021, 14:51:37 UTC
e9b6abc [FLINK-25147] add keyspace drop because the docker image is reused and modified by the tests. 29 December 2021, 14:51:36 UTC
f851f58 [FLINK-25468] Copy SST files if they cannot be hard linked in RocksDBHandle.restoreInstanceDirectoryFromPath The RocksDBHandle.restoreInstanceDirectoryFromPath hard links SST files. If this operation does not work because the source directory is on a different file system then it will now copy the file over. This closes #18222. 29 December 2021, 08:24:38 UTC
24016b8 [FLINK-25446][state] Avoid improper sanity check on read bytes on DataInputStream#read(byte[]) 28 December 2021, 14:03:30 UTC
457c42f [FLINK-23047] Ignore CassandraConnectorITCase until the flakiness of this test is fixed. This closes #18204. 27 December 2021, 10:27:03 UTC
ebbf772 [FLINK-25132][connector/kafka] Move record deserializing from SplitFetcher to RecordEmitter to support object-reusing deserializer 26 December 2021, 11:39:15 UTC
49971b8 [FLINK-25375] Update log4j2 dependency to 2.17.0 to address (#18167) CVE-2021-45105 Co-authored-by: Bernard Joseph Jean Bruno <brunobernard@busymind101.com> 26 December 2021, 07:41:52 UTC
a9d43ee [FLINK-24481][docs] Translate buffer debloat documenation to chinese This closes #17953 23 December 2021, 07:37:27 UTC
2bf213c [hotfix][docs] Minor fixes in Network Memory Tuning Guide 23 December 2021, 07:37:22 UTC
ae4856a [FLINK-25422][python] Specify requirements in dev-requirements.txt 23 December 2021, 06:24:47 UTC
68148d9 [FLINK-25271][clients] Harden the ApplicationDispatcherBootstrapITCase. 22 December 2021, 10:38:13 UTC
cc78ea5 [FLINK-25147][connectors][test] This test case now works on java 11 This closes #18138. 21 December 2021, 14:20:57 UTC
a80c179 [FLINK-25147][connectors][test] Migrate Cassandra connector tests to testContainers 17 December 2021, 10:52:45 UTC
11d2470 [FLINK-24728][tests] Add tests to ensure SQL file sink closes all created files This closes #18073 17 December 2021, 05:37:11 UTC
069d629 [FLINK-24232][coordination] Skip history server archiving for suspended jobs Do not create an archive for suspended jobs, as this would eventually lead to multiple archive attempts which we currently do not support. 16 December 2021, 15:31:21 UTC
311fa53 [FLINK-25326][connectors/kafka] Fix application of log levels in KafaUtils.createKafkacontainer 16 December 2021, 14:03:17 UTC
9fb9824 Update for 1.14.2 16 December 2021, 13:23:26 UTC
8d5d7d4 [FLINK-24846][streaming] Guava import fix in AsyncWaitOperatorTest 15 December 2021, 13:14:29 UTC
8a939cc [hotfix][tests] Await broker shutdown during KafkaTestEnvironmentImpl#shutdown 15 December 2021, 13:06:37 UTC
2318077 [hotfix][tests] Close Kafka AdminClients to prevent resource leaks 15 December 2021, 13:06:37 UTC
3de8b3d [FLINK-25222][tests] Remove NetworkFailureProxy used in Kafka tests We suspect that the NetworkFailureProxy is causing constant connectivity problems to the brokers during testing resulting in either network timeouts or corrupted results. Since the NetworkFailureProxy is only used for testing the deprecated FlinkKafkaProducer/Consumer we can safely remove it because we will not add new features to the connectors. 15 December 2021, 13:06:37 UTC
e7df5ec [FLINK-24846][streaming] Ignoring completing async operator record if mailbox is closed already 15 December 2021, 12:51:45 UTC
31112ca [FLINK-25295][build] Update log4j2 dependency to 2.16.0 14 December 2021, 22:11:24 UTC
1aa1231 [FLINK-22775][cassandra][tests] Lower write consistency level to ANY This consistency level is only available on write, so we need to create one builder for reading and one for writing. Some sinks are used for both reading and writing, in that case, reading builder is used. (cherry picked from commit c40bbf1e87cc62880905cd567dca05a4e15aff35) 14 December 2021, 15:02:51 UTC
39c6949 [FLINK-24987][docs] Improve ExternalizedCheckpointCleanup documentation 14 December 2021, 07:15:26 UTC
30da65c [FLINK-24987][streaming-java] Add explicit enum value NO_EXTERNAL_CHECKPOINTS as default for externalized-checkpoint-retention 14 December 2021, 07:15:26 UTC
980bb03 [hotfix][docs] Fix Scala example for MiniCluster test This closes #17949 13 December 2021, 15:36:22 UTC
256153e [FLINK-22096][tests] Fix port conflict for ServerTransportErrorHandlingTest#testRemoteClose This closes #18089. 13 December 2021, 13:11:12 UTC
d3977d2 [FLINK-20195][coordination] Deduplicate jobs for overview 12 December 2021, 11:26:05 UTC
d35a983 [hotfix][docs] Update Log4j version in Gradle template 12 December 2021, 10:53:04 UTC
031f46f [FLINK-25240][build] Upgrade Log4j2 to 2.15.0 12 December 2021, 10:44:16 UTC
cc78095 [FLINK-24077][HBase/IT] use MiniClusterWithClientResource as @ClassRule. while using TableEnvironment in the ITCase, a Flink MiniCluster will be started/stopped automatically in the background. Since the shutdown of the MiniCluster will be called asynchronously, CollectResultFetcher will get data lost sometimes based on race conditions and the unchecked RuntimeException java.lang.IllegalStateException will be thrown that we were not aware of. The solution is to control the lifecycle of the MiniCluster manually in this test. The MiniClusterWithClientResource could be a good fit in this case. (cherry picked from commit fca04c3aaf6346d61cf9fe022a7ac77ab4d66c91) 11 December 2021, 15:33:30 UTC
4e962d9 [FLINK-24077][HBase/IT] Add check of row count after insert and wait explicitly for job to finish. (cherry picked from commit 7976be0f8675a8753a5bb7e7a44dda6b4a347247) 11 December 2021, 15:33:30 UTC
dccd7f0 [FLINK-25126][kafka] Reset internal transaction state of FlinkKafkaInternalProducer if transaction finalization fails In the KafkaCommitter we retry transactions if they failed during committing. Since we reuse the KafkaProducers we update the used transactionalId to continue committing other transactions. To prevent accidental overwrites we track the transaction state inside the FlinkKafkaInternalProducer. Before this change, the state was not reset on a failures during the transaction finalization and setting a new transactionalId failed. The state is now always reset nevertheless whether finalizing the transaction fails (commit, abort). 10 December 2021, 09:02:02 UTC
b194e83 [FLINK-23946] Flink 1.14 compatibility + disable a flaky test `ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange` (FLINK-25235) This closes #18066. 10 December 2021, 08:32:02 UTC
0a99256 [FLINK-23946][clients] Code review based fixes. 10 December 2021, 08:32:01 UTC
4567d87 [FLINK-23946][FLINK-24038][tests] Harden ZooKeeperLeaderElectionITCase. 10 December 2021, 08:32:00 UTC
ff96e93 [FLINK-23946][clients] Dispatcher in application mode should be able to recover after losing and regaining leadership. 10 December 2021, 08:32:00 UTC
7c380ba [FLINK-25096] Fixes empty exception history for JobInitializationException (#18035) 10 December 2021, 07:37:31 UTC
946056e [FLINK-25091][docs] Change ORC compression attribute reference error in FileSink doc 09 December 2021, 07:39:19 UTC
347becb [FLINK-19142][runtime] Fix slot hijacking after task failover This closes #15229. 09 December 2021, 02:44:07 UTC
63cf221 [FLINK-19142][runtime] Use LocationPreferenceSlotSelectionStrategy for batch jobs even if local recovery is enabled 09 December 2021, 02:44:07 UTC
f915f09 [hotfix][tests] Factor PerJobMiniClusterFactoryTest#MyCancellableInvokable out to be a standalone test class in flink-runtime 09 December 2021, 02:44:07 UTC
3eae179 [hotfix][runtime] Rename `previousExecutionGraphAllocations` in SlotProfile to `reservedAllocations` to avoid confusion 09 December 2021, 02:44:07 UTC
a1f7a5c [hotfix][runtime] Refactor testing methods out from SlotProfile into SlotProfileTestingUtils 09 December 2021, 02:44:07 UTC
94f269d Revert "[FLINK-24859][doc][formats] Make new formats name coherent" This reverts commit 50cd7bb2df1c384ccf5cfc5ed7808e177d62ee1c. 08 December 2021, 15:46:06 UTC
7c5ddbd [FLINK-20370][table] part1: Fix wrong results when sink primary key is not the same with query result's changelog upsert key This closes #18048 08 December 2021, 09:03:37 UTC
0ec9924 [FLINK-22113][table-planner] Implement column uniqueness checking for TableSourceTable This closes #18040 Co-authored-by: guanghxu <xuguangheng1995@gmail.com> 08 December 2021, 02:35:35 UTC
5207fe5 [FLINK-25022][rest] Run jars in separate threads Use a dedicated thread to run each jar, so that pooled threads can't keep references to user-code (e.g., in a ThreadLocal). 07 December 2021, 10:26:43 UTC
b4fda42 [FLINK-23493][python] Remove the calling of child process in the beam_boot.py This closes #18025. 07 December 2021, 02:06:14 UTC
a87ca1e [FLINK-24859][doc][formats] document parquet file reading 06 December 2021, 18:50:25 UTC
47d496a [FLINK-24859][doc][formats] document text file reading 06 December 2021, 18:50:25 UTC
3b9aaca [FLINK-24859][doc][formats] Make new formats name coherent 06 December 2021, 18:50:25 UTC
ef0e17a [FLINK-24777][docs] Correct description of 'Processed (persisted) in-flight data' This closes #17686. 06 December 2021, 12:25:15 UTC
7e4cc6f [FLINK-24506][config] Adds checkpoint directory to CheckpointConfig This enables the user to pass in the checkpoint directory through the Flink configuration again. This fixes an issue that was introduced by FLINK-19463. 05 December 2021, 10:50:06 UTC
5914139 [hotfix][tests] Remove Mocking from TaskLocalStateStoreImplTest Mockito's spy prevented TaskLocalStateStoreImplTest from succeeding because a mock cannot be serialized. 03 December 2021, 14:49:26 UTC
f6fa4ff [hotfix] Make IncrementalLocalKeyedStateHandle serializable by copying sharedStateHandleIDs 03 December 2021, 14:49:26 UTC
bbfe652 [FLINK-24813][table-planner] Improve ImplicitTypeConversionITCase This closes #17771 (cherry picked from commit d489558f46e8348e7f7aaa066925f5c0adaa09a8) 03 December 2021, 09:39:13 UTC
a495312 [FLINK-21407][doc][formats] Split DataSet connectors page into different formats and create a formats sub-folder like in table api doc 02 December 2021, 20:14:20 UTC
928d4c4 [FLINK-21407] bump microsoft-hadoop-azure version 02 December 2021, 20:14:20 UTC
9ad998a [FLINK-21407][doc][formats] Drop old formats 02 December 2021, 20:14:20 UTC
7a20741 [FLINK-21407][doc][formats] Update hadoop doc 02 December 2021, 20:14:20 UTC
e7d8209 [FLINK-21407][doc][formats] Move haddop input and output formats to hadoop.md formats page 02 December 2021, 20:14:20 UTC
db8be1d [FLINK-21407][doc][formats] Add formats to DataStream connectors doc 02 December 2021, 20:14:20 UTC
d26c0e5 [FLINK-24919][runtime] Getting vertex only under synchronization 02 December 2021, 16:01:24 UTC
7b0b22b [hotfix][ci] Enable cron build 02 December 2021, 12:36:20 UTC
0d9aed9 [FLINK-25134][test] Remove unused RetryRule from KafkaConsumerTestBase Before this commit the RetryRule actually prevented retries of tests inheriting from KafkaConsumerTestBase. Now, the retries are handled by KafkaTestBase and all subclasses have the same retry behaviour. 02 December 2021, 07:42:21 UTC
a67afb2 [FLINK-15493][test] Add retry rule for all tests based on KafkaTestBase 02 December 2021, 07:42:21 UTC
42e0e58 [FLINK-15493][test] Inherit retry rule annotations to sub classes 02 December 2021, 07:42:21 UTC
d52874a [FLINK-24348][FLINK-24740][testinfrastructure][kafka] Update testcontainers dependency to v1.16.2 01 December 2021, 16:27:00 UTC
b620225 [FLINK-25092][tests][elasticsearch] Refactor test to use artifact cacher (cherry picked from commit 5eeef8371ed0e726f737547bfd888d0d66cb3ab5) 01 December 2021, 16:26:22 UTC
ab9f939 [FLINK-21467] Clarify javadocs of Bounded(One/Multi)Input interfaces We clarify contracts of Bounded(One/Multi)Input interfaces. Especially adding a warning none of those interfaces should be used for commiting side effects. 01 December 2021, 15:57:46 UTC
c8c60e1 [FLINK-25112][tests] Remove cache-ttl for Java e2e tests 01 December 2021, 08:57:37 UTC
66cf720 [FLINK-24596][kafka] Make passed lambdas of UpsertKafka serializable 01 December 2021, 08:04:58 UTC
b0f5639 [FLINK-24596][core] Introduce SerializableFunction and unify usages 01 December 2021, 08:04:58 UTC
b7cd97b [FLINK-24596][table] Allow using unified Sinks with the DataStreamSinkProvider 01 December 2021, 08:04:58 UTC
da39169 [FLINK-24310][doc]Use >= instead of == to cover the downscaling scenario 29 November 2021, 11:03:58 UTC
f7c0381 [FLINK-23798][state] Avoid using reflection to get filter when partition filter is enabled 29 November 2021, 02:44:02 UTC
0258419 [FLINK-24789][runtime] Close CheckpointCleaner after checkpoint services in `DefaultScheduler#closeAsync()` and `AdaptiveScheduler#closeAsync()`.' This closes #17926. 26 November 2021, 17:10:07 UTC
0a5481b [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperStateHandleStore in case of unstable connection. This closes #17925. 26 November 2021, 16:32:07 UTC
29c2889 [FLINK-21214][kafka/IT] Add retry rule for the ITCase. The issue has been solved after bumping Kafka to 2.8.1. 26 November 2021, 15:31:00 UTC
2343b9c [FLINK-24971][tests] Adding retry function for failures in Bash e2e tests 26 November 2021, 14:17:09 UTC
315f3bc [FLINK-25067][doc] Correct the description of RocksDB's background threads for flush and compaction 26 November 2021, 09:11:45 UTC
d654297 [FLINK-24922][docs]Fix spelling errors in the word parallism (#17816) 25 November 2021, 05:19:28 UTC
564dee0 [FLINK-24858][core] Prevent version mismatches in TypeSerializers Before this commit some serializers handled the version information incorrectly in the corresponding serializer snapshot which could lead during eagerly instantiation that the wrong version of the serializer was used to deserialize the data. 24 November 2021, 14:11:09 UTC
1592494 [FLINK-24958][docs] Fix the link and typo in SQL "Joins" page (#17835) 24 November 2021, 04:10:10 UTC
ca42ca0 [FLINK-24739][docs] Highlight the fact that the Application Mode excpects user jars to be bundled with the Flink distribution. 23 November 2021, 09:20:01 UTC
a75515a [FLINK-24739][docs] Add backreference from the deployment mode of a resource provider to the high-level deployment mode overview. 23 November 2021, 09:20:01 UTC
6ca6c9c [FLINK-24937][e2e] Return correct exit code in build_image This closes #17875. 23 November 2021, 09:11:39 UTC
back to top