| cb26108 | huangxingbo | 13 September 2022, 11:28:39 UTC | Commit for release 1.16.0 | 13 September 2022, 11:28:39 UTC |
| 30d6e61 | Chesnay Schepler | 01 February 2022, 14:10:37 UTC | [FLINK-25868][build] Enable japicmp for all modules | 13 September 2022, 09:58:52 UTC |
| 72da618 | Chesnay Schepler | 31 August 2022, 14:27:17 UTC | [FLINK-25868][build] Use custom japicmp plugin version | 13 September 2022, 09:58:52 UTC |
| 84d9e21 | Chesnay Schepler | 01 February 2022, 14:09:19 UTC | [FLINK-25868][build] Disable japicmp in packaging/e2e modules Optimize build times and reduce noise (warnings would be printed as these modules are not being deployed, so the previous versions can not be found). | 13 September 2022, 09:58:52 UTC |
| 414d389 | Chesnay Schepler | 01 February 2022, 14:08:05 UTC | [FLINK-25868][build] Limit japicmp to jar modules Skips quickstart and pom modules. | 13 September 2022, 09:58:52 UTC |
| 438edde | Weijie Guo | 09 September 2022, 06:23:16 UTC | [FLINK-29238] Wrong index information will be obtained after the downstream failover in hybrid full mode This closes #20796 | 13 September 2022, 09:02:28 UTC |
| efc9eb7 | Weijie Guo | 09 September 2022, 07:42:51 UTC | [hotfix] Avoid possible deadlock in SubpartitionView and FileDataManager. | 13 September 2022, 09:02:20 UTC |
| ef5941e | Matthias Pohl | 12 September 2022, 09:35:44 UTC | [FLINK-29253][runtime] Removes synchronous close call from DefaultJobManagerRunnerRegistry#localCleanupAsync localCleanupAsync is meant to be called from the Dispatcher's main thread. Any blocking calls should be avoided here. Instead, we could use closeAsync which is implemented by JobManagerRunner. Two additional tests needed to be touched because the previously used AutoCloseableAsync#close method added another FlinKException to the Stacktrace. | 13 September 2022, 07:10:50 UTC |
| a342e7f | Martijn Visser | 12 September 2022, 13:51:40 UTC | Revert "[FLINK-19869][connectors/jdbc] Add support for postgres UUID type" This reverts commit 6aeb91ef0b4abcde0c3e9f561f1e8b849976ec50. | 13 September 2022, 06:16:32 UTC |
| 4ed1ef3 | Steven van Rossum | 08 September 2022, 10:19:01 UTC | [hotfix][python] Fix typo in PyFlink's JsonRowDeserializationSchema This closes #20788. | 13 September 2022, 02:49:10 UTC |
| dbcf949 | Qingsheng Ren | 06 September 2022, 09:01:45 UTC | [FLINK-29153][connector/kafka] Retry KafkaConsumer#commitAsync on WakeupException in KafkaConsumerThread KafkaConsumerThread makes a wakeup on the KafkaConsumer on offset commit to wakeup the potential blocking KafkaConsumer.poll(). However the wakeup might happen when the consumer is not polling. The wakeup will be remembered by the consumer and re-examined while committing the offset asynchronously, which leads to an unnecessary WakeupException. | 13 September 2022, 02:19:42 UTC |
| 3035a8e | snuyanzin | 08 September 2022, 07:24:39 UTC | [FLINK-29223][coordination] Add missing output info for jobs already reached terminal state | 12 September 2022, 12:16:50 UTC |
| 357221b | xuyang | 29 August 2022, 07:12:36 UTC | [FLINK-29120][table-planner] Avoid join hint propagating into view This closes #20697 (cherry picked from commit 6722c89d0df35643dde38c1b8f096aa785579884) | 10 September 2022, 02:45:45 UTC |
| 3cc2f5b | yunfengzhou-hub | 10 September 2022, 02:39:51 UTC | [FLINK-29217][tests] Guarantee checkpoint order in OC test This closes #20780. | 10 September 2022, 02:39:51 UTC |
| d09f3eb | Chesnay Schepler | 09 September 2022, 09:39:42 UTC | [FLINK-29211][hive][legal] Update 2.3.9 NOTICE | 09 September 2022, 09:40:05 UTC |
| 7750058 | wenbingshen | 09 September 2022, 09:04:11 UTC | [FLINK-29207][pulsar][BP-1.16] Fix Pulsar message eventTime may be incorrectly set to a negative number (#20798) | 09 September 2022, 09:04:11 UTC |
| 1c65409 | huangxingbo | 09 September 2022, 03:30:18 UTC | [hotfix] Fix the missing comma in config.toml | 09 September 2022, 03:30:18 UTC |
| 77574b7 | lincoln lee | 06 September 2022, 08:58:08 UTC | [FLINK-28787][table-planner] Rename getUniqueKeys to getUpsertKeys in CommonPhysicalJoin This closes #20763 (cherry picked from commit 347316ea6394b24c4471aa8616f2632e126f733d) | 09 September 2022, 02:47:09 UTC |
| 4dad2e2 | Gen Luo | 01 September 2022, 09:08:53 UTC | [FLINK-29132][rest] Cleanup subtask attempt metrics according to the JobDetails to avoid memory leak. This closes #20733. | 08 September 2022, 12:57:31 UTC |
| 219b78d | Shengkai | 06 September 2022, 09:12:17 UTC | [FLINK-29184][sql-gateway] Close resource manager when closing Session | 08 September 2022, 11:39:44 UTC |
| c8e75d2 | yuzelin | 31 August 2022, 05:42:03 UTC | [FLINK-29118][sql-gateway][hive] Remove default GenericInMemoryCatalog in the HiveServer2 Endpoint when openSession This closes #20714 | 08 September 2022, 11:39:44 UTC |
| f599a8c | sxnan | 09 August 2022, 13:07:17 UTC | [FLINK-28860][runtime] JobMaster wait for partition promote before close | 08 September 2022, 03:21:00 UTC |
| 7d13918 | sxnan | 17 August 2022, 05:39:45 UTC | [hotfix][datastream] Fix cache invalidate with remote session cluster | 08 September 2022, 03:21:00 UTC |
| 4ada919 | sxnan | 09 August 2022, 10:08:19 UTC | [FLINK-28860][datastream] Cache consumption in stream mode recompute result in case of cache miss | 08 September 2022, 03:21:00 UTC |
| 3808823 | Jark Wu | 06 September 2022, 11:50:02 UTC | [FLINK-29096][table] Keep backward compatibility of JdbcCatalog constructor | 07 September 2022, 02:33:50 UTC |
| b8517a1 | fengli | 29 August 2022, 12:18:20 UTC | [FLINK-29074][Connectors/JDBC] Fix ClassNotFound exception when using jdbc connector by add jar syntax This closes #20707 | 07 September 2022, 02:33:42 UTC |
| 3760a37 | fengli | 29 August 2022, 12:10:53 UTC | [fixup][table-planner] Using user classloader instead of thread context classloader | 07 September 2022, 02:33:29 UTC |
| b0830ce | Danny Cranmer | 06 September 2022, 12:14:39 UTC | [FLINK-29205][connectors/kinesis] Passthrough use config to HTTP client when constructing Async Client for Kinesis EFO | 06 September 2022, 15:58:37 UTC |
| 37bcc5b | yunfengzhou-hub | 06 September 2022, 13:36:59 UTC | [FLINK-28941][Runtime/Checkpointing] Add concurrent checkpoint support in Operator Coordinator This closes #20754. | 06 September 2022, 13:36:59 UTC |
| f07df68 | Jark Wu | 06 September 2022, 10:04:17 UTC | [FLINK-28897][runtime] Fix bug of failed to generate JobGraph when using UDF and enable checkpoint This closes #20761 | 06 September 2022, 10:04:17 UTC |
| e22bfd5 | huangxingbo | 06 September 2022, 04:04:33 UTC | [FLINK-29196][python] Update flink-python NOTICE This closes #20758. | 06 September 2022, 09:21:45 UTC |
| 905a965 | Ron | 06 September 2022, 09:18:51 UTC | [FLINK-29022][docs][table] Add document for CREATE FUNCTION USING JAR feature (#20628) | 06 September 2022, 09:19:22 UTC |
| 5ea9cc1 | yuxia Luo | 05 September 2022, 13:10:08 UTC | [FLINK-27718][hive] Fix fail to count mutiple fields excpetion in Hive dialect (#19406) | 05 September 2022, 13:11:05 UTC |
| 3c6e11e | yuxia Luo | 05 September 2022, 09:11:36 UTC | [FLINK-29013][hive] Fix fail to use BinaryRecordReader in "transform using" syntax with Hive dialect (#20643) | 05 September 2022, 09:33:45 UTC |
| 6c3de76 | huangxingbo | 29 August 2022, 11:41:40 UTC | [FLINK-28429][python] Upgrade the version of grpcio-tools This closes #20685. | 05 September 2022, 07:02:10 UTC |
| 5737b45 | huangxingbo | 29 August 2022, 03:17:39 UTC | [FLINK-28429][python] Skip cython test on python-only-PRs This closes #20685. | 05 September 2022, 07:01:51 UTC |
| 79c0b1f | huangxingbo | 22 August 2022, 02:15:30 UTC | [FLINK-28429][python] Optimize PyFlink tests This closes #20685. | 05 September 2022, 07:01:36 UTC |
| 6191a04 | huangxingbo | 19 August 2022, 07:41:38 UTC | [FLINK-28429][python] Remove the warnings in the Python tests This closes #20685. | 05 September 2022, 07:01:11 UTC |
| c049171 | yuxia Luo | 05 September 2022, 04:22:31 UTC | [FLINK-27017][hive] Fix divide by zero exception with Hive dialect (#19216) | 05 September 2022, 04:27:00 UTC |
| bf3896b | huangxingbo | 05 September 2022, 02:29:06 UTC | Update for 1.16.0 | 05 September 2022, 02:29:06 UTC |
| 4b15bc9 | lincoln.lil | 24 August 2022, 10:00:09 UTC | [FLINK-29091][table-planner] Fix the determinism declaration of the rand function to be consistent with the current behavior This closes #20674 | 04 September 2022, 13:31:02 UTC |
| 72f0cb6 | zhengyunhong.zyh | 09 August 2022, 08:40:10 UTC | [FLINK-28858][docs] Add document to describe join hints for batch sql This closes #20513 | 04 September 2022, 13:17:21 UTC |
| 121e63e | Brayno | 02 September 2022, 09:03:36 UTC | [FLINK-29180] fix: show subtask metrics as default in vertex detail (#20737) | 02 September 2022, 09:03:36 UTC |
| 6987224 | lincoln lee | 26 August 2022, 08:30:55 UTC | [FLINK-29112][table-planner] Print the lookup join hint on the node in the original RelNode tree for easier debugging This closes #20686 | 02 September 2022, 07:56:09 UTC |
| bbe9690 | lincoln lee | 15 August 2022, 10:11:47 UTC | [FLINK-28971][docs] Adds user documentation for the new LOOKUP hint This closes #20577 | 02 September 2022, 07:33:29 UTC |
| 20e00fd | Smirnov Alexander | 01 September 2022, 05:30:20 UTC | [FLINK-28948][table] Increase test coverage for lookup full caching + fix metrics | 01 September 2022, 16:43:41 UTC |
| 655184c | Matthias Pohl | 29 August 2022, 12:48:38 UTC | [FLINK-28078][tests] Mitigate likelihood to run into test stability issues caused by CURATOR-645 CURATOR-645 covers a bug in the LeaderLatch implementation that causes a race condition if a child node, participating in the leader election, is removed too fast. This results in a different code branch being executed which triggers a reset of the LeaderLatch instead of re-collecting the children to determine the next leader. The issue occurs because LeaderLatch#checkLeadership is not executed transactionally, i.e. retrieving the children and setting up the watcher for the predecessor is not done atomically. This leads to the race condition where a children (the previous leader's node) is removed before setting up the watcher which results in an invalid handling of the situation using reset. Adding some sleep here (simulating the leader actually doing something) will reduce the risk of falling into the race condition because it will give the concurrently running LeaderLatch instances more time to set up the watchers properly. This is only meant as a temporary solution until CURATOR-645 is resolved and the curator dependency on the Flink side is upgraded. | 01 September 2022, 12:39:16 UTC |
| 5c8db12 | Sergey Nuyanzin | 01 September 2022, 11:59:00 UTC | [hotfix][csv][javadoc] Fix reference | 01 September 2022, 11:59:00 UTC |
| 87cbea3 | Metehan Yıldırım | 01 September 2022, 08:46:53 UTC | [hotfix][docs] Fix typo | 01 September 2022, 08:46:53 UTC |
| a9c94e0 | huangxingbo | 01 September 2022, 02:51:17 UTC | [FLINK-29161][tests] Fix the built docker image name | 01 September 2022, 08:37:13 UTC |
| 8b8245b | Weijie Guo | 19 August 2022, 10:51:19 UTC | [FLINK-29053] Hybrid shuffle has concurrent modification of buffer when compression is enabled This closes #20647 | 01 September 2022, 03:34:56 UTC |
| 2e2fb24 | lincoln lee | 01 September 2022, 02:04:08 UTC | [FLINK-29138][table-planner] fix project can not be pushed into lookup source This closes #20717 | 01 September 2022, 02:04:08 UTC |
| 5590205 | Wencong Liu | 30 August 2022, 03:40:30 UTC | [FLINK-28974][sql-gateway]Add doc for the API and Option of sql gateway rest endpoint This closes #20622 | 01 September 2022, 01:47:47 UTC |
| 8ccbf3b | Wencong Liu | 30 August 2022, 03:42:59 UTC | [hotfix][doc]Update doc of REST API in runtime module | 01 September 2022, 01:47:47 UTC |
| 549d432 | Shengkai | 29 August 2022, 10:14:47 UTC | [FLINK-28938][hive] Improve error messages for unsupported interfaces | 31 August 2022, 11:25:06 UTC |
| 6630ce7 | luoyuxia | 23 August 2022, 04:33:03 UTC | [FLINK-28938][hive] Fix HiveServer2 Endpoint can not set variable correctly | 31 August 2022, 11:25:06 UTC |
| 4411978 | Sergey Nuyanzin | 31 August 2022, 10:11:57 UTC | [hotfix][tests] Replace deprecated AbstractThrowableAssert#getRootCause | 31 August 2022, 10:11:57 UTC |
| a377d0d | Ron Cohen | 31 August 2022, 09:49:20 UTC | [hotfix][docs] List FileSystem also as a source | 31 August 2022, 09:49:20 UTC |
| c0f0807 | Ryan Skraba | 31 August 2022, 08:56:16 UTC | [FLINK-24718] Update Avro dependency to 1.11.1 | 31 August 2022, 08:56:16 UTC |
| 581e1fe | Yun Tang | 29 August 2022, 12:49:33 UTC | [FLINK-29130][state] Correct the doc description of local-recovery | 31 August 2022, 08:27:08 UTC |
| 2798565 | fengli | 18 August 2022, 11:26:53 UTC | [FLINK-29019][doc][parquet] Updating parquet format document that support read complex type | 31 August 2022, 08:14:04 UTC |
| fc5730a | yuxia Luo | 31 August 2022, 05:39:34 UTC | [FLINK-26474][hive] Fold exprNode to fix the issue of failing to call some hive udf required constant parameters with implicit constant passed This closes #18975 | 31 August 2022, 05:39:34 UTC |
| 00f5852 | Kai Chen | 31 August 2022, 04:09:19 UTC | [FLINK-29005][parquet] Parquet row type reader should not return null value when some child fields is null This closes #20616 | 31 August 2022, 04:09:19 UTC |
| d55be68 | Xuyang | 31 August 2022, 01:43:25 UTC | [FLINK-29087][connector/jdbc] Change dependencies order to avoid compile failure while running in idea This closes #20670. | 31 August 2022, 01:43:25 UTC |
| 2220f24 | Aitozi | 30 August 2022, 12:30:42 UTC | [FLINK-28751][table] Improve the performance of JSON functions with json path (#20397) | 30 August 2022, 12:30:42 UTC |
| c376430 | pvary | 30 August 2022, 12:15:10 UTC | [FLINK-29123][k8s] Dynamic paramters are not pushed to working with kubernetes | 30 August 2022, 12:15:10 UTC |
| b3dcafa | Chengkai Yang | 03 July 2022, 14:44:47 UTC | [FLINK-28121][docs-zh]Translate "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page | 30 August 2022, 11:21:54 UTC |
| 7669daf | Sergey Nuyanzin | 04 August 2022, 12:42:26 UTC | [FLINK-28814][Connectors][JDBC] Update org.postgresql:postgresql to 42.4.1 | 30 August 2022, 09:17:15 UTC |
| a1d74c1 | lincoln.lil | 29 August 2022, 09:27:34 UTC | [FLINK-29038][runtime] Fix unstable case AsyncWaitOperatorTest#testProcessingTimeRepeatedCompleteOrderedWithRetry This closes #20702. | 30 August 2022, 02:45:57 UTC |
| d9bcbff | Yufan Sheng | 30 August 2022, 02:31:36 UTC | [FLINK-28609][Connector/Pulsar] PulsarSchema didn't get properly serialized. (#20698) | 30 August 2022, 02:31:36 UTC |
| e18782f | Wencong Liu | 25 August 2022, 04:50:25 UTC | [FLINK-29097][sql-gateway] Move json se/deserializers from sql-gateway-api to sql-gateway This closes #20678 | 30 August 2022, 01:42:03 UTC |
| d0434e6 | Chesnay Schepler | 29 August 2022, 11:31:05 UTC | [hotfix][tests] Minor cleanup | 29 August 2022, 15:13:23 UTC |
| aa3c124 | Chesnay Schepler | 29 August 2022, 11:28:25 UTC | [FLINK-27030][tests] Prevent race-condition | 29 August 2022, 15:13:23 UTC |
| 7ac37c0 | jiabao.sun | 22 August 2022, 12:35:41 UTC | [FLINK-29062][build] Fix protobuf plugin proxy issue on flink-protobuf module. | 29 August 2022, 14:11:22 UTC |
| d61a7a9 | Chesnay Schepler | 29 August 2022, 13:07:14 UTC | [hotfix][tests] Nicer migration path for typo fix | 29 August 2022, 13:07:14 UTC |
| e246a05 | Shengkai | 29 August 2022, 02:22:59 UTC | [FLINK-29121][sql-gateway] Fix failed SqlGatewayRestAPIStabilityTest | 29 August 2022, 06:08:29 UTC |
| b63424e | 愚鲤 | 20 August 2022, 14:41:47 UTC | [hotfix] Add TaskManager id in the exception message | 28 August 2022, 05:07:14 UTC |
| 7b394a3 | wangyang0918 | 26 August 2022, 05:25:21 UTC | [FLINK-29105][k8s] Fix the unstable k8s test 'testAddAndLockShouldNotThrowAlreadyExistExceptionWithSameContents' | 27 August 2022, 10:18:18 UTC |
| c643a29 | Weijie Guo | 22 August 2022, 09:31:35 UTC | [FLINK-29056] Throw PartitionNotFoundException if the partition file is not readable for hybird shuffle. This closes #20666 | 26 August 2022, 14:37:12 UTC |
| 4399b3f | yuxia Luo | 26 August 2022, 12:19:25 UTC | [FLINK-28883][hive] Fix HiveTableSink failed to report statistic to hive metastore in batch mode This closes #20549 | 26 August 2022, 12:19:25 UTC |
| 0ade193 | Ron | 26 August 2022, 11:57:59 UTC | [FLINK-29035][table-planner] Fix bug of ExpressionReducer does not work with jar resources This closes #20635 | 26 August 2022, 11:57:59 UTC |
| c086a91 | yuxia Luo | 26 August 2022, 09:49:19 UTC | [FLINK-27175][hive] Fix fail to call Hive UDAF when the UDAF accepts one parameter with array type This closes #19423 | 26 August 2022, 09:49:19 UTC |
| d501b88 | zhengyunhong.zyh | 23 August 2022, 03:06:46 UTC | [FLINK-29046][Connectors/Hive] Fix HiveTableSourceStatisticsReportTest fails with Hive 3.x This closes #20664 | 26 August 2022, 07:49:39 UTC |
| 91e1291 | Roman Khachatryan | 15 August 2022, 17:30:36 UTC | [FLINK-28976][state] Don't add extra delay to the 1st materialization | 26 August 2022, 07:45:26 UTC |
| 0e083c1 | Roman Khachatryan | 15 August 2022, 17:29:58 UTC | [hotfix][state] Fix logging in Materializer and make FLINK-28976 more explicit | 26 August 2022, 07:45:26 UTC |
| aaa3560 | Roman Khachatryan | 24 August 2022, 16:20:02 UTC | [hotfix][tests] Use negative changelog materialization interval in tests ...instead of a big value so that the subsequent change won't break them. | 26 August 2022, 07:45:26 UTC |
| a38b852 | Roman Khachatryan | 25 March 2022, 20:02:35 UTC | [hotfix][state] Extract PeriodicMaterializationManager into state-backend-common This commit is copied from #19312 / FLINK-26965 . It allows to: - test PeriodicMaterializationManager easier (subsequent commit) - reuse PeriodicMaterializationManager for non-changelog cases (e.g. FLIP-151) | 26 August 2022, 07:45:26 UTC |
| 3149c62 | Jark Wu | 26 August 2022, 07:32:17 UTC | [FLINK-29096][table] Update documentation for JSON_VALUE special characters | 26 August 2022, 07:34:02 UTC |
| 60e5944 | liuyongvs | 24 August 2022, 12:45:32 UTC | [FLINK-29096][table] Add test for json_value, which json path has blank characters. This closes #20675 | 26 August 2022, 07:34:01 UTC |
| 0fd718c | Wencong Liu | 25 August 2022, 06:31:09 UTC | fixup! [FLINK-27773][sql-gateway]Introduce the rest E2E tests for SQL Gateway | 26 August 2022, 03:27:58 UTC |
| 221fb98 | Wencong Liu | 18 August 2022, 07:10:53 UTC | [FLINK-27773][sql-gateway]Introduce the rest E2E tests for SQL Gateway | 26 August 2022, 03:27:58 UTC |
| ad68495 | Wencong Liu | 18 August 2022, 07:08:37 UTC | [hotfix][sql-gateway]Modify the response format and adjust SqlGatewayRestEndpointFactory | 26 August 2022, 03:27:58 UTC |
| b1db372 | Wencong Liu | 24 August 2022, 09:29:20 UTC | [hotfix][sql-gateway]Modify url in operation related message headers | 26 August 2022, 03:27:58 UTC |
| cdc4f4b | kurt | 26 July 2022, 07:57:55 UTC | [FLINK-28177][Connectors/ElasticSearch] Fix the unstable Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey This closes #20362. | 26 August 2022, 02:32:04 UTC |
| fe39264 | zhengyunhong.zyh | 24 August 2022, 03:51:29 UTC | [FLINK-29059][table-planner] Fix the existing column stats are deleted incorrectly when analyze table for partial columns This closes #20672 | 25 August 2022, 13:59:02 UTC |
| 0af535a | huangxingbo | 18 August 2022, 12:33:40 UTC | [FLINK-29029][python] Fix the bug of InternalTypeInfo mapping to IdentityConverter in Thread Mode This closes #20621. | 25 August 2022, 09:12:48 UTC |
| 7166625 | zhengyunhong.zyh | 08 August 2022, 16:07:00 UTC | [FLINK-28493][docs] Add document to describe "ANALYZE TABLE" syntax This closes #20506 | 25 August 2022, 09:04:41 UTC |
| fcaa4f7 | xuyang | 23 August 2022, 10:03:26 UTC | [FLINK-29081][table-planner] Capitalize join hints to avoid case sensitive This closes #20669 | 25 August 2022, 08:59:18 UTC |
| 58c4be4 | Chesnay Schepler | 15 August 2022, 11:37:46 UTC | [FLINK-28841][scripts][docs] Document dynamic properties support | 25 August 2022, 07:24:01 UTC |
| 64f11ee | yuzelin | 25 August 2022, 03:26:31 UTC | [FLINK-28936][sql-gateway] Fix REST endpoint can not serialize uncompacted LogicalType (#20617) | 25 August 2022, 03:26:31 UTC |
