Commits

Branch selector

 master

User selector

pnowojski

Datepicker

All time

Commit History

Commits on Oct 11, 2019

• [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure

  Show description for 0bd0ec1
  pnowojski

  committed
  0bd0ec1

  Copy full SHA for 0bd0ec1

• [hotfix][runtime, test] Refactor StreamConfigChainer to support StreamOperatorFactory and honour pass down the bufferTimeout

  pnowojski

  committed
  db6fdea

  Copy full SHA for db6fdea

• [hotfix][runtime, test] Unify formatting in StreamConfigChainer

  pnowojski

  committed
  1c74725

  Copy full SHA for 1c74725

Commits on Oct 2, 2019

• [FLINK-14214][runtime] Shortcut isAvailable().isDone() anti-starvation check in StreamTwoInputProcessor

  Show description for bed28ab
  pnowojski

  committed
  bed28ab

  Copy full SHA for bed28ab

Commits on Oct 1, 2019

• [FLINK-10995][benchmarks] Use BroadcastRecordWriter for network broadcast benchmarks

  pnowojski

  committed
  9f21c77

  Copy full SHA for 9f21c77

• [hotfix][benchmarks] Remove unused field from benchmark environment

  pnowojski

  committed
  c552082

  Copy full SHA for c552082

• [hotfix][benchmarks] Expose RecordWriterBuilder from the benchmark environment

  pnowojski

  committed
  5cace47

  Copy full SHA for 5cace47

Commits on Aug 8, 2019

• fixup! StringWriter support custom row delimiter

  pnowojski

  committed
  e30f3ad

  Copy full SHA for e30f3ad

• [hotfix][task,test] Do not override performDefaultAction in StreamTaskTest

  pnowojski

  committed
  434f59f

  Copy full SHA for 434f59f

• [FLINK-12479][operators] Integrate StreamInputProcessor with mailbox

  pnowojski

  committed
  04b5cbf

  Copy full SHA for 04b5cbf

Commits on Jul 10, 2019

• [hotfix][checkpointing] Extract MINIMAL_CHECKPOINT_TIME magic constant

  pnowojski

  committed
  294fcb2

  Copy full SHA for 294fcb2

• [hotfix][test] Clean up NettyShuffleEnvironmentTest

  pnowojski

  committed
  4ed73a5

  Copy full SHA for 4ed73a5

Commits on Jul 9, 2019

• [hotfix][network] Make InputGate#requestPartitions a private method

  pnowojski

  committed
  8d277d4

  Copy full SHA for 8d277d4

• [FLINK-13013][network] Request partitions during InputGate#setup

  Show description for c27d0d6
  pnowojski

  committed
  c27d0d6

  Copy full SHA for c27d0d6

• [hotfix][test] Deduplicate NettyShuffleEnvironmentTest code

  pnowojski

  committed
  282646e

  Copy full SHA for 282646e

• [hotfix][test] Move CloseableRegistry as field in InputBuffersMetricsTest

  pnowojski

  committed
  479b689

  Copy full SHA for 479b689

• [hotfix][test] Guarantee order of CloseableRegistry

  pnowojski

  committed
  a68dc3c

  Copy full SHA for a68dc3c

Commits on Jul 4, 2019

• [hotfix][operator] Deduplicate code by introducing StreamInputProcessor interface

  pnowojski

  committed
  83a204e

  Copy full SHA for 83a204e

• [hotfix][operator] Rename StreamInputProcessor to StreamOneInputProcessor

  Show description for de44130
  pnowojski

  committed
  de44130

  Copy full SHA for de44130

• [hotfix][operator] Deduplicate StreamTask code

  pnowojski

  committed
  6caa61b

  Copy full SHA for 6caa61b

• [FLINK-13016][network] Fix StreamTaskNetworkInput#isAvailable

  Show description for 76eb11f
  pnowojski

  committed
  76eb11f

  Copy full SHA for 76eb11f

• [hotfix][test] Drop unused closedChannels field in MockInputGate

  pnowojski

  committed
  de91684

  Copy full SHA for de91684

• [hotfix][test] Drop InputGateConcurrentTest

  Show description for 42d671c
  pnowojski

  committed
  42d671c

  Copy full SHA for 42d671c

Commits on Jul 1, 2019

• [hotfix][network] Drop one testing constructor of CheckpointedInputGate

  pnowojski

  committed
  6311a65

  Copy full SHA for 6311a65

• [hotfix][network] Minor code simplification in CachedBufferStorage

  pnowojski

  committed
  777aefb

  Copy full SHA for 777aefb

• [hotfix][network] Drop unneccessary reference in the comment

  Show description for 9bdcfac
  pnowojski

  committed
  9bdcfac

  Copy full SHA for 9bdcfac

• [FLINK-12777][operator] Use CheckpointedInputGate StreamTwoInputSelectableProcessor

  pnowojski

  committed
  6c7a69a

  Copy full SHA for 6c7a69a

• [hotfix][operator] Fix checkpointing lock in StreamTwoInputSelectableProcessor

  pnowojski

  committed
  530a5e4

  Copy full SHA for 530a5e4

• [FLINK-12777][network] Introduce LinkedBufferStorage class

  pnowojski

  committed
  76b2993

  Copy full SHA for 76b2993

• [hotfix][network] Split InputProcessorUtil into smaller methods

  pnowojski

  committed
  2e5c499

  Copy full SHA for 2e5c499

• [FLINK-12777][network] Rename existing classes to make them in sync with the refactor

  Show description for 0d502b6
  pnowojski

  committed
  0d502b6

  Copy full SHA for 0d502b6

• [FLIKN-12777][network] Refactor BarrierTracker to use the same code structure as BarrierBuffer

  pnowojski

  committed
  5252588

  Copy full SHA for 5252588

• [FLINK-12777][network] Extract CheckpointBarrierAligner from BarrierBuffer

  pnowojski

  committed
  aa5f061

  Copy full SHA for aa5f061

• [hotfix][test] Drop mockito usage from BarrierTrackerTest

  pnowojski

  committed
  814f47e

  Copy full SHA for 814f47e

• [hotfix][network] Do not abort the same checkpoint barrier twice when cancellation marker was lost

  pnowojski

  committed
  62927c9

  Copy full SHA for 62927c9

Pagination

Previous

Next