Commits

Branch selector

 master

User selector

zhijiangW

Datepicker

All time

Commit History

Commits on Mar 20, 2020

• [FLINK-16653][network][tests] Implement MockResultPartitionWriter base for simplifying tests

  Show description for c60d11d
  zhijiangW

  committed
  c60d11d

  Copy full SHA for c60d11d

Commits on Mar 18, 2020

• [hotfix][task][tests] Remove useless import from TaskTest class

  Show description for ddec073
  zhijiangW

  committed
  ddec073

  Copy full SHA for ddec073

• [FLINK-16586][network] Build ResultSubpartitionInfo and InputChannelInfo in respective constructors

  Show description for 0a8eb8d
  zhijiangW

  committed
  0a8eb8d

  Copy full SHA for 0a8eb8d

Commits on Mar 17, 2020

• [FLINK-16454][build] Update the copyright with 2020 year in NOTICE files

  zhijiangW

  committed
  4035f03

  Copy full SHA for 4035f03

Commits on Mar 2, 2020

• [hotfix][tests] Remove the dead codes of StreamTestSingleInputGate and TestInputChannel

  zhijiangW

  committed
  d4ca6ea

  Copy full SHA for d4ca6ea

• [FLINK-16285][network] Refactor SingleInputGate#setInputChannel to remove IntermediateResultPartitionID argument

  Show description for 569468f
  zhijiangW

  committed
  569468f

  Copy full SHA for 569468f

Commits on Feb 27, 2020

• [hotfix][network] Cleanup the unused method from SingleInputGate

  Show description for d19d747
  zhijiangW

  committed
  d19d747

  Copy full SHA for d19d747

• [FLINK-16257][network] Remove useless ResultPartitionID from AddCredit message

  Show description for 556c6d2
  zhijiangW

  committed
  556c6d2

  Copy full SHA for 556c6d2

Commits on Feb 11, 2020

• [FLINK-15914][tests] Fix the fragile tests caused by race condition of multiple threads

  zhijiangW

  committed
  e591947

  Copy full SHA for e591947

• [FLINK-15914][checkpointing][metrics] Miss the checkpoint related metrics for the case of two inputs

  Show description for 2a0555b
  zhijiangW

  committed
  2a0555b

  Copy full SHA for 2a0555b

• [hotfix][task] Fix the comment typo in TwoInputStreamTask class

  zhijiangW

  committed
  2558c9e

  Copy full SHA for 2558c9e

Commits on Jan 21, 2020

• [FLINK-15444][runtime] Make the component AbstractInvokable in CheckpointBarrierHandler NonNull

  Show description for 9f92ddf
  zhijiangW

  committed
  9f92ddf

  Copy full SHA for 9f92ddf

• [hotfix][tests] Remove legany codes from CheckpointBarrierAlignerTestBase

  zhijiangW

  committed
  86ebb10

  Copy full SHA for 86ebb10

Commits on Jan 10, 2020

• [FLINK-15306][network] Adjust the default netty transport option from nio to auto

  Show description for 169edef
  zhijiangW

  committed
  169edef

  Copy full SHA for 169edef

Commits on Jan 7, 2020

• [FLINK-15021][network] Remove the setting of netty channel watermark in NettyServer

  Show description for 12d0950
  zhijiangW

  committed
  12d0950

  Copy full SHA for 12d0950

• [hotfix][network] Remove unused method from NettyConfig class

  zhijiangW

  committed
  22cf1c5

  Copy full SHA for 22cf1c5

• [hotfix][network] Fix the import format of NettyConfig class

  zhijiangW

  committed
  961ecd7

  Copy full SHA for 961ecd7

Commits on Jan 6, 2020

• [hotfix][runtime] Remove unused IOManager parameter while constructing BufferStorage

  Show description for a50d9ff
  zhijiangW

  committed
  a50d9ff

  Copy full SHA for a50d9ff

• [hotfix][runtime] Fix a comment typo in CheckpointBarrierAligner

  zhijiangW

  committed
  aff2b99

  Copy full SHA for aff2b99

Commits on Jan 5, 2020

• [hotfix][doc] Remove invalid comment from CheckpointedInputGate

  Show description for 99ef937
  

  zhijiangW

  authored and

  tisonkun

  committed
  99ef937

  Copy full SHA for 99ef937

Commits on Dec 12, 2019

• [FLINK-14952][network] Solve the issue of exceeding memory limits when using mmap blocking partition

  Show description for 7600e8b
  zhijiangW

  committed
  7600e8b

  Copy full SHA for 7600e8b

• [hotfix][documentation] Generate the respective htmls because of previous configuration changes

  zhijiangW

  committed
  2ae4c42

  Copy full SHA for 2ae4c42

Commits on Dec 11, 2019

• [FLINK-15069][benchmark] Supplement the pipelined shuffle compression case for benchmark

  Show description for 04ab225
  zhijiangW

  committed
  04ab225

  Copy full SHA for 04ab225

Commits on Nov 17, 2019

• [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

  Show description for 2c8b4ef
  zhijiangW

  committed
  2c8b4ef

  Copy full SHA for 2c8b4ef

• [hotfix][network] Make ResultPartitionWriter extend AvailabilityProvider to avoid defining duplicate method

  Show description for 7374ccc
  zhijiangW

  committed
  7374ccc

  Copy full SHA for 7374ccc

• [hotfix][runtime] Refactor the method of AvailabilityProvider#isAvailable

  Show description for e0824a0
  zhijiangW

  committed
  e0824a0

  Copy full SHA for e0824a0

Commits on Oct 28, 2019

• [hotfix][tests] Fix the missing class reference in LocalInputChannelTest

  zhijiangW

  committed
  60ce77a

  Copy full SHA for 60ce77a

• [FLINK-14396][network] Implement rudimentary non-blocking network output

  Show description for ad70e06
  zhijiangW

  committed
  ad70e06

  Copy full SHA for ad70e06

• [hotfix][runtime] Implement AvailabilityHelper for providing resetAvailable/Unavailble functions for InputGate

  Show description for a385254
  zhijiangW

  committed
  a385254

  Copy full SHA for a385254

Commits on Oct 21, 2019

• [FLINK-14394][network] Remove unnecessary interface method BufferProvider#requestBufferBlocking

  Show description for 47e9a82
  zhijiangW

  committed
  47e9a82

  Copy full SHA for 47e9a82

• [hotfix][network] Remove optional class field from LocalBufferPool

  zhijiangW

  committed
  34e53d1

  Copy full SHA for 34e53d1

• [hotfix][runtime] Remove legacy NullableAsyncDataInput class

  zhijiangW

  committed
  09c2c98

  Copy full SHA for 09c2c98

• [hotfix][task] Fix the code formatting in StreamTask

  zhijiangW

  committed
  ccfb82e

  Copy full SHA for ccfb82e

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

Pagination

Previous

Next