Commits

Branch selector

 master

User selector

kl0u

Datepicker

All time

Commit History

Commits on Mar 25, 2019

• [FLINK-11984][docs] MPU timeout implications on StreamingFileSink.

  kl0u

  committed
  fd318d8

Commits on Feb 28, 2019

• [FLINK-10881] Use cancelWithSavepoint in SavepointITCase test.

  Show description for bc3e665
  kl0u

  committed
  bc3e665

Commits on Feb 26, 2019

• [FLINK-11185] Fix StreamSourceOperatorWatermarksTest instability.

  Show description for 7a5f047
  kl0u

  committed
  7a5f047

Commits on Feb 22, 2019

• [hotfix] Fixing test instabilities in streaming.runtime.tasks.

  kl0u

  committed
  6051f5c

Commits on Feb 4, 2019

• [FLINK-11419][filesystem] Wait for lease to be revoked when truncating file in Hadoop.

  Show description for 892ff1d
  kl0u

  committed
  892ff1d

Commits on Jan 9, 2019

• [FLINK-10583][table] Add State Retention support to TemporalProcessTimeJoin.

  kl0u

  committed
  120c4fc

• [FLINK-10584][table] Add State Retention support to TemporalRowtimeJoin.

  kl0u

  committed
  f828031

• [hotfix] Avoid redundant state access in TemporalProcessTimeJoin.

  kl0u

  committed
  81ec2d7

• [FLINK-10583][table] Add base TwoInputStreamOperator with TTL operator.

  kl0u

  committed
  4ec77d6

Commits on Dec 18, 2018

• [FLINK-10457][fs-connector] Add SequenceFile support to StreamingFileSink.

  Show description for cf88590
  kl0u

  committed
  cf88590

Commits on Dec 5, 2018

• [FLINK-10522][fs-connector] Check if RecoverableWriter supportsResume() and act accordingly.

  Show description for 600bd9c
  kl0u

  committed
  600bd9c

Commits on Dec 4, 2018

• [FLINK-10963][fs-connector, s3] Cleanup tmp S3 objects uploaded as backups of in-progress files.

  Show description for bf5dc6c
  kl0u

  committed
  bf5dc6c

• [hotfix] Method renaming in the RecoverableMultiPartUploadImpl.

  kl0u

  committed
  153ca54

• [hotfix] Consolidated all S3 accesses under the S3AccessHelper.

  kl0u

  committed
  cf79300

• [hotfix][s3-connector] Renamed S3MultiPartUploader to S3AccessHelper.

  kl0u

  committed
  0c791cf

• [hotfix][fs-connector] Refactor Bucket to statically import Preconditions.

  kl0u

  committed
  7dc8e69

• [hotfix][fs-connector] Refactor PartFileWriter to take stream.

  kl0u

  committed
  0c1328a

Commits on Nov 16, 2018

• [FLINK-10531][e2e] Fix unstable TTL end-to-end test.

  Show description for 52c2ad0
  kl0u

  committed
  52c2ad0

Commits on Nov 8, 2018

• [FLINK-10803][docs] Update the StreamingFileSink documentation for S3.

  kl0u

  committed
  2190c6d

• [FLINK-10803][docs] Update the filesystem documentation for S3 (s3p).

  kl0u

  committed
  16e0520

Commits on Nov 1, 2018

• [FLINK-10739][tests] Harden ProcessFailureCancelingITCase.testCancelingOnProcessFailure.

  Show description for b9934c6
  kl0u

  committed
  b9934c6

• [FLINK-10097][DataStream API] Additional tests for StreamingFileSink.

  kl0u

  committed
  9ad932c

Commits on Oct 31, 2018

• [FLINK-8987][e2e] Add state evolution/migration e2e test.

  Show description for e7b7393
  kl0u

  committed
  e7b7393

Commits on Oct 12, 2018

• [hotfix] S3 tests are ignored when no credentials provided.

  kl0u

  committed
  a75da0f

Commits on Oct 11, 2018

• [FLINK-10529][build] Add flink-s3-fs-base to travis stage file.

  Show description for 86f88f7
  kl0u

  committed
  86f88f7

• [FLINK-9752][s3-fs-connector] Add s3 recoverable writer.

  Show description for 88ea996
  kl0u

  committed
  88ea996

Commits on Sep 19, 2018

• [FLINK-10366] [s3] Update build script shading checks to new patterns.

  

  kl0u

  authored and

  StephanEwen

  committed
  9d56e69

Commits on Aug 2, 2018

• [FLINK-10027][DataStream API] Add logging to StreamingFileSink.

  Show description for 852502b
  kl0u

  committed
  852502b

• [FLINK-10029][DataStream API] Refactoring the StreamingFileSink code.

  kl0u

  committed
  1b0baa1

Commits on Aug 1, 2018

• [FLINK-10005][DataStream API] StreamingFileSink: initPartCounter=maxUsed in new Buckets

  Show description for 296f6a8
  kl0u

  committed
  296f6a8

Commits on Jul 29, 2018

• [FLINK-9994][DataStream API] IntervalJoinOp Context#getTimestamp() returns max timestamp.

  Show description for dc78030
  kl0u

  committed
  dc78030

Commits on Jul 23, 2018

• [FLINK-9921][DataStream API] Update RollingPolicy interface

  kl0u

  committed
  9e348d3

Commits on Jul 20, 2018

• [FLINK-9903] [DataStream API] Refactor StreamingFileSink / add bulk encoders

  Show description for b56c75c
  

  kl0u

  authored and

  StephanEwen

  committed
  b56c75c

Commits on Jul 17, 2018

• [FLINK-9880] Fix order in BucketerContext#update.

  kl0u

  committed
  056486a

Commits on Jul 16, 2018

• [FLINK-9750] [DataStream API] Add new StreamingFileSink on top of the ResumableWriter.

  

  kl0u

  authored and

  StephanEwen

  committed
  0bbc91e

Pagination

PreviousNext