Commits

Branch selector

 master

User selector

StephanEwen

Datepicker

All time

Commit History

Commits on Feb 10, 2016

• [FLINK-3384] [kafka] Add ClosableQueue for message exchanges between Kafka Threads

  StephanEwen

  committed
  fd324ea

  Copy full SHA for fd324ea

• [FLINK-3371] [api-breaking] Move TriggerResult and TriggerContext to dedicated classes

  Show description for 50bd65a
  StephanEwen

  committed
  50bd65a

  Copy full SHA for 50bd65a

• [FLINK-3373] [build] Shade away Hadoop's HTTP Components dependency

  Show description for 8ccd754
  StephanEwen

  committed
  8ccd754

  Copy full SHA for 8ccd754

Commits on Feb 9, 2016

• [FLINK-3373] [build] Revert HTTP Components versions because of incompatibility with Hadoop >= 2.6.0

  StephanEwen

  committed
  de231d7

  Copy full SHA for de231d7

• [hotfix] Add missing entries to condif reference doc and removed outdated webclient entries

  StephanEwen

  committed
  72f8228

  Copy full SHA for 72f8228

• [FLINK-3373] [build] Bump version of transitine HTTP Components dependency to 4.4.4 (core) / 4.5.1 (client)

  StephanEwen

  committed
  c57a7e9

  Copy full SHA for c57a7e9

• [FLINK-3355] [rocksdb backend] Allow passing options to the RocksDB backend.

  Show description for 9ee1679
  StephanEwen

  committed
  9ee1679

  Copy full SHA for 9ee1679

Commits on Feb 8, 2016

• [hotfix] Cleanup routing of records in OperatorChain

  StephanEwen

  committed
  28c6254

  Copy full SHA for 28c6254

• [hotfix] Update comments in 'ChainingStrategy' and remove outdated 'FORCE_ALWAYS' constant

  StephanEwen

  committed
  e9c83ea

  Copy full SHA for e9c83ea

• [FLINK-3334] [conf] Include year-month-day in the log output

  StephanEwen

  committed
  d51bec1

  Copy full SHA for d51bec1

• [FLINK-3365] [taskmanager] Properly shut down cleanup timer thread

  StephanEwen

  committed
  457cb14

  Copy full SHA for 457cb14

• [FLINK-3363] [jobmanager] Properly shut down executor thread pool when JobManager shuts down

  StephanEwen

  committed
  a277543

  Copy full SHA for a277543

• [FLINK-3361] [jobmanager] Fix error messages about execution delay and max heartbeat pause

  StephanEwen

  committed
  af3e689

  Copy full SHA for af3e689

Commits on Feb 7, 2016

• [FLINK-3286] [build] Remove not maintained JDEB profile from flink-dist

  StephanEwen

  committed
  e0fd489

  Copy full SHA for e0fd489

Commits on Feb 5, 2016

• [FLINK-3338] [kafka] Use proper classloader when cloning the deserialization schema.

  Show description for 2eb2a0e
  StephanEwen

  committed
  2eb2a0e

  Copy full SHA for 2eb2a0e

Commits on Feb 4, 2016

• [FLINK-3268] [tests] Enhance stability of ZooKeeperTestEnvironment.deleteAll()

  StephanEwen

  committed
  f8f747f

  Copy full SHA for f8f747f

Commits on Feb 3, 2016

• [FLINK-3201] Adjust CEP code for changes state interfaces

  StephanEwen

  committed
  1198664

  Copy full SHA for 1198664

• [FLINK-3312] Add simple constructors for State Descriptors

  StephanEwen

  committed
  180cd3f

  Copy full SHA for 180cd3f

• [FLINK-3312] Add accessors for various state types to RuntimeContext

  StephanEwen

  committed
  e4d05f7

  Copy full SHA for e4d05f7

• [FLINK-3201] Add operator state to make change backwards compatible

  StephanEwen

  committed
  6f75596

  Copy full SHA for 6f75596

Commits on Feb 2, 2016

• [FLINK-3314] [streaming] Fix case where early cancel messages do not properly cancel a stream operator.

  StephanEwen

  committed
  8fc7e7a

  Copy full SHA for 8fc7e7a

• [hotfix] Fix warnings concerning joda-time in "flink-tests"

  StephanEwen

  committed
  c356ef3

  Copy full SHA for c356ef3

• [hotfix] Remove old sysout debug message in UdfAnalyzerTest

  StephanEwen

  committed
  b90542e

  Copy full SHA for b90542e

• [hotfix] [streaming] Various cleanups in StreamTask

  Show description for 168532e
  StephanEwen

  committed
  168532e

  Copy full SHA for 168532e

• [FLINK-2348] Fix unstable IterateExampleITCase.

  Show description for bfff86c
  StephanEwen

  committed
  bfff86c

  Copy full SHA for bfff86c

• [hotfix] Reduce the heavy sysout verbosity for certain tests

  StephanEwen

  committed
  6f042e7

  Copy full SHA for 6f042e7

• [FLINK-3303] [core] Move all type utilities to flink-core

  StephanEwen

  committed
  21a7158

  Copy full SHA for 21a7158

• [FLINK-3303] [core] Move Tuple classes to flink-core

  StephanEwen

  committed
  7081836

  Copy full SHA for 7081836

• [FLINK-3049] [api breaking] Move 'Either' type to 'flink-core / org.apache.flink.types'

  StephanEwen

  committed
  5474386

  Copy full SHA for 5474386

Commits on Feb 1, 2016

• [hotfix] Remove 'ByteArrayInputView' and replace deserialization in TypeInformationSerializationSchema with more efficient reusable buffers.

  StephanEwen

  committed
  92efcd3

  Copy full SHA for 92efcd3

• [hotfix] Add deprecation message to old Key interface

  StephanEwen

  committed
  5e2fb3c

  Copy full SHA for 5e2fb3c

• [FLINK-3305] [core] Remove limited and inconsistent auto-magic for Joda Time

  Show description for b6110dc
  StephanEwen

  committed
  b6110dc

  Copy full SHA for b6110dc

• [FLINK-3306] [core] Fix auto-type registry util

  StephanEwen

  committed
  c4bc47a

  Copy full SHA for c4bc47a

• [hotfix] Clean up warnings in Serializers util class

  StephanEwen

  committed
  d902d16

  Copy full SHA for d902d16

• [hotfix] [streaming] Tasks print subtask in log statements

  StephanEwen

  committed
  8c8f1c4

  Copy full SHA for 8c8f1c4

Pagination

Previous

Next