Commits

Branch selector

 master

User selector

aljoscha

Datepicker

All time

Commit History

Commits on Mar 6, 2017

• [FLINK-4460] Update doc: ProcessFunction now possible on DataStream

  aljoscha

  committed
  746c1ef

  Copy full SHA for 746c1ef

• [FLINK-4660] Allow CoProcessFunction on non-keyed ConnectedStreams

  Show description for 06740fb
  aljoscha

  committed
  06740fb

  Copy full SHA for 06740fb

• [FLINK-4460] Make CoProcessFunction abstract, add default onTime() method

  Show description for e12f320
  aljoscha

  committed
  e12f320

  Copy full SHA for e12f320

• [FLINK-4660] Allow ProcessFunction on DataStream

  Show description for 0228676
  aljoscha

  committed
  0228676

  Copy full SHA for 0228676

• [FLINK-4460] Make ProcessFunction abstract, add default onTime() method

  Show description for 82eddca
  aljoscha

  committed
  82eddca

  Copy full SHA for 82eddca

Commits on Feb 24, 2017

• [FLINK-5743] Mark WindowedStream.aggregate() methods as PublicEvolving

  aljoscha

  committed
  5983069

  Copy full SHA for 5983069

Commits on Feb 23, 2017

• [FLINK-5716] Add StreamStatusMaintainer mock in StreamSourceOperatorTest

  aljoscha

  committed
  8dac436

  Copy full SHA for 8dac436

Commits on Feb 17, 2017

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

  aljoscha

  committed
  5368a7d

  Copy full SHA for 5368a7d

• [FLINK-4997] Add ProcessWindowFunction support for .aggregate()

  aljoscha

  committed
  fe2a301

  Copy full SHA for fe2a301

• [FLINK-4997] Add doc for ProcessWindowFunction

  aljoscha

  committed
  4f047e1

  Copy full SHA for 4f047e1

• [hotfix] Fix trailing whitespace in WindowedStream.java

  aljoscha

  committed
  82db667

  Copy full SHA for 82db667

Commits on Feb 10, 2017

• [FLINK-5415] Harden ContinuousFileProcessingTest

  Show description for f6709b4
  aljoscha

  committed
  f6709b4

  Copy full SHA for f6709b4

Commits on Feb 6, 2017

• [FLINK-5721] Add FoldingState to State Documentation

  aljoscha

  committed
  588d7c6

  Copy full SHA for 588d7c6

• [FLINK-5709] Add Max Parallelism to Parallel Execution Doc

  aljoscha

  committed
  fffc8f0

  Copy full SHA for fffc8f0

Commits on Jan 27, 2017

• [FLINK-5670] Properly clean up local RocksDB directories

  Show description for 54b7092
  aljoscha

  committed
  54b7092

  Copy full SHA for 54b7092

• [FLINK-5529] Fix Trailing Whitespace in Window Documentation

  aljoscha

  committed
  4fbc631

  Copy full SHA for 4fbc631

• [FLINK-5529] Update Window Documentation Figures

  aljoscha

  committed
  9e5ebe4

  Copy full SHA for 9e5ebe4

Commits on Jan 24, 2017

• [FLINK-4552] Refactor WindowOperator/Trigger Tests

  Show description for d1475ee
  aljoscha

  committed
  d1475ee

  Copy full SHA for d1475ee

• [FLINK-4994] Don't Clear Trigger State and Merging Window Set When Purging

  Show description for 0b331a4
  aljoscha

  committed
  0b331a4

  Copy full SHA for 0b331a4

• [hotfix] Use correct ClassLoader in WindowOperatorMigrationTest

  aljoscha

  committed
  bcca3fe

  Copy full SHA for bcca3fe

• [hotfix] Use correct ClassLoader in ContinuousFileProcessingMigrationTest

  aljoscha

  committed
  238c503

  Copy full SHA for 238c503

• [hotfix] Use correct ClassLoader in FlinkKafkaConsumerBaseMigrationTest

  aljoscha

  committed
  c5d77a8

  Copy full SHA for c5d77a8

• [hotfix] Use own SumReducer in WindowOperatorMigrationTest

  aljoscha

  committed
  5461b95

  Copy full SHA for 5461b95

Commits on Jan 23, 2017

• [hotfix] Make MergingWindowSet resilient to misbehaving window assigners

  aljoscha

  committed
  16d33d0

  Copy full SHA for 16d33d0

Commits on Jan 22, 2017

• [hotfix] Fix type in ProcessFunction documentation

  aljoscha

  committed
  4e050b8

  Copy full SHA for 4e050b8

Commits on Jan 13, 2017

• [FLINK-5250] Unwrap WrappingFunction in AbstractStreamOperator.setOutputType()

  Show description for ce02350
  aljoscha

  committed
  ce02350

  Copy full SHA for ce02350

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

  aljoscha

  committed
  7a2d3be

  Copy full SHA for 7a2d3be

Commits on Jan 12, 2017

• [hotfix] Remove deprecated method in HeapKeyedStateBackend

  Show description for 46423b9
  aljoscha

  committed
  46423b9

  Copy full SHA for 46423b9

Commits on Jan 11, 2017

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

  aljoscha

  committed
  aa220e4

  Copy full SHA for aa220e4

• [FLINK-5237] Don't Fire Processing-Time Timer in registerTimer()

  Show description for 8c8c028
  aljoscha

  committed
  8c8c028

  Copy full SHA for 8c8c028

Commits on Jan 9, 2017

• [FLINK-4651] Ensure processing-time timers are set on restore

  Show description for 36cf7eb
  aljoscha

  committed
  36cf7eb

  Copy full SHA for 36cf7eb

Commits on Dec 20, 2016

• [FLINK-5366] SavepointUtil into SavepointMigrationTestBase/Add Test

  Show description for 2cbd9f5
  aljoscha

  committed
  2cbd9f5

  Copy full SHA for 2cbd9f5

• [hotfix] Add null checks in StateAssignmentOperation

  aljoscha

  committed
  74df763

  Copy full SHA for 74df763

• [hotfix] Fix compatibility check in RegisteredBackendStateMetaInfo

  Show description for d1eaa1e
  aljoscha

  committed
  d1eaa1e

  Copy full SHA for d1eaa1e

• [FLINK-5294] Add tests for WindowOperator restore from 1.1 snapshot

  aljoscha

  committed
  ac134d6

  Copy full SHA for ac134d6

Pagination

Previous

Next