Commits

Branch selector

 master

User selector

tzulitai

Datepicker

All time

Commit History

Commits on Mar 31, 2017

• [FLINK-4577] [kinesis] Transparent reshard handling for FlinkKinesisConsumer

  Show description for 1932240
  tzulitai

  committed
  1932240

  Copy full SHA for 1932240

Commits on Mar 22, 2017

• [FLINK-6139] [doc] Add documentation for running Flink on MapR

  Show description for 36cf94a
  tzulitai

  committed
  36cf94a

  Copy full SHA for 36cf94a

• [FLINK-6139] [build] Add "mapr" build profile

  Show description for a84aa3c
  tzulitai

  committed
  a84aa3c

  Copy full SHA for a84aa3c

Commits on Mar 14, 2017

• [FLINK-3398] [kafka] Allow disabling offset committing for FlinkKafkaConsumer

  Show description for 90c7415
  tzulitai

  committed
  90c7415

  Copy full SHA for 90c7415

• [FLINK-5949] [yarn] Don't check Kerberos credentials for non-Kerberos authentication methods

  Show description for 87779ad
  tzulitai

  committed
  87779ad

  Copy full SHA for 87779ad

Commits on Mar 13, 2017

• [FLINK-3123] [kafka] Allow custom specific start offsets for FlinkKafkaConsumer

  Show description for 5f08e53
  tzulitai

  committed
  5f08e53

  Copy full SHA for 5f08e53

• [FLINK-6025] [core] Add Flink's own JavaSerializer for Kryo serialization

  Show description for f214317
  tzulitai

  committed
  f214317

  Copy full SHA for f214317

Commits on Mar 9, 2017

• [hotfix] [FLINK-3679] Improve Javadocs of DeserializationSchemas

  Show description for 96d2444
  tzulitai

  committed
  96d2444

  Copy full SHA for 96d2444

• [FLINK-3679] [kafka] Improve null record handling for FlinkKafkaConsumer

  Show description for c39ad31
  tzulitai

  committed
  c39ad31

  Copy full SHA for c39ad31

Commits on Feb 27, 2017

• [hotfix] [kafka] Cleanup star / unused imports in all Flink Kafka tests

  tzulitai

  committed
  8bcb2ae

  Copy full SHA for 8bcb2ae

• [FLINK-5849] [kafka] Move FlinkKafkaConsumer start offset determination to open()

  Show description for ed68fed
  tzulitai

  committed
  ed68fed

  Copy full SHA for ed68fed

• [FLINK-5772] [elasticsearch] Allow Elasticsearch 1.x tests to rerun on failure

  Show description for 72f56d1
  tzulitai

  committed
  72f56d1

  Copy full SHA for 72f56d1

Commits on Feb 24, 2017

• [FLINK-5487] [elasticsearch] At-least-once Elasticsearch Sink

  Show description for 2437da6
  tzulitai

  committed
  2437da6

  Copy full SHA for 2437da6

• [FLINK-5353] [elasticsearch] User-provided failure handler for ElasticsearchSink

  Show description for 3743e89
  tzulitai

  committed
  3743e89

  Copy full SHA for 3743e89

Commits on Feb 23, 2017

• [hotfix] [kafka] Indent Kafka010FetcherTest with tabs instead of spaces

  tzulitai

  committed
  de2605e

  Copy full SHA for de2605e

Commits on Feb 22, 2017

• [FLINK-5716] [streaming] Make StreamSourceContexts aware of source idleness

  Show description for b0f0f37
  tzulitai

  committed
  b0f0f37

  Copy full SHA for b0f0f37

• [FLINK-5701] [kafka] FlinkKafkaProducer should check asyncException on checkpoints

  Show description for 646490c
  tzulitai

  committed
  646490c

  Copy full SHA for 646490c

Commits on Feb 15, 2017

• [FLINK-4280] [kafka] Explicit start position configuration for FlinkKafkaConsumer

  Show description for 7477c5b
  tzulitai

  committed
  7477c5b

  Copy full SHA for 7477c5b

