Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Apr 19, 2016

• [hotfix] [cep] Make cep window border treatment consistent

  Show description for 7462a5b
  tillrohrmann

  committed
  7462a5b

  Copy full SHA for 7462a5b

• [FLINK-3764] [tests] Improve LeaderChangeStateCleanupTest stability

  Show description for 716d832
  

  tillrohrmann

  authored and

  zentol

  committed
  716d832

  Copy full SHA for 716d832

• [FLINK-3748] [table] Add CASE function to Table API

  Show description for 4be297e
  twalthr

  committed
  4be297e

  Copy full SHA for 4be297e

Commits on Apr 18, 2016

• [FLINK-3770] [gelly] Fix TriangleEnumerator performance

  Show description for 85fcfc4
  greghogan

  committed
  85fcfc4

  Copy full SHA for 85fcfc4

• [FLINK-3587] Bump Calcite version to 1.7.0

  Show description for 367687d
  

  fhueske

  authored and

  zentol

  committed
  367687d

  Copy full SHA for 367687d

• [FLINK-3664] Create DataSetUtils method to easily summarize a DataSet of Tuples

  Show description for 7eb5877
  

  Todd Lisonbee

  authored and

  zentol

  committed
  7eb5877

  Copy full SHA for 7eb5877

• [FLINK-3773] Scanners are left unclosed in SqlExplainTest

  Show description for fabc5f9
  

  samaitra

  authored and

  zentol

  committed
  fabc5f9

  Copy full SHA for fabc5f9

• [FLINK-2732] Display TM logs in Dashboard

  Show description for 6d53bbc
  zentol

  committed
  6d53bbc

  Copy full SHA for 6d53bbc

Commits on Apr 15, 2016

• [FLINK-3657] [dataSet] Change access of DataSetUtils.countElements() to 'public'

  Show description for 5f993c6
  

  smarthi

  authored and

  fhueske

  committed
  5f993c6

  Copy full SHA for 5f993c6

• [FLINK-2544] [docs] Add Java 8 version for building PowerMock tests to docs

  Show description for d938c5f
  

  skavulya

  authored and

  fhueske

  committed
  d938c5f

  Copy full SHA for d938c5f

• [FLINK-3762] [core] Enable Kryo reference tracking

  Show description for dc78a74
  

  andrewpalumbo

  authored and

  fhueske

  committed
  dc78a74

  Copy full SHA for dc78a74

• [FLINK-3732] [core] Fix potential null deference in ExecutionConfig#equals()

  Show description for f3d3a44
  

  Tianji Li

  authored and

  fhueske

  committed
  f3d3a44

  Copy full SHA for f3d3a44

• [FLINK-3759] [table] Throw exception if NULL literal is encountered in non-null mode.

  Show description for 722155a
  

  twalthr

  authored and

  fhueske

  committed
  722155a

  Copy full SHA for 722155a

• [FLINK-3738] [table] Refactor TableEnvironments. Remove Translators and TranslationContext.

  Show description for 1acd844
  fhueske

  committed
  1acd844

  Copy full SHA for 1acd844

• [FLINK-3700] [core] Remove Guava dependency from flink-core

  Show description for 760a0d9
  

  StephanEwen

  authored and

  fhueske

  committed
  760a0d9

  Copy full SHA for 760a0d9

• [hotfix] Make initial currentWatermark==Long.MIN_VALUE everywhere

  aljoscha

  committed
  1b93b32

  Copy full SHA for 1b93b32

• [FLINK-3739] [table] Add a null literal to Table API

  Show description for 50d8797
  twalthr

  committed
  50d8797

  Copy full SHA for 50d8797

Commits on Apr 14, 2016

• [FLINK-3760] Fix StateDescriptor.readObject

  aljoscha

  committed
  494212b

  Copy full SHA for 494212b

Commits on Apr 13, 2016

• [FLINK-3743] upgrading breeze from 0.11.2 to 0.12

  Show description for 1a34f21
  

  Todd Lisonbee

  authored and

  StephanEwen

  committed
  1a34f21

  Copy full SHA for 1a34f21

• [FLINK-3375] [Kafka Connector] Add tests for per-kafka-partition watermarks.

  StephanEwen

  committed
  2dcd27f

  Copy full SHA for 2dcd27f

• [FLINK-3747] Consolidate TimestampAssigner Methods in Kafka Consumer

  Show description for e40e29d
  

  aljoscha

  authored and

  StephanEwen

  committed
  e40e29d

  Copy full SHA for e40e29d

• [FLINK-3745] [runtime] Fix early stopping of stream sources

  StephanEwen

  committed
  8570b6d

  Copy full SHA for 8570b6d

• [hotfix] [kafka consumer] Increase Kafka test stability

  StephanEwen

  committed
  2728f92

  Copy full SHA for 2728f92

• [FLINK-2909] [gelly] Graph Generators

  Show description for b0a7a1b
  

  greghogan

  authored and

  EC2 Default User

  committed
  b0a7a1b

  Copy full SHA for b0a7a1b

• [FLINK-3589] Allow setting Operator parallelism to default value

  Show description for 5350bc4
  greghogan

  committed
  5350bc4

  Copy full SHA for 5350bc4

• [hotfix] [tests] Add cross transformation to OverwriteObjects manual test

  greghogan

  committed
  6c06168

  Copy full SHA for 6c06168

• [hotfix] [storm] Add proper exception forwarding to FlinkTopology.copyObject

  tillrohrmann

  committed
  e7d78e6

  Copy full SHA for e7d78e6

• [FLINK-3735] Make DataSetUnionRule match only for union-all

  Show description for 8e036c3
  vasia

  committed
  8e036c3

  Copy full SHA for 8e036c3

• [FLINK-3730] Fix RocksDB Local Directory Initialization

  aljoscha

  committed
  db6528b

  Copy full SHA for db6528b

Commits on Apr 12, 2016

• [FLINK-3126] [core] Remove accumulator type from "value" in web frontend

  Show description for db85f38
  

  Zack Pierce

  authored and

  StephanEwen

  committed
  db85f38

  Copy full SHA for db85f38

• [FLINK-3737] [tests] Adding comment about SOCKS proxy server for WikipediaEditsSourceTest

  Show description for 342db48
  

  Todd Lisonbee

  authored and

  StephanEwen

  committed
  342db48

  Copy full SHA for 342db48

• [FLINK-3644] [web monitor] Add new config option to set web monitor tmp dir

  Show description for b188637
  

  xueyan.li

  authored and

  StephanEwen

  committed
  b188637

  Copy full SHA for b188637

• [FLINK-3444] [APIs] Add fromElements method with based class type to avoid the exception.

  Show description for 6bb085e
  

  gallenvara

  authored and

  StephanEwen

  committed
  6bb085e

  Copy full SHA for 6bb085e

• [FLINK-3541] [Kafka Connector] Clean up workaround in FlinkKafkaConsumer09

  Show description for 693d5ab
  

  skyahead

  authored and

  StephanEwen

  committed
  693d5ab

  Copy full SHA for 693d5ab

• [hotfix] [kafka consumer] Increase Kafka test stability by validating written data before consuming

  StephanEwen

  committed
  d20eda1

  Copy full SHA for d20eda1

Pagination

Previous

Next