Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Aug 31, 2016

• [FLINK-3755] Fix variety of test problems cause by Keyed-State Refactoring

  

  StefanRRichter

  authored and

  aljoscha

  committed
  f44b57c

  Copy full SHA for f44b57c

• [FLINK-4380] Introduce KeyGroupAssigner and Max-Parallelism Parameter

  Show description for ec975aa
  

  tillrohrmann

  authored and

  aljoscha

  committed
  ec975aa

  Copy full SHA for ec975aa

Commits on Aug 25, 2016

• [FLINK-3677] FileInputFormat: Allow to specify include/exclude file name patterns

  Show description for 4810910
  

  mushketyk

  authored and

  mxm

  committed
  4810910

  Copy full SHA for 4810910

Commits on Aug 16, 2016

• [FLINK-4366] Add 'forceNonParallel()' to stream transformations and enforce parallelism=1 for AllWindowedStream

  Show description for ffe4065
  

  wuchong

  authored and

  StephanEwen

  committed
  ffe4065

  Copy full SHA for ffe4065

Commits on Aug 9, 2016

• [FLINK-3779] [streaming-java, streaming-scala] Add QueryableStateStream to KeyedStream

  Show description for 490e7eb
  uce

  committed
  490e7eb

  Copy full SHA for 490e7eb

Commits on Aug 5, 2016

• [FLINK-4310] [build] Selectively run API compatibility checks in API projects.

  Show description for e629b2e
  StephanEwen

  committed
  e629b2e

  Copy full SHA for e629b2e

Commits on Aug 3, 2016

• [build] Bump version to 1.2-SNAPSHOT

  Show description for 036f4d0
  

  mbalassi

  authored and

  StephanEwen

  committed
  036f4d0

  Copy full SHA for 036f4d0

Commits on Aug 1, 2016

• [FLINK-4292] [batch connectors] Fix setup of HCatalog project by adding Scala SDK dependency

  StephanEwen

  committed
  923c6a7

  Copy full SHA for 923c6a7

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

  Show description for 0f92a6b
  uce

  committed
  0f92a6b

  Copy full SHA for 0f92a6b

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

Pagination

Previous

Next