Commits

Branch selector

 master

User selector

wanglijie95

Datepicker

All time

Commit History

Commits on Jan 5, 2024

• [FLINK-33968][runtime] Advance the calculation of num of subpartitions to the time of initializing execution job vertex

  Show description for b25dfae
  

  wanglijie95

  authored and

  zhuzhurk

  committed
  b25dfae

  Copy full SHA for b25dfae

Commits on Sep 20, 2023

• [FLINK-32974][client] Avoid creating a new temporary directory every time for RestClusterClient

  Show description for 6034d5f
  wanglijie95

  committed
  6034d5f

  Copy full SHA for 6034d5f

Commits on Aug 30, 2023

• [FlINK-32865][table-planner] Make ExecutionOrderEnforcer support OFCG

  Show description for 3fffed0
  wanglijie95

  committed
  3fffed0

  Copy full SHA for 3fffed0

• [FlINK-32865][table-planner] Add ExecutionOrderEnforcer to exec plan and put it into BatchExecMultipleInput

  wanglijie95

  committed
  5ce5c81

  Copy full SHA for 5ce5c81

Commits on Aug 28, 2023

• [FLINK-32831][table-planner] Add check to ensure all tests in RuntimeFilterITcase have applied runtime filter.

  Show description for a68dd41
  wanglijie95

  committed
  a68dd41

  Copy full SHA for a68dd41

• [FLINK-32831][table-planner] Adjust default value of max build data size of runtime filter to cover more cases

  wanglijie95

  committed
  07888af

  Copy full SHA for 07888af

• [FLINK-32831][table-planner] RuntimeFilterProgram should aware join type when looking for the build side

  wanglijie95

  committed
  f518f8a

  Copy full SHA for f518f8a

• [hotfix][table-planner] Fix the wrong traitSet and inputs in runtime filter related exec node

  wanglijie95

  committed
  43bcf31

  Copy full SHA for 43bcf31

Commits on Aug 16, 2023

• [FLINK-32844][table-planner] Does not apply runtime filter and DPP on same key

  Show description for 6b7d6d6
  wanglijie95

  committed
  6b7d6d6

  Copy full SHA for 6b7d6d6

Commits on Aug 8, 2023

• [FLINK-32144][connector/filesystem][test] Create a new minicluser instead of using MiniClusterExtension in tests that would kill JM/TM

  Show description for fa61dd4
  

  wanglijie95

  authored and

  PatrickRen

  committed
  fa61dd4

  Copy full SHA for fa61dd4

Commits on Jul 23, 2023

• [FLINK-32492][table-planner] Add ITCase for runtime filter

  Show description for 9f73d3d
  wanglijie95

  committed
  9f73d3d

  Copy full SHA for 9f73d3d

• [FLINK-32492][table-planner] Introduce FlinkRuntimeFilterProgram

  wanglijie95

  committed
  72bee90

  Copy full SHA for 72bee90

• [FLINK-32492][table-planner] Introduce ExecNode for runtime filter

  wanglijie95

  committed
  ad20b19

  Copy full SHA for ad20b19

• [FLINK-32492][table-planner] Introduce configuration options for runtime filter.

  wanglijie95

  committed
  8659dd7

  Copy full SHA for 8659dd7

Commits on Jul 22, 2023

• [FLINK-32491][table-runtime] Introduce RuntimeFilterCodeGenerator

  Show description for 59850a9
  wanglijie95

  committed
  59850a9

  Copy full SHA for 59850a9

Commits on Jul 21, 2023

• [FLINK-32493][table-runtime] Introduce GlobalRuntimeFilterBuilderOperator

  Show description for 41b3526
  wanglijie95

  committed
  41b3526

  Copy full SHA for 41b3526

• [FLINK-32493][table-runtime] Introduce LocalRuntimeFilterBuilderOperator

  wanglijie95

  committed
  47596ea

  Copy full SHA for 47596ea

Commits on May 23, 2023

