This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from b6db9b1ff87 [MINOR] Fix flaky testStructuredStreamingWithCompaction
(#7485)
add 6aa8e9681b2 [HUDI-5538] Fix ContinuousFileSource and
ITTestDataStreamWrite for flink 1.16 support (#7637)
No new revisions were added by this update.
Summary of changes:
azure-pipelines.yml | 5 +-
.../quickstart/source/ContinuousFileSource.java | 18 ++----
.../hudi/util/JsonDeserializationFunction.java | 73 ++++++++++++++++++++++
.../apache/hudi/sink/ITTestDataStreamWrite.java | 51 ++-------------
.../hudi/utils/source/ContinuousFileSource.java | 43 ++-----------
5 files changed, 92 insertions(+), 98 deletions(-)
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/JsonDeserializationFunction.java
