Commits

Branch selector

 master

User selector

aljoscha

Datepicker

All time

Commit History

Commits on Jun 10, 2015

• [FLINK-2191] Fix inconsistent use of closure cleaner in Scala Streaming

  Show description for e2304c4
  

  aljoscha

  authored and

  mbalassi

  committed
  e2304c4

  Copy full SHA for e2304c4

• [hotfix] Bring KMeansDataGenerator and KMeans quickstart in sync

  aljoscha

  committed
  b5b71e1

  Copy full SHA for b5b71e1

Commits on Jun 9, 2015

• [FLINK-2182] Add stateful Streaming Sequence Source

  Show description for 31d3eaa
  

  aljoscha

  authored and

  mbalassi

  committed
  31d3eaa

  Copy full SHA for 31d3eaa

• [hotfix] Fix YARNSessionFIFOITCase

  Show description for 2eb5cfe
  aljoscha

  committed
  2eb5cfe

  Copy full SHA for 2eb5cfe

Commits on Jun 8, 2015

• [FLINK-2054] Add object-reuse switch for streaming

  Show description for 26304c2
  aljoscha

  committed
  26304c2

  Copy full SHA for 26304c2

Commits on Jun 6, 2015

• [hotfix][doc] Fix typo in Scala Shell doc

  aljoscha

  committed
  1ac0fb4

  Copy full SHA for 1ac0fb4

Commits on Jun 5, 2015

• [FLINK-2160] Change Streaming Source Interface to run(Context)/cancel()

  Show description for 235b02c
  aljoscha

  committed
  235b02c

  Copy full SHA for 235b02c

Commits on Jun 4, 2015

• [FLINK-2098] Ensure checkpoints and element emission are in order

  Show description for 6685b0b
  aljoscha

  committed
  6685b0b

  Copy full SHA for 6685b0b

Commits on Jun 3, 2015

• [FLINK-2069] Fix Scala CSV Output Format

  Show description for a750415
  

  aljoscha

  authored and

  mbalassi

  committed
  a750415

  Copy full SHA for a750415

• [FLINK-2103] [streaming] [api-extending] Expose partitionBy to user

  Show description for a43e0d5
  

  aljoscha

  authored and

  mbalassi

  committed
  a43e0d5

  Copy full SHA for a43e0d5

Commits on May 28, 2015

• Properly include Scala Shell in Documentation

  Show description for 4118160
  aljoscha

  committed
  4118160

  Copy full SHA for 4118160

• Some code cleanups on Scala Shell

  aljoscha

  committed
  6bb6de2

  Copy full SHA for 6bb6de2

• [FLINK-2096] Remove implicit conversion from Window Stream to Stream

  Show description for 7ec95c9
  aljoscha

  committed
  7ec95c9

  Copy full SHA for 7ec95c9

Commits on May 27, 2015

• [stream] Remove unused StreamSource.java

  Show description for 8e35feb
  aljoscha

  committed
  8e35feb

  Copy full SHA for 8e35feb

Commits on May 26, 2015

• Fix moved comment in StreamTask

  aljoscha

  committed
  4dcfc43

  Copy full SHA for 4dcfc43

• [FLINK-2074] Fix erroneous emission of Sliding Time PreReducer

  Show description for 6bc6dbe
  aljoscha

  committed
  6bc6dbe

  Copy full SHA for 6bc6dbe

Commits on May 22, 2015

• [hotfix][table] Fix not-equals code generation

  Show description for 24c4f83
  aljoscha

  committed
  24c4f83

  Copy full SHA for 24c4f83

Commits on May 21, 2015

• [FLINK-2052] Fix Serialization warnings in Stream Operators

  Show description for 8b904ae
  

  aljoscha

  authored and

  StephanEwen

  committed
  8b904ae

  Copy full SHA for 8b904ae

• [FLINK-2023] [scala] Improve type analysis

  Show description for f8a381f
  

  aljoscha

  authored and

  StephanEwen

  committed
  f8a381f

  Copy full SHA for f8a381f

• [FLINK-1418] [apis] Change print() to print on the client and to eagerly execute the program.

  Show description for e9c1562
  

  aljoscha

  authored and

  StephanEwen

  committed
  e9c1562

  Copy full SHA for e9c1562

Commits on May 19, 2015

• Disable Test in ComplexIntegrationTest

  aljoscha

  committed
  f59d6a1

  Copy full SHA for f59d6a1

• [FLINK-2009] Force chaining for System Operators

  Show description for a04f091
  aljoscha

  committed
  a04f091

  Copy full SHA for a04f091

• [FLINK-1977] Rework Stream Operators to always be push based

  aljoscha

  committed
  58865ff

  Copy full SHA for 58865ff

Commits on May 18, 2015

• [hotfix] Fix link to coding guidelines

  aljoscha

  committed
  7378054

  Copy full SHA for 7378054

Commits on May 15, 2015

• [hotfix] Add missing import

  aljoscha

  committed
  8f28f41

  Copy full SHA for 8f28f41

Commits on May 8, 2015

• [FLINK-1998][table] Fix equals expression

  Show description for 84dcb7c
  aljoscha

  committed
  84dcb7c

  Copy full SHA for 84dcb7c

• [FLINK-1997][table] Add <> and != for un-equal in expressions

  aljoscha

  committed
  3b8f60e

  Copy full SHA for 3b8f60e

Commits on Apr 30, 2015

• [hotfix] Remove asm dependency from root pom

  aljoscha

  committed
  58de10a

  Copy full SHA for 58de10a

Commits on Apr 27, 2015

• [hotfix] Raise Akka test timeouts some more

  aljoscha

  committed
  a2c9cbb

  Copy full SHA for a2c9cbb

Commits on Apr 24, 2015

• [FLINK-1867/1880] Raise test timeouts in hope of fixing Travis fails

  aljoscha

  committed
  b2aafe5

  Copy full SHA for b2aafe5

• [hotfix] Bump asm version to 5.0.3

  aljoscha

  committed
  2347363

  Copy full SHA for 2347363

Commits on Apr 23, 2015

• [FLINK-1799][scala] Fix handling of generic arrays

  aljoscha

  committed
  4672e95

  Copy full SHA for 4672e95

Commits on Apr 17, 2015

• [FLINK-1856][doc] Add notice about implicit TypeInformation

  aljoscha

  committed
  c2faa6f

  Copy full SHA for c2faa6f

• [FLINK-1900] Fix Scala Table API Example in doc

  aljoscha

  committed
  8c5cd97

  Copy full SHA for 8c5cd97

Commits on Apr 13, 2015

• [FLINK-1710] [table] Switch compile backend to Janino

  Show description for f81d9f0
  aljoscha

  committed
  f81d9f0

  Copy full SHA for f81d9f0

Pagination

Previous

Next