| fb4d4ef | Weijie Guo | 17 May 2023, 10:01:35 UTC | Commit for release 1.16.2 | 17 May 2023, 10:01:35 UTC |
| 2203bc3 | Stefan Richter | 16 May 2023, 18:37:02 UTC | [FLINK-31963][state] Fix rescaling bug in recovery from unaligned checkpoints. (#22584) (#22595) This commit fixes problems in StateAssignmentOperation for unaligned checkpoints with stateless operators that have upstream operators with output partition state or downstream operators with input channel state. (cherry picked from commit 354c0f455b92c083299d8028f161f0dd113ab614) | 16 May 2023, 18:37:02 UTC |
| ffa58e1 | Yuxin Tan | 14 March 2023, 09:55:20 UTC | [FLINK-31418][network][tests] Fix unstable test case SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout This closes #22172. | 16 May 2023, 11:44:21 UTC |
| 1a3b539 | Weijie Guo | 09 May 2023, 14:58:43 UTC | [FLINK-32024][docs] Short code related to externalized connector retrieve version from its own data yaml. | 15 May 2023, 13:26:52 UTC |
| 7b41bd2 | wangfeifan | 21 April 2023, 15:43:31 UTC | [FLINK-31743][statebackend/rocksdb] disable rocksdb log relocating when instance path too long | 11 May 2023, 12:51:45 UTC |
| 55c7486 | Matthias Pohl | 08 May 2023, 12:25:28 UTC | [FLINK-32029][core] Adds fallback error handling to FutureUtils.handleUncaughtException. This was added to avoid missing errors that were caused by the error handling code. Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 10 May 2023, 16:14:46 UTC |
| 538edbd | 1996fanrui | 27 April 2023, 11:03:58 UTC | [FLINK-31959][checkpoint] Correct the unaligned checkpoint type at checkpoint level | 10 May 2023, 08:38:40 UTC |
| de5d190 | 1996fanrui | 28 April 2023, 03:25:06 UTC | [hotfix] Migrate checkpoint statistics related tests to JUnit5 and AssertJ | 10 May 2023, 08:38:40 UTC |
| c5a883d | Weijie Guo | 09 May 2023, 08:08:36 UTC | [FLINK-32027][runtime] Fix the potential concurrent reading bug of index file for SortMergeShuffle. This closes #22549 | 10 May 2023, 02:59:43 UTC |
| c1e8156 | Weijie Guo | 09 May 2023, 05:50:38 UTC | [hotfix] Remove unnecessary public modifier for PartitionedFileWriteReadTest | 10 May 2023, 02:59:43 UTC |
| 68a79a0 | Mingliang Liu | 02 May 2023, 23:18:53 UTC | [FLINK-31984][fs][checkpoint] Savepoint should be relocatable if entropy injection is not effective This closes #22541 | 08 May 2023, 14:30:14 UTC |
| b6b8ef6 | Weijie Guo | 21 April 2023, 09:35:23 UTC | [FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool. | 07 May 2023, 03:12:51 UTC |
| 7e8716f | Weijie Guo | 21 April 2023, 09:46:02 UTC | [FLINK-31764][runtime] Introduce getNumberOfRequestedMemorySegments and rename the old one to a more appropriate name. | 07 May 2023, 03:12:51 UTC |
| d316f08 | Weijie Guo | 21 April 2023, 09:40:58 UTC | [hotfix] Fix the link to a private field in other class. This illegal link will make IDE not happy. | 07 May 2023, 03:12:51 UTC |
| 6aa8463 | David Moravek | 05 May 2023, 10:32:55 UTC | [FLINK-32010][kubernetes] Properly handle KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in case the leader is already known. | 06 May 2023, 06:18:58 UTC |
| af734bf | David Moravek | 05 May 2023, 10:31:09 UTC | [FLINK-32010][runtime] Leader election/retrieval drivers should properly extend AutoCloseable instead of having their own close method with the same signature. | 06 May 2023, 06:18:58 UTC |
| 57c9764 | David Moravek | 05 May 2023, 08:10:46 UTC | [FLINK-32010][kubernetes] Rename KubernetesUtils#checkConfigMaps to KubernetesUtils#getOnlyConfigMap to provide more clarity. | 06 May 2023, 06:18:58 UTC |
| 9d0d926 | David Moravek | 05 May 2023, 08:09:49 UTC | [FLINK-32010][kubernetes] Remove an unused parameter from KubernetesLeaderRetrievalDriver. | 06 May 2023, 06:18:58 UTC |
| 9e08f20 | Matthias Pohl | 04 May 2023, 11:17:14 UTC | Revert "[FLINK-31984][fs][checkpoint] Savepoint should be relocatable if entropy injection is not effective" This reverts commit cccef2da73e0a12e7e19bac182497919c72e46f0. | 04 May 2023, 11:22:06 UTC |
| cccef2d | Mingliang Liu | 02 May 2023, 23:18:53 UTC | [FLINK-31984][fs][checkpoint] Savepoint should be relocatable if entropy injection is not effective | 04 May 2023, 08:50:43 UTC |
| d3f93d0 | Matthias Pohl | 06 February 2023, 18:55:57 UTC | [FLINK-30921][ci] Adds mirrors instead of relying on a single source for Ubuntu packages We don't want to rely on an external service for retrieving mirrors dynamically to prevent supply chain attacks. Therefore, we selected a few mirrors manually. This prevents us from relying on a dynamic mirror list based on the CI machines location which might be a performance issue. But generally, we want to rely on the Azure mirror anyway. The fallback list is only meant to jump in if Azure's mirror is not accessible temporarily. Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 03 May 2023, 08:47:49 UTC |
| 4944df6 | Martijn Visser | 27 April 2023, 19:57:54 UTC | [FLINK-31962][Build System] Update libssl to 5.12, which is needed for all E2E tests (cherry picked from commit ed7ca22efc68203d4882887a3856434137e6980f) | 27 April 2023, 19:59:58 UTC |
| ae998dd | Dian Fu | 26 April 2023, 15:02:27 UTC | [FLINK-28786][python] Check if cython could be enabled in only one place This closes #22490. | 27 April 2023, 05:40:39 UTC |
| 5eb7188 | Lijie Wang | 24 April 2023, 09:20:38 UTC | [FLINK-31831][runtime][tests] Use random ports as rest bind port and jobmanager rpc port to avoid port binding failure This closes #22477 | 26 April 2023, 06:23:06 UTC |
| 2712a30 | Lijie Wang | 24 April 2023, 09:16:08 UTC | [hotfix][runtime][tests] Migrate assertions in TaskManagerDisconnectOnShutdownITCase to Junit5 Assertions | 26 April 2023, 06:23:06 UTC |
| b3a5273 | Yuxin Tan | 24 April 2023, 14:59:24 UTC | [FLINK-31897][tests] Fix the unstable test ClientTest#testRequestUnavailableHost | 25 April 2023, 08:49:56 UTC |
| 60cadec | 1996fanrui | 21 April 2023, 10:02:07 UTC | [FLINK-31588][checkpoint] Correct the unaligned checkpoint type based on the bytesPersistedDuringAlignment | 25 April 2023, 02:22:15 UTC |
| ea0f5ef | Weijie Guo | 11 April 2023, 06:50:56 UTC | [FLINK-31799][docs] Introduce py_connector_download_link shortcode for externalized connectors. | 24 April 2023, 02:33:36 UTC |
| 43214fd | Weijie Guo | 23 April 2023, 05:59:17 UTC | [hotfix][docs] Make the Chinese description in py_download_link.html more conventional | 24 April 2023, 02:33:36 UTC |
| 226ec59 | Wencong Liu | 21 April 2023, 04:20:20 UTC | [FLINK-31131][doc] Fix the missed INITIALIZING of ExecutionState in the state_machine doc | 24 April 2023, 02:05:32 UTC |
| fc39a91 | kevin.cyj | 09 March 2023, 03:52:21 UTC | [FLINK-31386][network] Fix the potential deadlock issue of blocking shuffle Currently, the SortMergeResultPartition may allocate more network buffers than the guaranteed size of the LocalBufferPool. As a result, some result partitions may need to wait other result partitions to release the over-allocated network buffers to continue. However, the result partitions which have allocated more than guaranteed buffers relies on the processing of input data to trigger data spilling and buffer recycling. The input data further relies on batch reading buffers used by the SortMergeResultPartitionReadScheduler which may already taken by those blocked result partitions that are waiting for buffers. Then deadlock occurs. This patch fixes the deadlock issue by reserving the guaranteed buffers on initializing. (cherry picked from commit b90bf7acde9) | 23 April 2023, 09:58:37 UTC |
| b7dcf31 | Weijie Guo | 10 April 2023, 15:04:48 UTC | [FLINK-31758][doc] Handles $full_version for sql_url in document. | 21 April 2023, 05:31:31 UTC |
| f4d4182 | Chesnay Schepler | 12 December 2022, 12:10:55 UTC | [FLINK-30378][docs] Load sql connector data from any data file | 21 April 2023, 05:31:31 UTC |
| c524b89 | Chesnay Schepler | 12 December 2022, 12:10:16 UTC | [FLINK-30378][docs] Load data/ directory from externalized connector docs | 21 April 2023, 05:31:31 UTC |
| 8d98e69 | haishui | 29 March 2023, 03:06:40 UTC | [FLINK-31632] Fix maxAllowedWatermark arithmetic overflow when the source is idle This closes #22291. | 20 April 2023, 16:54:25 UTC |
| 1e2c2e6 | Sergey Nuyanzin | 20 April 2023, 15:18:48 UTC | [FLINK-31834][Azure] Free up disk space before caching Co-authored-by: Robert Metzger <rmetzger@apache.org> | 20 April 2023, 15:18:48 UTC |
| 389389f | 沈嘉琦 | 03 April 2023, 11:43:14 UTC | [FLINK-31708][API/Type Serialization System] Make DataInputView#read(byte[], int, int) return 0 if len is 0. This closes #22335. | 20 April 2023, 06:57:31 UTC |
| ab2ba96 | Weijie Guo | 11 April 2023, 15:33:57 UTC | [FLINK-31763][runtime] Convert requested buffers to overdraft buffers when pool size is decreased | 17 April 2023, 09:28:13 UTC |
| 09e8e57 | Weijie Guo | 15 April 2023, 17:00:17 UTC | [FLINK-31779][docs] Track stable branch of externalized connector instead of specific release tag | 17 April 2023, 03:19:22 UTC |
| 8e961e4 | Weijie Guo | 06 April 2023, 07:28:10 UTC | [FLINK-31670][doc] Using v3.0.0-docs branch for es connector docs build. | 06 April 2023, 07:28:10 UTC |
| 75fab27 | Weijie Guo | 16 February 2023, 17:16:09 UTC | [FLINK-30989][runtime] Some config options related to sorting and spilling are not valid. | 05 April 2023, 14:17:01 UTC |
| 3291e4d | Dian Fu | 03 April 2023, 11:41:29 UTC | [FLINK-31707][python] Fix Pandas UDAF to support accepting constant string as inputs This closes #22332. | 04 April 2023, 05:24:50 UTC |
| 9582727 | Weijie Guo | 06 March 2023, 17:12:14 UTC | [FLINK-31293][runtime] LocalBufferPool request overdraft buffer only when no available buffer and pool size is reached. | 04 April 2023, 02:31:29 UTC |
| f1ba3ee | Weijie Guo | 02 March 2023, 16:03:35 UTC | [hotfix] Add missing @GuardedBy annotation for LocalBufferPool. | 04 April 2023, 02:31:29 UTC |
| 10a0f32 | Weijie Guo | 02 March 2023, 15:45:01 UTC | [hotfix] Some minor clean-up and typo fix for LocalBufferPool. | 04 April 2023, 02:31:29 UTC |
| f35cf96 | Weijie Guo | 06 March 2023, 17:05:47 UTC | [hotfix][test] Migrate LocalBufferPoolTest to Junit5 and AssertJ. | 04 April 2023, 02:31:29 UTC |
| a48e62b | Danny Cranmer | 03 April 2023, 18:18:01 UTC | [hotfix][Connectors/AWS][docs] Updating AWS docs branch to fix build | 03 April 2023, 18:18:01 UTC |
| 95db617 | Danny Cranmer | 03 April 2023, 12:01:46 UTC | [FLINK-31703][Connectors/AWS][docs] Update AWS connector docs to v4.1.0 | 03 April 2023, 16:34:01 UTC |
| 3bdb855 | Danny Cranmer | 03 April 2023, 10:22:32 UTC | [FLINK-31692][Connectors/MongoDB] Integrate MongoDB connector docs into Flink website | 03 April 2023, 11:56:46 UTC |
| 99c025b | sunxia | 31 March 2023, 02:19:56 UTC | [FLINK-31652][k8s] Handle the deleted event in case pod is deleted during the pending phase This closes #22311 | 03 April 2023, 08:02:58 UTC |
| 01cdaee | Dian Fu | 03 April 2023, 03:57:52 UTC | [FLINK-31690][python] Fix KeyedCoProcessFunction to set the current key into the context This closes #22323. | 03 April 2023, 05:42:47 UTC |
| e8507e2 | mas-chen | 29 March 2023, 23:40:22 UTC | [FLINK-31305] fix error propagation bug in WriterCallback and use TestSinkInitContext general purpose sink testing tool This closes #22303. | 31 March 2023, 19:23:18 UTC |
| 701fccf | Yun Tang | 31 March 2023, 09:36:57 UTC | [FLINK-31683][docs-zh] Update the outdated Chinese filesystem connector docs | 31 March 2023, 13:46:47 UTC |
| 18b6f33 | Joao Boto | 30 March 2023, 12:53:25 UTC | [FLINK-31525][tests] Stabilize JdbcExactlyOnceSinkE2eTest (#22266) | 30 March 2023, 12:53:25 UTC |
| ec386ae | Lijie Wang | 29 March 2023, 02:40:54 UTC | [FLINK-31651][runtime] Improve logging of granting/revoking leadership in JobMasterServiceLeadershipRunner to INFO level This closes #22292 | 30 March 2023, 09:53:55 UTC |
| 8e470b5 | Chesnay Schepler | 29 March 2023, 11:08:59 UTC | [FLINK-31657][rest][docs] Exclude isEmpty property | 30 March 2023, 08:31:20 UTC |
| 36f3971 | Sergey Nuyanzin | 29 March 2023, 19:30:46 UTC | [FLINK-27640][Connector/Hive][SQL Client] Exclude Pentaho dependency from Hive to avoid build problems with newer Maven versions. Newer Maven versions block http repositories such as conjars. Conjars is where Pentaho artifacts are stored (#22299) Co-authored-by: Martijn Visser <martijnvisser@apache.org> | 29 March 2023, 19:30:46 UTC |
| 822461b | mas-chen | 10 March 2023, 08:42:21 UTC | [FLINK-31305] Propagate producer exceptions outside of mailbox executor so that checkpoints can correctly fail This closes #22150. | 28 March 2023, 00:17:22 UTC |
| 80ee512 | Roman Khachatryan | 21 March 2023, 21:08:27 UTC | [FLINK-31527][tests] Stabilize ChangelogRescalingITCase | 22 March 2023, 16:58:58 UTC |
| e891bfc | Dian Fu | 19 March 2023, 09:48:31 UTC | [python][examples] Add Python streaming word count examples | 19 March 2023, 10:31:47 UTC |
| d438b3b | Dian Fu | 17 March 2023, 15:03:11 UTC | [FLINK-31503][python] Makes sure it loads Beam classes using the same class loader as the PyFlink classes This closes #22206. | 19 March 2023, 06:47:04 UTC |
| a5f085e | Ran Tao | 18 March 2023, 09:56:34 UTC | [FLINK-31319][connectors/kafka] Fix kafka new source partitionDiscoveryIntervalMs error condition check cause bounded source can not quit This closes #22192. | 18 March 2023, 09:56:34 UTC |
| cadf4b3 | Dian Fu | 16 March 2023, 06:31:23 UTC | [FLINK-31478][python] Fix ds.execute_and_collect to support nested tuple This closes #22190. | 17 March 2023, 15:13:05 UTC |
| 3d84e59 | Hang Ruan | 17 March 2023, 10:09:09 UTC | [FLINK-30959][table][docs] Improve the documentation of UNIX_TIMESTAMP function for different argument formats This closes #22186. | 17 March 2023, 10:09:09 UTC |
| 1bd25a4 | yunhong | 17 March 2023, 02:14:22 UTC | [FLINK-31477][table-planner] Fix NestedLoopJoinTest.testLeftOuterJoin failed with unexpected plan This closes #22188. | 17 March 2023, 02:14:22 UTC |
| 3ffd113 | Weijie Guo | 13 March 2023, 15:09:08 UTC | [FLINK-31420][test] Fix unstable test ThreadInfoRequestCoordinatorTest#testShutDown. testShutDown using two gateways contains a timeout gateway but expected all request futures not done before shutdown. If the timeout reached, this future will be failed, result in request future to be done. | 15 March 2023, 10:29:00 UTC |
| f2f9104 | wangfeifan | 13 March 2023, 08:11:21 UTC | [FLINK-31414][checkpointing] make BarrierAlignmentUtil.DelayableTimer not hidden exception | 15 March 2023, 10:17:17 UTC |
| f0361c7 | zhengyunhong.zyh | 01 March 2023, 07:28:50 UTC | [FLINK-31273][table-planner] Fix left join with IS_NULL filter be wrongly pushed down and get wrong join results This closes #22049 (cherry picked from commit 8990822bd77d70f3249e1220a853e16dadd8ef54) | 15 March 2023, 09:55:56 UTC |
| 5c723dd | JunRuiLee | 14 March 2023, 09:18:00 UTC | [FLINK-31437][jdbc][docs] Fix wrong key 'lookup.cache.caching-missing-key' in 'jdbc.md' This closes #22174. | 15 March 2023, 09:25:51 UTC |
| d2f1fcc | xzw | 13 March 2023, 07:58:39 UTC | [FLINK-31437][hbase][docs] Fix wrong key 'lookup.cache.caching-missing-key' in 'hbase.md' | 15 March 2023, 09:25:25 UTC |
| f200775 | K.I. (Dennis) Jung | 13 March 2023, 08:03:16 UTC | [FLINK-31227][docs] Remove Scala suffix for ORC and Parquet format download links on the the FileSystem documentation. This closes #22039 Remove Scala suffix for ORC and Parquet format download links on the the FileSystem documentation (cherry picked from commit a8848f8d6aa700e0325e79a8f7b44f611d287cb3) | 13 March 2023, 08:10:38 UTC |
| a97a507 | Weijie Guo | 10 March 2023, 07:56:08 UTC | [FLINK-31393] Fix the bug that HsFileDataManager use an incorrect default timeout. | 12 March 2023, 15:01:24 UTC |
| b7b1cce | Wencong Liu | 06 March 2023, 14:08:34 UTC | [FLINK-31298] fix ConnectionUtilsTest.testFindConnectingAddressWhenGetLocalHostThrows swallows IllegalArgumentException | 09 March 2023, 05:59:22 UTC |
| 860ce4f | Weijie Guo | 06 March 2023, 14:29:43 UTC | [FLINK-31346][runtime] IO scheduler does not throw TimeoutException if numRequestedBuffers is greater than 0. | 09 March 2023, 04:20:59 UTC |
| 45c2758 | Weijie Guo | 06 March 2023, 14:29:43 UTC | [hotfix][runtime] IO Scheduler should handle un-expected exceptions. (cherry picked from commit faf663a6298c602d93c351f9971eed8aa8dabb93) | 09 March 2023, 04:20:59 UTC |
| 772429f | Weijie Guo | 06 March 2023, 16:26:58 UTC | [hotfix][test] Remove meaningless reader in SortMergeResultPartitionReadSchedulerTest#testRequestTimeoutIsRefreshedAndSuccess. (cherry picked from commit a3068310ba90ad851f660d4efb43ddf364218cdb) | 09 March 2023, 04:20:59 UTC |
| 6fd3b9b | Shengkai | 08 March 2023, 04:12:05 UTC | [FLINK-31351][sql-gateway] Don't stop the stuck thread by force | 09 March 2023, 03:15:56 UTC |
| 49d9ea6 | David Moravek | 07 March 2023, 12:39:51 UTC | [FLINK-31348][Docs] Fix unclosed shortcodes (/tabs) in the docs, that causes issues with Hugo version 0.111.0 and higher. This closes #22113 (cherry picked from commit 3ea83baad0c8413f8e1f4a027866335d13789538) | 07 March 2023, 12:43:35 UTC |
| 085a70c | Yun Tang | 01 March 2023, 14:14:40 UTC | [FLINK-31283][docs] Update the scala-2.11 related building doc | 07 March 2023, 06:17:17 UTC |
| 07f0778 | Juntao Hu | 06 March 2023, 12:48:56 UTC | [FLINK-31337][python] Fix python keyed broadcast batch operator input not sorted This closes #22107. | 06 March 2023, 15:39:50 UTC |
| d71a87d | Timo Walther | 27 February 2023, 13:37:30 UTC | [FLINK-31182][table] Fix CompiledPlan containing UNNEST This closes #22040. | 06 March 2023, 13:38:35 UTC |
| 93cd23c | Matthias Pohl | 02 March 2023, 14:13:58 UTC | [FLINK-31092][table-common] Fix ServiceLoaderUtil keeps loading even though the classloader has been closed Co-authored-by: Shengkai Fang <1059623455@qq.com> | 06 March 2023, 11:03:05 UTC |
| 2dcd6cc | Shengkai | 02 March 2023, 09:57:55 UTC | [FLINK-31092][sql-gateway] Fix OperationManager can not kill the running task by force | 06 March 2023, 11:03:05 UTC |
| cf04b2c | Roman Khachatryan | 25 February 2023, 21:24:46 UTC | [FLINK-31133][tests] Prevent timeouts in PartiallyFinishedSourcesITCase - Only obtain execution exception if the job is in globally terminal state - [hotfix] Unsubscribe finished TestEventSources from test commands. Otherwise, any command with SINGLE_SUBTASK scope might be dispatched to a finished source. This will result in TestJobExecutor.waitForFailover timing out while waiting for the command to be executed and ACKed. - [hotfix] Mark TestEventSource.scheduledCommands volatile - [hotfix] Make sure to process all commands in TestEventSource | 03 March 2023, 19:55:35 UTC |
| 01c8eb5 | Weijie Guo | 02 March 2023, 10:08:37 UTC | [FLINK-31288][doc] Update doc ralated to overdraft buffer. | 03 March 2023, 14:49:15 UTC |
| 7c69131 | Weijie Guo | 02 March 2023, 07:29:25 UTC | [FLINK-31288][runtime] Disable overdraft buffer for non pipelined result partition. | 03 March 2023, 14:49:15 UTC |
| 8713b17 | Juntao Hu | 23 February 2023, 07:47:42 UTC | [FLINK-31185][python] Support side-output in broadcast processing This closes #22003. | 03 March 2023, 12:07:51 UTC |
| 57cabdc | Weihua Hu | 02 March 2023, 06:29:49 UTC | [FLINK-29852][Runtime] Fix AdaptiveScheduler add operator repeatedly in json plan. | 02 March 2023, 17:16:25 UTC |
| c05c772 | Weijie Guo | 02 March 2023, 09:44:25 UTC | [FLINK-29884][test] Fix flaky test SortMergeResultPartitionTest.testRelease | 02 March 2023, 15:29:50 UTC |
| ed47440 | Dian Fu | 02 March 2023, 03:48:03 UTC | [FLINK-31286][python] Make sure Python processes are cleaned up when TaskManager crashes This closes #22065. | 02 March 2023, 06:36:19 UTC |
| 5bb44a1 | Jark Wu | 02 March 2023, 02:01:19 UTC | [FLINK-29729][parquet] Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader (#22057) | 02 March 2023, 02:01:19 UTC |
| 823aa25 | Dian Fu | 01 March 2023, 10:36:56 UTC | [FLINK-31272][python] Handle properly for SinkTransformation to avoid duplicate operators introduced by chaining optimization This closes #22053. | 01 March 2023, 13:21:11 UTC |
| 247a099 | yunhong | 01 March 2023, 01:27:37 UTC | [FLINK-31082][table-planner] Setting maven property 'flink.resueForks' to false in table planner module This closes #22045 | 01 March 2023, 01:27:37 UTC |
| 5b9398a | JunRuiLee | 27 February 2023, 08:42:45 UTC | [FLINK-29859][e2e] Running TPC-DS with adaptive batch scheduler supports custom errors check. This closes #22029. | 28 February 2023, 12:03:46 UTC |
| 2f0df80 | Roc Marshal | 26 February 2023, 04:18:00 UTC | [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring (cherry picked from commit a98bb9a6c978d5458cf4cc11dc7b68034f4def4b) | 27 February 2023, 15:27:42 UTC |
| eaac06c | Roc Marshal | 24 February 2023, 05:19:37 UTC | [hotfix] Migrate StreamTaskTest to Junit5 and Assertj (cherry picked from commit eb4106a166f367091d2f25a9aa0c522c461372c0) | 27 February 2023, 15:27:42 UTC |
| 4c81591 | JunRuiLee | 16 February 2023, 05:47:29 UTC | [FLINK-31077][runtime] Mark pending checkpoint onCompletionPromise complete only after the completed checkpoint is added to the checkpoint store. This closes #21943. | 27 February 2023, 07:02:18 UTC |
| ca60b10 | JunRuiLee | 15 February 2023, 10:30:44 UTC | [hotfix] Migrate PendingCheckpointTest to Junit5 and AssertJ. | 27 February 2023, 07:02:08 UTC |
| b60178b | JunRuiLee | 15 February 2023, 10:30:03 UTC | [hotfix] Migrate DefaultSchedulerTest to Junit5 and AssertJ. | 27 February 2023, 07:01:51 UTC |
| cd7b049 | Danny Cranmer | 23 February 2023, 13:12:31 UTC | [FLINK-31183][Connector/Kinesis] Fix bug where EFO Consumer can fail to stop gracefully during stop-with-savepoint | 23 February 2023, 17:05:33 UTC |
