Commits

Branch selector

 master

User selector

zhijiangW

Datepicker

All time

Commit History

Commits on Oct 12, 2019

• [FLINK-14004][runtime] Define SourceReaderOperator to verify the integration with StreamOneInputProcessor

  Show description for cee9bf0
  zhijiangW

  committed
  cee9bf0

  Copy full SHA for cee9bf0

Commits on Oct 11, 2019

• [hotfix][runtime] Add missing generics in RecordWriterBuilder for avoiding unchecked warning

  zhijiangW

  committed
  64557da

  Copy full SHA for 64557da

• [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes

  Show description for 71e440d
  zhijiangW

  committed
  71e440d

  Copy full SHA for 71e440d

Commits on Sep 27, 2019

• [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

  Show description for 7f2382a
  zhijiangW

  committed
  7f2382a

  Copy full SHA for 7f2382a

• [hotfix][tests] Adjust to use constant BUFFER_SIZE in PipelinedSubpartitionWithReadViewTest

  zhijiangW

  committed
  ca206d8

  Copy full SHA for ca206d8

• [hotfix][tests] Remove dead codes in PartitionTestUtils

  zhijiangW

  committed
  4ccb0a1

  Copy full SHA for 4ccb0a1

• [hotfix][tests] Fix the invalid method reference in javadoc of unit tests

  zhijiangW

  committed
  9e5d970

  Copy full SHA for 9e5d970

Commits on Sep 25, 2019

• [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus

  Show description for f41bda6
  

  zhijiangW

  authored and

  pnowojski

  committed
  f41bda6

  Copy full SHA for f41bda6

• [hotfix][task] Refactor to integrate the logics of TwoInputSelectionHandler#setAvailable/UnavailableIndex

  Show description for 9a8344e
  

  zhijiangW

  authored and

  pnowojski

  committed
  9a8344e

  Copy full SHA for 9a8344e

• [hotfix][task] Remove invalid condition in StreamTwoInputProcessor#isAnyInputAvailable

  Show description for ba07cef
  

  zhijiangW

  authored and

  pnowojski

  committed
  ba07cef

  Copy full SHA for ba07cef

• [hotfix][task] Refactor the class name AvailabilityListener to AvailabilityProvider

  

  zhijiangW

  authored and

  pnowojski

  committed
  da7484a

  Copy full SHA for da7484a

Commits on Sep 23, 2019

• [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on PushingAsyncDataInput#emitNext

  Show description for a80bbf1
  

  zhijiangW

  authored and

  pnowojski

  committed
  a80bbf1

  Copy full SHA for a80bbf1

• [hotfix][task] Refactor the constrcutor of StreamOneInputProcessor

  

  zhijiangW

  authored and

  pnowojski

  committed
  68386c4

  Copy full SHA for 68386c4

• [hotfix][task] Refactor the constrcutor of StreamTwoInputProcessor

  Show description for 4d42eab
  

  zhijiangW

  authored and

  pnowojski

  committed
  4d42eab

  Copy full SHA for 4d42eab

• [hotfix][network] Refactor the class name AsyncDataInput to PullingAsyncDataInput

  

  zhijiangW

  authored and

  pnowojski

  committed
  c727190

  Copy full SHA for c727190

• [hotfix][task] Remove unused argument from constructor of StreamTaskNetworkInput

  

  zhijiangW

  authored and

  pnowojski

  committed
  0983d1f

  Copy full SHA for 0983d1f

• [hotfix][task] Remove unncessary SuppressWarnings from StreamOneInputProcessor

  

  zhijiangW

  authored and

  pnowojski

  committed
  7aa0671

  Copy full SHA for 7aa0671

• [hotfix][task] Refactor the process of checking input index for StreamOneInputProcessor#processInput

  Show description for f5b6952
  

  zhijiangW

  authored and

  pnowojski

  committed
  f5b6952

  Copy full SHA for f5b6952

Commits on Aug 27, 2019

• [FLINK-13765][task] Introduce the TwoInputSelectionHandler for selecting input in StreamTwoInputSelectableProcessor

  Show description for 261c2dc
  zhijiangW

  committed
  261c2dc

  Copy full SHA for 261c2dc

Commits on Aug 23, 2019

• [FLINK-13442][network] Remove unnecessary notifySubpartitionConsumed method from view reader

  Show description for 482462f
  zhijiangW

  committed
  482462f

  Copy full SHA for 482462f

• [hotfix][task] Adjust the code format of OneInputStreamTask

  zhijiangW

  committed
  d3f6f8e

  Copy full SHA for d3f6f8e

• [FLINK-13764][task,metrics] Pass the counter of numRecordsIn into the constructor of StreamInputProcessor

  Show description for a7f1fee
  zhijiangW

  committed
  a7f1fee

  Copy full SHA for a7f1fee

• [FLINK-13762][task] Add the exception throwable in the interface methods of ValveOutputHandler

  Show description for a30fd9a
  

  zhijiangW

  authored and

  pnowojski

  committed
  a30fd9a

  Copy full SHA for a30fd9a

Commits on Jul 29, 2019

• [FLINK-13245][network] Remove redundant bookkeeping for already canceled input channel IDs

  

  zhijiangW

  authored and

  StephanEwen

  committed
  71a53d4

  Copy full SHA for 71a53d4

• [FLINK-13245][network] Make subpartition consumption notification independant

  

  zhijiangW

  authored and

  StephanEwen

  committed
  acd15d2

  Copy full SHA for acd15d2

• [FLINK-13245][network] Fix the bug of file resource leak while canceling partition request

  Show description for 653ba1a
  

  zhijiangW

  authored and

  StephanEwen

  committed
  653ba1a

  Copy full SHA for 653ba1a

Commits on Jul 12, 2019

• [FLINK-13100][network] Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer

  Show description for 2c8ee78
  

  zhijiangW

  authored and

  pnowojski

  committed
  2c8ee78

  Copy full SHA for 2c8ee78

• [hotfix][network] Make BoundedBlockingSubpartitionType configurable

  Show description for 67bc355
  

  zhijiangW

  authored and

  pnowojski

  committed
  67bc355

  Copy full SHA for 67bc355

• [hotfix][network] Move private NoOpResultSubpartitionView class out of PartitionRequestQueueTest

  Show description for 130e797
  

  zhijiangW

  authored and

  pnowojski

  committed
  130e797

  Copy full SHA for 130e797

Commits on Jul 11, 2019

• [FLINK-13141][network] Remove getBufferSize method from BufferPoolFactory

  Show description for 775cd8f
  

  zhijiangW

  authored and

  pnowojski

  committed
  775cd8f

  Copy full SHA for 775cd8f

Commits on Jul 8, 2019

• [FLINK-11082][network] Fix the calculation of backlog in PipelinedSubpartition

  Show description for d051ccc
  

  zhijiangW

  authored and

  pnowojski

  committed
  d051ccc

  Copy full SHA for d051ccc

Commits on Jul 4, 2019

• [hotfix][network] Remove unnecessary getMemorySegmentSize method from NetworkBufferPool

  Show description for 666aeaf
  

  zhijiangW

  authored and

  pnowojski

  committed
  666aeaf

  Copy full SHA for 666aeaf

• [hotfix][network] Remove getMemorySegmentSize method from BufferProvider interface

  

  zhijiangW

  authored and

  pnowojski

  committed
  4004835

  Copy full SHA for 4004835

• [FLINK-12738][network] Remove abstract getPageSize method from InputGate

  Show description for b6563e3
  

  zhijiangW

  authored and

  pnowojski

  committed
  b6563e3

  Copy full SHA for b6563e3

• [hotfix][runtime] Make BufferStorage independent with InputGate#getPageSize

  Show description for 1899069
  

  zhijiangW

  authored and

  pnowojski

  committed
  1899069

  Copy full SHA for 1899069

Pagination

Previous

Next