This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 1635a284d75 Revert "[FLINK-28046][connectors] Mark SourceFunction
interface as @deprecated"
add 99c652ce347 [FLINK-32624][network] Fix the
TieredStorageConsumerClientTest
No new revisions were added by this update.
Summary of changes:
.../tiered/netty/TestingTierConsumerAgent.java | 120 ++++++++++++++++++
.../netty/TieredStorageConsumerClientTest.java | 141 +++++++--------------
2 files changed, 167 insertions(+), 94 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/TestingTierConsumerAgent.java
