Commits

Branch selector

 master

User selector

pnowojski

Datepicker

All time

Commit History

Commits on Sep 28, 2017

• [FLINK-7683][state backends] Introduce iterator for keys in KeyedStateBackend.

  Show description for 3ff0592
  

  pnowojski

  authored and

  StefanRRichter

  committed
  3ff0592

  Copy full SHA for 3ff0592

• [FLINK-7541][runtime] Refactor StateAssignmentOperation and use OperatorID

  Show description for 685ca8a
  

  pnowojski

  authored and

  StefanRRichter

  committed
  685ca8a

  Copy full SHA for 685ca8a

Commits on Sep 25, 2017

• [FLINK-7541][runtime] Refactor StateAssignmentOperation and use OperatorID

  Show description for f1b2b83
  

  pnowojski

  authored and

  StefanRRichter

  committed
  f1b2b83

  Copy full SHA for f1b2b83

• [hotfix][runtime] Checkstyle changes in TaskStateSnapshot

  

  pnowojski

  authored and

  StefanRRichter

  committed
  79b916c

  Copy full SHA for 79b916c

Commits on Sep 6, 2017

• [hotfix][kafka][docs] Add warning regarding data losses when writing to Kafka

  

  pnowojski

  authored and

  aljoscha

  committed
  d0636c8

  Copy full SHA for d0636c8

Commits on Aug 29, 2017

• [hotfix] [docs] Add section in docs about writing unit and integration tests

  Show description for 00fc641
  

  pnowojski

  authored and

  twalthr

  committed
  00fc641

  Copy full SHA for 00fc641

• [hotfix][streaming] Fix logging in TwoPhaseCommitSinkFunction

  

  pnowojski

  authored and

  aljoscha

  committed
  1e2a638

  Copy full SHA for 1e2a638

• [hotfix][streaming] Allow to override methods from TwoPhaseCommitSinkFunction

  Show description for 9d9cdcb
  

  pnowojski

  authored and

  aljoscha

  committed
  9d9cdcb

  Copy full SHA for 9d9cdcb

• [FLINK-7497][streaming] Introduce user context in TwoPhaseCommitSinkFunction

  

  pnowojski

  authored and

  aljoscha

  committed
  959d54f

  Copy full SHA for 959d54f

• [FLINK-7498][streaming] Bind together state fields of TwoPhaseCommitSinkFunction

  Show description for ac72360
  

  pnowojski

  authored and

  aljoscha

  committed
  ac72360

  Copy full SHA for ac72360

Commits on Aug 24, 2017

• [hotfix][streaming] Refactor TwoPhaseCommitSinkFunctionTest

  

  pnowojski

  authored and

  aljoscha

  committed
  3f4de57

  Copy full SHA for 3f4de57

• [hotfix][tests] Implement AutoCloseable in TestHarness

  

  pnowojski

  authored and

  aljoscha

  committed
  87e5b8b

  Copy full SHA for 87e5b8b

Commits on Aug 23, 2017

• [hotifx][streaming] Simplify state of TwoPhaseCommitSinkFunction

  

  pnowojski

  authored and

  aljoscha

  committed
  3e706b1

  Copy full SHA for 3e706b1

Commits on Aug 15, 2017

• [hotfix][misc] More verbose logging in NetworkFailuresProxy

  Show description for be196f7
  

  pnowojski

  authored and

  zentol

  committed
  be196f7

  Copy full SHA for be196f7

• [hotfix][misc] Fix logging of local port in NetworkFailuresProxy

  Show description for ff27e20
  

  pnowojski

  authored and

  zentol

  committed
  ff27e20

  Copy full SHA for ff27e20

Commits on Aug 8, 2017

• [hotfix][Kafka] Clean up getKafkaServer method

  

  pnowojski

  authored and

  StefanRRichter

  committed
  14bcac7

  Copy full SHA for 14bcac7

• [FLINK-7343][Kafka] Use NetworkFailureProxy in kafka tests

  Show description for cd373ef
  

  pnowojski

  authored and

  StefanRRichter

  committed
  cd373ef

  Copy full SHA for cd373ef

• [hotfix][Kafka] Refactor properties for KafkaTestEnvironment setup

  

  pnowojski

  authored and

  StefanRRichter

  committed
  e11a591

  Copy full SHA for e11a591

• [FLINK-7343][utils] Add network proxy utility to simulate network failures

  

  pnowojski

  authored and

  StefanRRichter

  committed
  b7f96f7

  Copy full SHA for b7f96f7

Commits on Aug 7, 2017

• [FLINK-7343][kafka] Increase Xmx for tests

  Show description for 4406d48
  

  pnowojski

  authored and

  zentol

  committed
  4406d48

  Copy full SHA for 4406d48

• [FLINK-7210] Implement TwoPhaseCommitSinkFunction

  Show description for 62e9991
  

  pnowojski

  authored and

  tzulitai

  committed
  62e9991

  Copy full SHA for 62e9991

Commits on Jul 24, 2017

• [hotfix] [kafka, tests] Commit read offsets in Kafka integration tests

  Show description for c65afdb
  

  pnowojski

  authored and

  tzulitai

  committed
  c65afdb

  Copy full SHA for c65afdb

Commits on Jul 23, 2017

• [FLINK-7174] [kafka connector] Bump Kafka 0.10 dependency to 0.10.2.1

  Show description for 0285054
  

  pnowojski

  authored and

  StephanEwen

  committed
  0285054

  Copy full SHA for 0285054

Commits on Jul 18, 2017

• [FLINK-7058] Fix scala-2.10 dependencies

  Show description for 8b59b4f
  

  pnowojski

  authored and

  zentol

  committed
  8b59b4f

  Copy full SHA for 8b59b4f

Commits on Jul 6, 2017

• [FLINK-6996] [kafka] Fix at-least-once semantic for FlinkKafkaProducer010

  Show description for 21ec86f
  

  pnowojski

  authored and

  tzulitai

  committed
  21ec86f

  Copy full SHA for 21ec86f

Commits on Jul 4, 2017

• [FLINK-7032] [build] Overwrite inherited compiler versions from parent pom

  Show description for d17a4b9
  

  pnowojski

  authored and

  uce

  committed
  d17a4b9

  Copy full SHA for d17a4b9

Commits on Jul 3, 2017

• [FLINK-7066] [tests] Fix integration tests in airplane mode

  Show description for d414fe1
  

  pnowojski

  authored and

  tillrohrmann

  committed
  d414fe1

  Copy full SHA for d414fe1

Commits on Jul 1, 2017

• [FLINK-7030] Build with scala-2.11 by default

  Show description for caf149e
  

  pnowojski

  authored and

  zentol

  committed
  caf149e

  Copy full SHA for caf149e