Commits

Branch selector

 master

User selector

pnowojski

Datepicker

All time

Commit History

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

  Copy full SHA for 00a94ad

Commits on Oct 1, 2024

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

  pnowojski

  committed
  8412dea

  Copy full SHA for 8412dea

Commits on Aug 28, 2024

• [FLINK-35773][docs] Document s5cmd

  pnowojski

  committed
  20e6d63

  Copy full SHA for 20e6d63

Commits on Aug 21, 2024

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

  pnowojski

  committed
  56c8199

  Copy full SHA for 56c8199

Commits on Aug 17, 2024

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

  pnowojski

  committed
  5f6200c

  Copy full SHA for 5f6200c

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

  pnowojski

  committed
  6d100ab

  Copy full SHA for 6d100ab

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

  pnowojski

  committed
  02d89ca

  Copy full SHA for 02d89ca

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

  pnowojski

  committed
  49eaba0

  Copy full SHA for 49eaba0

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

  Show description for a76c711
  pnowojski

  committed
  a76c711

  Copy full SHA for a76c711

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

  pnowojski

  committed
  934007c

  Copy full SHA for 934007c

• [FLINK-35886][task] Implement PausableRelativeClock

  pnowojski

  committed
  9659a5c

  Copy full SHA for 9659a5c

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

  pnowojski

  committed
  8476664

  Copy full SHA for 8476664

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

  pnowojski

  committed
  8ad0346

  Copy full SHA for 8ad0346

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

  pnowojski

  committed
  287eff2

  Copy full SHA for 287eff2

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

  pnowojski

  committed
  308f05a

  Copy full SHA for 308f05a

Commits on Jul 18, 2024

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

  pnowojski

  committed
  55db68c

  Copy full SHA for 55db68c

Commits on Jul 12, 2024

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

  pnowojski

  committed
  a056e02

  Copy full SHA for a056e02

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

  pnowojski

  committed
  dd85349

  Copy full SHA for dd85349

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

  pnowojski

  committed
  73b0fac

  Copy full SHA for 73b0fac

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

  pnowojski

  committed
  1da48e5

  Copy full SHA for 1da48e5

• [FLINK-35767][filesystems] Add PathsCopyingFileSystem

  pnowojski

  committed
  5c4b1aa

  Copy full SHA for 5c4b1aa

• [hotfix] Use newly defined ConfigOptions in MinioTestContainer

  pnowojski

  committed
  f710597

  Copy full SHA for f710597

• [hotfix] Move CompressionUtils to flink-core

  pnowojski

  committed
  1226ab5

  Copy full SHA for 1226ab5

• [hotfix] Create ConfigOptions for s3 access/secret keys and endpoint

  pnowojski

  committed
  957804a

  Copy full SHA for 957804a

Commits on Jun 18, 2024

• fixup! [FLINK-34252][table] Optimize WatermarkAssignerOperator to avoid calling System.currentTimeMillis per every record

  pnowojski

  committed
  d93e92c

  Copy full SHA for d93e92c

Commits on Jun 14, 2024

• [hotfix] Improve execution.checkpointing.unaligned.interruptible-timers.enabled documentation

  pnowojski

  committed
  6f47913

  Copy full SHA for 6f47913

Commits on Jun 12, 2024

• [FLINK-35528][task] Skip execution of interruptible mails when yielding

  Show description for 77cd1cd
  pnowojski

  committed
  77cd1cd

  Copy full SHA for 77cd1cd

• [FLINK-20217][docs] Regenerate docs

  pnowojski

  committed
  986d06d

  Copy full SHA for 986d06d

• [FLINK-20217][task] Add support for splittable timers to AbstractStreamOperatorV2

  pnowojski

  committed
  3e9d047

  Copy full SHA for 3e9d047

• [FLINK-20217][task] Enable splittable timers in CepOperator and TableStreamOperator

  pnowojski

  committed
  f26ee47

  Copy full SHA for f26ee47

• [FLINK-20217][task] Introduce YieldingOperator to get access to MailboxExecutor for V1 operators

  pnowojski

  committed
  a64c00b

  Copy full SHA for a64c00b

• [FLINK-20217][task] Add MailboxExecutor::shouldInterrupt

  pnowojski

  committed
  53bdac9

  Copy full SHA for 53bdac9

• [hotfix] Setup BufferDataOverWindowOperatorTest a bit more properly

  pnowojski

  committed
  503593a

  Copy full SHA for 503593a

Commits on Jun 4, 2024

• fixup! [FLINK-35351][checkpoint] Fix fail during restore from unaligned checkpoint with custom partitioner

  pnowojski

  committed
  62f9de8

  Copy full SHA for 62f9de8

• [hotfix] Unify Preconditions import in StreamConfig

  pnowojski

  committed
  5411956

  Copy full SHA for 5411956

Pagination

Previous

Next