This is an automated email from the ASF dual-hosted git repository.
thw pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8525c37 [FLINK-15308][runtime] Remove data compression for pipelined
partition
add c2c38b1 [FLINK-15301] [kinesis] Exception propagation from record
emitter to source thread
No new revisions were added by this update.
Summary of changes:
.../kinesis/internals/KinesisDataFetcher.java | 14 +++++++++++-
.../connectors/kinesis/util/RecordEmitter.java | 13 ++++++-----
.../kinesis/FlinkKinesisConsumerTest.java | 26 +++++++++++++++++++++-
3 files changed, 46 insertions(+), 7 deletions(-)
