You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/09/15 10:30:29 UTC
[flink] branch master updated (bff1fc2782e -> 06b75071062)
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