Commits

Branch selector

 master

User selector

becketqin

Datepicker

All time

Commit History

Commits on Jun 24, 2020

• [FLINK-18428][API/DataStream] Rename StreamExecutionEnvironment#continuousSource() to StreamExecutionEnvironment#source().

  Show description for 49b5103
  

  becketqin

  authored and

  StephanEwen

  committed
  49b5103

  Copy full SHA for 49b5103

Commits on Jun 16, 2020

• [FLINK-18322][connector/common][tests] Fix unstable ExecutorNotifierTest#testExceptionInHandler (apache#12676)

  becketqin

  authored
  8e2af35

  Copy full SHA for 8e2af35

Commits on Jun 15, 2020

• [FLINK-18162][connector/common] Serialize the splits in the AddSplitsEvent.

  becketqin

  committed
  f883f11

  Copy full SHA for f883f11

• [FLINK-18039] Ensure the source events are sent via the coordinator thread.

  becketqin

  committed
  e01cab2

  Copy full SHA for e01cab2

• [FLINK-18039][connector/common] Introduce a RecreateOnResetOperatorCoordinator class to recreate an OperatorCoordinator instance when resetToCheckpoint() is invoked. Let SourceCoordinator leverage …

  Show description for 24201cc
  becketqin

  committed
  24201cc

  Copy full SHA for 24201cc

Commits on Jun 10, 2020

• [hotfix][doc] Some minor languange clean-ups for the Source doc.

  becketqin

  committed
  162994f

  Copy full SHA for 162994f

Commits on Jun 9, 2020

• [FLINK-10740][docs] Add documentation for FLIP-27 Source API and SplitReader API.

  

  becketqin

  authored and

  StephanEwen

  committed
  9fc1ac4

  Copy full SHA for 9fc1ac4

Commits on May 20, 2020

• [FLINK-12030][connector/kafka] Check the topic existence after topic creation using KafkaConsumer.

  becketqin

  committed
  51a0d42

  Copy full SHA for 51a0d42

Commits on May 17, 2020

• [FLINK-15102][datastream/api] Add continuousSource() methods to the StreamExecutionEvironment.

  Show description for 7abced6
  becketqin

  committed
  7abced6

  Copy full SHA for 7abced6

Commits on May 12, 2020

• [FLINK-16845] Adds implmentation of SourceOperator. This patch does the following:

  Show description for aa1ede9
  becketqin

  committed
  aa1ede9

  Copy full SHA for aa1ede9

Commits on May 5, 2020

• [FLINK-15101][connector/common] Add the SourceCoordinator implementation

  becketqin

  committed
  ed40049

  Copy full SHA for ed40049

Commits on Apr 27, 2020

• [FLINK-17268][connector/common] Fix the shutdown sequence in SplitFetcher to avoid blocking on shutdown.

  Show description for 90a38e8
  becketqin

  committed
  90a38e8

  Copy full SHA for 90a38e8

• [hotfix] Remove the unused Boundedness parameter.

  becketqin

  committed
  b7b2c43

  Copy full SHA for b7b2c43

• [FLINk-17268][connector/common] Fix the bug of missing records during SplitFetcher wakeup. Added unit test for SplitFetcher.

  becketqin

  committed
  237a63f

  Copy full SHA for 237a63f

Commits on Mar 29, 2020

• [FLINK-15101][hotfix] Remove the BOUNDEDNESS option from SourceReaderOptions

  becketqin

  committed
  ae3b0ff

  Copy full SHA for ae3b0ff

Commits on Mar 28, 2020

• [FLINK-15100][connector/common] Add abstract implementation for SourceReader (FLIP-27).

  becketqin

  committed
  4f6efed

  Copy full SHA for 4f6efed

Commits on Mar 10, 2020

• [FLINK-15131][connector/source] Add the APIs for Source (FLIP-27).

  Show description for 5a81fa0
  becketqin

  committed
  5a81fa0

  Copy full SHA for 5a81fa0

Commits on Jan 16, 2020

• [FLINK-13595][connector/kafka][test] Close the KafkaAdminClient with a timeout. Print stacktrace if a long closure happens.

  becketqin

  committed
  fff0952

  Copy full SHA for fff0952

Commits on Jan 10, 2020

• [FLINK-15490][kafka][test-stability] Enable idempotence producing in KafkaITCase to avoid intermittent test failure.

  becketqin

  committed
  f0f9343

  Copy full SHA for f0f9343

Commits on Oct 28, 2019

• [hotfix][kafka][test-stability] Accelerate the KafkaProducerTest by reducing the timeout values.

  becketqin

  committed
  96640ca

  Copy full SHA for 96640ca

• [FLINK-14370][kafka][test-stability] Fix the cascading test failure in KafkaProducerTestBase.

  becketqin

  committed
  6e7bdc3

  Copy full SHA for 6e7bdc3

Commits on Aug 1, 2019

• [hotfix] Fix static inner class name collision in KafkaConsumerTestBase.

  becketqin

  committed
  09f96b3

  Copy full SHA for 09f96b3

• [FLINK-13226][connector/kafka] Fix deadlock between producer closure and transaction commit in the universal Kafka connector.

  Show description for cc3184a
  becketqin

  committed
  cc3184a

  Copy full SHA for cc3184a

• [FLINK-13226][connector/kafka] Fix deadlock between producer closure and transaction commit in Kafka connector 0.11

  Show description for 6d47498
  becketqin

  committed
  6d47498

  Copy full SHA for 6d47498

Commits on Jul 5, 2019

• [FLINK-9311] [pubsub] Improvements to builders + minor improvement to PubSubSink flush logic

  

  becketqin

  authored and

  rmetzger

  committed
  f2494ce

  Copy full SHA for f2494ce

Commits on Jun 11, 2019

• [FLINK-10455][Connectors/Kafka] Ensure all the KafkaProducers closed on an exception

  Show description for 8364849
  

  becketqin

  authored and

  pnowojski

  committed
  8364849

  Copy full SHA for 8364849