Commits

Branch selector

 master

User selector

tzulitai

Datepicker

All time

Commit History

Commits on Oct 2, 2017

• [FLINK-7728] [DataStream] Make StatusWatermarkValve unit tests more fine-grained

  Show description for ea86a53
  

  tzulitai

  authored and

  aljoscha

  committed
  ea86a53

  Copy full SHA for ea86a53

• [FLINK-7728] [DataStream] Flush max watermark across all inputs once all become idle

  Show description for f9b7966
  

  tzulitai

  authored and

  aljoscha

  committed
  f9b7966

  Copy full SHA for f9b7966

• [FLINK-7728] [DataStream] Simplify BufferedValveOutputHandler used in StatusWatermarkValveTest

  Show description for 6481564
  

  tzulitai

  authored and

  aljoscha

  committed
  6481564

  Copy full SHA for 6481564

• [FLINK-7721] [DataStream] Only emit new min watermark iff it was aggregated from watermark-aligned inputs

  Show description for c81a7e5
  

  tzulitai

  authored and

  aljoscha

  committed
  c81a7e5

  Copy full SHA for c81a7e5

Commits on Sep 26, 2017

• [FLINK-7647] [flip6] Introduce test base for REST response marshalling

  Show description for 4ba3eec
  tzulitai

  committed
  4ba3eec

  Copy full SHA for 4ba3eec

• [FLINK-7647] [flip6] Rename JobManagerConfigHandler to ClusterConfigHandler

  Show description for 2b0008c
  tzulitai

  committed
  2b0008c

  Copy full SHA for 2b0008c

• [FLINK-7647] [flip6] Port JobManagerConfigHandler to new REST endpoint

  Show description for 97ff043
  tzulitai

  committed
  97ff043

  Copy full SHA for 97ff043

Commits on Sep 7, 2017

• [FLINK-7363] [kinesis] Clean up deprecation of ProducerConfigConstants

  Show description for 59eab45
  tzulitai

  committed
  59eab45

  Copy full SHA for 59eab45

• [FLINK-7440] [kinesis] Eagerly check that provided schema and partitioner is serializable in FlinkKinesisProducer

  Show description for 98737f9
  tzulitai

  committed
  98737f9

  Copy full SHA for 98737f9

• [FLINK-7440] [kinesis] Eagerly check serializability of deserialization schema in FlinkKinesisConsumer

  Show description for eaafb61
  tzulitai

  committed
  eaafb61

  Copy full SHA for eaafb61

• [hotfix] [kafka] Remove unused shouldAssignToThisSubtask method in AbstractPartitionDiscoverer

  Show description for 36412c6
  tzulitai

  committed
  36412c6

  Copy full SHA for 36412c6

• [FLINK-7407] [kafka] Adapt AbstractPartitionDiscoverer to handle non-contiguous partition metadata

  Show description for 93369e7
  tzulitai

  committed
  93369e7

  Copy full SHA for 93369e7

Commits on Aug 25, 2017

• [FLINK-7429] [kinesis] Add IT tests for migration from 1.3

  

  tzulitai

  authored and

  aljoscha

  committed
  c384e52

  Copy full SHA for c384e52

Commits on Aug 3, 2017

• [FLINK-6493] Fix ineffective null check in equality of RegisteredKeyedBackendStateMetaInfo snapshots

  Show description for 875a136
  tzulitai

  committed
  875a136

  Copy full SHA for 875a136

Commits on Jul 28, 2017

• [FLINK-6998] [kafka] Remove unfruitful null checks on provided KafkaCommitCallbacks

  Show description for 1ded2d8
  tzulitai

  committed
  1ded2d8

  Copy full SHA for 1ded2d8

• [FLINK-7248] [kafka, tests] Remove invalid checkRestoredNullCheckpointWhenFetcherNotReady test

  Show description for c5221c8
  tzulitai

  committed
  c5221c8

  Copy full SHA for c5221c8

