Commits

Branch selector

 master

User selector

1996fanrui

Datepicker

All time

Commit History

Commits on May 25, 2024

• [FLINK-35215][core] Add a test for deserializing an object whose serialization result is an empty byte array

  1996fanrui

  committed
  5b535e1

  Copy full SHA for 5b535e1

Commits on May 23, 2024

• [hotfix][rest] Add getter methods for SubtasksTimesInfo to get all values easily

  1996fanrui

  committed
  5ba0141

  Copy full SHA for 5ba0141

Commits on May 22, 2024

• [FLINK-35215][core] Fix the bug when Kryo serialize length is 0

  Show description for c1baf07
  1996fanrui

  committed
  c1baf07

  Copy full SHA for c1baf07

• Revert "[FLINK-34954][core] Kryo Input bug fix"

  Show description for 46db926
  1996fanrui

  committed
  46db926

  Copy full SHA for 46db926

Commits on May 16, 2024

• [FLINK-35225][Web] Remove Execution mode in Flink WebUI

  1996fanrui

  committed
  48c14fe

  Copy full SHA for 48c14fe

• [FLINK-35226][rest] Deprecate execution-mode in ExecutionConfigInfo related rest api

  1996fanrui

  committed
  0c28e1c

  Copy full SHA for 0c28e1c

Commits on May 11, 2024

• [FLINK-35041][test] Fix the IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

  Show description for 86c8304
  1996fanrui

  committed
  86c8304

  Copy full SHA for 86c8304

• [hotfix][test] Fix InstantiationUtilTest cannot find assertFalse

  1996fanrui

  committed
  ec5364d

  Copy full SHA for ec5364d

Commits on May 8, 2024

• [FLINK-35306][test] Migrate flink-tests-java17 module to JUnit5 and assertj to solve jdk17 compile fails

  1996fanrui

  committed
  1c34ca0

  Copy full SHA for 1c34ca0

Commits on Apr 29, 2024

• [FLINK-35224][web] Show the JobType on Flink WebUI

  1996fanrui

  committed
  86de622

  Copy full SHA for 86de622

• [FLINK-35223][rest] Add jobType in JobDetailsInfo related rest api

  1996fanrui

  committed
  917352e

  Copy full SHA for 917352e

• [FLINK-35222][rest] Add getJobType for AccessExecutionGraph

  1996fanrui

  committed
  5263f9c

  Copy full SHA for 5263f9c

Commits on Mar 28, 2024

• [FLINK-34956][doc] Fix the config type wrong of Duration

  1996fanrui

  committed
  f31c128

  Copy full SHA for f31c128

Commits on Mar 11, 2024

• [hotfix] Fix the StateTtlConfig#newBuilder doc from Time to Duration

  1996fanrui

  committed
  972dc0c

  Copy full SHA for 972dc0c

• [FLINK-34522][core] Changing the Time to Duration for StateTtlConfig.Builder.cleanupInRocksdbCompactFilter

  1996fanrui

  committed
  7bfa1d3

  Copy full SHA for 7bfa1d3

Commits on Mar 1, 2024

• [hotfix][runtime] Remove unneeded requestTaskManagerFileUploadByName (apache#24386)

  Show description for f88f750
  1996fanrui

  authored
  f88f750

  Copy full SHA for f88f750

Commits on Feb 20, 2024

• [FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes

  1996fanrui

  committed
  e2e3de2

  Copy full SHA for e2e3de2

Commits on Feb 8, 2024

• [FLINK-34200][test] Fix the bug that AutoRescalingITCase.testCheckpointRescalingInKeyedState fails occasionally

  1996fanrui

  committed
  1b95b19

  Copy full SHA for 1b95b19

• [hotfix][tests] Disables cool down phase for faster test execution

  1996fanrui

  committed
  9d7de68

  Copy full SHA for 9d7de68

• [FLINK-33960][Scheduler] Fix the bug that Adaptive Scheduler doesn't respect the lowerBound when one flink job has more than 1 tasks

  1996fanrui

  committed
  777e96f

  Copy full SHA for 777e96f

• [FLINK-33960][JUnit5 migration] Migrate SlotSharingSlotAllocatorTest to Junit5 and Assertj

  1996fanrui

  committed
  71336d6

  Copy full SHA for 71336d6

Commits on Feb 6, 2024

• [FLINK-33739][doc] Document FLIP-364: Improve the exponential-delay restart-strategy

  1996fanrui

  committed
  2f040e3

  Copy full SHA for 2f040e3

Commits on Feb 5, 2024

• [FLINK-34247][doc] Fix the wrong zh link for flink-configuration-file and repeated flink configuration file

  1996fanrui

  committed
  d44e940

  Copy full SHA for d44e940

Commits on Jan 24, 2024

• [FLINK-33865][runtime] Adding an ITCase to ensure exponential-delay.attempts-before-reset-backoff works well

  1996fanrui

  committed
  393ef1c

  Copy full SHA for 393ef1c

• [FLINK-33865][runtime][refactor] Refactor the RestartStrategyType to reduce repeated magic string

  1996fanrui

  committed
  5c895aa

  Copy full SHA for 5c895aa

Commits on Jan 23, 2024

• [hotfix] Remove the wrong @Nullable annotation of FailureHandlingResult due to the constructor checks verticesToRestart is not null

  1996fanrui

  committed
  ad3f13f

  Copy full SHA for ad3f13f

• [FLINK-33565][Scheduler] Correct the numberOfRestarts metric

  1996fanrui

  committed
  d031f60

  Copy full SHA for d031f60

• [FLINK-33565][Scheduler] ConcurrentExceptions works with exception merging

  1996fanrui

  committed
  9f20bc4

  Copy full SHA for 9f20bc4

• [FLINK-33565][Exception] Restart strategy checks whether current failure is a new attempt

  1996fanrui

  committed
  bb437bd

  Copy full SHA for bb437bd

• [FLINK-33565][Exception] Archive exceptions into the exception history immediately when they occur, instead of archiving them when restarting

  1996fanrui

  committed
  8a7e549

  Copy full SHA for 8a7e549

Commits on Jan 22, 2024

• [FLINK-34081][configuration] Refactor all callers of deprecated getXxx(ConfigOption<Xxx>), getXxx(ConfigOption<Xxx>, Xxx) and setXxx(ConfigOption<Integer>, Xxx) methods of Configuration

  1996fanrui

  committed
  c8f27c2

  Copy full SHA for c8f27c2

Commits on Jan 19, 2024

• [FLINK-34080][configuration] Remove the @Deprecated for getString(String key, String defaultValue) of Configuration

  1996fanrui

  committed
  725b3ed

  Copy full SHA for 725b3ed

• [FLINK-34080][configuration] Deprecate all getXxx and setXxx methods for Configuration

  1996fanrui

  committed
  a2cc47a

  Copy full SHA for a2cc47a

• [FLINK-34080][configuration] Add the T get(ConfigOption<T> configOption, T overrideDefault) for Configuration

  1996fanrui

  committed
  79abfaa

  Copy full SHA for 79abfaa

Commits on Jan 11, 2024

• [FLINK-32852][hotfix] DefaultSchedulerTest should use the LOG instead of TestLogger of junit4

  1996fanrui

  committed
  8a04ae0

  Copy full SHA for 8a04ae0

Pagination

Previous

Next