This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from ddc163a [FLINK-19762][WebUI] Improve content selection when
double-clicking IDs
add da67eeb [FLINK-18363] Add user classloader to context in
DeSerializationSchema
No new revisions were added by this update.
Summary of changes:
.../connectors/gcp/pubsub/PubSubSink.java | 6 +-
.../connectors/gcp/pubsub/PubSubSource.java | 6 +-
.../connectors/kafka/FlinkKafkaConsumerBase.java | 8 +-
.../connectors/kafka/FlinkKafkaProducer.java | 6 +-
.../connectors/kafka/FlinkKafkaProducerBase.java | 6 +-
.../connectors/kinesis/FlinkKinesisProducer.java | 6 +-
.../kinesis/internals/KinesisDataFetcher.java | 26 +++--
.../streaming/connectors/rabbitmq/RMQSink.java | 6 +-
.../streaming/connectors/rabbitmq/RMQSource.java | 6 +-
.../streaming/connectors/rabbitmq/RMQSinkTest.java | 5 +
.../serialization/DeserializationSchema.java | 10 ++
...untimeContextInitializationContextAdapters.java | 127 +++++++++++++++++++++
.../common/serialization/SerializationSchema.java | 10 ++
.../java/connectors/SocketSourceFunction.java | 5 +-
14 files changed, 216 insertions(+), 17 deletions(-)
create mode 100644
flink-core/src/main/java/org/apache/flink/api/common/serialization/RuntimeContextInitializationContextAdapters.java