• [FLINK-7143] [kafka] Introduce KafkaTopicPartitionAssigner with stricter assignment contracts

  Show description for 888fabe
  tzulitai

  committed
  888fabe

  Copy full SHA for 888fabe

Commits on Jul 24, 2017

• [FLINK-7143] [kafka, tests] Stricter tests for deterministic partition assignment

  Show description for e16e9d9
  tzulitai

  committed
  e16e9d9

  Copy full SHA for e16e9d9

• [FLINK-7224] [kafka, docs] Fix incorrect Javadoc / docs regarding Kafka partition metadata querying

  Show description for 58b5374
  tzulitai

  committed
  58b5374

  Copy full SHA for 58b5374

Commits on Jul 13, 2017

• [hotfix] [docs] Fix broken links in 1.2 -> 1.3 API migration docs

  tzulitai

  committed
  bf6b9aa

  Copy full SHA for bf6b9aa

Commits on Jul 6, 2017

• [FLINK-7038] Correct misused terms (WindowedDataStream, JoinedDataStream)

  Show description for 5c6d797
  tzulitai

  committed
  5c6d797

  Copy full SHA for 5c6d797

Commits on Jul 1, 2017

• [FLINK-6680] [docs] Update "Upgrading Applications and Flink Versions" for 1.3

  Show description for daed460
  tzulitai

  committed
  daed460

  Copy full SHA for daed460

• [FLINK-6674] [docs] Bootstrap API Migration docs update for 1.2 -> 1.3

  tzulitai

  committed
  da74980

  Copy full SHA for da74980

• [FLINK-6376] [yarn] Improve inline code comments related to HDFS delegation token inclusion

  Show description for e575c6c
  tzulitai

  committed
  e575c6c

  Copy full SHA for e575c6c

• [FLINK-6867] [elasticsearch] Fix instable Elasticsearch 1.x ITCases

  Show description for 2d275e0
  tzulitai

  committed
  2d275e0

  Copy full SHA for 2d275e0

• [FLINK-7011] [kafka] Remove Kafka testStartFromKafkaCommitOffsets ITCases

  Show description for ba75bde
  tzulitai

  committed
  ba75bde

  Copy full SHA for ba75bde

• [FLINK-4022] [kafka] Partition / topic discovery for FlinkKafkaConsumer

  Show description for 085d4db
  tzulitai

  committed
  085d4db

  Copy full SHA for 085d4db

Commits on Jun 20, 2017

• [FLINK-6922] [serializer] Remove Java serialization from Enum(Value)SerializerConfigSnapshot

  Show description for f24a499
  tzulitai

  committed
  f24a499

  Copy full SHA for f24a499

Commits on Jun 13, 2017

• [hotfix] [tests] Fix failing Scala StatefulJobSavepointMigrationITCase

  tzulitai

  committed
  3bad77c

  Copy full SHA for 3bad77c

• [FLINK-6803] [tests] Fully enable PojoSerializerUpgradeTests for all state backends

  Show description for 8b26460
  tzulitai

  committed
  8b26460

  Copy full SHA for 8b26460

• [FLINK-6804] [state] Consistent state migration behaviour across state backends

  Show description for f0f2e99
  tzulitai

  committed
  f0f2e99

  Copy full SHA for f0f2e99

• [FLINK-6801] [core] Allow deserialized PojoSerializer to have removed fields

  Show description for ae285f9
  tzulitai

  committed
  ae285f9

  Copy full SHA for ae285f9

• [FLINK-6801] [core] Relax missing fields check when reading PojoSerializerConfigSnapshot

  Show description for c929eb3
  tzulitai

  committed
  c929eb3

  Copy full SHA for c929eb3

• [FLINK-6803] [tests] Enhancements to PojoSerializerUpgradeTest

  Show description for 7c157d6
  tzulitai

  committed
  7c157d6

  Copy full SHA for 7c157d6

• [hotfix] [tests] Fix failing tests in AsyncWaitOperatorTest and StateBackendTestBase

  tzulitai

  committed
  61a45e4

  Copy full SHA for 61a45e4

Pagination

Previous

Next