Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Jul 12, 2016

• [FLINK-4111] [table] Flink Table & SQL doesn't work in very simple example

  Show description for 508965e
  twalthr

  committed
  508965e

  Copy full SHA for 508965e

Commits on Jul 11, 2016

• [FLINK-3190] failure rate restart strategy

  Show description for a7274d5
  

  fijolekProjects

  authored and

  tillrohrmann

  committed
  a7274d5

  Copy full SHA for a7274d5

• [FLINK-4154] [core] Correction of murmur hash breaks backwards compatibility

  Show description for 81cf229
  greghogan

  committed
  81cf229

  Copy full SHA for 81cf229

Commits on Jul 5, 2016

• [FLINK-3995] [build] flink-test-utils also contains the streaming test utilities.

  Show description for b9f42e9
  

  StephanEwen

  authored and

  rmetzger

  committed
  b9f42e9

  Copy full SHA for b9f42e9

• [FLINK-3995] [build] Properly structure test scopes and dependencies

  Show description for 4b71e0e
  

  StephanEwen

  authored and

  rmetzger

  committed
  4b71e0e

  Copy full SHA for 4b71e0e

Commits on Jun 21, 2016

• [FLINK-3714] Add Support for "Allowed Lateness"

  Show description for 34a8b03
  

  kl0u

  authored and

  aljoscha

  committed
  34a8b03

  Copy full SHA for 34a8b03

Commits on Jun 14, 2016

• [FLINK-2314] Make Streaming File Sources Persistent

  Show description for d353895
  

  kl0u

  authored and

  aljoscha

  committed
  d353895

  Copy full SHA for d353895

Commits on May 27, 2016

• [FLINK-3129] Fix breaking changes in flink-core

  rmetzger

  committed
  b0acd97

  Copy full SHA for b0acd97

• [FLINK-3129] Bring infrastructure for ensuring interface stability in place

  Show description for 6c07936
  rmetzger

  committed
  6c07936

  Copy full SHA for 6c07936

Commits on May 4, 2016

• [FLINK-1827] [tests] Move test classes in test folders and fix scope of test dependencies.

  Show description for 70978f5
  

  stefanobortoli

  authored and

  fhueske

  committed
  70978f5

  Copy full SHA for 70978f5

Commits on Apr 28, 2016

• [FLINK-3428] Adds a fixed time trailing watermark extractor.

  Show description for 6225aa6
  

  kl0u

  authored and

  rmetzger

  committed
  6225aa6

  Copy full SHA for 6225aa6

Commits on Apr 26, 2016

• [FLINK-3708] [cep] Add Scala CEP API

  Show description for e29ac03
  

  StefanRRichter

  authored and

  tillrohrmann

  committed
  e29ac03

  Copy full SHA for e29ac03

Commits on Apr 25, 2016

• [FLINK-3778] [shell] Forward configuration from FlinkILoop to ScalaShellRemoteStreamEnvironment

  Show description for 7498d3e
  tillrohrmann

  committed
  7498d3e

  Copy full SHA for 7498d3e

Commits on Apr 15, 2016

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

  Show description for 760a0d9
  

  StephanEwen

  authored and

  fhueske

  committed
  760a0d9

  Copy full SHA for 760a0d9

Commits on Apr 5, 2016

• [FLINK-3614] Remove Non-Keyed Window Operator

  Show description for 505512d
  aljoscha

  committed
  505512d

  Copy full SHA for 505512d

Commits on Apr 4, 2016

• [FLINK-3623] [runtime] Adjust MurmurHash Algorithm

  Show description for 641a0d4
  

  greghogan

  authored and

  StephanEwen

  committed
  641a0d4

  Copy full SHA for 641a0d4

• [FLINK-1159] [Scala API] Add API extension to support case-style anonymous functions

  Show description for 5cb84f1
  

  stefanobaghino

  authored and

  StephanEwen

  committed
  5cb84f1

  Copy full SHA for 5cb84f1

