Commits

Branch selector

 master

User selector

guoweiM

Datepicker

All time

Commit History

Commits on Jul 13, 2021

• [FLINK-23235][connector] Fix SinkITCase instability

  Show description for 2268baf
  guoweiM

  committed
  2268baf

Commits on May 1, 2021

• Update japicmp configuration for 1.13.0

  guoweiM

  committed
  a76e1f8

Commits on Apr 18, 2021

• Update version to 1.14-SNAPSHOT

  guoweiM

  committed
  bb17562

Commits on Nov 30, 2020

• [FLINK-20337] Let StatefulSinkWriterOperator load StreamingFileSink's state

  Show description for ff32471
  

  guoweiM

  authored and

  aljoscha

  committed
  ff32471

Commits on Nov 8, 2020

• [FLINK-20031] Keep the UID of SinkWriter same as the SinkTransformation

  Show description for dd17dc7
  

  guoweiM

  authored and

  aljoscha

  committed
  dd17dc7

Commits on Nov 7, 2020

• [FLINK-19963] Allow SinkWriter use processing timer service.

  Show description for 0ccea43
  

  guoweiM

  authored and

  kl0u

  committed
  0ccea43

Commits on Nov 5, 2020

• [FLINK-20007] SinkTransformationTranslator connect SinkWriter to correct upstream node

  Show description for 747566d
  

  guoweiM

  authored and

  kl0u

  committed
  747566d

• [FLINK-19958] Add IOException to all I/O related Sink API signatures

  

  guoweiM

  authored and

  aljoscha

  committed
  79b1632

Commits on Nov 4, 2020

• [FLINK-19936] Stabilize the SinkITCase

  Show description for 7a2d76d
  

  guoweiM

  authored and

  kl0u

  committed
  7a2d76d

Commits on Nov 3, 2020

• [FLINK-19841] Sink API: Rename GlobalStreamingCommitterOperator to StreamingGlobalCommitterOperator

  Show description for d3fdc17
  

  guoweiM

  authored and

  kl0u

  committed
  d3fdc17

• [FLINK-19760] Sink API: Make the GlobalCommitter not extend the Committer

  Show description for 926e1bc
  

  guoweiM

  authored and

  kl0u

  committed
  926e1bc

• [FLINK-19833] Rename Sink API Writer interface to SinkWriter

  Show description for 34d0a9c
  

  guoweiM

  authored and

  kl0u

  committed
  34d0a9c

Commits on Nov 2, 2020

• [FLINK-19736] Add SinkTransformation along with Translator

  Show description for 34d143f
  

  guoweiM

  authored and

  aljoscha

  committed
  34d143f

Commits on Oct 28, 2020

• [FLINK-19834] Make the TestSink reusable in all sink related tests

  Show description for 0a98318
  

  guoweiM

  authored and

  aljoscha

  committed
  0a98318

Commits on Oct 24, 2020

• [FLINK-19696] Add committer operator for BATCH mode for the new sink API

  Show description for 8dba1a8
  

  guoweiM

  authored and

  kl0u

  committed
  8dba1a8

• [FLINK-19586] Add global committer operator for STREAMING mode for new Sink API

  Show description for ec04072
  

  guoweiM

  authored and

  kl0u

  committed
  ec04072

• [FLINK-19586] Add committer operators for STREAMING mode for new Sink API

  

  guoweiM

  authored and

  kl0u

  committed
  e90e8cc

• [FLINK-19586] Extract 'TestSink' from 'WriterOperatorTestBase'

  Show description for 07c8918
  

  guoweiM

  authored and

  kl0u

  committed
  07c8918

Commits on Oct 15, 2020

• [FLINK-19531] Add runtime writer operators for new Sink API

  Show description for 8d52860
  

  guoweiM

  authored and

  aljoscha

  committed
  8d52860

Commits on Oct 13, 2020

• [FLINK-19512] Introduce the new sink API

  Show description for 28c1646
  

  guoweiM

  authored and

  kl0u

  committed
  28c1646

• [FLINK-19511] Rename the 'SinkTransformation' to 'LegacySinkTransformation'

  Show description for f6f9cb7
  

  guoweiM

  authored and

  kl0u

  committed
  f6f9cb7

Commits on Sep 23, 2020

• [FLINK-11779] Update documentation based on bin/flink output

  

  guoweiM

  authored and

  aljoscha

  committed
  5e29fb6

• [FLINK-11779] Update documentation about ‘RestOptions’

  

  guoweiM

  authored and

  aljoscha

  committed
  6878d7c

• [FLINK-11779] Update the description of the CLI -m parameter

  Show description for 0baa1c4
  

  guoweiM

  authored and

  aljoscha

  committed
  0baa1c4

Commits on Sep 8, 2020

• [FLINK-17637][connector] fix the unstable HadoopS3RecoverableWriterITCase#testCleanupRecoverableState

  

  guoweiM

  authored and

  aljoscha

  committed
  390926e

Commits on Jun 24, 2020

• [FLINK-17639] Document which FileSystems are supported by the StreamingFileSink

  Show description for 00863a2
  

  guoweiM

  authored and

  kl0u

  committed
  00863a2

Commits on May 18, 2020

• [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

  Show description for 220f7da
  

  guoweiM

  authored and

  aljoscha

  committed
  220f7da

• [FLINK-17593][Connectors/FileSystem] Turn BucketStateSerializerTest into an upgrade test

  

  guoweiM

  authored and

  aljoscha

  committed
  f1e9362

Commits on May 17, 2020

• [FLINK-17593][fs-connector] Support arbitrary recovery mechanism for PartFileWriter

  Show description for 339f5d8
  

  guoweiM

  authored and

  JingsongLi

  committed
  339f5d8

Commits on Mar 28, 2020

• [FLINK-16262][connectors/kafka] Set the context classloader for parallel stream in FlinkKafkaProducer

  Show description for ff0d0c9
  guoweiM

  authored
  ff0d0c9

Commits on Mar 2, 2020

• [FLINK-2336][DataStream API] Fix ArrayIndexOufOBoundsException in TypeExtractor for type erased lambdas

  Show description for cc75e01
  

  guoweiM

  authored and

  StephanEwen

  committed
  cc75e01

Commits on Jan 25, 2020

• [FLINK-10819] Replace with the Flink's Deadline implementation

  Show description for 53f956f
  

  guoweiM

  authored and

  tillrohrmann

  committed
  53f956f

Commits on Dec 2, 2019

• [hotfix][docs] Fix an error in mesos.zh.md

  

  guoweiM

  authored and

  GJL

  committed
  5066a00

• [FLINK-14467][mesos] Implement user code classloading in per-job cluster

  Show description for d1926e8
  

  guoweiM

  authored and

  GJL

  committed
  d1926e8

Commits on Nov 19, 2019

• [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader

  Show description for 0a9db1e
  

  guoweiM

  authored and

  GJL

  committed
  0a9db1e

Pagination

PreviousNext