Commits

Breadcrumbs

History for

on06b0e9c

User selector

All users

Datepicker

All time

Commit History

Commits on Oct 23, 2024

• [FLINK-35029][state/forst] Store timer in JVM heap when use async state backend (apache#25501)

  fredia

  authored
  039a07d

Commits on Oct 14, 2024

• [FLINK-36350][tests] Fix IllegalAccessError in UnalignedCheckpointRescaleITCase during JDK17 runs

  

  codenohup

  authored and

  reswqa

  committed
  d6cb8b3

Commits on Oct 12, 2024

• [FLINK-36446][runtime] Refactor Job Submission Process to Use ExecutionPlan Instead of JobGraph.

  

  JunRuiLee

  authored and

  zhuzhurk

  committed
  e151265

Commits on Oct 11, 2024

• [hotfix][test] Fix TypeHintITCase if adaptive scheduler enabled

  reswqa

  committed
  d2c241a

• [FLINK-36423][api] Fix RichMapPartitionFunction does not invoke open method in KeyedPartitionWindowedStream

  codenohup

  authored
  2949815

Commits on Oct 10, 2024

• [hotfix][test] Fix unstable tests in CustomSerializationITCase

  reswqa

  committed
  24282df

• [FLINK-36444] Fix unstable test case SimpleRecoveryITCaseBase#testFailedRunThenSuccessfulRun

  

  codenohup

  authored and

  reswqa

  committed
  6e7bf9b

Commits on Oct 9, 2024

• [FLINK-36064][runtime] Refactor REST API for Client and Operator Coordinator Communication to Use operatorUid.

  Show description for 63b92bd
  

  JunRuiLee

  authored and

  zhuzhurk

  committed
  63b92bd

• [hotfix] Fix CustomSerializationITCase#testIncorrectSerializer1 unstable test case

  

  codenohup

  authored and

  reswqa

  committed
  c7b2b0b

Commits on Oct 3, 2024

• [FLINK-19153] Remove deprecated ExecutionMode in flink-core module

  

  codenohup

  authored and

  reswqa

  committed
  8931ce4

• [FLINK-32483][tests] Ensure RescaleCheckpointManuallyITCase always runs against aligned checkpoints.

  dmvk

  committed
  dd8c485

Commits on Oct 2, 2024

• [FLINK-36355][runtime] Remove deprecated TimeCharacteristic

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  d7c87f2

• [FLINK-36355][runtime] Remove deprecated TimestampAssigner

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  a75df87

Commits on Oct 1, 2024

• [FLINK-36355][runtime] Remove deprecated SetupableStreamOperator

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  3b2a968

• [FLINK-36355][runtime] Remove deprecated KeyedStream#process

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  05a0018

• [FLINK-36355][runtime] Remove deprecated DataStream#partitionCustom

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  8834c6d

• [FLINK-36355][runtime] Remove deprecated DataStream#keyBy

  

  yunfengzhou-hub

  authored and

  reswqa

  committed
  96ed2b8

• [FLINK-36336] Remove deprecated dataset API exclude table module

  codenohup

  authored
  4e6dc79

Commits on Sep 30, 2024

• [FLINK-36323][State] Remove deprecated FsStateBackend and RocksDBStateBackend

  

  Kaitian Hu

  authored and

  Zakelly

  committed
  36c3d77

• [FLINK-36323][State] Remove deprecated MemoryStateBackend

  

  Kaitian Hu

  authored and

  Zakelly

  committed
  5dcfdf7

• [FLINK-36245] Relocate deprecated SourceFunction / SinkFunction and remove deprecated Sink V1 in 2.0 (apache#25331)

  lvyanquan

  authored
  f2d6b57

• [FLINK-36355][runtime] Remove deprecated iterative stream

  Show description for c0cd27e
  

  yunfengzhou-hub

  authored and

  Sxnan

  committed
  c0cd27e

Commits on Sep 29, 2024

• [FLINK-14068][streaming] Removes non-deprecated API that uses org.apache.flink.streaming.api.windowing.time.Time;

  XComp

  committed
  d2ac6bd

Commits on Sep 27, 2024

• [FLINK-36366][core] Remove deprecated serializer related config option and method

  Show description for 6633719
  reswqa

  committed
  6633719

• [FLINK-36366][core] Remove deprecate API in flink-core exclude connector and state part

  reswqa

  committed
  aa514a0

Commits on Sep 26, 2024

• [FLINK-36287] Disallow UC for inner sink channels

  Show description for 9d21878
  AHeise

  committed
  9d21878

• [FLINK-36287] Migrate SinkITCase to AssertJ

  AHeise

  committed
  7976880

Commits on Sep 25, 2024

• [FLINK-36308][cep] Remove deprecated APIs from CEP module (apache#25381)

  dianfu

  authored
  42d918d

Commits on Sep 24, 2024

• [FLINK-34511][Runtime/State] Remove deprecated checkpointing related APIs

  Zakelly

  committed
  c5ed471

• [FLINK-34511][Runtime/State] Remove deprecated state related APIs

  Zakelly

  committed
  cbc4c58

• [FLINK-34511][Checkpoint] Cleanup CheckpointConfig

  Zakelly

  committed
  f3239e0

• [FLINK-34511][Checkpoint] Remove force checkpointing flag

  Zakelly

  committed
  b497726

• [FLINK-36349][tests] Fix ClosureCleanerITCase fail in the AdaptiveScheduler test profile

  codenohup

  authored
  b2d3289

• [FLINK-36346][API] Remove deprecated API in flink-streaming-java module

  reswqa

  committed
  0c5f96c

Commits on Sep 23, 2024

• [FLINK-36251][streaming-java] Remove StateBackend-related configuration getters/setters that return/set complex Java objects.

  

  JunRuiLee

  authored and

  zhuzhurk

  committed
  950fceb

Pagination

PreviousNext