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 39779829b88 [FLINK-34954][core] Kryo Input bug fix
add 7c4dec63eb4 [FLINK-28048][connectors] Introduce Source API alternative
to FiniteTestSource (#23777)
No new revisions were added by this update.
Summary of changes:
.../f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e | 118 +++++++--------
flink-connectors/flink-connector-datagen/pom.xml | 16 +++
...tion.java => IndexLookupGeneratorFunction.java} | 145 ++++++++-----------
.../datagen/source/DataGeneratorSource.java | 2 +-
...ittingSourceReaderWithCheckpointsInBetween.java | 158 +++++++++++++++++++++
.../datagen/source/TestDataGenerators.java | 83 +++++++++++
flink-connectors/flink-connector-hive/pom.xml | 8 ++
.../flink/connectors/hive/HiveTableSinkITCase.java | 49 ++++---
.../connectors/hive/HiveTableSourceITCase.java | 40 +++---
.../source/lib/util/IteratorSourceReaderBase.java | 10 +-
flink-formats/flink-avro/pom.xml | 8 ++
.../formats/avro/AvroStreamingFileSinkITCase.java | 25 +++-
flink-formats/flink-compress/pom.xml | 8 ++
.../formats/compress/CompressionFactoryITCase.java | 10 +-
flink-formats/flink-csv/pom.xml | 8 ++
flink-formats/flink-hadoop-bulk/pom.xml | 8 ++
.../bulk/HadoopPathBasedPartFileWriterITCase.java | 15 +-
flink-formats/flink-json/pom.xml | 8 ++
flink-formats/flink-orc/pom.xml | 8 ++
.../flink/orc/writer/OrcBulkWriterITCase.java | 10 +-
flink-formats/flink-parquet/pom.xml | 8 ++
.../avro/AvroParquetStreamingFileSinkITCase.java | 21 ++-
.../ParquetProtoStreamingFileSinkITCase.java | 10 +-
flink-formats/flink-sequence-file/pom.xml | 8 ++
.../SequenceStreamingFileSinkITCase.java | 12 +-
flink-table/flink-table-planner/pom.xml | 10 +-
.../runtime/stream/sql/CompactionITCaseBase.java | 20 +--
flink-tests/pom.xml | 2 +
.../flink/test/streaming/runtime/SinkITCase.java | 75 +++++-----
29 files changed, 652 insertions(+), 251 deletions(-)
copy
flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/functions/{FromElementsGeneratorFunction.java
=> IndexLookupGeneratorFunction.java} (61%)
create mode 100644
flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/source/DoubleEmittingSourceReaderWithCheckpointsInBetween.java
create mode 100644
flink-connectors/flink-connector-datagen/src/test/java/org/apache/flink/connector/datagen/source/TestDataGenerators.java
