| 7f68106 | dependabot[bot] | 20 February 2024, 19:46:54 UTC | Bump ip from 2.0.0 to 2.0.1 in /flink-runtime-web/web-dashboard Bumps [ip](https://github.com/indutny/node-ip) from 2.0.0 to 2.0.1. - [Commits](https://github.com/indutny/node-ip/compare/v2.0.0...v2.0.1) --- updated-dependencies: - dependency-name: ip dependency-type: indirect ... Signed-off-by: dependabot[bot] <support@github.com> | 20 February 2024, 19:46:54 UTC |
| 890a995 | hejufang | 06 February 2024, 09:10:12 UTC | [FLINK-34386][state] Add RocksDB bloom filter metrics | 20 February 2024, 14:41:16 UTC |
| 8fe005c | JunRuiLee | 20 February 2024, 04:14:43 UTC | [FLINK-33241][doc] Align config option generation documentation for Flink's config documentation. | 20 February 2024, 11:40:30 UTC |
| 049de66 | Stefan Richter | 20 February 2024, 11:01:03 UTC | [hotfix] Remove redundant call to remove(). | 20 February 2024, 11:26:58 UTC |
| 4f28512 | rmoff | 13 February 2024, 15:39:11 UTC | Fix grammar Fix tests that reference the message Fix text in docs Fix tests that reference the message | 20 February 2024, 11:08:32 UTC |
| c24e2c9 | Jacky Lau | 20 February 2024, 08:24:21 UTC | [FLINK-33948][table] Cleanup usage of deprecated org.apache.flink.table.api.dataview.MapView#MapView (#23996) | 20 February 2024, 08:24:21 UTC |
| dc25bca | lincoln lee | 17 January 2024, 15:11:59 UTC | [FLINK-33182][table] Allow metadata columns in Ndu-analyze with ChangelogNormalize This closes #24121. | 20 February 2024, 08:16:14 UTC |
| 68d8c5b | Jiabao Sun | 20 February 2024, 03:23:15 UTC | [hotfix][docs] Update the versions of mongodb supported by mongodb-connector This closes #24337. | 20 February 2024, 03:23:15 UTC |
| 1a494bc | Yangze Guo | 19 February 2024, 02:35:45 UTC | [FLINK-34434][slotmanager] Complete the returnedFuture when slot removed before allocation success | 20 February 2024, 02:37:41 UTC |
| 15af3e4 | Yangze Guo | 19 February 2024, 09:58:06 UTC | [hotfix][test] Assert the slot allocation eventually succeed in dedicated tests of DefaultSlotStatusSyncerTest Also deduplicate the code of these tests. | 20 February 2024, 02:37:41 UTC |
| e2e3de2 | Rui Fan | 02 February 2024, 05:08:01 UTC | [FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes | 20 February 2024, 02:21:15 UTC |
| c2eac7e | Sergey Nuyanzin | 19 February 2024, 22:30:28 UTC | [FLINK-34160][table] Migration of FlinkCalcMergeRule to java | 19 February 2024, 22:30:28 UTC |
| e644bea | Sergey Nuyanzin | 19 February 2024, 22:06:21 UTC | [FLINK-27891][Table] Add ARRAY_APPEND and ARRAY_PREPEND functions | 19 February 2024, 22:06:21 UTC |
| 4645880 | Matthias Pohl | 15 February 2024, 15:59:05 UTC | [hotfix][test] Migrates ExceptionUtilsITCase to JUnit5/AssertJ | 19 February 2024, 15:43:18 UTC |
| ac91054 | Matthias Pohl | 15 February 2024, 14:19:15 UTC | [FLINK-22765][test] Hardens ExceptionUtilsITCase#testIsMetaspaceOutOfMemoryError in JDK21 This test started to fail quite regularly in JDK21. The problem was that the low heap size could have caused an OutOfMemoryError to appear when compiling the dummy classes. An OOM in the compilation phase results in a different error message being printed to stdout that wasn't captured by the test. The solution is to pre-compile the classes upfront (with the normal heap size). The test main method will only load the classes. No compilation is necessary. | 19 February 2024, 15:43:18 UTC |
| f43972a | Matthias Pohl | 19 February 2024, 08:58:33 UTC | [hotfix][test] Replaces String#replaceAll with String#replace in ClassLoaderUtils to avoid regex compilation | 19 February 2024, 15:43:18 UTC |
| 7e260aa | Matthias Pohl | 15 February 2024, 13:20:31 UTC | [hotfix][test] Removes duplicate Apache header | 19 February 2024, 15:43:18 UTC |
| 6c9ac5c | Jim Hughes | 19 January 2024, 18:22:34 UTC | [FLINK-33495][FLINK-33496] Add DISTRIBUTED BY clause for CREATE TABLE - Adds distribution support to CatalogTable - Adds connector ability SupportsBucketing - Adds distribution to TableDescriptor. This closes #24155. | 19 February 2024, 12:36:55 UTC |
| 64463d4 | Leonard Xu | 19 February 2024, 12:06:48 UTC | [hotfix] Integrate mongodb v1.1 docs (#24330) | 19 February 2024, 12:06:48 UTC |
| 4cc04a0 | Matthias Pohl | 16 February 2024, 12:16:55 UTC | [FLINK-34418][ci] Mounts /mnt folder to /root | 19 February 2024, 11:41:05 UTC |
| 05544c6 | Matthias Pohl | 13 February 2024, 17:11:52 UTC | [hotfix][ci] Removes obsolete line | 19 February 2024, 11:41:05 UTC |
| dcb30f9 | Xiangyu Feng | 18 February 2024, 06:56:26 UTC | [FLINK-25015][Table SQL] Use SQL string as jobName for DQL jobs submitted by sql-gateway | 19 February 2024, 03:28:27 UTC |
| 050503c | caicancai | 17 February 2024, 03:28:27 UTC | [Hotfix] fix typo for pipelne | 18 February 2024, 02:52:38 UTC |
| 620e597 | Hanyu Zheng | 03 July 2023, 14:59:23 UTC | [FLINK-26948][table] Add-ARRAY_SORT-function. [FLINK-26948][table] Add-ARRAY_SORT-function. | 16 February 2024, 09:39:21 UTC |
| 6e93394 | bvarghese1 | 27 January 2024, 01:44:14 UTC | [FLINK-34248] Remove ChangelogNormalize Json Plan & IT tests | 15 February 2024, 11:22:18 UTC |
| e76ccdc | bvarghese1 | 26 January 2024, 23:04:19 UTC | [FLINK-34248] Implement restore tests for changelog normalize node | 15 February 2024, 11:22:18 UTC |
| 2298e53 | Matthias Pohl | 14 February 2024, 09:34:33 UTC | [FLINK-34403][ci] Transforms VeryBigPbRowToProtoTest into an integration test | 14 February 2024, 16:55:04 UTC |
| 403694e | Martijn Visser | 12 February 2024, 15:18:20 UTC | [FLINK-34432][Table/Planner] Re-enable fork reuse | 14 February 2024, 09:26:41 UTC |
| 6bf9767 | Stefan Richter | 22 January 2024, 14:50:09 UTC | [FLINK-34199] Add documentation. | 13 February 2024, 16:07:57 UTC |
| 16eae41 | Stefan Richter | 22 January 2024, 14:46:32 UTC | [FLINK-34199] Add tracing for durations of rescaling/restoring (from local and downloaded remote state). | 13 February 2024, 16:07:57 UTC |
| 268a308 | Stefan Richter | 12 February 2024, 12:35:40 UTC | [FLINK-31238] Deactivate parts of the code until new FRocksDB release is available. Then this commit should be reverted. | 13 February 2024, 16:07:57 UTC |
| 5495a96 | Stefan Richter | 05 January 2024, 14:32:32 UTC | [FLINK-31238] Use IngestDB to speed up Rocksdb rescaling recovery (part 2) | 13 February 2024, 16:07:57 UTC |
| 4ddedeb | 马越 | 08 August 2023, 12:56:17 UTC | [FLINK-31238] Use IngestDB to speed up Rocksdb rescaling recovery (part 1) | 13 February 2024, 16:07:57 UTC |
| 5844092 | bvarghese1 | 19 January 2024, 17:11:28 UTC | [FLINK-34000] Remove IncrementalGroupAgg Json Plan & IT tests - These are covered by restore tests | 13 February 2024, 11:33:14 UTC |
| 14d5dbc | bvarghese1 | 19 January 2024, 17:07:00 UTC | [FLINK-34000] Implement restore tests for IncrementalGroupAgg node | 13 February 2024, 11:33:14 UTC |
| 9a316a5 | Matthias Pohl | 12 February 2024, 12:49:47 UTC | [FLINK-34403][ci] Transforms VeryBigPbProtoToRowTest into an integration test The integration test configuration enables a bigger for test execution. | 13 February 2024, 09:44:50 UTC |
| 6f74889 | Sergey Nuyanzin | 12 February 2024, 22:18:32 UTC | [FLINK-34157][table] Migrate FlinkLimit0RemoveRule to java | 12 February 2024, 22:18:32 UTC |
| 9caa3bb | Chesnay Schepler | 12 February 2024, 10:50:39 UTC | [hotfix] Rename ProtobufSQLITCaseTest -> ProtobufSQLITCase | 12 February 2024, 11:03:33 UTC |
| 4c4643c | Chesnay Schepler | 11 February 2024, 00:38:45 UTC | [FLINK-34422][test] BatchTestBase uses MiniClusterExtension | 12 February 2024, 11:03:33 UTC |
| 65727fb | Chesnay Schepler | 11 February 2024, 15:06:59 UTC | [FLINK-34422] Migrate BatchTestBase subclass to jUnit5 Usually this should've been done _before_ you ban jUnit4 annotations in BatchTestBase... | 12 February 2024, 11:03:33 UTC |
| 25a604a | Chesnay Schepler | 12 February 2024, 10:02:08 UTC | [hotfix][build] Wire up spotless.skip property Our version of the plugin has a plugin configuration option, but it's not honored when specified on the command-line. Manually wire up a property that takes care of this. Can be removed once we upgrade post to 2.38+ | 12 February 2024, 10:02:08 UTC |
| 1fbf92d | bvarghese1 | 25 January 2024, 19:22:22 UTC | [FLINK-33958] Fix IntervalJoin restore test flakiness - Update input data to make test output predictable | 12 February 2024, 08:25:14 UTC |
| 6f4d31f | slfan1989 | 11 February 2024, 12:37:02 UTC | [hotfix][sql-client] Improve logging using placeholders | 11 February 2024, 12:37:02 UTC |
| 5277f65 | Roman Khachatryan | 09 February 2024, 20:35:41 UTC | [FLINK-34410] Correct hadoop.tar.gz download url | 11 February 2024, 12:31:10 UTC |
| d2abd74 | Matthias Pohl | 08 February 2024, 07:23:09 UTC | [FLINK-34410][ci] Disables the nightly trigger workflow for forks | 09 February 2024, 08:35:01 UTC |
| c84f42c | Roman Khachatryan | 02 February 2024, 15:02:14 UTC | [FLINK-34344] Pass JobID to CheckpointStatsTracker | 08 February 2024, 19:47:13 UTC |
| a33a057 | Martijn Visser | 26 January 2024, 15:09:42 UTC | [hotfix] Remove no longer necessary `kafka.version` parameters | 08 February 2024, 15:25:09 UTC |
| 6bfc53c | Martijn Visser | 26 January 2024, 15:09:06 UTC | [FLINK-34244] Upgrade Confluent Platform Avro Schema Registry to version 7.5.3 | 08 February 2024, 15:25:09 UTC |
| 01cdc70 | Dawid Wysakowicz | 08 February 2024, 14:26:16 UTC | [FLINK-24239] Event time temporal join should support values from array, map, row, etc. as join key (#24253) | 08 February 2024, 14:26:16 UTC |
| 1b95b19 | Rui Fan | 01 February 2024, 13:07:40 UTC | [FLINK-34200][test] Fix the bug that AutoRescalingITCase.testCheckpointRescalingInKeyedState fails occasionally | 08 February 2024, 02:14:53 UTC |
| 9d7de68 | Rui Fan | 01 February 2024, 13:09:34 UTC | [hotfix][tests] Disables cool down phase for faster test execution | 08 February 2024, 02:14:53 UTC |
| 777e96f | Rui Fan | 01 January 2024, 03:59:54 UTC | [FLINK-33960][Scheduler] Fix the bug that Adaptive Scheduler doesn't respect the lowerBound when one flink job has more than 1 tasks | 08 February 2024, 02:08:36 UTC |
| 71336d6 | Rui Fan | 01 January 2024, 03:26:18 UTC | [FLINK-33960][JUnit5 migration] Migrate SlotSharingSlotAllocatorTest to Junit5 and Assertj | 08 February 2024, 02:08:36 UTC |
| 042a4d2 | Jiabao Sun | 07 February 2024, 15:01:04 UTC | [FLINK-21949][table] Support ARRAY_AGG aggregate function (#23411) | 07 February 2024, 15:01:04 UTC |
| 6ca9ec7 | Matthias Pohl | 06 February 2024, 15:23:31 UTC | [hotfix][build] Fixes error message when printing the 15 biggest directories | 07 February 2024, 14:16:50 UTC |
| f468b5b | Matthias Pohl | 06 February 2024, 14:46:15 UTC | [FLINK-34360][ci] Adds cleanup to job_init action | 07 February 2024, 14:16:50 UTC |
| 2962b2a | Matthias Pohl | 07 February 2024, 12:10:07 UTC | [FLINK-34282][ci] Adds release-1.18 back to GHA nightly trigger workflow | 07 February 2024, 13:46:50 UTC |
| eb1f7c8 | Martijn Visser | 07 February 2024, 08:14:58 UTC | [hotfix] Include `release-1.19` for building documentation | 07 February 2024, 08:14:58 UTC |
| f1fba33 | caicancai | 03 February 2024, 06:24:56 UTC | [FLINK-34345][runtime] Remove TaskExecutorManager related logic | 07 February 2024, 06:06:48 UTC |
| df03ada | dsaisharath | 13 December 2023, 22:14:38 UTC | [FLINK-33611][flink-protobuf] Split last segment only when size exceeds split threshold limit in deserializer Close apache/flink#23937 | 07 February 2024, 04:47:22 UTC |
| b8b2596 | lincoln lee | 07 February 2024, 02:54:05 UTC | Add new version 1.20 and update GHA nightly build versions | 07 February 2024, 02:54:05 UTC |
| bf5068c | lincoln lee | 07 February 2024, 02:50:09 UTC | Update version to 1.20-SNAPSHOT | 07 February 2024, 02:50:09 UTC |
| 03b4584 | Jiabao Sun | 06 February 2024, 19:19:43 UTC | [FLINK-34337][Core] Sink.InitContextWrapper should implement metadataConsumer method. This closes #24249 * Sink.InitContextWrapper should implement metadataConsumer method * Add test for InitContextWrapper | 06 February 2024, 19:19:43 UTC |
| 4264c30 | Alan Sheinberg | 06 February 2024, 17:53:36 UTC | [FLINK-34095] Adds restore tests for StreamExecAsyncCalc (#24220) | 06 February 2024, 17:53:36 UTC |
| 2f040e3 | Rui Fan | 04 February 2024, 09:48:38 UTC | [FLINK-33739][doc] Document FLIP-364: Improve the exponential-delay restart-strategy | 06 February 2024, 11:34:19 UTC |
| d2ed2df | Yun Tang | 06 February 2024, 11:12:23 UTC | [hotfix][web] Correct the hint of options name of rest.profiling.enabled | 06 February 2024, 11:27:56 UTC |
| 1ebcaf5 | yeming | 31 January 2024, 06:07:35 UTC | [FLINK-34256][docs] Add documentation for mini-batch regular join This closes #24240 | 06 February 2024, 08:06:27 UTC |
| 79cccd7 | Matthias Pohl | 02 February 2024, 13:47:42 UTC | [FLINK-34007][k8s] Adds graceful shutdown logic to KubernetesLeaderElector We need to make sure that any ongoing leadership event is properly handled. shutdownNow and the Precondition are too aggressive. | 05 February 2024, 22:09:34 UTC |
| 39e2eaf | Matthias Pohl | 02 February 2024, 13:34:47 UTC | [hotfix][core] Makes ExecutorUtils#gracefulShutdown return any outstanding tasks | 05 February 2024, 22:09:34 UTC |
| 3d0cdde | bvarghese1 | 17 January 2024, 02:20:34 UTC | [FLINK-33441] Remove unused json plan | 05 February 2024, 13:30:56 UTC |
| f5d889f | bvarghese1 | 17 January 2024, 02:16:42 UTC | [FLINK-33441] Move Union restore tests - Moving from nodes.exec.testutil to nodes.exec.stream - Related commit: f362dcc | 05 February 2024, 13:30:56 UTC |
| 839f298 | Chesnay Schepler | 03 February 2024, 10:20:08 UTC | [FLINK-34343][rpc] Use actor path when rejecting early messages | 05 February 2024, 11:44:27 UTC |
| d44e940 | Rui Fan | 05 February 2024, 05:21:34 UTC | [FLINK-34247][doc] Fix the wrong zh link for flink-configuration-file and repeated flink configuration file | 05 February 2024, 10:41:43 UTC |
| 360c1a0 | Feng Jiajie | 29 January 2024, 02:39:27 UTC | [FLINK-33981][runtime] Fix not closing DirectoryStream after listing local state files | 05 February 2024, 07:08:27 UTC |
| de2d175 | xuyang | 04 February 2024, 10:17:33 UTC | [FLINK-34353][table-planner] Fix unclear exception without setting minibatch size when enable minibatch optimization This closes #24264 | 05 February 2024, 03:45:27 UTC |
| e9bea09 | JunRuiLee | 04 February 2024, 08:47:52 UTC | [FLINK-34247][doc] Update the usage of flink-conf.yaml in doc. This closes #24251. | 05 February 2024, 02:11:51 UTC |
| 04dd91f | JunRuiLee | 04 February 2024, 08:40:35 UTC | [FLINK-34247][doc] Update the usage of "env.java.home" in doc. | 05 February 2024, 02:11:51 UTC |
| 5b61baa | JunRuiLee | 04 February 2024, 08:38:55 UTC | [FLINK-34247][doc] Add documentation of new Flink configuration file config.yaml. | 05 February 2024, 02:11:51 UTC |
| 6be30b1 | Xuyang | 05 February 2024, 02:06:03 UTC | [FLINK-34323][table-planner] Fix named params in session window tvf This close #24243 | 05 February 2024, 02:06:03 UTC |
| a603f2b | zoudan | 30 January 2024, 11:18:21 UTC | [FLINK-34229][table-runtime] Set CodeGeneratorContext of outer class as ancestor context when generate inner classes to avoid naming conflicts This closes #24228 | 05 February 2024, 02:01:15 UTC |
| eff073f | Xuyang | 04 February 2024, 15:24:54 UTC | [FLINK-34313][doc][table] Add document for session window tvf This closes #24250 | 04 February 2024, 15:24:54 UTC |
| 433b025 | yunhong | 04 February 2024, 09:46:44 UTC | [FLINK-34034][docs] Update the query hint docs to clarify the resolution of conflicts in kv hint and list hint This closes #24077 | 04 February 2024, 09:46:44 UTC |
| 60795b7 | Zhanghao Chen | 30 January 2024, 12:34:39 UTC | [FLINK-34217][docs] Update user doc for type serialization with FLIP-398 | 04 February 2024, 08:40:52 UTC |
| 5fe6f20 | gongzhongqiang | 22 July 2022, 07:11:04 UTC | [FLINK-26369][doc-zh] Translate the part zh-page mixed with not be translated. | 03 February 2024, 05:51:18 UTC |
| 0779c91 | Jane Chan | 02 February 2024, 02:10:40 UTC | [FLINK-34258][docs][table] Fix incorrect retract example for TableAggregateFunction This closes #24215 | 02 February 2024, 02:10:40 UTC |
| d6c7eee | Sergey Nuyanzin | 01 February 2024, 13:02:03 UTC | Revert "[FLINK-33705] Upgrade to flink-shaded 18.0" | 01 February 2024, 13:02:03 UTC |
| 7b95dc3 | Danny Cranmer | 01 February 2024, 10:31:31 UTC | [hotfix] Integrate opensearch v1.1 docs | 01 February 2024, 10:31:31 UTC |
| 95417a4 | Matthias Pohl | 29 January 2024, 10:29:07 UTC | [FLINK-34007][k8s] Upgrade k8s client to v6.9.2 to cover client issue #5464 https://github.com/fabric8io/kubernetes-client/issues/5463 | 01 February 2024, 09:36:06 UTC |
| 927972f | Matthias Pohl | 23 January 2024, 15:27:02 UTC | [FLINK-34007][k8s] fabric8io LeaderElector is created with every new #run() call v5.12.4 allowed us to reuse the LeaderElector. With v6.6.2 (fabric8io/kubernetes-client#4125) this behavior changed. One LeaderElector can only be used until the leadership is lost. An ITCase is added to cover the scenario where the leadership is lost. | 01 February 2024, 09:36:06 UTC |
| 8ff011f | Matthias Pohl | 29 January 2024, 08:28:27 UTC | [hotfix][test] Refactors TestingLeaderCallbackHandler to allow async calls This way, we can use FlinkAssertions#assertThatFuture and use assertion messages instead of comments. | 01 February 2024, 09:36:06 UTC |
| de6b397 | Matthias Pohl | 23 January 2024, 15:21:45 UTC | [hotfix][test] Makes ManuallyTriggeredScheduledExecutorService#execute rely on a BlockingQueue This allows us to wait for tasks to "arrive". | 01 February 2024, 09:36:06 UTC |
| 4a50d37 | Matthias Pohl | 26 January 2024, 10:25:34 UTC | [hotfix][test] Moves ConfigMap lifecycle management into @BeforeEach/@AfterEach methods | 01 February 2024, 09:36:06 UTC |
| dd3e60a | JunRuiLee | 01 February 2024, 04:18:25 UTC | [FLINK-34132][runtime] Correct the error message and doc that AdaptiveBatch only supports all edges being BLOCKING or HYBRID_FULL/HYBRID_SELECTIVE. This closes #24118. | 01 February 2024, 07:58:59 UTC |
| 2be1ea8 | JunRuiLee | 17 January 2024, 05:54:55 UTC | [FLINK-34126][configuration] Correct the description of config option jobmanager.scheduler This closes #24112. | 01 February 2024, 07:54:24 UTC |
| b737b71 | sunxia | 30 January 2024, 06:26:26 UTC | [FLINK-34206][runtime] Fix potential job failure due to concurrent global failure and source paralelism inference This closes #24223. | 01 February 2024, 07:51:02 UTC |
| fa364c7 | Prabhu Joseph | 01 February 2024, 03:51:40 UTC | [FLINK-33358][sql-client] Fix Flink SQL Client fail to start in Flink on YARN (#23629) Co-authored-by: Prabhu Joseph <joprabhu@amazon.com> | 01 February 2024, 03:51:40 UTC |
| 98e1d07 | Zhanghao Chen | 27 January 2024, 16:43:18 UTC | [FLINK-34270][docs] Update doc for the new Table source & sink interfaces introduced in FLIP-146/367 Close apache/flink#24234 | 01 February 2024, 02:35:28 UTC |
| 3c8088b | Zhanghao Chen | 30 January 2024, 16:05:19 UTC | [hotfix][table-common] Mark SinkV2Provider as the recommended core interface for SinkRuntimeProvider | 01 February 2024, 02:35:16 UTC |
| 8e11b60 | David Moravek | 30 January 2024, 20:45:04 UTC | [FLINK-34272][runtime] ExecutingState should never transition during its construction. | 31 January 2024, 17:22:55 UTC |
| cb9e220 | Xuyang | 31 January 2024, 13:32:43 UTC | [FLINK-34271][table-planner] Fix unstable GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT This closes #24226 | 31 January 2024, 13:32:43 UTC |
