Sebastian Mattheis

[FLINK-28853][connector-base] Add FLIP-217 support for watermark alignment of source splits

1

## What is the purpose of the change * The change implements FLIP-217 (https://cwiki.apache.org/confluence/display/FLINK/FLIP-217+Support+watermark+alignment+of+source+splits) to support watermark alignment of source splits. ## Brief change log * Revised `SplitFetcher` threading model...

- Revise `submit/stream.py` to use Python sockets instead of `netcat` (similar to `submit/batch.py`). - Change `Calendar.getInstance().getTimeInMillis()` to `System.currentTimeMillis()` in `TemporaryMemory`. - Add a `tracker.properties` option to bound `MatcherKState`. - Consider...

To all users of the library: help wanted for maintenance of the project!

3

To all users of the library, First of all, I'm sorry for the lack of maintenance of the project and not merging pull requests. I'm maintaining the library for some...

# Issue Report # ## Bug ## In a bare-metall cluster of 24 (desktop) machines that boot CoreOS via PXE boot, machines randomly fail/freeze from time to time. All machines...

Slow disk write speed for shared folders mounted via vmhgfs-fuse

50

I'm using VMWare Fusion 10.1.1 on Mac OS X 10.12.6 with Ubuntu 16.04 (Linux ubuntu 4.4.0-121-generic) and observe that the speed for writing to shared folders mounted with vmhgfs-fuse is...