• [hotfix][doc] Use the flink-connector-jdbc v3.1 branch docs

  Show description for 9b0a30f
  wanglijie95

  committed
  9b0a30f

  Copy full SHA for 9b0a30f

Commits on May 12, 2023

• [hotfix][runtime][security] Change the log level to DEBUG in HBaseDelegationTokenProvider#getHBaseConfiguration

  Show description for 00d4419
  wanglijie95

  committed
  00d4419

  Copy full SHA for 00d4419

Commits on Apr 26, 2023

• [FLINK-31831][runtime][tests] Use random ports as rest bind port and jobmanager rpc port to avoid port binding failure

  Show description for aa2110f
  wanglijie95

  committed
  aa2110f

  Copy full SHA for aa2110f

• [hotfix][runtime][tests] Migrate assertions in TaskManagerDisconnectOnShutdownITCase to Junit5 Assertions

  wanglijie95

  committed
  262140c

  Copy full SHA for 262140c

Commits on Apr 14, 2023

• [FLINK-27144][runtime] Provide timeout details when calling FutureUtils.orTimeout

  Show description for a81ffa6
  wanglijie95

  committed
  a81ffa6

  Copy full SHA for a81ffa6

Commits on Apr 13, 2023

• [FLINK-31628][runtime] Check the heap index to avoid the same channel status being added/removed repeatedly.

  Show description for a9bc791
  wanglijie95

  committed
  a9bc791

  Copy full SHA for a9bc791

• [FLINK-31628][runtime] Migrate related tests to Junit5

  wanglijie95

  committed
  fc31869

  Copy full SHA for fc31869

Commits on Mar 30, 2023

• [FLINK-31651][runtime] Improve logging of granting/revoking leadership in JobMasterServiceLeadershipRunner to INFO level

  Show description for 4882fbd
  wanglijie95

  committed
  4882fbd

  Copy full SHA for 4882fbd

Commits on Feb 24, 2023

• [FLINK-31114][runtime] Set parallelism of job vertices in forward group at compilation phase

  Show description for b987ae1
  wanglijie95

  committed
  b987ae1

  Copy full SHA for b987ae1

• [FLINK-31114][runtime] Refactor the package path of ForwardGroup

  wanglijie95

  committed
  738b53f

  Copy full SHA for 738b53f

Commits on Feb 16, 2023

• [FLINK-31055][runtime] Fix the bug that dynamic flag of stream graph does not take effect when translating the transformations

  Show description for 1c0870a
  wanglijie95

  committed
  1c0870a

  Copy full SHA for 1c0870a

• [hotfix] Refactor code to configure stream graph at the same location

  wanglijie95

  committed
  c423110

  Copy full SHA for c423110

• [hotfix] Fix the missing parameter error in ForwardForConsecutiveHashPartitionerTest

  wanglijie95

  committed
  9c21560

  Copy full SHA for 9c21560

Commits on Feb 14, 2023

• [FLINK-30917][runtime] Let adaptive batch scheduler also respect the user-configured max parallelism when deciding parallelism

  Show description for b399832
  wanglijie95

  committed
  b399832

  Copy full SHA for b399832

• [hotfix] Adjust the parameters of AdaptiveBatchSchedulerITCase to make tests more reasonable

  wanglijie95

  committed
  2fc9024

  Copy full SHA for 2fc9024

Commits on Feb 9, 2023

• [FLINK-30942][runtime] Eagerly sets the parallelism of job vertices in the parallelism-decided forward groups.

  Show description for 5a4e0ea
  

  wanglijie95

  authored and

  zhuzhurk

  committed
  5a4e0ea

  Copy full SHA for 5a4e0ea

• [hotfix] Migrate related tests to Junit5

  

  wanglijie95

  authored and

  zhuzhurk

  committed
  040a72b

  Copy full SHA for 040a72b

Commits on Feb 2, 2023

• [FLINK-29859][e2e] Add allowed exceptions in logs for speculative execution e2e

  Show description for 19f2230
  

  wanglijie95

  authored and

  zhuzhurk

  committed
  19f2230

  Copy full SHA for 19f2230

Pagination

Previous

Next