Commits

Branch selector

 master

User selector

pnowojski

Datepicker

All time

Commit History

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

• [hotfix] Unify Preconditions import in Transformation

  pnowojski

  committed
  eb42701

  Copy full SHA for eb42701

• [hotfix] Simplify SinkTransformationTranslator

  pnowojski

  committed
  d5b2b3c

  Copy full SHA for d5b2b3c

• [hotfix] Rewrite Transformation#equals and #hashCode to use Objects helper methods

  pnowojski

  committed
  9c925e0

  Copy full SHA for 9c925e0

Commits on May 29, 2024

• [FLINK-35351][checkpoint] Clean up and unify code for the custom partitioner test case

  pnowojski

  committed
  ce0b61f

  Copy full SHA for ce0b61f

Commits on May 23, 2024

• [FLINK-35420][hadoop-compatibility][test] Workaround some strange scala compilation issue

  Show description for 9ccfb65
  pnowojski

  committed
  9ccfb65

  Copy full SHA for 9ccfb65

Commits on May 16, 2024

• [FLINK-32828] Properly initialize initial splits in WatermarkOutputMultiplexer

  Show description for 7fd6c6d
  pnowojski

  committed
  7fd6c6d

  Copy full SHA for 7fd6c6d

• [hotfix] Allow to use per split output via SourceOperatorTestContext

  pnowojski

  committed
  4139106

  Copy full SHA for 4139106

• [hotfix] Allow configuring initial splits in SourceOperatorTestContext

  pnowojski

  committed
  f5ceb78

  Copy full SHA for f5ceb78

• [hotfix] Make MockSourceSplit#addRecord calls chainable

  pnowojski

  committed
  8df0466

  Copy full SHA for 8df0466

Commits on Apr 9, 2024

• [FLINK-35065][metrics] Add numFiredTimers and numFiredTimersPerSecond

  pnowojski

  committed
  98bd265

  Copy full SHA for 98bd265

• fixup! [FLINK-19010][metric] Introduce subtask level restore metric

  pnowojski

  committed
  0944eb0

  Copy full SHA for 0944eb0

Commits on Mar 25, 2024

• [hotfix] Enable rocksdb ingest restore mode randomization

  pnowojski

  committed
  1a5ca7f

  Copy full SHA for 1a5ca7f

• [FLINK-34913][metrics][state] Fix ConcurrentModificationException in SubTaskInitializationMetricsBuilder.addDurationMetric

  pnowojski

  committed
  048a77c

  Copy full SHA for 048a77c

Commits on Mar 15, 2024

• [hotfix] In case of unexpected errors do not loose the primary failure reason

  Show description for f6e1b49
  pnowojski

  committed
  f6e1b49

  Copy full SHA for f6e1b49

Commits on Mar 11, 2024

• [hotfix] Add toString to StateHandleDownloadSpec

  pnowojski

  committed
  2ec2a60

  Copy full SHA for 2ec2a60

• [hotfix][e2e] Fix wait_oper_metric_num_in_records

  Show description for d79a200
  pnowojski

  committed
  d79a200

  Copy full SHA for d79a200

• [hotfix][e2e] Fix naming of MAX_NUM_METRICS

  pnowojski

  committed
  7ae0a82

  Copy full SHA for 7ae0a82

Commits on Feb 29, 2024

• [hotfix] Fix missing flink-end-to-end-tests-jdbc-driver dependency

  pnowojski

  committed
  06fdc01

  Copy full SHA for 06fdc01

Commits on Jan 12, 2024

• [FLINK-33697][state] Allow incorrect public evolving API violation

  Show description for e6556fa
  pnowojski

  committed
  e6556fa

  Copy full SHA for e6556fa

• [hotfix] Removed incorrect VisibleForTesting

  pnowojski

  committed
  674107b

  Copy full SHA for 674107b

• [FLINK-33697][state][metrics] Trace RocksDBIncremental remote files download time

  pnowojski

  committed
  7725216

  Copy full SHA for 7725216

• [FLINK-33697][state] Add custom metrics to the StateBackend interface

  pnowojski

  committed
  40f76e1

  Copy full SHA for 40f76e1

• [hotfix][test] Fix some Architecture Violation errors

  pnowojski

  committed
  1d45dd0

  Copy full SHA for 1d45dd0

• [hotfix][test] Fix propagation of useManagedMemory flag

  pnowojski

  committed
  b660b06

  Copy full SHA for b660b06

Pagination

Previous

Next