Commits

Commits on Feb 20, 2024

[FLINK-34434][slotmanager] Complete the returnedFuture when slot removed before allocation success
KarmaGYZ
committedFeb 20, 2024
[hotfix][test] Assert the slot allocation eventually succeed in dedicated tests of DefaultSlotStatusSyncerTest
KarmaGYZ
committedFeb 20, 2024

Commits on Nov 20, 2023

[hotfix][docs] Fix the messed navigation bar on Flink’s official website
KarmaGYZ
committedNov 20, 2023

Commits on Nov 17, 2023

[FLINK-32299][gateway] Upload python jar when sql contains python udf jar
KarmaGYZ
committedNov 17, 2023

Commits on Oct 31, 2023

[FLINK-25055][network] Support listen and notify mechanism for remote partition request
KarmaGYZ
committedOct 31, 2023

Commits on Oct 16, 2023

[FLINK-33203][sql-gateway] Introduce env.java.opts.sql-gateway to specify the jvm options of sql gateway
KarmaGYZ
committedOct 16, 2023

Commits on Sep 11, 2023

[FLINK-33054][datastream] Align the execution result fetching timeout in CollectResultFetcher with akka ask timeout
KarmaGYZ
committedSep 11, 2023

Commits on Jul 11, 2022

[FLINK-26675][runtime] Parallelized heavy serialization in StreamingJobGraphGenerator
KarmaGYZ
committedJul 11, 2022

Commits on Jul 7, 2022

[FLINK-28312][rest] Introduce REST APIs for log URL retrieval
KarmaGYZ
committedJul 7, 2022

Commits on Jul 6, 2022

Commits on Jul 4, 2022

[FLINK-19358][runtime] Make the job id distinct in application mode when HA is enabled.
KarmaGYZ
committedJul 4, 2022
[FLINK-28310][rest] Introduce aggregating task metrics
KarmaGYZ
committedJul 4, 2022

Commits on Jul 1, 2022

Commits on Apr 27, 2022

[FLINK-27409][runtime] Cleanup stale slot allocation record when the resource requirement of a job is empty
KarmaGYZ
committedApr 27, 2022

Commits on Apr 19, 2022

[FLINK-27256][runtime] Log the root exception in closing the task manager connection
KarmaGYZ
committedApr 19, 2022

Commits on Mar 17, 2022

Commits on Mar 3, 2022

[hotfix][runtime] Remove unused ResourceManagerServices
KarmaGYZ
committedMar 3, 2022

Commits on Mar 2, 2022

[FLINK-26347][rpc] Using system classloader in deserialization of RemoteRpcInvocation
KarmaGYZ
committedMar 2, 2022

Commits on Feb 16, 2022

[FLINK-15455][network] Enabled tcp connection reuse across multi jobs.
KarmaGYZ
committedFeb 16, 2022
[hotfix][network] Remove the deduplication for CancelPartitionRequest.
KarmaGYZ
committedFeb 16, 2022

Commits on Feb 7, 2022

[FLINK-25741][runtime] Skip buffer pools which have no floating buffer in buffer redistributing.
KarmaGYZ
committedFeb 7, 2022

Commits on Oct 27, 2021

[FLINK-24541][runtime] Quoting the external resource list in generating dynamic config string

KarmaGYZ
authored and
xintongsong
committedOct 27, 2021

Commits on Sep 29, 2021

[FLINK-24380][k8s] Terminate the pod if it failed

KarmaGYZ
authored and
wangyang0918
committedSep 29, 2021

Commits on Sep 23, 2021

[FLINK-24315][k8s] Add retry logic when watching pods

KarmaGYZ
authored and
wangyang0918
committedSep 23, 2021

Commits on Sep 22, 2021

[FLINK-24262][runtime] Remove unused ContainerOverlays
KarmaGYZ
committedSep 22, 2021

Commits on Sep 6, 2021

[FLINK-23912][coordination] Ignore repeated empty requirements declarations
KarmaGYZ
committedSep 6, 2021