Commits

Commits on Apr 19, 2021

[FLINK-22085][tests] Update NetworkFailureHandler to prevent closeOnFlush() from being called recursively

lindong28
authored and
dawidwys
committedApr 19, 2021

Commits on Apr 1, 2021

[FLINK-21976] Remove pyflink/ml related configs from python scripts

lindong28
authored and
dianfu
committedApr 1, 2021
[FLINK-21976] Remove python packages under flink-python/pyflink/ml

lindong28
authored and
dianfu
committedApr 1, 2021
[FLINK-21976] Remove Flink ML related examples from flink-examples

lindong28
authored and
dianfu
committedApr 1, 2021
[FLINK-21976] Remove fink-ml-* related configs from pom.xml

lindong28
authored and
dianfu
committedApr 1, 2021
[FLINK-21976] Remove all files under flink-ml-parent

lindong28
authored and
dianfu
committedApr 1, 2021

Commits on Mar 29, 2021

[FLINK-20114][connector/kafka] Remove duplicated warning and remove redundant default value for partition.discovery.interval.ms

lindong28
authored and
becketqin
committedMar 29, 2021
[hotfix][examples] Update StateMachineExample to use KafkaSource

lindong28
authored and
becketqin
committedMar 29, 2021
[FLINK-20114][connector/kafka] Add IT cases for KafkaSource by migrating IT cases from FlinkKafkaConsumer.

lindong28
authored and
becketqin
committedMar 29, 2021
[FLINK-20114][connector/kafka] Auto offset commit should be disabled by default.

lindong28
authored and
becketqin
committedMar 29, 2021
[FLINK-20114][connector/kafka] SourceOperatorStreamTask should check the committed offset first before using OffsetResetStrategy.

lindong28
authored and
becketqin
committedMar 29, 2021
[FLINK-20114][connector/kafka] PartitionOffsetsRetrieverImpl.committedOffsets() should handle the case without committed offsets.

lindong28
authored and
becketqin
committedMar 29, 2021
[hotfix][connector/kafka] Remove the unused close.timeout.ms config.

lindong28
authored and
becketqin
committedMar 29, 2021
[FLINK-20114][connector/kafka] KafkaSourceEnumerator should close the admin client early if periodic partition discovery is disabled.

lindong28
authored and
becketqin
committedMar 29, 2021
[FLINK-20114][connector/common] SourceOperatorStreamTask should update the numRecordsOutCount metric

lindong28
authored and
becketqin
committedMar 29, 2021
[hotfix][connector/kafka] Reduce the offset commit logging verbosity from INFO to DEBUG.

lindong28
authored and
becketqin
committedMar 29, 2021
[FLINK-20114][connector/common] SourceCoordinatorContext should not log and fail job again if it receives InterruptedException after it is closed.

lindong28
authored and
becketqin
committedMar 29, 2021
[FLINK-20114][connector/kafka] KafkaSourceReader should not commit offsets for partitions whose offsets have not been initialized.

lindong28
authored and
becketqin
committedMar 29, 2021

Commits on Mar 11, 2021

[FLINK-20379][connector/common][test] Add TestingDeserializationContext and KafkaRecordDeserializationSchemaTest

lindong28
authored and
becketqin
committedMar 11, 2021
[FLINK-20379][connector/kafka] Add a convenient method setValueOnlyDeserializer(DeserializationSchema) to KafkaSourceBuilder.

lindong28
authored and
becketqin
committedMar 11, 2021
[FLINK-20379][connector/kafka] Added methods valueOnly(...) and open(..) in the KafkaRecordDeserializationSchema interface to enable the reuse of the DeserializationSchema and KafkaDeserializationS…

lindong28
authored and
becketqin
committedMar 11, 2021
[FLINK-20379][connector/common] Add a method of getUserCodeClassLoader() method to the SourceReaderContext.

lindong28
authored and
becketqin
committedMar 11, 2021
[FLINK-20379][connector/kafka] Rename KafkaRecordDeserializer to KafkaRecordDeserializationSchema to follow the naming convention.

lindong28
authored and
becketqin
committedMar 11, 2021