https://github.com/apache/flink

sort by:
Revision Author Date Message Commit Date
a8c8b1c Commit for release 1.18.1 19 December 2023, 21:17:36 UTC
54fd94a [FLINK-33872] Retrieve checkpoint history for jobs in completed state 19 December 2023, 13:49:30 UTC
c53493e Fix NullArgumentException of getQuantile method in DescriptiveStatisticsHistogramStatistics (cherry picked from commit 5e1deeea19c2e73f3bc6f1f9881a778d13abf6a4) 19 December 2023, 13:37:16 UTC
ff1ef78 [FLINK-31650][metrics][rest] Remove transient metrics for subtasks in terminal state This closes #23447 19 December 2023, 12:42:04 UTC
0d6ab1d [FLINK-33531][python] Remove cython upper bounds Co-authored-by: HuangXingBo <hxb@apache.org> 18 December 2023, 22:14:17 UTC
8951f90 [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 [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 [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 [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 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 [FLINK-33693][checkpoint] Force aligned barrier works with timeoutable aligned checkpoint barrier 07 December 2023, 14:54:32 UTC
b3e3dce [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 [FLINK-33752][JUnit5 migration] Migrate TimeUtilsPrettyPrintingTest to Junit5 and Assertj 06 December 2023, 05:28:18 UTC
4ac3049 [docs][hotfix] Update AWS connector docs to v4.2 05 December 2023, 20:57:43 UTC
b3b7240 [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 [hotfix][docs] Aligns Chinese documentation with English version on Maven version 28 November 2023, 14:19:45 UTC
afa434d [FLINK-33501][ci] Makes use of Maven wrapper 28 November 2023, 14:19:45 UTC
e9548a6 [FLINK-33418][test] Uses getHost() 27 November 2023, 09:29:46 UTC
f6d0056 [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 [FLINK-33613][python] Port Beam DefaultJobBundleFactory class to flink-python module 24 November 2023, 10:20:49 UTC
6f30c6e [FLINK-33598][k8s] Watch HA configmap via name instead of lables to reduce pressure on APIserver 24 November 2023, 02:21:31 UTC
73273ae [FLINK-33225][python] Parse `JVM_ARGS` as an array This closes #23500. 22 November 2023, 12:30:09 UTC
dbbe4c1 [hotfix][python][docs] Fix broken syntax in Flink Table API query example This closes #23043. 22 November 2023, 12:21:48 UTC
c96095c [FLINK-32918][release] Generate reference data for state migration tests based on release-1.18.0 21 November 2023, 22:49:06 UTC
e469922 [FLINK-18356] Update CI image 21 November 2023, 14:35:04 UTC
2e86568 [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 [FLINK-33589][docs] Fix connector_artifact to prevent generation of broken layout 17 November 2023, 21:59:28 UTC
10bc438 [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 [hotfix] Add support for Scala suffixed in connector download links 16 November 2023, 13:15:41 UTC
0b9af32 [hotfix] Remove debug print line in connector artifact shortcode 16 November 2023, 12:45:39 UTC
c198706 [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 [FLINK-32922][docs] Update compatibility matrix for release 1.18 15 November 2023, 23:26:32 UTC
07067f3 [FLINK-32913][tests] Updates base version for japicmp check for 1.18.0 15 November 2023, 21:58:37 UTC
e53acef [FLINK-33276][ci] Merges connect_1 and connect_2 stages into a single one 15 November 2023, 17:33:49 UTC
f098049 [hotfix] Move permission fix to correct line 14 November 2023, 09:50:20 UTC
7475a17 [hotfix][docs] Fix git permission issue attempt 14 November 2023, 09:47:17 UTC
2844ea2 [FLINK-33529][python] Updated GET_SITE_PACKAGES_SCRIPT to include purelib This closes #23700. 14 November 2023, 02:51:35 UTC
0538ff3 [hotfix] Remove Kafka documentation for SQL/Table API, since this is now externalized 09 November 2023, 15:11:48 UTC
2409184 [FLINK-33474][runtime-web] fix undefined error of show plan in job submit page 07 November 2023, 12:14:50 UTC
68b49a3 [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 [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 [FLINK-32107][test] Adds retry to artifact downloads (#23637) Co-authored-by: yu <13485876233> 01 November 2023, 12:44:13 UTC
c7bd556 [hotfix][python] Fix Kafka csv example 01 November 2023, 09:27:37 UTC
7d83ffe [FLINK-26624][Runtime] Running HA (hashmap, async) end-to-end test failed on azu 31 October 2023, 13:31:34 UTC
013b337 [FLINK-33360][connector/common] Clean up finishedReaders after switch to next Enumerator This closes #23616. 31 October 2023, 07:20:52 UTC
371d9ab [FLINK-33369] Use Java 17 docker image for e2e tests on Java 17 27 October 2023, 13:04:39 UTC
358cfb6 [FLINK-33274][release] Add release note for version 1.18 26 October 2023, 05:58:04 UTC
ef950f8 [FLINK-33352][rest][docs] Add schema mappings to discriminator properties 25 October 2023, 08:49:37 UTC
8be1c87 [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 [FLINK-33342][ci] Adds target version to Java 17 CI build 24 October 2023, 11:26:14 UTC
1d17dc7 [FLINK-32671] Document Externalized Declararative Resource Management + minor Elastic Scaling page restructuring. 23 October 2023, 22:00:07 UTC
a85832f [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 [FLINK-33316][runtime] Avoid unnecessary heavy getStreamOperatorFactory This closes #23550. 23 October 2023, 02:48:42 UTC
7eedd42 [FLINK-33116][tests] Fix CliClientTest.testCancelExecutionInteractiveMode fails with NPE 20 October 2023, 10:49:38 UTC
2f66dd4 [FLINK-33291][build] Sets the enforced range for Maven and JDK within the release profile 20 October 2023, 10:24:37 UTC
9b83772 [FLINK-33223] MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan 10 October 2023, 06:42:52 UTC
70ee020 [FLINK-33000][sql-gateway] ResultFetcherTest should utilize TestExecutorExtension instead of using a ThreadFactory 05 October 2023, 04:38:26 UTC
4f11dfb [FLINK-33000][sql-gateway] OperationManagerTest should utilize TestExecutorExtension instead of using a ThreadFactory 05 October 2023, 04:38:26 UTC
5fbf5d5 [FLINK-33000][sql-gateway] SqlGatewayServiceITCase should utilize TestExecutorExtension instead of using a ThreadFactory 05 October 2023, 04:38:26 UTC
3659413 [hotfix][docs] Update KDA to MSF in vendor solutions docs 04 October 2023, 09:42:05 UTC
2c8207a [FLINK-33158] Cryptic exception when there is a StreamExecSort in JsonPlan 03 October 2023, 12:49:16 UTC
f4093fc [BP-1.18][FLINK-33149][build] Bump snappy to 1.1.10.4 27 September 2023, 14:00:59 UTC
deb07e9 [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 [FLINK-33050][docs] Add notice of data duplicates for RTAS in docs This closes #23448 22 September 2023, 01:47:24 UTC
11882e9 [FLINK-33050][table] Atomicity is not supported prompting the user to disable 21 September 2023, 03:28:16 UTC
2aeb998 [FLINK-32974][client] Avoid creating a new temporary directory every time for RestClusterClient This closes #23363 21 September 2023, 02:20:52 UTC
7997cf1 [FLINK-33044][network] Reduce the frequency of triggering flush for the disk tier of tiered storage 21 September 2023, 02:03:13 UTC
59368ae [hotfix][network] Flush writing buffers when closing HashSubpartitionBufferAccumulator of tiered storage 21 September 2023, 02:03:13 UTC
9c1318c [FLINK-15736][docs] Add Java compatibility page 20 September 2023, 20:07:27 UTC
6e13c60 [FLINK-33071][metrics,checkpointing] Log a json dump of checkpoint statistics when checkpoint completes or fails 15 September 2023, 11:37:04 UTC
dea458d [hotfix][network] Fix the bug of triggering disk writing in Hybrid Shuffle 15 September 2023, 09:52:19 UTC
9c96053 [hotfix][network] Optimize the backlog calculation logic in Hybrid Shuffle 15 September 2023, 09:52:19 UTC
0501d03 [FLINK-33088][network] Fix NullPointerException in RemoteTierConsumerAgent for tiered storage 15 September 2023, 09:35:51 UTC
206609e [FLINK-33086] Protect failure enrichment against unhandled exceptions Co-authored-by: Chesnay Schepler <chesnay@apache.org> 14 September 2023, 15:32:03 UTC
9e5659e [FLINK-32731][e2e] Fix NameNode uses port 9870 in hadoop3 This closes #23370 12 September 2023, 07:21:22 UTC
3dcdc7f [FLINK-32731][e2e] Add retry mechanism when fails to start the namenode (#23267) 12 September 2023, 07:21:22 UTC
73632fa [FLINK-30025][doc] improve the option description with more precise content (cherry picked from commit 3b9fcb5fd1060abd02d761eff767c6e2bead7046) 12 September 2023, 06:50:04 UTC
8ad22b8 [FLINK-33010][table] GREATEST/LEAST should work with other functions as input (#23393) 12 September 2023, 06:44:48 UTC
d100ab6 [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 [hotfix][network] Fix the close method for the tiered producer client 12 September 2023, 03:42:09 UTC
f2584a1 [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 [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 [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 [FLINK-31889][docs] Add documentation for implementing/loading enrichers 11 September 2023, 08:24:24 UTC
97d1166 [FLINK-32796][docs] Extend catalog store documentation (#23294) 10 September 2023, 21:32:33 UTC
184cfcd [FLINK-32796][table] Try to create catalog store path if not exists (#23293) 10 September 2023, 21:24:54 UTC
7f99a27 [FLINK-32962][python] Remove pip version check on installing dependencies. 08 September 2023, 11:08:14 UTC
69dd59c [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 [FLINK-28513] Fix Flink Table API CSV streaming sink throws 05 September 2023, 11:02:38 UTC
5a8d423 [FLINK-32996][Tests] Fix the CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails This closes #23331. 01 September 2023, 10:40:45 UTC
c4093b8 [FLINK-32909][dist]fix the bug of Pass arguments to jobmanager.sh failed (#23278) 01 September 2023, 09:17:27 UTC
534279e [FLINK-32821][examples] Add integrated tests for streaming examples (cherry picked from commit 3a44c1fbff1acf429f010d3f0fb06a6457727e16) 31 August 2023, 10:40:24 UTC
e21e362 [FLINK-32821][examples] Include flink-connector-datagen for streaming examples (cherry picked from commit 79f7bdbe6be973623e418a771588533bdef321b6) 31 August 2023, 10:40:24 UTC
eccae4b [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 [hotfix][doc] Fix wrong documentation of INSERT OVERWRITE statement for Hive dialect 31 August 2023, 07:56:42 UTC
ade9b5f [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 [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 [FlINK-32865][table-planner] Make ExecutionOrderEnforcer support OFCG This closes #23282 30 August 2023, 13:07:29 UTC
83915d9 [FlINK-32865][table-planner] Add ExecutionOrderEnforcer to exec plan and put it into BatchExecMultipleInput 30 August 2023, 13:07:29 UTC
6e4c2d1 [hotfix][network] Fix the notification of inaccurate data availability in Hybrid Shuffle 30 August 2023, 06:07:06 UTC
back to top