Commits

Branch selector

 release-1.2

User selector

All users

Datepicker

All time

Commit History

Commits on Apr 20, 2017

• [FLINK-6311] [kinesis] NPE in FlinkKinesisConsumer if source was closed before run

  Show description for 80dc704
  

  zhangminglei

  authored and

  tzulitai

  committed
  80dc704

Commits on Apr 18, 2017

• [FLINK-6300] Use 'exec' in start-foreground calls

  Show description for 4a1aa4c
  

  patricklucas

  authored and

  greghogan

  committed
  4a1aa4c

• [FLINK-6292] fix transfer.sh upload by using https

  Show description for 58d09d5
  

  Nico Kruber

  authored and

  zentol

  committed
  58d09d5

Commits on Apr 14, 2017

• [FLINK-6298] [java api] Set context in RichOutputFormat

  Show description for 5061e7e
  

  wenlong.lwl

  authored and

  greghogan

  committed
  5061e7e

Commits on Apr 11, 2017

• [FLINK-5756] Replace RocksDB dependency with FRocksDB

  Show description for 6e903bf
  rmetzger

  committed
  6e903bf

Commits on Apr 6, 2017

• [FLINK-4848] [ssl] Throw meaningful exception when SSL is misconfigured

  Show description for 2c0e915
  zentol

  committed
  2c0e915

• [FLINK-2814] [optimizer] DualInputPlanNode cannot be cast to SingleInputPlanNode

  Show description for fea5d1f
  greghogan

  committed
  fea5d1f

Commits on Apr 5, 2017

• [FLINK-6203] [docs] [batch] Fix scala GroupReduce example

  zentol

  committed
  f825588

• [FLINK-6181][Start scripts] Fix regex in start scripts

  Show description for d2a8df4
  

  rmetzger

  authored and

  zentol

  committed
  d2a8df4

• [FLINK-6212] [docs] Add avro dependency reference

  Show description for 36b068b
  

  omrsin

  authored and

  zentol

  committed
  36b068b

Commits on Apr 4, 2017

• Revert "[FLINK-5808] Move default parallelism to StreamingJobGraphGenerator"

  Show description for 3e41ed1
  aljoscha

  committed
  3e41ed1

• Revert "[FLINK-5808] Move max keygroup constants to ExecutionConfig"

  Show description for fd98e8b
  aljoscha

  committed
  fd98e8b

• Revert "[FLINK-5808] Add proper checks in setParallelism()/setMaxParallelism()"

  Show description for 04a1d6b
  aljoscha

  committed
  04a1d6b

• [FLINK-6183] [metrics] Prevent some cases of TaskMG not being closed

  Show description for 3c63c9e
  zentol

  committed
  3c63c9e

• [FLINK-6184] Prevent NPE in buffer metrics

  zentol

  committed
  961134d

Commits on Mar 31, 2017

• [FLINK-6044] Replace all unintentional calls to InputStream#read(...) with InputStream#readFully(...)

  

  StefanRRichter

  authored and

  fhueske

  committed
  a359b4c

Commits on Mar 28, 2017

• [FLINK-6207] Duplicate TypeSerializers for async snapshots of CopyOnWriteStateTable

  StefanRRichter

  committed
  bb3e26f

Commits on Mar 25, 2017

• [hotfix] [kafka] Add log info for partitions subscribed by FlinkKafkaConsumer subtasks

  tzulitai

  committed
  75db91e

Commits on Mar 24, 2017

• [FLINK-5715] Asynchronous snapshots for heap-based keyed state backend (backport from 1.3)

  StefanRRichter

  committed
  c6a8072

• [FLINK-6182] Fix possible NPE in SourceStreamTask

  Show description for b703a24
  uce

  committed
  b703a24

• [FLINK-5972] Don't allow shrinking merging windows

  Show description for b998834
  

  aljoscha

  authored and

  tzulitai

  committed
  b998834

• [hotfix] Fix various small issues in WindowOperatorContractTest

  

  aljoscha

  authored and

  tzulitai

  committed
  785ae63

• [hotfix] Add EvictingWindowOperatorContractTest

  Show description for e27b697
  

  aljoscha

  authored and

  tzulitai

  committed
  e27b697

Commits on Mar 22, 2017

• [FLINK-6170] [metrics] Don't rely on stats snapshot for checkpoint metrics

  Show description for 7fbb115
  uce

  committed
  7fbb115

• [FLINK-6139] [doc] Add documentation for running Flink on MapR

  Show description for 09239ea
  tzulitai

  committed
  09239ea

• [FLINK-6139] [build] Add "mapr" build profile

  Show description for b4d1eb4
  tzulitai

  committed
  b4d1eb4

Commits on Mar 21, 2017

• [FLINK-6084][Cassandra] Promote transitive dependencies

  Show description for ffd146a
  rmetzger

  committed
  ffd146a

• [FLINK-6000] [scripts] Fix starting HA cluster with start-cluster.sh

  Show description for d398205
  

  dawidwys

  authored and

  StephanEwen

  committed
  d398205

• [FLINK-4326] [scripts] [fixup] Fix taskmanager bash script

  StephanEwen

  committed
  d4bfee9

• [FLINK-4326] [scripts] Flink foreground services

  Show description for 88db01a
  

  greghogan

  authored and

  StephanEwen

  committed
  88db01a

Commits on Mar 20, 2017

• [docs] Document per-Kafka-partition watermarks

  StephanEwen

  committed
  fb95f02

• [FLINK-5985] Report no task states for stateless tasks on checkpointing

  StefanRRichter

  committed
  a9e74b5

Commits on Mar 18, 2017

• [FLINK-5808] Add proper checks in setParallelism()/setMaxParallelism()

  Show description for 99fb80b
  aljoscha

  committed
  99fb80b

• [FLINK-5808] Move max keygroup constants to ExecutionConfig

  Show description for d3b275f
  aljoscha

  committed
  d3b275f

• [FLINK-5808] Move default parallelism to StreamingJobGraphGenerator

  Show description for b563f0a
  aljoscha

  committed
  b563f0a

Pagination

PreviousNext