Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Sep 19, 2016

• [FLINK-4610] [core] Replace keySet/getValue with entrySet in UdfAnalyzerUtils

  Show description for 5901bf3
  

  apivovarov

  authored and

  StephanEwen

  committed
  5901bf3

  Copy full SHA for 5901bf3

• [FLINK-4625] [core] Add a safety net to forcibly terminate JVM is clean shutdown freezed.

  StephanEwen

  committed
  5066125

  Copy full SHA for 5066125

• [FLINK-4081] [core] [table] FieldParsers should support empty strings

  Show description for 4b1a9c7
  twalthr

  committed
  4b1a9c7

  Copy full SHA for 4b1a9c7

Commits on Sep 16, 2016

• [FLINK-4622] Include 'savepoint' in the CLI help message

  Show description for d7b59d7
  

  skidder

  authored and

  zentol

  committed
  d7b59d7

  Copy full SHA for d7b59d7

• [FLINK-4607] Close FileInputStream in ParameterTool and other

  Show description for db90580
  

  apivovarov

  authored and

  zentol

  committed
  db90580

  Copy full SHA for db90580

• [FLINK-4608] Use short-circuit AND in Max/Min AggregationFunction

  Show description for 9046374
  

  apivovarov

  authored and

  zentol

  committed
  9046374

  Copy full SHA for 9046374

• [FLINK-4612] Close FileWriter using try with resources

  Show description for f06930b
  

  apivovarov

  authored and

  zentol

  committed
  f06930b

  Copy full SHA for f06930b

• [FLINK-4626] Add missing break in MEtricStore#add()

  zentol

  committed
  1586fc8

  Copy full SHA for 1586fc8

Commits on Sep 15, 2016

• [FLINK-4589] [DataStream API] Fix Merging of Covering Window in MergingWindowSet

  Show description for 7143a24
  

  aljoscha

  authored and

  StephanEwen

  committed
  7143a24

  Copy full SHA for 7143a24

• [hotfix] [metrics] Add missing @internal annotations

  zentol

  committed
  0492dcc

  Copy full SHA for 0492dcc

• [FLINK-4389] Expose metrics to WebFrontend

  Show description for 70704de
  zentol

  committed
  70704de

  Copy full SHA for 70704de

• [FLINK-4599] [table] Add 'explain()' also to StreamTableEnvironment

  Show description for 545b72b
  

  chobeat

  authored and

  twalthr

  committed
  545b72b

  Copy full SHA for 545b72b

• [FLINK-3497] [table] Add SQRT function

  twalthr

  committed
  5fdc720

  Copy full SHA for 5fdc720

Commits on Sep 9, 2016

• [FLINK-3580] [table] Add QUARTER function

  twalthr

  committed
  9420a77

  Copy full SHA for 9420a77

• [FLINK-4592] [table] Fix flaky test ScalarFunctionsTest.testCurrentTimePoint

  twalthr

  committed
  8c0d624

  Copy full SHA for 8c0d624

• [FLINK-4601] [java] Check for empty string properly

  Show description for e92f91a
  

  apivovarov

  authored and

  twalthr

  committed
  e92f91a

  Copy full SHA for e92f91a

• [FLINK-3497] [table] Add POSITION/OVERLAY functions

  twalthr

  committed
  95b673f

  Copy full SHA for 95b673f

Commits on Sep 8, 2016

• [FLINK-4571] [gelly] Configurable little parallelism in Gelly drivers

  Show description for bdd3c0d
  greghogan

  committed
  bdd3c0d

  Copy full SHA for bdd3c0d

• [FLINK-4257] [gelly] Handle delegating algorithm change of class

  Show description for 8210ff4
  greghogan

  committed
  8210ff4

  Copy full SHA for 8210ff4

• [FLINK-4522] [docs] Gelly link broken in homepage

  Show description for 95ad865
  greghogan

  committed
  95ad865

  Copy full SHA for 95ad865

• [FLINK-4456] Replace Akka specific types by interfaces in Task

  Show description for 0735b5b
  tillrohrmann

  committed
  0735b5b

  Copy full SHA for 0735b5b

• [FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFlinkMiniCluster

  Show description for 02b852e
  tillrohrmann

  committed
  02b852e

  Copy full SHA for 02b852e

• [FLINK-4595] Close FileOutputStream in ParameterTool

  Show description for 920cda4
  

  apivovarov

  authored and

  zentol

  committed
  920cda4

  Copy full SHA for 920cda4

• [FLINK-4436] Unclosed DataOutputBuffer in Utils#setTokensFor()

  Show description for 7e07bde
  

  biaoma-ty

  authored and

  zentol

  committed
  7e07bde

  Copy full SHA for 7e07bde

Commits on Sep 6, 2016

• [FLINK-4265] [dataset api] Add a NoOpOperator

  Show description for 66d4b87
  greghogan

  committed
  66d4b87

  Copy full SHA for 66d4b87

• [FLINK-4559][kinesis-connector] Fix AWSUtil.getCredentialsProvider() to not return null

  Show description for cab76f6
  tzulitai

  committed
  cab76f6

  Copy full SHA for cab76f6

• [FLINK-4073] remove unstable testing code in TaskManagerFailure test

  Show description for 87aea72
  mxm

  committed
  87aea72

  Copy full SHA for 87aea72

Commits on Sep 5, 2016

• [FLINK-4073] fix stability of TaskManagerFailure test

  mxm

  committed
  2f87f61

  Copy full SHA for 2f87f61

• [hotfix] Delete leftover (superseded) StreamTaskAsyncCheckpointTest

  Show description for 9bbb8fa
  aljoscha

  committed
  9bbb8fa

  Copy full SHA for 9bbb8fa

Commits on Sep 4, 2016

• [FLINK-4459] [distributed runtime] Introduce SlotProvider for Scheduler

  Show description for 6e40f59
  

  KurtYoung

  authored and

  StephanEwen

  committed
  6e40f59

  Copy full SHA for 6e40f59

Commits on Sep 2, 2016

• [FLINK-4570] remove conflicting Unicode character

  Show description for 502a79d
  mxm

  committed
  502a79d

  Copy full SHA for 502a79d

• [FLINK-3580] [table] Add current time point functions

  Show description for e376c00
  twalthr

  committed
  e376c00

  Copy full SHA for e376c00

• [FLINK-4525] [core] (followup) Remove remaining redundant code for pre-defined strictly local assignments.

  StephanEwen

  committed
  fb8f2c9

  Copy full SHA for fb8f2c9

• [FLINK-4490] [distributed coordination] (part 3) Rename methods on 'Instance' to have more intuitive names

  Show description for eac6088
  StephanEwen

  committed
  eac6088

  Copy full SHA for eac6088

• [FLINK-4490] [distributed coordination] (part 2) Make slots independent of 'Instance'.

  Show description for aaa474a
  StephanEwen

  committed
  aaa474a

  Copy full SHA for aaa474a

Pagination

Previous

Next