| 4ad4f55 | Dawid Wysakowicz | 14 September 2021, 21:01:57 UTC | Commit for release 1.14.0 | 14 September 2021, 21:01:57 UTC |
| 5f2ec45 | syhily | 14 September 2021, 15:03:40 UTC | [FLINK-24283][connector/pulsar] Use stick key consumer in Key_Shared subscription. This would make sure Pulsar won't treat the flink reader as a shared consumer. This fix https://github.com/apache/pulsar/pull/12035 | 14 September 2021, 19:52:55 UTC |
| 8c1033d | Fabian Paul | 14 September 2021, 14:26:15 UTC | [FLINK-24282][connectors/kafka] Make topic selector for KafkaSink serializable It is possible to calculate the target topic per record. Therefore users can provide a lambda when constructing the KafkaSink. Before this commit the lambda was not marked as serializable and could not be transferred to the workers. | 14 September 2021, 19:52:22 UTC |
| d008496 | Roman Khachatryan | 25 August 2021, 10:16:19 UTC | [FLINK-23607][state/changelog] Document checkpointing.changelog in pom.xml | 14 September 2021, 13:28:31 UTC |
| 2169b79 | Roman Khachatryan | 25 August 2021, 09:29:05 UTC | [FLINK-23607][state/changelog] Cleanup dependencies of DSTL DFS | 14 September 2021, 13:28:31 UTC |
| e7ba160 | Roman Khachatryan | 25 August 2021, 09:13:26 UTC | [FLINK-23607][state/changelog] Make Changelog Backend a transitive dependency ...of flink-test-utils instead of direct dependency of each module. | 14 September 2021, 13:28:31 UTC |
| 918fde8 | Marios Trivyzas | 13 September 2021, 12:21:38 UTC | [hotfix][docs] Fix output of test job Previously, the output listed here was the one for `head` and not `tail` as it's described in the steps to execute the test. This closes #17261. | 14 September 2021, 07:36:28 UTC |
| 753947a | Yun Gao | 13 September 2021, 06:39:18 UTC | [FLINK-24266][checkpoint] Log improvement for aborting checkpoint due to tasks are finishing This closes #17250. | 14 September 2021, 07:03:51 UTC |
| 83ab9eb | Yun Gao | 13 September 2021, 07:26:22 UTC | [hotfix][connector] Use null to replace empty pending transaction in 2pc sink This closes #17251. | 14 September 2021, 07:03:51 UTC |
| 574e80f | huangxingbo | 14 September 2021, 03:23:01 UTC | [FLINK-24276][python] Avoid confusing output when executing in loopback mode This closes #17274. | 14 September 2021, 06:38:51 UTC |
| beb7009 | Dian Fu | 14 September 2021, 03:29:20 UTC | [FLINK-24267][python][docs] Update the example tutorial to use latest API This closes #17273. | 14 September 2021, 06:36:44 UTC |
| b26f7e7 | Qingsheng Ren | 23 August 2021, 03:26:44 UTC | [FLINK-23773][connector/kafka] Mark empty splits as finished to cleanup states in SplitFetcher | 14 September 2021, 05:34:48 UTC |
| 52a26c8 | Qingsheng Ren | 23 August 2021, 04:13:32 UTC | [hotfix][connector/common] Expose splitFinishedHook in SplitFetcher for fine-grained testing | 14 September 2021, 05:34:48 UTC |
| da82cb1 | Yuan Mei | 14 September 2021, 03:09:40 UTC | [FLINK-24155][documentation] Sync Chinese version of documentation to configure CheckpointFailureManager (#17173) (#17252) | 14 September 2021, 03:09:40 UTC |
| 742ba0a | sammieliu | 08 September 2021, 12:20:32 UTC | [FLINK-24212][k8s]fix the problem that kerberos krb5.conf file is mounted as empty directory, not the expected file This closes #17198 | 14 September 2021, 01:58:01 UTC |
| 28677f3 | syhily | 13 September 2021, 08:40:08 UTC | [FLINK-24206][connector/pulsar] Close the pulsar client properly. Pulsar Consumer would be closed in SplitReader if it reaches the end of split. The registered Consumer would also be closed in PulsarClient if we call PulsarClient.close(). This would cause race condition. We have to use PulsarClient.shutdown() which don't close Consumer instead. This closes #17255 | 14 September 2021, 01:40:05 UTC |
| 1e3a923 | martijnvisser | 13 September 2021, 14:32:42 UTC | [hotfix][docs] Adding new sources on overview pages This closes #17266 | 13 September 2021, 16:02:17 UTC |
| dc94e85 | Dawid Wysakowicz | 03 September 2021, 10:05:03 UTC | [FLINK-24098] Document FLIP-147 capabiliites and limitations This closes #17135 | 13 September 2021, 13:00:40 UTC |
| b7e4550 | Dian Fu | 10 September 2021, 09:59:12 UTC | [FLINK-24243][python] Cleanup code to use latest API to avoid warnings This closes #17237. | 13 September 2021, 12:22:23 UTC |
| daad7e2 | Anton Kalashnikov | 25 August 2021, 16:38:49 UTC | [FLINK-23458][docs] Added the network buffer documentation along with the buffer debloat doc | 13 September 2021, 10:16:29 UTC |
| 23d63ed | huangxingbo | 10 September 2021, 11:08:31 UTC | [FLINK-24245][python] Fix the problem caused by multiple jobs sharing the loopback mode address stored in the environment variable in PyFlink This closes #17239. | 13 September 2021, 07:28:54 UTC |
| 79a801a | Piotr Nowojski | 09 September 2021, 12:22:33 UTC | [FLINK-24184][task] Introduce lock to guard against race conditions around shouldInterruptOnCancel Previously there was a potential race condition in disabling interrupts while closing resources. It used be guarded by a volatile variable, but there might have been a race condition when: 1. interrupter thread first checked the shouldInterruptOnCancel flag 2. shouldInterruptOnCancel flag switched to false as Task/StreamTask entered cleaning up phase 3. interrupter issued an interrupt while Task/StreamTask are closing/releasing resources, potentially causing a memory leak | 13 September 2021, 07:24:41 UTC |
| b3a97b1 | Dian Fu | 10 September 2021, 08:56:10 UTC | [FLINK-24244][python] Logging whether it's executed in loopback mode This closes #17234. | 13 September 2021, 03:21:32 UTC |
| ed022d2 | Dian Fu | 09 September 2021, 02:53:42 UTC | [FLINK-18880][python] Respect configurations defined in flink-conf.yaml and environment variables when executing in local mode This closes #17216. | 13 September 2021, 03:17:51 UTC |
| 22e7617 | Yun Gao | 02 September 2021, 11:41:40 UTC | [FLINK-24065][connector] Upgrade the state of TwoPhaseCommitSink to support empty transaction after finished | 13 September 2021, 02:38:55 UTC |
| 7b213e4 | Stephan Ewen | 27 August 2021, 00:26:27 UTC | [hotfix] Improve language for error message when checkpoint is declined due to some tasks being finished already. | 10 September 2021, 14:08:18 UTC |
| b32e6a6 | Yufan Sheng | 10 September 2021, 06:01:34 UTC | [FLINK-23864][docs] Add pulsar connector document (Chinese & English). | 10 September 2021, 12:53:14 UTC |
| 982db57 | Yufan Sheng | 10 September 2021, 04:10:48 UTC | [FLINK-23864][connector/pulsar] Remove PULSAR_AUTO_UPDATE_PARTITIONS option. | 10 September 2021, 12:53:14 UTC |
| d40cfc6 | Yufan Sheng | 10 September 2021, 04:10:12 UTC | [FLINK-23864][connector/pulsar] Release Pulsar Message if user enable poolMessage option. | 10 September 2021, 12:53:14 UTC |
| 77012db | Yufan Sheng | 10 September 2021, 04:09:54 UTC | [FLINK-23864][docs] Add flink-connector-pulsar module to flink-docs, auto generate the config document. | 10 September 2021, 12:53:14 UTC |
| df3b723 | Dawid Wysakowicz | 08 September 2021, 14:41:16 UTC | [FLINK-24161] Fix interplay of stop-with-savepoint w/o drain with final checkpoints This closes #17200 | 10 September 2021, 09:18:24 UTC |
| d9e6abf | huangxingbo | 07 September 2021, 09:24:15 UTC | [FLINK-24123][python] Optimize the python operator instances of the same job to share one python environment resources in the same jvm This closes #17180. | 10 September 2021, 06:05:01 UTC |
| 4e68c45 | Yufan Sheng | 08 September 2021, 15:13:06 UTC | [FLINK-23944][connector/pulsar] Enable PulsarSourceITCase.testTaskManagerFailure after test framework was fixed. This closes #17201 | 10 September 2021, 03:00:18 UTC |
| 4e732ad | Yufan Sheng | 07 September 2021, 06:51:19 UTC | [FLINK-23848][connector/pulsar] Make sure the topic would only be sought once. This closes #17199 | 10 September 2021, 02:58:42 UTC |
| 1a7bc49 | Yufan Sheng | 03 September 2021, 07:45:04 UTC | [FLINK-23848][connector/pulsar] Fix the consumer not found. | 10 September 2021, 02:58:41 UTC |
| 3621b00 | Dian Fu | 09 September 2021, 13:00:56 UTC | [FLINK-23345][python] Limits the version requests to 2.26.0 or above This closes #17219. | 10 September 2021, 02:01:34 UTC |
| c56ecf3 | Stephan Ewen | 24 August 2021, 14:06:04 UTC | [FLINK-23527][core] Clarify semantics of SourceFunction.cancel() with respect to thread interruptions. | 09 September 2021, 15:18:44 UTC |
| 9a26fe9 | Stephan Ewen | 24 August 2021, 13:37:09 UTC | [hotfix][core] Make the example for checkpointed SourceFunction a bit less strange. | 09 September 2021, 15:18:37 UTC |
| 18e94e4 | Stephan Ewen | 24 August 2021, 13:36:12 UTC | [hotfix] Deduplicate JavaDocs in SourceFunction | 09 September 2021, 15:18:25 UTC |
| 814f278 | Stephan Ewen | 24 August 2021, 13:22:56 UTC | [hotfix] Remove outdated JavaDocs in SourceFunction about deprecated TimeCharacteristic | 09 September 2021, 15:18:13 UTC |
| 2af65df | Stephan Ewen | 09 September 2021, 14:14:54 UTC | [hotfix][connectors] Deduplicate config default in FutureCompletingBlockingQueue. | 09 September 2021, 15:17:17 UTC |
| a76854f | Stephan Ewen | 19 April 2021, 16:22:07 UTC | [FLINK-22358][connector base] Add stability annotations to connector base and iterator sources. | 09 September 2021, 15:17:04 UTC |
| 2a13b24 | Stephan Ewen | 09 September 2021, 13:48:19 UTC | [hotfix][core] Improve/fix JavaDocs in SplitEnumeratorContext class. | 09 September 2021, 15:12:27 UTC |
| 4aa457d | Stephan Ewen | 19 April 2021, 16:05:01 UTC | [FLINK-22357][core] Upgrades API stability of unified source API to @Public (= stable). | 09 September 2021, 15:12:23 UTC |
| 2459a3c | Chesnay Schepler | 09 September 2021, 07:40:20 UTC | [FLINK-24213][qs] Use single lock in ServerConnection | 09 September 2021, 12:37:13 UTC |
| a2185c0 | Chesnay Schepler | 09 September 2021, 07:34:26 UTC | [FLINK-24213][qs] Introduce factory for established connection | 09 September 2021, 12:37:06 UTC |
| 2db50d6 | Dian Fu | 09 September 2021, 09:27:07 UTC | [FLINK-24137][python] Fix the issue that tests planned to run in process mode was actually executed in loopback mode This closes #17214. | 09 September 2021, 12:25:11 UTC |
| 4d131d5 | Dian Fu | 09 September 2021, 07:34:17 UTC | [FLINK-24137][python] Fix the cases that Python boot process exits before Python SDK harness connects to the Java Operator in lookback mode This closes #17214. | 09 September 2021, 12:25:07 UTC |
| e859af6 | Roman Khachatryan | 07 September 2021, 00:36:45 UTC | [FLINK-22889][tests] Increase timeouts in JdbcExactlyOnceSinkE2eTest ...to tolerate occasional long XA PREPARE executions in MySQL. | 09 September 2021, 08:47:59 UTC |
| 8e982b7 | LB-Yu | 15 August 2021, 10:45:47 UTC | [FLINK-23462] [docs-zh] Translate the abfs documentation to chinese (cherry picked from commit 19804811351c5a66503bf2c6d3b626d1fd1f8c65) | 09 September 2021, 08:08:27 UTC |
| adc9d43 | Chesnay Schepler | 09 September 2021, 07:48:26 UTC | [hotfix] Add .eslintcache to .gitignore The file only exists on master; the entry is just added for convenience. | 09 September 2021, 07:48:28 UTC |
| e7766f7 | Chesnay Schepler | 09 September 2021, 07:27:32 UTC | [FLINK-24031] Extend vcs.xml | 09 September 2021, 07:45:37 UTC |
| b56041b | Roman Khachatryan | 06 September 2021, 20:13:28 UTC | [FLINK-24160][tests] Use FS checkpoint storage in PartiallyFinishedSourcesITCase This closes #17165. | 08 September 2021, 16:04:17 UTC |
| 28109d0 | Yun Gao | 03 September 2021, 02:39:59 UTC | [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels This closes #17131. | 08 September 2021, 15:50:41 UTC |
| f907ef2 | martijnvisser | 07 September 2021, 11:55:23 UTC | [FLINK-24034] Upgrade commons-compress to 1.21 | 08 September 2021, 14:24:36 UTC |
| 21fd895 | Qingsheng Ren | 07 September 2021, 08:16:42 UTC | [FLINK-23807][connector/testing-framework] Use RestClient to detect TaskManager failure in test environments | 08 September 2021, 13:51:55 UTC |
| b434f0a | Qingsheng Ren | 02 September 2021, 08:02:00 UTC | [FLINK-24126][connector/kafka] Use increment of bytes consumed/produced for updating numBytesIn/Out in Kafka connector (cherry picked from commit 0dc46ca03933890bc14b9025702b56e32ee8b40f) | 08 September 2021, 13:51:09 UTC |
| 7818495 | David Moravek | 08 September 2021, 08:41:17 UTC | [FLINK-23961][kubernetes] Hint user about missing 'kubernetes.cluster-id' config option | 08 September 2021, 08:41:55 UTC |
| adb9009 | Francesco Guardiani | 08 September 2021, 08:30:30 UTC | [FLINK-24170][build] Use maven-directory-plugin:directory-of goal | 08 September 2021, 08:30:58 UTC |
| a4cd43b | Chesnay Schepler | 07 September 2021, 09:56:25 UTC | [FLINK-24183][legal] Add aws-java-sdk-s3 to source NOTICE | 08 September 2021, 08:16:35 UTC |
| 602a177 | wangfeifan | 06 September 2021, 06:43:52 UTC | [FLINK-23949][checkpoint] Fix first incremental checkpoint after a savepoint degenerate into a full checkpoint this fix #16969. Co-authored-by: wangfeifan <zoltar9264@163.com> Co-authored-by: jinghaihang <jinghaihang_hrbeu@163.com> | 08 September 2021, 07:18:33 UTC |
| 3a8a6b0 | Yun Gao | 07 September 2021, 05:41:46 UTC | [FLINK-24163][test] Increase the checkpoint timeout for PartiallyFinishedSourcesITCase This closes #17170. | 08 September 2021, 03:12:23 UTC |
| c10de14 | Leonard Xu | 08 September 2021, 02:43:22 UTC | [FLINK-24115][docs] Fix outdated SQL Temporal Join example (#17122) | 08 September 2021, 02:43:22 UTC |
| 6b4abd5 | Dian Fu | 07 September 2021, 12:59:47 UTC | [FLINK-24137][python][tests] Upload logs for PyFlink tests | 08 September 2021, 01:42:37 UTC |
| 2235dcb | Dian Fu | 07 September 2021, 12:58:39 UTC | [FLINK-24137][python] Add more logs during starting up Python worker | 08 September 2021, 01:42:33 UTC |
| 6472d5b | Matthias Pohl | 06 September 2021, 13:40:40 UTC | [FLINK-23611][yarn-tests] Disables INFO log messages coming from YARN's ResourceLocalizationService We observed regular INFO log messages being produced by ResourceLocalizationService after the test ran into a timeout: ``` 22:51:31,785 [AsyncDispatcher event handler] INFO org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.ResourceLocalizationService [] - Cache Size Before Clean: 0, Total Deleted: 0, Public Deleted: 0, Private Deleted: 0 22:51:32,398 [AsyncDispatcher event handler] INFO org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.ResourceLocalizationService [] - Cache Size Before Clean: 0, Total Deleted: 0, Public Deleted: 0, Private Deleted: 0 ``` These log messages appeared every 10 minutes which prevented the ci/tools/test_controller.sh's watchdog mechanism to kick in. The watchdog mechanism relies on no output being produced for a given amount of time. This way, the test_controller script was unable to archive the YARN Flink log. | 07 September 2021, 14:06:24 UTC |
| de07689 | Matthias Pohl | 27 August 2021, 10:00:50 UTC | [hotfix][yarn-tests] Replaces runtime by timestamp The intend is to improve local debugging matching log events in different log files (YARN, Flink) via the timestamp. | 07 September 2021, 14:06:24 UTC |
| 27843b3 | Matthias Pohl | 25 August 2021, 13:49:57 UTC | [hotfix][yarn-tests] Fixes path definition for local YARN-test working directory artifact collection | 07 September 2021, 14:06:24 UTC |
| 3c20439 | Roman Khachatryan | 06 September 2021, 17:24:08 UTC | [FLINK-24162][tests] Check MAX_WATERMARK per attempt in FLIP-147 tests Adjust DrainingValidator to validate subtask events if: - finished normally, last attempt - finished normally, recovered, finished - both attempts must emit MAX_WATERMARK and end input Skip if task wasn't finished and the attempt failed (by any subtask). | 07 September 2021, 13:46:40 UTC |
| ba749b7 | Roman Khachatryan | 06 September 2021, 17:59:09 UTC | [hotfix][tests] Parameterize PartiallyFinishedSourcesITCase with failover strategy | 07 September 2021, 13:46:40 UTC |
| 510c2fc | Arvid Heise | 05 September 2021, 21:39:32 UTC | [FLINK-24151][connectors/kafka] Add concurrent checkpoint test to KafkaSinkITCase. | 07 September 2021, 12:07:24 UTC |
| 869befd | Arvid Heise | 05 September 2021, 20:08:07 UTC | [FLINK-24131][connectors/kafka] Fix KafkaWriter currentSendTime metric. The metric can only be registered once and should simply take the currentProducer to calculate. | 07 September 2021, 12:07:24 UTC |
| 40da6fc | Arvid Heise | 04 September 2021, 20:56:24 UTC | [FLINK-24131][connectors/kafka] Improve threading model of KafkaWriter. Removed pending records as it doesn't add anything to KafkaWriter#flush (same post-condition as per JavaDoc) but introduces instabilities because of concurrency. | 07 September 2021, 12:07:24 UTC |
| 270513b | Arvid Heise | 05 September 2021, 21:19:46 UTC | [FLINK-24131][connectors/kafka] Improve handling of committer errors in KafkaCommitter. | 07 September 2021, 12:07:24 UTC |
| c04fa00 | Arvid Heise | 04 September 2021, 20:49:24 UTC | [FLINK-24131][connectors/kafka] Improve debuggability of KafkaWriter. This also aligns the transaction ids with checkpoint ids starting at 1. | 07 September 2021, 12:07:24 UTC |
| 2c8951b | Arvid Heise | 06 September 2021, 11:50:55 UTC | [FLINK-24131][runtime] Introduce CheckpointIDCounter#INITIAL_CHECKPOINT_ID. | 07 September 2021, 12:07:24 UTC |
| 9e9ae8c | Arvid Heise | 04 September 2021, 20:48:01 UTC | [FLINK-24131][connectors/kafka] Ensure kafka writer and producer closed correctly even with Interruptions. | 07 September 2021, 12:07:24 UTC |
| a81f1c8 | Arvid Heise | 04 September 2021, 20:44:33 UTC | [FLINK-24131][datastream] Ensure writer and committer are closed correctly even with Interruptions. | 07 September 2021, 12:07:24 UTC |
| d2c5b13 | Arvid Heise | 04 September 2021, 20:35:41 UTC | [FLINK-24131][datastream] Recommit recovered transactions as quickly as possible. | 07 September 2021, 12:07:24 UTC |
| 69ead8f | Arvid Heise | 04 September 2021, 20:34:51 UTC | [FLINK-24131][datastream] Ensure that SinkWriter#prepareCommit is not called twice for final commit. With FLIP-147 (final checkpoint) and the respective opt-in option, a sink would invoke prepareCommit twice for the final commit. | 07 September 2021, 12:07:24 UTC |
| 39d303f | Arvid Heise | 03 September 2021, 13:32:10 UTC | [FLINK-24131][tests] Harden leak check in KafkaSinkITCase. | 07 September 2021, 12:07:24 UTC |
| bf96ba3 | martijnvisser | 07 September 2021, 10:11:23 UTC | [hotfix][docs] Update Window TopN SQL example | 07 September 2021, 10:41:42 UTC |
| b61289a | Chesnay Schepler | 06 September 2021, 09:54:54 UTC | [FLINK-22971][tests] Bump testcontainers to 1.16.0 This version uses http5 as the default transport, which is not affected by the race condition we run into. https://github.com/testcontainers/testcontainers-java/issues/3531 | 07 September 2021, 10:24:19 UTC |
| 1217518 | Timo Walther | 18 August 2021, 07:34:54 UTC | [FLINK-23832][docs] Update DataStream API Integration page This closes #16871. | 07 September 2021, 06:22:21 UTC |
| c1b6acd | Anton Kalashnikov | 01 September 2021, 15:37:58 UTC | [FLINK-24069][tests] Added exponentially increasing checkpoint interval for every next attempt of testIgnoreInFlightDataDuringRecovery | 07 September 2021, 06:11:28 UTC |
| 24baf7f | Anton Kalashnikov | 01 September 2021, 15:35:35 UTC | [FLINK-24069][tests] Fail IgnoreInFlightData test when there is not enough data for it for all checkpoints not only the first one | 07 September 2021, 06:11:19 UTC |
| 7bf4240 | Yun Tang | 02 September 2021, 06:51:36 UTC | [FLINK-23983][tests] Ensure to close and dispose created keyed-statebackend in StateBackendTestBase | 07 September 2021, 02:29:00 UTC |
| cb71c37 | Thomas Weise | 31 August 2021, 12:48:40 UTC | [FLINK-24064][connector/common] HybridSource restore from savepoint | 06 September 2021, 16:40:05 UTC |
| f354aee | Yangze Guo | 06 September 2021, 15:33:26 UTC | [FLINK-23912][coordination] Ignore repeated empty requirements declarations | 06 September 2021, 15:33:56 UTC |
| c3e64ad | Gabor Somogyi | 27 August 2021, 07:57:50 UTC | [FLINK-24020][web] Aggregate HTTP requests before custom netty handers are getting the data Closes #17156 | 06 September 2021, 12:49:19 UTC |
| f675aca | David Moravek | 06 September 2021, 10:45:35 UTC | [FLINK-23839][kafka] Improve warnings on InvalidTxnState-/ProducerFencedException | 06 September 2021, 10:46:18 UTC |
| 5a68bb8 | Anton Kalashnikov | 03 September 2021, 17:54:08 UTC | [FLINK-23960][streaming] checkScheduledTimestamps changed according to semantic of the calculation processing time delay | 06 September 2021, 07:53:45 UTC |
| 08481d9 | Anton Kalashnikov | 01 September 2021, 13:32:35 UTC | [refactor][streaming] Busy waiting in checkScheduledTimestamps replaced by CompletableFuture | 06 September 2021, 07:53:44 UTC |
| 6fa6033 | Anton Kalashnikov | 01 September 2021, 13:30:57 UTC | [refactor][streaming] Improved description of the calculation of the processing time delay | 06 September 2021, 07:53:43 UTC |
| bf71226 | Anton Kalashnikov | 02 September 2021, 14:23:36 UTC | [FLINK-24090][docs] Added Troubleshooting section with ignoring in-flight data explanation into unaligned checkpoints page | 06 September 2021, 07:53:35 UTC |
| 9c8d21f | Yun Gao | 02 September 2021, 12:26:54 UTC | [FLINK-24096][checkpoint] Skip the complete notification for checkpoints before task startup This closes #17123. | 06 September 2021, 06:49:46 UTC |
| 41d08cd | Yun Gao | 02 September 2021, 11:58:11 UTC | Revert "[FLINK-23759][runtime][checkpoint] Ignore the restored checkpoints when reporting latest completed id with abortion message" This reverts commit 45d87361cbb6ab36956ddaa4c142ffa2249d1400. | 06 September 2021, 06:49:46 UTC |
| f6460e9 | Dian Fu | 06 September 2021, 02:24:32 UTC | [FLINK-24134][python][docs] Update the documentation about how to install PyFlink in docker This closes #17154. | 06 September 2021, 05:27:41 UTC |
| 2e76974 | Piotr Nowojski | 01 September 2021, 13:34:43 UTC | [FLINK-23916][docs] Update the documentation how to set tolerable checkpoint failure number | 03 September 2021, 13:53:19 UTC |
| e24ebea | Piotr Nowojski | 01 September 2021, 13:54:32 UTC | [FLINK-23916][python] Add python API to set tolerable checkpoint failure number | 03 September 2021, 13:53:17 UTC |
