Commits

Branch selector

 master

User selector

bowenli86

Datepicker

All time

Commit History

Commits on Nov 30, 2017

• [FLINK-8076] [kinesis] Upgrade KinesisProducer to 0.10.6 to set properties approperiately

  Show description for be91310
  

  bowenli86

  authored and

  tzulitai

  committed
  be91310

  Copy full SHA for be91310

Commits on Nov 23, 2017

• [FLIN-6505] Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

  

  bowenli86

  authored and

  StefanRRichter

  committed
  ccf917d

  Copy full SHA for ccf917d

Commits on Nov 6, 2017

• [hotfix][java] Add missing space to error message

  Show description for 2d56b11
  

  bowenli86

  authored and

  zentol

  committed
  2d56b11

  Copy full SHA for 2d56b11

Commits on Oct 26, 2017

• [hotfix] Reorder ProcessOperator methods so they conform to the order in the interface

  

  bowenli86

  authored and

  aljoscha

  committed
  68f446c

  Copy full SHA for 68f446c

• [FLINK-5967] Add support for AggregatingState in user functions

  Show description for e7a0609
  

  bowenli86

  authored and

  aljoscha

  committed
  e7a0609

  Copy full SHA for e7a0609

Commits on Oct 24, 2017

• [FLINK-7388] Don't set processing time as timestamp in ProcessFunction.onTimer()

  

  bowenli86

  authored and

  aljoscha

  committed
  904c951

  Copy full SHA for 904c951

• [FLINK-7864] Support side-outputs in CoProcessFunction

  

  bowenli86

  authored and

  aljoscha

  committed
  35ad539

  Copy full SHA for 35ad539

Commits on Oct 23, 2017

• [FLINK-6245] Fix late side output documentation in Window documents.

  

  bowenli86

  authored and

  aljoscha

  committed
  b2cc451

  Copy full SHA for b2cc451

Commits on Oct 20, 2017

• [hotfix][javadocs] Fix typos in RuntimeContext

  Show description for bc065cd
  

  bowenli86

  authored and

  zentol

  committed
  bc065cd

  Copy full SHA for bc065cd

Commits on Oct 15, 2017

• [FLINK-6703][docs] Document how to take a savepoint on YARN

  Show description for 89394ec
  

  bowenli86

  authored and

  zentol

  committed
  89394ec

  Copy full SHA for 89394ec

Commits on Oct 12, 2017

• [doc] Add ProcessWindowFunction to side output doc

  

  bowenli86

  authored and

  aljoscha

  committed
  4f8d01f

  Copy full SHA for 4f8d01f

• [FLINK-7660] Support sideOutput in ProcessAllWindowFunction

  

  bowenli86

  authored and

  aljoscha

  committed
  39682c4

  Copy full SHA for 39682c4

Commits on Sep 28, 2017

• [FLINK-7674] Fix NullPointerException in ContinuousFileMonitoringFunction#close

  Show description for 819fe20
  

  bowenli86

  authored and

  zentol

  committed
  819fe20

  Copy full SHA for 819fe20

• [FLINK-7659] Fix unprotected access to inProgress in JobCancellationWithSavepointHandlers#handleNewRequest

  Show description for 1b71040
  

  bowenli86

  authored and

  zentol

  committed
  1b71040

  Copy full SHA for 1b71040

• [FLINK-7724] [metrics] Add extra metrics to MetricStoreTest.setupStore

  Show description for f85bbf3
  

  bowenli86

  authored and

  zentol

  committed
  f85bbf3

  Copy full SHA for f85bbf3

Commits on Sep 26, 2017

• [FLINK-7393] [kinesis] Move unit tests of KinesisConfigUtil from FlinkKinesisConsumerTest to KinesisConfigUtilTest

  Show description for ff417e7
  

  bowenli86

  authored and

  tzulitai

  committed
  ff417e7

  Copy full SHA for ff417e7

Commits on Sep 25, 2017

• [FLINK-7635] Support side output in ProcessWindowFunction

  

  bowenli86

  authored and

  aljoscha

  committed
  c151a53

  Copy full SHA for c151a53

• [hotfix] Fix typos and other small things

  

  bowenli86

  authored and

  aljoscha

  committed
  d8ed58b

  Copy full SHA for d8ed58b

Commits on Sep 22, 2017

