GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/4915
[FLINK-7838] Bunch of hotfixes and fix missing synchronization in
FlinkKafkaProducer011
## What is the purpose of the change
Most important is the commit adding missing synchronization, that might
been the cause for some deadlocks on travis. Others are just non critical
hotfixes.
## Brief change log
Please check individual commit messages.
## Verifying this change
This change is already covered by existing Kafka 0.11 connector tests.
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): (**yes** / no)
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: (yes / **no**)
- The serializers: (yes / **no** / don't know)
- The runtime per-record code paths (performance sensitive): (yes /
**no** / don't know)
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Yarn/Mesos, ZooKeeper: (yes / **no** / don't know)
## Documentation
- Does this pull request introduce a new feature? (yes / **no**)
- If yes, how is the feature documented? (**not applicable** / docs /
JavaDocs / not documented)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/pnowojski/flink f7838
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/4915.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #4915
----
commit 4e0492595f497a49c63b8ffddcc66e720e4e4433
Author: Piotr Nowojski <[email protected]>
Date: 2017-10-24T15:35:56Z
[hotfix][kafka] Bump Kafka 0.11 dependency
This might include some bugfixes
commit e38b3461bc97a175bf67f1072b2e8a2a891c1f1a
Author: Piotr Nowojski <[email protected]>
Date: 2017-10-24T15:57:05Z
[FLINK-7838][kafka] Add missing synchronization in FlinkKafkaProducer
commit 04127b9c44807f5379e07d801847d993c39e94b1
Author: Piotr Nowojski <[email protected]>
Date: 2017-10-26T08:02:15Z
[hotfix][kafka] Fix FlinkKafkaProducer011 logger
commit 8b47ac214c4022563be8128e84bc02d5de98819c
Author: Piotr Nowojski <[email protected]>
Date: 2017-10-27T13:11:24Z
[hotfix][kafka-tests] Fix test names so that they are not ignored by mvn
build
commit a6c4c8bbdbfc5c238557e151fa8598e71a562411
Author: Piotr Nowojski <[email protected]>
Date: 2017-10-25T16:08:46Z
[hotfix][kafka] Move checkpointing enable checking to initializeState
initializeState is called before open and since both of those functions
relay on chosen semantic, that means checkpointing enable check should
happen in initializeState.
commit 055e5d125df895fd010e1171d1d39f37177518a2
Author: Piotr Nowojski <[email protected]>
Date: 2017-10-27T13:14:58Z
[hotfix][kafka] Remove unsued field in FlinkKafkaProducer011
commit 6cf55ed8977135af01099452962962199e253348
Author: Piotr Nowojski <[email protected]>
Date: 2017-10-27T13:47:26Z
[hotfix][kafka] Do not return producers to a pool in abort for non
EXACTLY_ONCE modes
Previously on abort(...) producers were returned to the pool. This was
minor bug,
probably without any negative side effect, however this patch fixes it
and adds additional sanity checks to guard against similar bugs
in the future.
----
---