Commits on Mar 11, 2016

• [build] Consolidate scala checkstyle usage and update version to 0.8.0

  Show description for 5aca6f4
  mbalassi

  committed
  5aca6f4

  Copy full SHA for 5aca6f4

Commits on Mar 4, 2016

• [FLINK-3578] [streaming scala] Support RichFunctions for Scala WindowFunction and AllWindowFunction

  Show description for 7bdac1a
  StephanEwen

  committed
  7bdac1a

  Copy full SHA for 7bdac1a

Commits on Mar 2, 2016

• [FLINK-3422][streaming] Update tests reliant on hashing

  Show description for f0f93c2
  mbalassi

  committed
  f0f93c2

  Copy full SHA for f0f93c2

• [FLINK-3422][streaming][api-breaking] Scramble HashPartitioner hashes.

  

  Xazax-hun

  authored and

  mbalassi

  committed
  0ff286d

  Copy full SHA for 0ff286d

Commits on Mar 1, 2016

• [FLINK-3554] [streaming] Emit a MAX Watermark after finite sources finished

  Show description for ff80dc0
  StephanEwen

  committed
  ff80dc0

  Copy full SHA for ff80dc0

• [FLINK-3557] [stream, scala] Introduce secondary parameter list for fold function

  Show description for 93733cc
  tillrohrmann

  committed
  93733cc

  Copy full SHA for 93733cc

Commits on Feb 29, 2016

• [FLINK-3548] [api-breaking] Remove unnecessary generic parameter from SingleOutputStreamOperator

  aljoscha

  committed
  a922473

  Copy full SHA for a922473

• [FLINK-3536] Make clearer distinction between event time and processing time

  Show description for 9922d10
  aljoscha

  committed
  9922d10

  Copy full SHA for 9922d10

• [FLINK-3538] [api-breaking] Streamline Scala DataStream.join/coGroup

  Show description for 0ac2b1a
  aljoscha

  committed
  0ac2b1a

  Copy full SHA for 0ac2b1a

• Bump version to 1.1-SNAPSHOT

  rmetzger

  committed
  512c84f

  Copy full SHA for 512c84f

Commits on Feb 26, 2016

• [FLINK-3527] Add Scala DataStream.transform()

  Show description for adddcd8
  aljoscha

  committed
  adddcd8

  Copy full SHA for adddcd8

• [FLINK-3528] Add FoldingWindowBuffer for Non-Keyed Windows

  Show description for 20884c0
  aljoscha

  committed
  20884c0

  Copy full SHA for 20884c0

• [FLINK-3521] Make Iterable part of method signature for WindowFunction

  Show description for 27b5c49
  

  aljoscha

  authored and

  rmetzger

  committed
  27b5c49

  Copy full SHA for 27b5c49

• [hotfix] Make DataStream property methods properly Scalaesk

  Show description for 4eabd4d
  StephanEwen

  committed
  4eabd4d

  Copy full SHA for 4eabd4d

Commits on Feb 24, 2016

• [FLINK-3435] [streaming] Proparly separate IngestionTime and EventTime

  Show description for ceb6424
  

  StephanEwen

  authored and

  rmetzger

  committed
  ceb6424

  Copy full SHA for ceb6424

Commits on Feb 23, 2016

• [FLINK-3315] Fix Slot Sharing in Streaming API

  Show description for c40cfd3
  

  aljoscha

  authored and

  tillrohrmann

  committed
  c40cfd3

  Copy full SHA for c40cfd3

Commits on Feb 22, 2016

• [FLINK-3439] Remove final Long.MAX_VALUE Watermark in StreamSource

  aljoscha

  committed
  80c0c65

  Copy full SHA for 80c0c65

Commits on Feb 17, 2016

• [FLINK-3419] [streaming] Drop 'partitionByHash' function, subsumed by 'keyBy()'

  StephanEwen

  committed
  06a42bf

  Copy full SHA for 06a42bf

Pagination

Previous

Next