This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from bff1fc2782e [FLINK-28569][table-planner] Fix SinkUpsertMaterializer
that should be aware of the input upsertKey if it is not empty to prevent wrong
results
add a98726ee416 [FLINK-29287][tests] Add PackagingTestUtils
add 06b75071062 [FLINK-29287][tests] Rewrite sql-client packaging tests
No new revisions were added by this update.
Summary of changes:
flink-connectors/flink-sql-connector-kafka/pom.xml | 6 +
.../flink/connectors/kafka/PackagingITCase.java | 25 ++--
.../flink-sql-connector-kinesis/pom.xml | 6 +
.../flink/connectors/kinesis/PackagingITCase.java | 35 +++---
.../test-scripts/test_sql_client.sh | 41 -------
flink-formats/flink-sql-avro/pom.xml | 6 +
.../apache/flink/formats/avro/PackagingITCase.java | 25 ++--
.../apache/flink/packaging/PackagingTestUtils.java | 104 ++++++++++++++++
.../flink/packaging/PackagingTestUtilsTest.java | 134 +++++++++++++++++++++
9 files changed, 299 insertions(+), 83 deletions(-)
copy
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarDeleteHeadersTest.java
=>
flink-connectors/flink-sql-connector-kafka/src/test/java/org/apache/flink/connectors/kafka/PackagingITCase.java
(57%)
copy
flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/JobSubmitRequestBodyTest.java
=>
flink-connectors/flink-sql-connector-kinesis/src/test/java/org/apache/flink/connectors/kinesis/PackagingITCase.java
(51%)
copy
flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarDeleteHeadersTest.java
=>
flink-formats/flink-sql-avro/src/test/java/org/apache/flink/formats/avro/PackagingITCase.java
(58%)
create mode 100644
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/packaging/PackagingTestUtils.java
create mode 100644
flink-test-utils-parent/flink-test-utils/src/test/java/org/apache/flink/packaging/PackagingTestUtilsTest.java
