Commits

Branch selector

 master

User selector

pnowojski

Datepicker

All time

Commit History

Commits on Oct 22, 2019

• [FLINK-14235][kafka,tests] Change source in at-least-once test from finite to infinite

  Show description for c31e44e
  pnowojski

  committed
  c31e44e

  Copy full SHA for c31e44e

• [hotfix][dist] Rename local variables in GlobalConfiguration

  pnowojski

  committed
  5ecb351

  Copy full SHA for 5ecb351

• [hotfix][kafka,test] Remove unused statement from testOneToOneAtLeastOnce

  pnowojski

  committed
  8a75dec

  Copy full SHA for 8a75dec

• [hotfix][kafka,test] Drop unused field in FailingIdentityMapper

  pnowojski

  committed
  ee43395

  Copy full SHA for ee43395

Commits on Oct 18, 2019

• [FLINK-14004][runtime,test] Add test coverage for stateful SourceReaderOperator implementation

  pnowojski

  committed
  bf473a4

  Copy full SHA for bf473a4

• [hotfix][test] Drop unused timeout parameter

  pnowojski

  committed
  3671b74

  Copy full SHA for 3671b74

Commits on Oct 15, 2019

• [hotfix][docs,metrics] Fix typo in the input pool usage metrics

  

  pnowojski

  authored and

  zhijiangW

  committed
  73ec89b

  Copy full SHA for 73ec89b

• [FLINK-12576][docs,metrics] Document that input pool usage metrics ignore LocalInputChannels

  

  pnowojski

  authored and

  zhijiangW

  committed
  4966b1f

  Copy full SHA for 4966b1f

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

Pagination

Previous

Next