You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by re...@apache.org on 2023/02/06 02:11:13 UTC

[flink] branch release-1.16 updated (5441cef7b03 -> 793b0f791c4)

This is an automated email from the ASF dual-hosted git repository.

renqs pushed a change to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 5441cef7b03 [FLINK-27848][runtime] Fix the problem that ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid.
     add 793b0f791c4 [FLINK-29405][table] Fix unstable test InputFormatCacheLoaderTest

No new revisions were added by this update.

Summary of changes:
 .../table/lookup/CachingLookupFunction.java        |   5 -
 .../table/lookup/fullcache/CacheLoader.java        |  63 +++++---
 .../table/lookup/fullcache/LookupFullCache.java    |  43 +++---
 .../lookup/fullcache/ReloadTriggerContext.java     |  11 +-
 .../inputformat/InputFormatCacheLoader.java        |  73 ++++-----
 .../inputformat/InputSplitCacheLoadTask.java       |  15 +-
 .../table/fullcache/LookupFullCacheTest.java       |   6 +-
 .../functions/table/fullcache/TestCacheLoader.java |   3 +-
 .../inputformat/FullCacheTestInputFormat.java      |  28 ++--
 .../inputformat/InputFormatCacheLoaderTest.java    | 171 +++++++++++----------
 10 files changed, 230 insertions(+), 188 deletions(-)