• [FLINK-7600] [kinesis] Shorten credential update delay to avoid updateCredentials Exception

  Show description for 6c1a946
  

  bowenli86

  authored and

  tzulitai

  committed
  6c1a946

  Copy full SHA for 6c1a946

• [FLINK-7508] [kinesis] Switch to POOLED ThreadingMode in FlinkKinesisProducer

  Show description for 637dde8
  

  bowenli86

  authored and

  tzulitai

  committed
  637dde8

  Copy full SHA for 637dde8

Commits on Sep 19, 2017

• [FLINK-7609][examples] Adjust WindowWordCount default window configuration values

  Show description for baebbab
  

  bowenli86

  authored and

  zentol

  committed
  baebbab

  Copy full SHA for baebbab

• [FLINK-6549] [datastream] Improve error message for type mismatches with side outputs

  Show description for 5fc1103
  

  bowenli86

  authored and

  zentol

  committed
  5fc1103

  Copy full SHA for 5fc1103

Commits on Sep 7, 2017

• [FLINK-7367] [kinesis] Generalize configuration for FlinkKinesisProducer properties

  

  bowenli86

  authored and

  tzulitai

  committed
  9ed5d9a

  Copy full SHA for 9ed5d9a

Commits on Sep 1, 2017

• [FLINK-7422] Upgrade Kinesis Client Library (KCL) and AWS SDK in flink-connector-kinesis

  

  bowenli86

  authored and

  aljoscha

  committed
  c872751

  Copy full SHA for c872751

Commits on Aug 29, 2017

• FLINK-7366 Upgrade kinesis-producer-library in flink-connector-kinesis from 0.10.2 to 0.12.5

  Show description for b915757
  

  bowenli86

  authored and

  rmetzger

  committed
  b915757

  Copy full SHA for b915757

• [FLINK-7454] [docs] Uupdate 'Monitoring Current Event Time' section

  Show description for 257a5a5
  

  bowenli86

  authored and

  zentol

  committed
  257a5a5

  Copy full SHA for 257a5a5

Commits on Aug 15, 2017

• [FLINK-7405] [metrics] Reduce excessive warning logging from DatadogHttpReporter

  Show description for 3b0321a
  

  bowenli86

  authored and

  zentol

  committed
  3b0321a

  Copy full SHA for 3b0321a

Commits on Aug 3, 2017

• [FLINK-7356] [config] misleading s3 file uri in configuration file

  Show description for 40901ed
  

  bowenli86

  authored and

  tzulitai

  committed
  40901ed

  Copy full SHA for 40901ed

Commits on Jul 25, 2017

• [FLINK-6940] [docs] Clarify the effect of configuring per-job state

  Show description for 8215f2e
  

  bowenli86

  authored and

  zentol

  committed
  8215f2e

  Copy full SHA for 8215f2e

Commits on Jul 24, 2017

• [FLINK-6365] [kinesis] Adapt default values of the Kinesis connector

  Show description for 35564f2
  

  bowenli86

  authored and

  tzulitai

  committed
  35564f2

  Copy full SHA for 35564f2

Commits on Jun 22, 2017

• [FLINK-6806] [docs] Add RocksDB to listed state backends in doc

  Show description for 2324a8e
  

  bowenli86

  authored and

  tzulitai

  committed
  2324a8e

  Copy full SHA for 2324a8e

Commits on May 9, 2017

• [FLINK-6013][metrics] Add Datadog HTTP metrics reporter

  Show description for 54ceec1
  

  bowenli86

  authored and

  zentol

  committed
  54ceec1

  Copy full SHA for 54ceec1

Commits on Apr 28, 2017

• [FLINK-6386] Missing bracket in 'Compiler Limitation' section

  Show description for 753763a
  

  bowenli86

  authored and

  tillrohrmann

  committed
  753763a

  Copy full SHA for 753763a

Commits on Mar 20, 2017

• [FLINK-6122] Add Travis build status to README

  Show description for 486f724
  

  bowenli86

  authored and

  uce

  committed
  486f724

  Copy full SHA for 486f724

Commits on Mar 10, 2017

• [FLINK-6010] [docs] Correct IntelliJ IDEA Plugins path in 'Installing the Scala plugin' section

  Show description for a87b527
  

  bowenli86

  authored and

  StephanEwen

  committed
  a87b527

  Copy full SHA for a87b527

Pagination

Previous

Next