a8c8b1c | jingge | 19 December 2023, 21:17:36 UTC | Commit for release 1.18.1 | 19 December 2023, 21:17:36 UTC |
54fd94a | Hong Liang Teoh | 18 December 2023, 11:39:13 UTC | [FLINK-33872] Retrieve checkpoint history for jobs in completed state | 19 December 2023, 13:49:30 UTC |
c53493e | 朱通通 | 14 December 2023, 12:05:28 UTC | Fix NullArgumentException of getQuantile method in DescriptiveStatisticsHistogramStatistics (cherry picked from commit 5e1deeea19c2e73f3bc6f1f9881a778d13abf6a4) | 19 December 2023, 13:37:16 UTC |
ff1ef78 | Zhanghao Chen | 25 November 2023, 13:43:28 UTC | [FLINK-31650][metrics][rest] Remove transient metrics for subtasks in terminal state This closes #23447 | 19 December 2023, 12:42:04 UTC |
0d6ab1d | Sergey Nuyanzin | 18 December 2023, 22:14:17 UTC | [FLINK-33531][python] Remove cython upper bounds Co-authored-by: HuangXingBo <hxb@apache.org> | 18 December 2023, 22:14:17 UTC |
8951f90 | Martijn Visser | 18 December 2023, 08:05:00 UTC | [FLINK-33704][Filesytems] Update GCS filesystems to latest available versions. This closes #23935 * [FLINK-33704][Filesystem] Update GCS filesystem dependencies - Update GS SDK from 2.15.0 to 2.29.1 - Update GS Hadoop Connector from 2.2.15 to 2.2.18 - Update GS GRPC to highest shared version * [FLINK-33704] Make NOTICE inclusion of com.google.re2j for GCS consistent RE2J is listed for the other filesystems as Go license, we should remain consistent throughout the project (cherry picked from commit 492a886248208904276fcd2bda138a79c86bc71c) | 18 December 2023, 08:05:00 UTC |
d608181 | xuyang | 23 November 2023, 06:05:07 UTC | [FLINK-33541][table-planner] RAND and RAND_INTEGER should return type nullable if the arguments are nullable Close apache/flink#23779 | 15 December 2023, 15:19:42 UTC |
4379f2c | Thomas Weise | 08 December 2023, 18:49:04 UTC | [FLINK-25565][Formats][Parquet] write and read parquet int64 timestamp (#18304) (#23887) Co-authored-by: Bo Cui <cuibo0108@163.com> | 08 December 2023, 18:49:04 UTC |
265d817 | zoudan | 19 October 2023, 09:48:05 UTC | [FLINK-33313][table] Fix RexNodeExtractor#extractConjunctiveConditions throws an Exception when handle binary literal Close apache/flink#23551 | 08 December 2023, 08:57:45 UTC |
674d3a7 | Martijn Visser | 07 December 2023, 15:43:23 UTC | Revert "[FLINK-31835][table-planner] Fix the array type that can't be converted from the external primitive array" This reverts commit a6adbdda0cdf90635f0cd7a3427486bced301fbd. | 08 December 2023, 08:18:08 UTC |
3884f65 | Rui Fan | 01 December 2023, 08:04:36 UTC | [FLINK-33693][checkpoint] Force aligned barrier works with timeoutable aligned checkpoint barrier | 07 December 2023, 14:54:32 UTC |
b3e3dce | Rui Fan | 05 December 2023, 11:54:29 UTC | [FLINK-33752][Configuration] Change the displayed timeunit to day when the duration is an integral multiple of 1 day | 06 December 2023, 05:28:19 UTC |
6675de8 | Rui Fan | 05 December 2023, 11:48:54 UTC | [FLINK-33752][JUnit5 migration] Migrate TimeUtilsPrettyPrintingTest to Junit5 and Assertj | 06 December 2023, 05:28:18 UTC |
4ac3049 | Danny Cranmer | 30 November 2023, 10:47:48 UTC | [docs][hotfix] Update AWS connector docs to v4.2 | 05 December 2023, 20:57:43 UTC |
b3b7240 | Jiabao Sun | 29 November 2023, 01:48:34 UTC | [FLINK-31339][table][tests] Comparing with materialized result when mini-batch enabled to fix unstable sql e2e tests This closes #23816. | 29 November 2023, 01:48:34 UTC |
922df3d | Matthias Pohl | 09 November 2023, 15:21:14 UTC | [hotfix][docs] Aligns Chinese documentation with English version on Maven version | 28 November 2023, 14:19:45 UTC |
afa434d | Matthias Pohl | 06 November 2023, 17:10:14 UTC | [FLINK-33501][ci] Makes use of Maven wrapper | 28 November 2023, 14:19:45 UTC |
e9548a6 | Matthias Pohl | 01 November 2023, 17:08:23 UTC | [FLINK-33418][test] Uses getHost() | 27 November 2023, 09:29:46 UTC |
f6d0056 | Dian Fu | 24 November 2023, 07:03:16 UTC | [FLINK-33613][python] Make sure gRPC server is shutdown gracefully if Python process startup failed This closes #23789. | 24 November 2023, 10:20:53 UTC |
112b481 | Dian Fu | 24 November 2023, 06:46:35 UTC | [FLINK-33613][python] Port Beam DefaultJobBundleFactory class to flink-python module | 24 November 2023, 10:20:49 UTC |
6f30c6e | Yun Tang | 17 November 2023, 08:06:35 UTC | [FLINK-33598][k8s] Watch HA configmap via name instead of lables to reduce pressure on APIserver | 24 November 2023, 02:21:31 UTC |
73273ae | Deepyaman Datta | 09 October 2023, 17:17:06 UTC | [FLINK-33225][python] Parse `JVM_ARGS` as an array This closes #23500. | 22 November 2023, 12:30:09 UTC |
dbbe4c1 | Deepyaman Datta | 21 July 2023, 18:22:54 UTC | [hotfix][python][docs] Fix broken syntax in Flink Table API query example This closes #23043. | 22 November 2023, 12:21:48 UTC |
c96095c | Sergey Nuyanzin | 21 November 2023, 22:49:06 UTC | [FLINK-32918][release] Generate reference data for state migration tests based on release-1.18.0 | 21 November 2023, 22:49:06 UTC |
e469922 | Chesnay Schepler | 15 November 2023, 09:48:56 UTC | [FLINK-18356] Update CI image | 21 November 2023, 14:35:04 UTC |
2e86568 | Martijn Visser | 20 November 2023, 09:40:14 UTC | [hotfix] Set available Flink Cassandra connector for 1.18 to v3.1 There is no Flink 1.18 compatible version for the Cassandra connector yet, but the v3.1 at least has the indicator that there's no version available so it will correctly display the results. | 20 November 2023, 09:40:14 UTC |
077346f | Aleksandr Pilipenko | 17 November 2023, 18:30:36 UTC | [FLINK-33589][docs] Fix connector_artifact to prevent generation of broken layout | 17 November 2023, 21:59:28 UTC |
10bc438 | Xuyang | 17 November 2023, 02:06:43 UTC | [FLINK-33395][table-planner] Fix the join hint doesn't work when appears in subquery This closes #23716 (cherry picked from commit 1d08b8bf6a67c6a1874e8003868d5735248a7e45) | 17 November 2023, 02:06:43 UTC |
07eb5b4 | Martijn Visser | 16 November 2023, 13:15:41 UTC | [hotfix] Add support for Scala suffixed in connector download links | 16 November 2023, 13:15:41 UTC |
0b9af32 | Martijn Visser | 16 November 2023, 12:45:39 UTC | [hotfix] Remove debug print line in connector artifact shortcode | 16 November 2023, 12:45:39 UTC |
c198706 | MartijnVisser | 16 November 2023, 12:18:05 UTC | [FLINK-33567][Documentation] Only display connector download links if its available. This closes #23732 For all download displays, this performs an additional check if there's a connector release available for that specific Flink release. If not, it will display that there's no connector release yet available for that Flink version. (cherry picked from commit 39eddc9a7295718e5171d922fb9888efa543c0e9) | 16 November 2023, 12:18:05 UTC |
f0c7c97 | Sergey Nuyanzin | 15 November 2023, 23:26:32 UTC | [FLINK-32922][docs] Update compatibility matrix for release 1.18 | 15 November 2023, 23:26:32 UTC |
07067f3 | Sergey Nuyanzin | 15 November 2023, 21:58:37 UTC | [FLINK-32913][tests] Updates base version for japicmp check for 1.18.0 | 15 November 2023, 21:58:37 UTC |
e53acef | Matthias Pohl | 14 November 2023, 15:31:29 UTC | [FLINK-33276][ci] Merges connect_1 and connect_2 stages into a single one | 15 November 2023, 17:33:49 UTC |
f098049 | Chesnay Schepler | 14 November 2023, 09:50:20 UTC | [hotfix] Move permission fix to correct line | 14 November 2023, 09:50:20 UTC |
7475a17 | Chesnay Schepler | 01 November 2023, 15:58:01 UTC | [hotfix][docs] Fix git permission issue attempt | 14 November 2023, 09:47:17 UTC |
2844ea2 | Prabhu Joseph | 13 November 2023, 09:53:57 UTC | [FLINK-33529][python] Updated GET_SITE_PACKAGES_SCRIPT to include purelib This closes #23700. | 14 November 2023, 02:51:35 UTC |
0538ff3 | Martijn Visser | 11 October 2023, 09:50:31 UTC | [hotfix] Remove Kafka documentation for SQL/Table API, since this is now externalized | 09 November 2023, 15:11:48 UTC |
2409184 | Yu Chen | 07 November 2023, 06:01:29 UTC | [FLINK-33474][runtime-web] fix undefined error of show plan in job submit page | 07 November 2023, 12:14:50 UTC |
68b49a3 | fengjiajie | 07 November 2023, 01:42:53 UTC | [FLINK-33171][table-planner] Consistent implicit type coercion support for equal and non-equal comparisons for codegen This closes #23669 | 07 November 2023, 01:42:53 UTC |
c086624 | Wencong Liu | 06 September 2023, 02:41:21 UTC | [FLINK-33041][docs] Add an article in English website to guide users to migrate their DataSet jobs to DataStream This closes #23362 | 02 November 2023, 08:17:33 UTC |
dc86179 | yuxiang | 01 November 2023, 12:44:13 UTC | [FLINK-32107][test] Adds retry to artifact downloads (#23637) Co-authored-by: yu <13485876233> | 01 November 2023, 12:44:13 UTC |
c7bd556 | Dian Fu | 01 November 2023, 09:26:49 UTC | [hotfix][python] Fix Kafka csv example | 01 November 2023, 09:27:37 UTC |
7d83ffe | yu | 31 October 2023, 02:48:08 UTC | [FLINK-26624][Runtime] Running HA (hashmap, async) end-to-end test failed on azu | 31 October 2023, 13:31:34 UTC |
013b337 | fengjiajie | 31 October 2023, 07:20:52 UTC | [FLINK-33360][connector/common] Clean up finishedReaders after switch to next Enumerator This closes #23616. | 31 October 2023, 07:20:52 UTC |
371d9ab | Chesnay Schepler | 27 October 2023, 08:23:42 UTC | [FLINK-33369] Use Java 17 docker image for e2e tests on Java 17 | 27 October 2023, 13:04:39 UTC |
358cfb6 | jingge | 16 October 2023, 10:30:40 UTC | [FLINK-33274][release] Add release note for version 1.18 | 26 October 2023, 05:58:04 UTC |
ef950f8 | Chesnay Schepler | 24 October 2023, 14:36:10 UTC | [FLINK-33352][rest][docs] Add schema mappings to discriminator properties | 25 October 2023, 08:49:37 UTC |
8be1c87 | Matthias Pohl | 24 October 2023, 07:55:43 UTC | [FLINK-33346][runtime][test] Removes timeout The instability is caused by the timeout. The fatal error hides the actual cause (i.e. the TimeoutException). It can be reproduced by setting the timeout of the test to 0ms. The actual cause is revealed when disabling the fatal error handling or not throwing a AssertionError in case of the fatal error. | 25 October 2023, 07:38:21 UTC |
dc5bc81 | Matthias Pohl | 23 October 2023, 13:43:20 UTC | [FLINK-33342][ci] Adds target version to Java 17 CI build | 24 October 2023, 11:26:14 UTC |
1d17dc7 | David Moravek | 23 October 2023, 10:22:12 UTC | [FLINK-32671] Document Externalized Declararative Resource Management + minor Elastic Scaling page restructuring. | 23 October 2023, 22:00:07 UTC |
a85832f | MartijnVisser | 23 October 2023, 06:29:02 UTC | [FLINK-33238][Formats/Avro] Upgrade used AVRO version to 1.11.3. This closes #23559 Mitigate scanners flagging Flink as vulnerable for CVE-2023-39410 Co-authored-by: AndreiLeib <andrei.leibovski@appdirect.com> | 23 October 2023, 06:29:02 UTC |
0dd3b4c | Rui Fan | 19 October 2023, 12:38:15 UTC | [FLINK-33316][runtime] Avoid unnecessary heavy getStreamOperatorFactory This closes #23550. | 23 October 2023, 02:48:42 UTC |
7eedd42 | Jiabao Sun | 12 October 2023, 06:58:44 UTC | [FLINK-33116][tests] Fix CliClientTest.testCancelExecutionInteractiveMode fails with NPE | 20 October 2023, 10:49:38 UTC |
2f66dd4 | Matthias Pohl | 17 October 2023, 13:23:15 UTC | [FLINK-33291][build] Sets the enforced range for Maven and JDK within the release profile | 20 October 2023, 10:24:37 UTC |
9b83772 | Dawid Wysakowicz | 09 October 2023, 14:39:51 UTC | [FLINK-33223] MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan | 10 October 2023, 06:42:52 UTC |
70ee020 | Jiabao Sun | 21 September 2023, 09:55:51 UTC | [FLINK-33000][sql-gateway] ResultFetcherTest should utilize TestExecutorExtension instead of using a ThreadFactory | 05 October 2023, 04:38:26 UTC |
4f11dfb | Jiabao Sun | 21 September 2023, 09:43:38 UTC | [FLINK-33000][sql-gateway] OperationManagerTest should utilize TestExecutorExtension instead of using a ThreadFactory | 05 October 2023, 04:38:26 UTC |
5fbf5d5 | Jiabao Sun | 21 September 2023, 07:30:45 UTC | [FLINK-33000][sql-gateway] SqlGatewayServiceITCase should utilize TestExecutorExtension instead of using a ThreadFactory | 05 October 2023, 04:38:26 UTC |
3659413 | Danny Cranmer | 03 October 2023, 07:41:27 UTC | [hotfix][docs] Update KDA to MSF in vendor solutions docs | 04 October 2023, 09:42:05 UTC |
2c8207a | Dawid Wysakowicz | 26 September 2023, 10:38:07 UTC | [FLINK-33158] Cryptic exception when there is a StreamExecSort in JsonPlan | 03 October 2023, 12:49:16 UTC |
f4093fc | Ryan Skraba | 25 September 2023, 08:21:23 UTC | [BP-1.18][FLINK-33149][build] Bump snappy to 1.1.10.4 | 27 September 2023, 14:00:59 UTC |
deb07e9 | yuxia Luo | 22 September 2023, 08:28:17 UTC | [FLINK-33119][table] The pojo result returned be procedure should be Row of fields in the pojo instead of whole pojo object (#23450) | 22 September 2023, 08:28:17 UTC |
78b0b7b | Tartarus0zm | 21 September 2023, 03:28:45 UTC | [FLINK-33050][docs] Add notice of data duplicates for RTAS in docs This closes #23448 | 22 September 2023, 01:47:24 UTC |
11882e9 | Tartarus0zm | 21 September 2023, 03:28:16 UTC | [FLINK-33050][table] Atomicity is not supported prompting the user to disable | 21 September 2023, 03:28:16 UTC |
2aeb998 | Lijie Wang | 20 September 2023, 04:04:25 UTC | [FLINK-32974][client] Avoid creating a new temporary directory every time for RestClusterClient This closes #23363 | 21 September 2023, 02:20:52 UTC |
7997cf1 | Yuxin Tan | 15 September 2023, 02:32:34 UTC | [FLINK-33044][network] Reduce the frequency of triggering flush for the disk tier of tiered storage | 21 September 2023, 02:03:13 UTC |
59368ae | Yuxin Tan | 15 September 2023, 02:31:51 UTC | [hotfix][network] Flush writing buffers when closing HashSubpartitionBufferAccumulator of tiered storage | 21 September 2023, 02:03:13 UTC |
9c1318c | Chesnay Schepler | 20 September 2023, 20:07:04 UTC | [FLINK-15736][docs] Add Java compatibility page | 20 September 2023, 20:07:27 UTC |
6e13c60 | Piotr Nowojski | 11 September 2023, 16:30:10 UTC | [FLINK-33071][metrics,checkpointing] Log a json dump of checkpoint statistics when checkpoint completes or fails | 15 September 2023, 11:37:04 UTC |
dea458d | Yuxin Tan | 11 September 2023, 12:56:51 UTC | [hotfix][network] Fix the bug of triggering disk writing in Hybrid Shuffle | 15 September 2023, 09:52:19 UTC |
9c96053 | Wencong Liu | 11 September 2023, 01:56:50 UTC | [hotfix][network] Optimize the backlog calculation logic in Hybrid Shuffle | 15 September 2023, 09:52:19 UTC |
0501d03 | Yuxin Tan | 14 September 2023, 07:51:41 UTC | [FLINK-33088][network] Fix NullPointerException in RemoteTierConsumerAgent for tiered storage | 15 September 2023, 09:35:51 UTC |
206609e | Panagiotis Garefalakis | 14 September 2023, 02:07:25 UTC | [FLINK-33086] Protect failure enrichment against unhandled exceptions Co-authored-by: Chesnay Schepler <chesnay@apache.org> | 14 September 2023, 15:32:03 UTC |
9e5659e | Shengkai | 07 September 2023, 09:55:31 UTC | [FLINK-32731][e2e] Fix NameNode uses port 9870 in hadoop3 This closes #23370 | 12 September 2023, 07:21:22 UTC |
3dcdc7f | Shengkai | 28 August 2023, 01:38:20 UTC | [FLINK-32731][e2e] Add retry mechanism when fails to start the namenode (#23267) | 12 September 2023, 07:21:22 UTC |
73632fa | jingge | 07 September 2023, 20:33:11 UTC | [FLINK-30025][doc] improve the option description with more precise content (cherry picked from commit 3b9fcb5fd1060abd02d761eff767c6e2bead7046) | 12 September 2023, 06:50:04 UTC |
8ad22b8 | Sergey Nuyanzin | 12 September 2023, 06:44:48 UTC | [FLINK-33010][table] GREATEST/LEAST should work with other functions as input (#23393) | 12 September 2023, 06:44:48 UTC |
d100ab6 | Yuxin Tan | 22 August 2023, 07:34:52 UTC | [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer This closes #23255 | 12 September 2023, 03:42:10 UTC |
ae647e2 | Yuxin Tan | 14 August 2023, 11:45:34 UTC | [hotfix][network] Fix the close method for the tiered producer client | 12 September 2023, 03:42:09 UTC |
f2584a1 | yunhong | 12 September 2023, 03:08:48 UTC | [FLINK-33063][table-runtime] Fix udaf with complex user defined pojo object throw error while generate record equaliser (#23388) Co-authored-by: zhengyunhong.zyh <zhengyunhong.zyh@alibaba-inc.com> | 12 September 2023, 03:08:48 UTC |
f66679b | yunhong | 12 September 2023, 03:07:23 UTC | [FLINK-32952][table-planner] Fix scan reuse with readable metadata and watermark push down get wrong watermark error (#23338) Co-authored-by: zhengyunhong.zyh <zhengyunhong.zyh@alibaba-inc.com> | 12 September 2023, 03:07:23 UTC |
53981d8 | Ferenc Csaky | 11 September 2023, 20:07:31 UTC | [FLINK-32999][connectors/hbase] Remove HBase connector code from main repo (#23343) --------- Co-authored-by: Sergey Nuyanzin <sergey.nuyanzin@aiven.io> | 11 September 2023, 20:07:31 UTC |
7339a53 | Panagiotis Garefalakis | 24 April 2023, 02:07:20 UTC | [FLINK-31889][docs] Add documentation for implementing/loading enrichers | 11 September 2023, 08:24:24 UTC |
97d1166 | Ferenc Csaky | 10 September 2023, 21:32:33 UTC | [FLINK-32796][docs] Extend catalog store documentation (#23294) | 10 September 2023, 21:32:33 UTC |
184cfcd | Ferenc Csaky | 10 September 2023, 21:24:54 UTC | [FLINK-32796][table] Try to create catalog store path if not exists (#23293) | 10 September 2023, 21:24:54 UTC |
7f99a27 | Aleksandr Pilipenko | 25 August 2023, 20:37:00 UTC | [FLINK-32962][python] Remove pip version check on installing dependencies. | 08 September 2023, 11:08:14 UTC |
69dd59c | Feng Jin | 06 September 2023, 01:33:50 UTC | [FLINK-32475][docs] Add doc for time travel (#23109) (#23346) Co-authored-by: luoyuxia <luoyuxia@alumni.sjtu.edu.cn> | 06 September 2023, 01:33:50 UTC |
2437cf5 | Samrat002 | 04 September 2023, 11:35:55 UTC | [FLINK-28513] Fix Flink Table API CSV streaming sink throws | 05 September 2023, 11:02:38 UTC |
5a8d423 | JiangXin | 01 September 2023, 10:38:22 UTC | [FLINK-32996][Tests] Fix the CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails This closes #23331. | 01 September 2023, 10:40:45 UTC |
c4093b8 | wuqqq | 01 September 2023, 09:17:27 UTC | [FLINK-32909][dist]fix the bug of Pass arguments to jobmanager.sh failed (#23278) | 01 September 2023, 09:17:27 UTC |
534279e | Zhanghao Chen | 28 August 2023, 13:53:55 UTC | [FLINK-32821][examples] Add integrated tests for streaming examples (cherry picked from commit 3a44c1fbff1acf429f010d3f0fb06a6457727e16) | 31 August 2023, 10:40:24 UTC |
e21e362 | Zhanghao Chen | 14 August 2023, 11:36:31 UTC | [FLINK-32821][examples] Include flink-connector-datagen for streaming examples (cherry picked from commit 79f7bdbe6be973623e418a771588533bdef321b6) | 31 August 2023, 10:40:24 UTC |
eccae4b | Zhanghao Chen | 26 August 2023, 11:52:30 UTC | [hotfix][flink-examples] Fix wrong filtering and remove Scala version suffix for state-machine example pom (cherry picked from commit ad6aa56004deb70ef65fded2d2972dfc936a77eb) | 31 August 2023, 10:40:24 UTC |
32743e1 | luoyuxia | 28 August 2023, 12:14:38 UTC | [hotfix][doc] Fix wrong documentation of INSERT OVERWRITE statement for Hive dialect | 31 August 2023, 07:56:42 UTC |
ade9b5f | luoyuxia | 28 August 2023, 12:04:51 UTC | [FLINK-32982][doc] Not to suggest to swap flink-table-planner lib for using Hive dialect This closes #23324 | 31 August 2023, 07:56:41 UTC |
5ec31f1 | Matthias Pohl | 30 August 2023, 07:55:09 UTC | [FLINK-32994][runtime] Adds proper toString() implementations to the LeaderElectionDriver implementations to have human-readable versions of the driver in log messages | 31 August 2023, 07:25:19 UTC |
94ba97a | Lijie Wang | 24 August 2023, 08:02:32 UTC | [FlINK-32865][table-planner] Make ExecutionOrderEnforcer support OFCG This closes #23282 | 30 August 2023, 13:07:29 UTC |
83915d9 | Lijie Wang | 24 August 2023, 07:47:11 UTC | [FlINK-32865][table-planner] Add ExecutionOrderEnforcer to exec plan and put it into BatchExecMultipleInput | 30 August 2023, 13:07:29 UTC |
6e4c2d1 | Wencong Liu | 24 August 2023, 04:08:42 UTC | [hotfix][network] Fix the notification of inaccurate data availability in Hybrid Shuffle | 30 August 2023, 06:07:06 UTC |