This is an automated email from the ASF dual-hosted git repository.
guoyangze pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 7e43674 [FLINK-22311] [connector/jdbc] Validate maxRetries for XA Sink
add b798470 [hotfix][runtime] Extract common inner classes and methods to
ExecutionGraphInfoStoreTestUtils
add 7cb00d1 [FLINK-25329][runtime] Use cache in memory graph store and
support memory graph store in session cluster
No new revisions were added by this update.
Summary of changes:
.../generated/all_jobmanager_section.html | 8 +-
.../generated/job_manager_configuration.html | 8 +-
.../flink/configuration/JobManagerOptions.java | 28 +-
.../dispatcher/MemoryExecutionGraphInfoStore.java | 78 +++++-
.../entrypoint/SessionClusterEntrypoint.java | 46 +++-
.../ExecutionGraphInfoStoreTestUtils.java | 254 ++++++++++++++++++
.../FileExecutionGraphInfoStoreTest.java | 195 +-------------
.../MemoryExecutionGraphInfoStoreTest.java | 291 +++++++++++++++++++++
8 files changed, 701 insertions(+), 207 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/ExecutionGraphInfoStoreTestUtils.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/MemoryExecutionGraphInfoStoreTest.java