Commits on Feb 10, 2017

• [FLINK-5017] [streaming] Introduce StreamStatus to facilitate idle sources

  Show description for 6630513
  

  tzulitai

  authored and

  aljoscha

  committed
  6630513

  Copy full SHA for 6630513

• [hotfix] [doc] Fix broken Flink on Windows link

  tzulitai

  committed
  0241032

  Copy full SHA for 0241032

Commits on Feb 7, 2017

• [FLINK-5702] [doc] At-least-once configuration info for FlinkKafkaProducer

  Show description for cba85db
  tzulitai

  committed
  cba85db

  Copy full SHA for cba85db

• [FLINK-4988] [elasticsearch] Restructure Elasticsearch connectors

  Show description for b5caaef
  tzulitai

  committed
  b5caaef

  Copy full SHA for b5caaef

Commits on Feb 2, 2017

• [hotfix] [doc] Fix broken externalized checkpoint reference link

  tzulitai

  committed
  7d2c25d

  Copy full SHA for 7d2c25d

Commits on Jan 31, 2017

• [FLINK-5581] [doc] Improve user accessibility for Kerberos-related documentation

  Show description for a459b0b
  

  tzulitai

  authored and

  StephanEwen

  committed
  a459b0b

  Copy full SHA for a459b0b

Commits on Jan 24, 2017

• [FLINK-5375] [doc] Fix Watermark Semantics

  Show description for f98af8c
  tzulitai

  committed
  f98af8c

  Copy full SHA for f98af8c

• [FLINK-4523] [kinesis] Add documentation for start position configuration

  Show description for 00d1ad8
  tzulitai

  committed
  00d1ad8

  Copy full SHA for 00d1ad8

Commits on Jan 20, 2017

• [FLINK-5580] [security] Fix path setting of shipped Kerberos keytabs in YARN mode

  Show description for 640a149
  tzulitai

  committed
  640a149

  Copy full SHA for 640a149

Commits on Jan 19, 2017

• [hotfix] [doc] Fix several broken "Linking with Flink" links

  Show description for 6a2970a
  

  tzulitai

  authored and

  zentol

  committed
  6a2970a

  Copy full SHA for 6a2970a

• [FLINK-5512] [doc] Improve RabbitMQ documentation

  Show description for bf72a7c
  tzulitai

  committed
  bf72a7c

  Copy full SHA for bf72a7c

Commits on Nov 24, 2016

• [FLINK-5075] [kinesis] Make connector fail-proof to incorrect Kinesalite API behaviour

  Show description for f5f4f7a
  tzulitai

  committed
  f5f4f7a

  Copy full SHA for f5f4f7a

Commits on Nov 22, 2016

• [FLINK-4155] [kafka] Move partition list fetching to open() for Kafka producers

  Show description for 1f9c0cf
  tzulitai

  committed
  1f9c0cf

  Copy full SHA for 1f9c0cf

Commits on Nov 16, 2016

• [FLINK-5013] [kinesis] Shade AWS dependencies to work with older EMR versions

  Show description for 53aae50
  tzulitai

  committed
  53aae50

  Copy full SHA for 53aae50

Commits on Oct 26, 2016

• [hotfix] [kafka] Fix RackAwareMode instantiation in Kafka 0.10 tests

  Show description for 307eae6
  tzulitai

  committed
  307eae6

  Copy full SHA for 307eae6

Commits on Oct 19, 2016

• [FLINK-4727] [kafka] Set missing initial offset states with starting KafkaConsumer position

  Show description for e4343ba
  tzulitai

  committed
  e4343ba

  Copy full SHA for e4343ba

Commits on Oct 18, 2016

• [FLINK-4723] [kafka] Unify committed offsets to Kafka to be next record to process

  Show description for f46ca39
  tzulitai

  committed
  f46ca39

  Copy full SHA for f46ca39

Pagination

Previous

Next