Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Nov 20, 2024

• [FLINK-36710] Log job ID in RecreateOnResetOperatorCoordinator

  

  rkhachatryan

  authored and

  pnowojski

  committed
  27569da

Commits on Nov 13, 2024

• [FLINK-36613] Make checkpoint include all source data in RescaleCheckpointManuallyITCase

  Zakelly

  committed
  6fe39c6

• [FLINK-36613] Fix unstable RescaleCheckpointManuallyITCase in parallel run

  Zakelly

  committed
  73c120d

Commits on Nov 4, 2024

• [FLINK-36624][checkpointing] Log JobID from the SourceCoordinator

  pnowojski

  committed
  96bb45d

Commits on Oct 30, 2024

• [FLINK-36606][tests] TimestampITCase generates test artifacts outside of tmp folder

  snuyanzin

  authored
  ec8d679

• [FLINK-35268][state] Add ttl interface for Async State API && implement TtlListStateV2/TtlValueStateV2 (apache#25515)

  fredia

  authored
  dbfc83d

Commits on Oct 29, 2024

• [FLINK-4602][State] Move RocksDB statebackend classes to o.a.f.state.rocksdb package. (apache#25543)

  AlexYinHan

  authored
  316daca

Commits on Oct 28, 2024

• [FLINK-36521][runtime] Introduce TtlAwareSerializer and TtlAwareSerializerSnapshot

  

  xiangyuf

  authored and

  Zakelly

  committed
  0fc9714

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

Pagination

PreviousNext