Commits

Breadcrumbs

History for

on80dc704

User selector

All users

Datepicker

All time

Commit History

Commits on Apr 4, 2017

• Revert "[FLINK-5808] Move default parallelism to StreamingJobGraphGenerator"

  Show description for 3e41ed1
  aljoscha

  committed
  3e41ed1

Commits on Mar 18, 2017

• [FLINK-5808] Move default parallelism to StreamingJobGraphGenerator

  Show description for b563f0a
  aljoscha

  committed
  b563f0a

Commits on Jan 23, 2017

• [FLINK-5247] [streaming api] Fix checks for allowed lateness in windowed streams

  Show description for 4697b97
  

  rohitagarwal003

  authored and

  StephanEwen

  committed
  4697b97

• [FLINK-5480] [savepoints] Add setUidHash method to DataStream API

  Show description for 35da413
  

  StefanRRichter

  authored and

  uce

  committed
  35da413

Commits on Jan 20, 2017

• [FLINK-5507] [queryable state] Remove list variant of asQueryableState

  Show description for 1c8a48f
  

  Nico Kruber

  authored and

  uce

  committed
  1c8a48f

Commits on Jan 13, 2017

• [FLINK-5250] Make AbstractUdfStreamOperator aware of WrappingFunction

  

  StefanRRichter

  authored and

  aljoscha

  committed
  33c5df6

• [FLINK-5155] Deprecate ValueStateDescriptor constructors with default value

  aljoscha

  committed
  8b73314

Commits on Jan 12, 2017

• [FLINK-5296] Expose the old AlignedWindowOperators through special assigners

  Show description for 68a2520
  

  kl0u

  authored and

  aljoscha

  committed
  68a2520

Commits on Jan 11, 2017

• [FLINK-5237] Consolidate and harmonize Window Translation Tests

  aljoscha

  committed
  8d3ad45

Commits on Dec 20, 2016

• [FLINK-4669] [apis] Harmonize the instantiations of local environments between Java/Scala Batch/Streaming

  StephanEwen

  committed
  9bc1063

• [FLINK-4669] [apis] Add createLocalEnvironment() utility method that starts the web UI

  Show description for 570ed4e
  

  shijinkui

  authored and

  StephanEwen

  committed
  570ed4e

• [FLINK-5295] Migrate the AlignedWindowOperators to the WindowOperator.

  Show description for e0819dc
  

  kl0u

  authored and

  aljoscha

  committed
  e0819dc

• [FLINK-4391] Add Scala API for asynchronous I/O operations

  Show description for bfdaa38
  tillrohrmann

  committed
  bfdaa38

Commits on Nov 28, 2016

• [FLINK-5026] Rename TimelyFlatMap to Process

  aljoscha

  committed
  910f733

• [FLINK-5168] Scaladoc annotation link use [[]] instead of {@link}

  Show description for 3542019
  

  shijinkui

  authored and

  StephanEwen

  committed
  3542019

Commits on Nov 24, 2016

• [FLINK-3702] FieldAccessor refactor to static factory

  Show description for 870e219
  mbalassi

  committed
  870e219

• [FLINK-3702] Make FieldAccessors support nested field expressions.

  

  ggevay

  authored and

  mbalassi

  committed
  1f04542

Commits on Nov 22, 2016

• [FLINK-3869] Replace WindowedStream.apply() by reduce()/fold()

  Show description for 698e53e
  

  Yassine Marzougui

  authored and

  aljoscha

  committed
  698e53e

Commits on Nov 11, 2016

• [FLINK-5012] Expose Timestamp in Timely FlatMap Functions

  Show description for 9918839
  aljoscha

  committed
  9918839

Commits on Nov 7, 2016

• [FLINK-4957] Provide API for TimelyCoFlatMapFunction

  aljoscha

  committed
  891950e

• [FLINK-4955] Add Translations Tests for KeyedStream.flatMap(TimelyFlatMapFunction)

  aljoscha

  committed
  06fb9f1

• [FLINK-4952] [scala] Add KeyedStream.flatMap(TimelyFlatMapFunction)

  aljoscha

  committed
  f0ef370

Commits on Sep 8, 2016

• [FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFlinkMiniCluster

  Show description for 02b852e
  tillrohrmann

  committed
  02b852e

Commits on Aug 31, 2016

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

  

  StefanRRichter

  authored and

  aljoscha

  committed
  f44b57c

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

  Show description for ec975aa
  

  tillrohrmann

  authored and

  aljoscha

  committed
  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

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

Commits on Aug 9, 2016

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

  Show description for 490e7eb
  uce

  committed
  490e7eb

Commits on Aug 1, 2016

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

  Show description for 0f92a6b
  uce

  committed
  0f92a6b

Commits on Jul 11, 2016

• [FLINK-3190] failure rate restart strategy

  Show description for a7274d5
  

  fijolekProjects

  authored and

  tillrohrmann

  committed
  a7274d5

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

  Show description for 81cf229
  greghogan

  committed
  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

Commits on Jun 21, 2016

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

  Show description for 34a8b03
  

  kl0u

  authored and

  aljoscha

  committed
  34a8b03

Commits on Jun 14, 2016

• [FLINK-2314] Make Streaming File Sources Persistent

  Show description for d353895
  

  kl0u

  authored and

  aljoscha

  committed
  d353895

Commits on Apr 28, 2016

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

  Show description for 6225aa6
  

  kl0u

  authored and

  rmetzger

  committed
  6225aa6

Pagination

PreviousNext