Commits

Branch selector

 master

User selector

pnowojski

Datepicker

All time

Commit History

Commits on Nov 27, 2024

• [FLINK-36764] Add checkpoint type and unaligned flag to the checkpoint trace

  pnowojski

  committed
  09ad451

Commits on Nov 5, 2024

• [FLINK-36099][task] Log jobID in TaskExecutor#failTask

  pnowojski

  committed
  0b64b57

Commits on Nov 4, 2024

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

  pnowojski

  committed
  96bb45d

• [FLINK-36624][checkpointing] Expose JobID to the OperatorCoordinators

  pnowojski

  committed
  4e2057d

Commits on Oct 25, 2024

• [FLINK-36555] Guarantee buffer grows even with very small alpha

  Show description for d488b7a
  pnowojski

  committed
  d488b7a

• [hotfix] Move BufferDebloatConfiguration's checkState's into constructor

  pnowojski

  committed
  63cf67e

• [FLINK-36556] Add starting buffer size config option

  Show description for 36d9edc
  pnowojski

  committed
  36d9edc

Commits on Oct 24, 2024

• [FLINK-33696][docs] Document OpenTelemetryMetric\TraceReporter

  pnowojski

  committed
  5ba3f91

• [hotfix] Clean up docs

  pnowojski

  committed
  a57790f

• [FLINK-33696][metrics][otel] Add OpenTelemetryTraceReporter"

  pnowojski

  committed
  e8cee19

• [FLINK-33696][metrics][otel] Add OpenTelemetryMetricReporter

  pnowojski

  committed
  06b0e9c

• [hotfix] Bump testcontainers

  pnowojski

  committed
  437a47f

Commits on Oct 2, 2024

• [FLINK-36416][table][runtime] Enable splittable timers for temporal join, temporal sort and windowed aggregations

  Show description for 00a94ad
  pnowojski

  committed
  00a94ad

Commits on Oct 1, 2024

• [FLINK-36260][metrics] Fix numBytesInLocal and numBuffersInLocal being reported as remote

  pnowojski

  committed
  8412dea

Commits on Aug 28, 2024

• [FLINK-35773][docs] Document s5cmd

  pnowojski

  committed
  20e6d63

Commits on Aug 21, 2024

• [FLINK-35772][filesystem] Drop DuplicatingFileSystem in favour of the newer PathsCopyingFileSystem

  pnowojski

  committed
  56c8199

Commits on Aug 17, 2024

• [FLINK-35886][source] Do not track already finished splits in watermark alignment

  pnowojski

  committed
  5f6200c

• [FLINK-35886][task] Hide backpressure from idleness detection in WatermarkAssignerOperator

  pnowojski

  committed
  6d100ab

• [FLINK-35886][task] Hide backpressure and watermark alignment from idleness detection in SourceOperator

  pnowojski

  committed
  02d89ca

• [FLINK-35886][task] Hide backpressure from idleness detection in TimestampsAndWatermarksOperator

  pnowojski

  committed
  49eaba0

• [FLINK-35886][task] Expose Clock from ProcessingTimeService

  Show description for a76c711
  pnowojski

  committed
  a76c711

• [FLINK-35886][task] Use RelativeClock in WatermarksWithIdleness

  pnowojski

  committed
  934007c

• [FLINK-35886][task] Implement PausableRelativeClock

  pnowojski

  committed
  9659a5c

• [FLINK-35886][task] Support markStart and markEnd listeners in TimerGauge

  pnowojski

  committed
  8476664

• [FLINK-35886][task] Define RelativeClock interface

  pnowojski

  committed
  8ad0346

• [hotfix][test] Do not add three splits with the same splitId in testMetrics

  pnowojski

  committed
  287eff2

• [hotfix] Refactor SourceOperatorSlitWatermarkAlignmentTest and support pausing splits in MockSourceReader

  pnowojski

  committed
  308f05a

Commits on Jul 18, 2024

• [FLINK-35860][test] Fix S5CmdOnMinioITCase failed due to IllegalAccessError in JDK17/21

  pnowojski

  committed
  55db68c

Commits on Jul 12, 2024

• [FLINK-35768][tests] Add an ITCase for s5cmd

  pnowojski

  committed
  a056e02

• [FLINK-35768][state,rocksdb] Use fast files download in RocksdBStateDownloader

  pnowojski

  committed
  dd85349

• [FLINK-35768][state,rocksdb] Refactor RocksDBStateDownloader

  pnowojski

  committed
  73b0fac

• [FLINK-35767][s3] Use s5cmd for fast files download from the s3

  pnowojski

  committed
  1da48e5

• [FLINK-35767][filesystems] Add PathsCopyingFileSystem

  pnowojski

  committed
  5c4b1aa

• [hotfix] Use newly defined ConfigOptions in MinioTestContainer

  pnowojski

  committed
  f710597

• [hotfix] Move CompressionUtils to flink-core

  pnowojski

  committed
  1226ab5

Pagination

PreviousNext