| 5b103ef | dependabot[bot] | 19 July 2023, 08:06:53 UTC | Bump word-wrap from 1.2.3 to 1.2.4 in /flink-runtime-web/web-dashboard Bumps [word-wrap](https://github.com/jonschlinkert/word-wrap) from 1.2.3 to 1.2.4. - [Release notes](https://github.com/jonschlinkert/word-wrap/releases) - [Commits](https://github.com/jonschlinkert/word-wrap/compare/1.2.3...1.2.4) --- updated-dependencies: - dependency-name: word-wrap dependency-type: indirect ... Signed-off-by: dependabot[bot] <support@github.com> | 19 July 2023, 08:06:53 UTC |
| 3886f1f | tison | 19 July 2023, 07:55:06 UTC | [FLINK-32625][tests] MiniClusterTestEnvironment supports customized MiniClusterResourceConfiguration This closes #23015. | 19 July 2023, 07:55:06 UTC |
| 99c652c | Wencong Liu | 19 July 2023, 02:00:55 UTC | [FLINK-32624][network] Fix the TieredStorageConsumerClientTest | 19 July 2023, 07:54:07 UTC |
| 1635a28 | Hang Ruan | 19 July 2023, 07:09:02 UTC | Revert "[FLINK-28046][connectors] Mark SourceFunction interface as @deprecated" This closes #23018 which reverts commit 07bf511a32b525f94d258daec347cf777b31bebb. We need to resolve all subtasks in FLINK-28045 and then deprecated SourceFunction interface. | 19 July 2023, 07:09:02 UTC |
| 698b128 | lincoln lee | 19 July 2023, 06:19:21 UTC | [FLINK-32578][table-planner] Fix wrong plan which group by window time columns on a proctime window operator may result hang for ever This closes #23001 | 19 July 2023, 06:19:21 UTC |
| 5430912 | Akinfolami Akin-Alamu | 18 July 2023, 16:27:36 UTC | [hotfix][docs] fix typo in table api operations scan is misspelled as scane | 19 July 2023, 04:16:13 UTC |
| 1786e2d | Yuxin Tan | 17 July 2023, 07:09:26 UTC | [FLINK-32576][network] ProducerMergedPartitionFileIndex supports caching regions and spilling regions to file | 19 July 2023, 02:26:25 UTC |
| 0ef0dbd | Yuxin Tan | 17 July 2023, 07:02:04 UTC | [FLINK-32576][network] Extract file data index cache for hybrid shuffle | 19 July 2023, 02:26:25 UTC |
| 663a68f | Timo Walther | 18 July 2023, 10:16:50 UTC | [FLINK-32613] Add ConfigOption for disabling TimestampInserter | 18 July 2023, 13:03:38 UTC |
| cc9712b | zhangmang | 18 July 2023, 12:43:41 UTC | [FLINK-32518][table] Enable atomicity for [CREATE OR] REPLACE TABLE AS statement (#22995) | 18 July 2023, 12:43:41 UTC |
| 36b4531 | Sergey Nuyanzin | 18 July 2023, 12:25:54 UTC | [FLINK-30984][table] Upgrade Janino to 3.1.10 and remove explicit cast required by 3.1.9 | 18 July 2023, 12:25:54 UTC |
| 9c3c8af | Wencong Liu | 17 July 2023, 02:26:35 UTC | [FLINK-31647][network] Introduce the RemoteTierConsumerAgent | 18 July 2023, 02:02:04 UTC |
| 1bf06cf | Wencong Liu | 10 July 2023, 03:27:16 UTC | [FLINK-31647][network] Introduce the SegmentPartitionFileReader | 18 July 2023, 02:02:04 UTC |
| 55f4d86 | Wencong Liu | 10 July 2023, 03:26:45 UTC | [hotfix][network] Remove unused helper and fix the TieredStorageConsumerClient | 18 July 2023, 02:02:04 UTC |
| 0f2ee60 | baiwuchang | 18 July 2023, 01:15:19 UTC | [FLINK-32365][hive] Allow Hive source to scan table to get statistics in parallel (#22805) | 18 July 2023, 01:15:19 UTC |
| aa21eac | Dawid Wysakowicz | 11 July 2023, 13:10:53 UTC | [FLINK-32584] Make it possible to unset default catalog and/or database | 17 July 2023, 15:24:25 UTC |
| bcdbc51 | leiyanfei | 15 June 2023, 08:29:47 UTC | [FLINK-24402][metric] Add a metric for back-pressure from the ChangelogStateBackend | 17 July 2023, 11:30:12 UTC |
| 5cacd12 | yuchengxin | 17 April 2023, 10:06:49 UTC | [FLINK-31819][doc] Added documentations for advanced watermark features in sql | 17 July 2023, 09:52:00 UTC |
| 2aa9af1 | yuchengxin | 03 March 2023, 02:37:03 UTC | [FLINK-31540][flink-table-planner] support to set idle-timeout options with table options and 'OPTIONS' hint | 17 July 2023, 09:52:00 UTC |
| 8f64775 | yuchengxin | 02 March 2023, 13:23:23 UTC | [FLINK-31539][flink-table-planner] supported watermark alignment in sql layer. | 17 July 2023, 09:52:00 UTC |
| a3471ea | yuchengxin | 03 March 2023, 04:20:22 UTC | [FLINK-31536][flink-table] support to set watermark emit strategy with table options and 'OPTIONS' hint | 17 July 2023, 09:52:00 UTC |
| e8b1185 | Feng Jin | 17 July 2023, 01:18:04 UTC | [FLINK-32569][table] Fix the incomplete serialization of ResolvedCatalogTable caused by the newly introduced time travel interface (#22977) | 17 July 2023, 01:18:04 UTC |
| 4690dc2 | fengli | 16 July 2023, 08:16:31 UTC | [FLINK-32489][runtime] Migrate tests of BloomFilterTest to junit5 This closes #22908 | 16 July 2023, 13:35:45 UTC |
| c2cba01 | fengli | 28 June 2023, 01:55:55 UTC | [FLINK-32489][runtime] Support serialize and merge BloomFilter for runtime filter | 16 July 2023, 13:35:24 UTC |
| 43f8976 | Hangxiang Yu | 15 June 2023, 17:55:24 UTC | [FLINK-23484][benchmark] Supports HEAP_CHANGELOG and ROCKSDB_CHANGELOG | 15 July 2023, 09:23:41 UTC |
| e593734 | Hangxiang Yu | 14 June 2023, 17:56:34 UTC | [FLINK-23484][benchmark] Move state benchmark to test-utils package | 15 July 2023, 09:23:41 UTC |
| 255ed35 | Sergey Nuyanzin | 14 July 2023, 20:50:07 UTC | [FLINK-26549][table][tests] Add tests for INSERT INTO with VALUES leads to wrong type inference with nested types | 14 July 2023, 20:50:07 UTC |
| 34f4f94 | 1996fanrui | 09 June 2023, 11:01:30 UTC | [FLINK-32298][network] Fix the bug that totalWrittenBytes of BufferWritingResultPartition misses some data | 14 July 2023, 13:20:01 UTC |
| e1c9656 | 1996fanrui | 09 June 2023, 10:57:35 UTC | [FLINK-32298][network][refactor] Add data to PipelinedSubpartition through BufferWritingResultPartition | 14 July 2023, 13:20:01 UTC |
| 72a30e5 | 1996fanrui | 08 June 2023, 08:12:50 UTC | [FLINK-32298][refactor] Using the static const instead of magic code in ResultSubpartition | 14 July 2023, 13:20:01 UTC |
| 8829b5e | lincoln lee | 14 July 2023, 02:40:56 UTC | [FLINK-28743][table-planner] Supports validating the determinism for StreamPhysicalMatchRecognize This closes #22981 | 14 July 2023, 02:40:56 UTC |
| e5324c0 | yuxia Luo | 14 July 2023, 01:34:02 UTC | [FLINK-32481][table] Support type inference for procedure (#22904) | 14 July 2023, 01:34:02 UTC |
| d7a3b38 | tison | 13 July 2023, 17:47:36 UTC | [FLINK-32585] Filter javax.xml.bind:jaxb-api false positive for Pulsar connector (#22989) Signed-off-by: tison <wander4096@gmail.com> | 13 July 2023, 17:47:36 UTC |
| f37d41c | archzi | 13 July 2023, 14:28:54 UTC | [FLINK-32157] Replaces LeaderConnectionInfo with LeaderInformation (#22988) | 13 July 2023, 14:28:54 UTC |
| bc4c21e | 1996fanrui | 12 July 2023, 05:55:53 UTC | [FLINK-32049][checkpoint] Fix thread-safe bug of channel state executor when some subtasks are closed while other subtasks are starting | 13 July 2023, 07:42:21 UTC |
| f89be70 | xuyu | 11 July 2023, 10:44:56 UTC | [FLINK-31035] add warn info to user when NoNodeException happend | 12 July 2023, 15:24:51 UTC |
| f480b6d | fengli | 26 June 2023, 10:05:42 UTC | [FLINK-22734][table-runtime] Fix comments for HashJoin and Calc OperatorFusionCodeGen This closes #22734 | 12 July 2023, 14:53:29 UTC |
| f03c26a | fengli | 15 June 2023, 11:41:20 UTC | [FLINK-32278][table-runtime] Calc and HashJoin operator support operator fusion codegen | 12 July 2023, 14:50:57 UTC |
| 6040f48 | fengli | 05 June 2023, 12:43:07 UTC | [FLINK-32278][table-runtime] Introduce the Calc and HashJoin operator spec to support operator fusion codegen | 12 July 2023, 14:50:57 UTC |
| 1f062a3 | fengli | 05 June 2023, 12:41:25 UTC | [FLINK-32277][table-runtime] Introduce the base FusionStreamOperator for OFCG | 12 July 2023, 14:50:57 UTC |
| 02be55a | fengli | 05 June 2023, 12:33:54 UTC | [FLINK-32277][table-runtime] Introduce the basic operator fusion codegen framework | 12 July 2023, 14:50:56 UTC |
| 354a885 | 1996fanrui | 28 June 2023, 17:06:08 UTC | [FLINK-32420][connectors/common] Using the HeapPriorityQueue to improve the watermark aggregation performance when parallelism is high | 12 July 2023, 10:41:34 UTC |
| 224aa2e | 1996fanrui | 28 June 2023, 16:36:58 UTC | [FLINK-32420][refactor] Add the AbstractHeapPriorityQueueElement | 12 July 2023, 10:41:34 UTC |
| 2dfff43 | Yuxin Tan | 10 July 2023, 03:48:44 UTC | [FLINK-32549][network] Tiered storage memory manager supports ownership transfer for buffers | 12 July 2023, 03:12:29 UTC |
| 61d8fec | Yuxin Tan | 10 July 2023, 05:18:17 UTC | [hotfix][network] Fix the availability of tiered result partition | 12 July 2023, 03:12:29 UTC |
| e6f77be | zhangmang | 12 July 2023, 01:45:03 UTC | [FLINK-32349][table] Support atomicity for CREATE TABLE AS SELECT(CTAS) statement (#22839) | 12 July 2023, 01:45:03 UTC |
| 4cf2124 | Timo Walther | 28 June 2023, 11:42:47 UTC | [FLINK-32466] Replace STRING with CHARACTER for functions that don't support binary strings This closes #22892. | 10 July 2023, 17:10:13 UTC |
| 2a6e8ae | 1996fanrui | 10 July 2023, 09:10:21 UTC | [FLINK-32568][web] Ensure that all subtasks are sorted by busy ratio at the backpressure tab by default | 10 July 2023, 14:48:19 UTC |
| c942d0f | Sergey Nuyanzin | 10 July 2023, 14:30:59 UTC | [FLINK-29319][table] Upgrade Calcite from 1.31.0 to 1.32.0 | 10 July 2023, 14:30:59 UTC |
| 773feeb | Matthias Pohl | 10 July 2023, 12:44:17 UTC | [FLINK-32556][runtime] Renames contenderID into componentId (#22967) * Renames local variables and parameters * Renames DefaultLeaderElectionServiceTest.createRandomContenderID * Renames occurrences in LeaderInformationRegister * Renames occurrences in KubernetesHighAvailabilityTestBase classes * Renames occurrences in LeaderElectionEvent * Replaced the log message parameter (componentId instead of contender) * Aligned component vs component ID in the log messages | 10 July 2023, 12:44:17 UTC |
| 4f5b2fb | Joao Boto | 10 July 2023, 08:47:51 UTC | [FLINK-32376][connector] Extend Sink#InitContext to expose TypeSerializer, ObjectReuse and JobID | 10 July 2023, 12:28:04 UTC |
| b4faca5 | lincoln lee | 29 June 2023, 01:46:13 UTC | [FLINK-32457][doc][table] Update documentation of JSON_OBJECTAGG/JSON_ARRAYAGG to clarify the limitation | 10 July 2023, 12:20:53 UTC |
| 7ec1813 | lincoln lee | 29 June 2023, 01:45:09 UTC | [FLINK-32457][table-planner] Add test cases of unsupported usage for JSON_OBJECTAGG & JSON_ARRAYAGG | 10 July 2023, 12:20:53 UTC |
| 9aecb0c | Weijie Guo | 06 July 2023, 09:13:27 UTC | [hotfix][streaming] Fix typo in DataStream.java and DataStream.scala. | 10 July 2023, 11:40:51 UTC |
| 9a4119f | Matthias Pohl | 05 July 2023, 12:17:36 UTC | [hotfix][runtime] Removes unused members and fixed typo Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 09 July 2023, 16:10:52 UTC |
| e65b12e | Matthias Pohl | 07 July 2023, 09:47:43 UTC | [hotfix][tests] Adds proper multi-threading to the test case The old implementation of the test didn't run in a multi-threaded context. That meant that there was no real race condition that needed to be handled (because the same thread tried to access DefaultLeaderElectionService#lock). The logic can be implemented by validating both, leaderElectionDriver and leadershipOperationExecutor. Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 09 July 2023, 16:10:52 UTC |
| d2e6b94 | Matthias Pohl | 30 June 2023, 13:14:58 UTC | [FLINK-31837] Makes the driver instantiation being performed lazily as soon as the first contender is registered - the driver's lifecycle is tied to the leaderContenderRegistry: it's only instantiated if there are contenders registered - the service's lifecycle takes care of the internally used leadershipOperationExecutor | 09 July 2023, 16:10:52 UTC |
| e6e0f47 | Hanyu Zheng | 08 July 2023, 10:15:19 UTC | [FLINK-32260][table] Add ARRAY_SLICE function | 08 July 2023, 10:15:19 UTC |
| 1aef1f1 | Benchao Li | 07 July 2023, 14:10:45 UTC | [FLINK-32547][docs] Add missing doc for Timestamp support in ProtoBuf format | 07 July 2023, 23:57:05 UTC |
| 6e61b93 | Alexander Fedulov | 07 July 2023, 19:54:37 UTC | [FLINK-32035][sql-client] Support HTTPS endpoints in SQL Client gateway mode (#22810) | 07 July 2023, 19:54:37 UTC |
| d88ef0e | Wencong Liu | 07 July 2023, 13:25:26 UTC | [FLINK-32502][runtime] Remove the AbstractLeaderElectionService (#22959) | 07 July 2023, 13:25:26 UTC |
| ffe7b07 | Matthias Pohl | 06 July 2023, 12:40:56 UTC | [hotfix][test] Removes unused ClusterComponent enum Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 07 July 2023, 09:30:49 UTC |
| 174cf25 | Matthias Pohl | 03 July 2023, 12:32:03 UTC | [FLINK-32381][runtime] Replaces FatalErrorHandler in LeaderElectionDriver with LeaderElectionDriver.Listener#onError interface method Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 07 July 2023, 09:30:49 UTC |
| af75268 | Matthias Pohl | 03 July 2023, 13:45:54 UTC | [hotfix][tests] Adds error handling to ZK-related DefaultLeaderElectionService tests Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 07 July 2023, 09:30:49 UTC |
| 0e69a7b | 1996fanrui | 01 July 2023, 05:49:22 UTC | [FLINK-32496][connectors/common] Fix the bug that source cannot resume after enabling the watermark alignment and idleness | 07 July 2023, 08:48:59 UTC |
| 4f995ff | 1996fanrui | 30 June 2023, 11:11:39 UTC | [FLINK-32496][connectors/common][refactor] Improve watermark alignment log for easier troubleshooting | 07 July 2023, 08:48:59 UTC |
| 73a0b87 | Yuxin Tan | 06 July 2023, 06:34:28 UTC | [FLINK-32541][network] Fix the buffer leaking when buffer accumulator is closed | 07 July 2023, 07:54:20 UTC |
| e31ecb9 | Matthias Pohl | 28 June 2023, 12:35:14 UTC | [hotfix][runtime] Removes obsolete Precondition (the executorService is final and set within the constructor) Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 07 July 2023, 07:53:59 UTC |
| c5fc723 | Matthias Pohl | 28 June 2023, 11:56:29 UTC | [FLINK-31814][runtime] Enables Precondition that checks that the issuedLeaderSessionID is set on revoke processing This Precondition can be enabled because the processing of revoke calls is not happening anymore during close. The event processing is protected by the running flag within DefaultLeaderElectionService which is set to false as part of the close mechanism. Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 07 July 2023, 07:53:59 UTC |
| d3a9ccb | Jacky Lau | 07 July 2023, 07:40:31 UTC | [hotfix][docs] Fix incorrect example of user-defined function. (#22948) | 07 July 2023, 07:40:31 UTC |
| 6074d7b | Hang Ruan | 07 July 2023, 01:26:19 UTC | [FLINK-32397][docs]Add doc for add/drop/show partition (#22927) | 07 July 2023, 01:26:19 UTC |
| 08ef36e | zhangmang | 07 July 2023, 01:16:08 UTC | [FLINK-32517][table] Support to execute [CREATE OR] REPLACE TABLE AS statement (#22949) | 07 July 2023, 01:16:08 UTC |
| 1354d2f | Alexander Fedulov | 06 July 2023, 19:34:36 UTC | [FLINK-32373][sql-client] Support passing headers with SQL Client gateway requests (#22816) | 06 July 2023, 19:34:36 UTC |
| df2747f | Matthias Pohl | 23 June 2023, 08:33:24 UTC | [FLINK-32419][runtime] Renames leader election related classes/fields/methods - Renames AllKnownLeaderInformationEvent into AllLeaderInformationChangeEvent - Renames LeaderElectionDriver.Listener methods: notifyLeaderInformationChange -> onLeaderInformationChange, notifyAllKnownLeaderInformation -> onLeaderInformationChange - Renames LeaderElectionDriver.Listener methods: isLeader -> onGrantLeadership, notLeader -> onRevokeLeadership - Renames MultipleComponentLeaderElectionDriverFactory (and its subclasses) into LeaderElectionDriverFactory - Renames MultipleComponentLeaderElectionDriver (and its subclasses) into LeaderElectionDriver - Renames componentId into contenderID to align the usage - Renames DefaultLeaderElectionServiceTest test method names to use close instead of stop - Renames KubernetesMultipleComponentLeaderRetrievalDriverFactory into KubernetesLeaderRetrievalDriverFactory - Renames ZooKeeperMultipleComponentLeaderElectionHaServices into ZooKeeperLeaderElectionHaServices - Renames KubernetesMultipleComponentLeaderElectionHaServices into KubernetesLeaderElectionHaServices Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 06 July 2023, 18:39:24 UTC |
| 716aa11 | Matthias Pohl | 23 June 2023, 08:29:33 UTC | [FLINK-32419][runtime] Deletes obsolete/unused leader election related classes - Deletes LeaderElectionDriver- and LeaderElectionEventHandler-related classes - Deletes old zk-related classes/methods/interfaces - Deletes old k8s-related classes - Deletes MultipleComponentLeaderElection-related classes and interfaces | 06 July 2023, 18:39:24 UTC |
| cc80494 | Ferenc Csaky | 06 July 2023, 15:19:20 UTC | [FLINK-32391][yarn][test] Extend log whitelist for expected Akka shutdown WARN exception | 06 July 2023, 18:22:35 UTC |
| 58a849b | David Moravek | 06 July 2023, 13:43:09 UTC | [FLINK-31996] Chaining operators with different max parallelism prevents rescaling * [FLINK-31996][flink-streaming-java] Introduce a new opt-in flag that can disable the chaining of operators with different max parallelism, which prevents rescaling in some cases when the AdaptiveScheduler is being used. - We introduce the new `pipeline.operator-chaining.chain-operators-with-different-max-parallelism` flag to opt-in. - We deprecate the `pipeline.operator-chaining` flag and surpass it with `pipeline.operator-chaining.enabled` to provide a more consistent configuration experience. - The StreamingJobGraphGenerator and StreamGraphHasherV2 respect the new flag. | 06 July 2023, 13:43:09 UTC |
| 32044dd | Yuxin Tan | 05 July 2023, 07:01:22 UTC | [FLINK-31646][network] Implement the remote tier producer for the tiered storage | 06 July 2023, 12:42:06 UTC |
| b9d21f1 | Yuxin Tan | 05 July 2023, 06:58:57 UTC | [FLINK-31646][network] Implement SegmentPartitionFile for the tiered storage | 06 July 2023, 12:42:06 UTC |
| f789db3 | Yuxin Tan | 05 July 2023, 07:00:34 UTC | [hotfix][network] Simplify the fields in TieredInternalShuffleMaster | 06 July 2023, 12:42:06 UTC |
| 13d0900 | Yuxin Tan | 03 July 2023, 12:22:51 UTC | [hotfix][network] Remove partition file writer and reader for TierFactory#createProducerAgent | 06 July 2023, 12:42:06 UTC |
| 1fc3b37 | lincoln lee | 06 July 2023, 09:46:49 UTC | [FLINK-32501][table-planner] Fix wrong plan of a proctime window aggregation generated due to incorrect cost evaluation This closes #22918 | 06 July 2023, 09:46:49 UTC |
| d946eaa | lincoln lee | 06 July 2023, 09:44:07 UTC | [FLINK-30598][table-planner] Fix wrong code generated for WatermarkGenerator due to inconsistent source type info when deserialized from compiled plan This closes #22894 | 06 July 2023, 09:44:07 UTC |
| 9b8a01c | Chesnay Schepler | 06 July 2023, 09:08:29 UTC | Revert "[FLINK-32327][ci] Java 17 skips python tests" This reverts commit d11266ee10230c4602e2abd9d79eea40a870adb3. | 06 July 2023, 09:08:29 UTC |
| 0e44dcc | Dian Fu | 06 July 2023, 09:07:42 UTC | [FLINK-32544][python] Fix test_java_sql_ddl to works in JDK17 | 06 July 2023, 09:07:42 UTC |
| 08d0e6b | Matthias Pohl | 05 July 2023, 14:30:14 UTC | [hotfix][runtime] Adds shutdown logic for the watchExecutorService to the k8s HA services Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 06 July 2023, 06:31:31 UTC |
| a46cf26 | Matthias Pohl | 27 June 2023, 07:27:34 UTC | [hotfix][runtime] Reorganizes ZooKeeperUtils Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 06 July 2023, 06:31:31 UTC |
| e35a236 | Matthias Pohl | 26 June 2023, 15:23:59 UTC | [FLINK-32409][runtime] Removes MultipleComponentLeaderElectionService dependency Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 06 July 2023, 06:31:31 UTC |
| 38f4d13 | Chesnay Schepler | 05 July 2023, 15:58:14 UTC | [FLINK-31476] AdaptiveScheduler respects minimum parallelism | 05 July 2023, 15:58:14 UTC |
| e56e87e | Matthias Pohl | 26 June 2023, 12:53:05 UTC | [hotfix][test] Migrates EmbeddedLeaderServiceTest to JUnit5/AssertJ Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 05 July 2023, 15:50:50 UTC |
| 5dbbc69 | Matthias Pohl | 26 June 2023, 12:52:05 UTC | [FLINK-32421][test] Fixes testConcurrentRevokeLeadershipAndShutdown to test the actual functionality consistently Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 05 July 2023, 15:50:50 UTC |
| 5509c61 | cailiuyang | 16 June 2023, 07:58:24 UTC | [FLINK-32362] [connectors/common] increase the robustness of announceCombinedWatermark to cover the case task failover | 05 July 2023, 13:44:36 UTC |
| ec222ea | Bangui Dunn | 05 July 2023, 12:10:07 UTC | [FLINK-32388][filesystem]Add the ability to pass parameters to CUSTOM PartitionCommitPolicy (#22831) | 05 July 2023, 12:10:07 UTC |
| 7f34df4 | Dian Fu | 05 July 2023, 11:51:52 UTC | [FLINK-32536][python] Add java 17 add-opens/add-exports JVM arguments relates to DirectByteBuffer (#22955) | 05 July 2023, 11:51:52 UTC |
| 44e1397 | Sergey Nuyanzin | 05 July 2023, 09:40:28 UTC | [FLINK-32539][tests] Update violations as a result of FLINK-27415 changes | 05 July 2023, 09:40:28 UTC |
| 4bc408b | Weijie Guo | 03 July 2023, 10:31:22 UTC | [FLINK-32459][connector] Force set the parallelism of SocketTableSource to 1 | 05 July 2023, 04:30:01 UTC |
| db4b594 | Matthias Pohl | 22 June 2023, 07:19:23 UTC | [FLINK-31784][runtime] Adds multi-component support to DefaultLeaderElectionService Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 04 July 2023, 20:44:55 UTC |
| b60c154 | Matthias Pohl | 22 June 2023, 08:32:15 UTC | [hotfix][runtime] Adds JavaDoc and tests besides adding some additional utility methods Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 04 July 2023, 20:44:55 UTC |
| 0c37b5e | Matthias Pohl | 22 June 2023, 07:39:06 UTC | [hotfix][test] Makes DefaultLeaderElectionService being instantiated within the try context Signed-off-by: Matthias Pohl <matthias.pohl@aiven.io> | 04 July 2023, 20:44:55 UTC |
| 0015fd3 | Jia Liu | 04 July 2023, 18:35:58 UTC | [FLINK-27415][Connectors / FileSystem] Read empty csv file throws exception in FileSystem table connector (#20006) * [FLINK-27415][Connectors / FileSystem] Remove size limit, so `StreamFormatAdapter` can read empty files. --------- Co-authored-by: Weijie Guo <reswqa@163.com> | 04 July 2023, 18:35:58 UTC |
