This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
The following commit(s) were added to refs/heads/master by this push:
new 39f06f2e [FLINK-30428] Fix SparkReadITCase.testSnapshotsTable
39f06f2e is described below
commit 39f06f2ea5db8eee10a044316e54aeb9623c9f9f
Author: shammon <[email protected]>
AuthorDate: Fri Dec 16 11:49:19 2022 +0800
[FLINK-30428] Fix SparkReadITCase.testSnapshotsTable
This closes #440
---
.../org/apache/flink/table/store/spark/SparkReadITCase.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git
a/flink-table-store-spark/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java
b/flink-table-store-spark/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java
index 1e3e35d3..1c6f8caf 100644
---
a/flink-table-store-spark/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java
+++
b/flink-table-store-spark/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java
@@ -96,13 +96,13 @@ public class SparkReadITCase extends SparkReadTestBase {
List<Row> schemas =
spark.table("tablestore.default.`schemasTable$schemas`").collectAsList();
List<?> fieldsList = schemas.stream().map(row ->
row.get(1)).collect(Collectors.toList());
- assertThat(fieldsList.toString())
- .isEqualTo(
- "[[{\"id\":0,\"name\":\"a\",\"type\":\"BIGINT NOT
NULL\"},"
- +
"{\"id\":1,\"name\":\"b\",\"type\":\"VARCHAR(2147483647)\"}], "
- + "[{\"id\":0,\"name\":\"a\",\"type\":\"BIGINT
NOT NULL\"},"
+
assertThat(fieldsList.stream().map(Object::toString).collect(Collectors.toList()))
+ .containsExactlyInAnyOrder(
+ "[{\"id\":0,\"name\":\"a\",\"type\":\"BIGINT NOT
NULL\"},"
+ +
"{\"id\":1,\"name\":\"b\",\"type\":\"VARCHAR(2147483647)\"}]",
+ "[{\"id\":0,\"name\":\"a\",\"type\":\"BIGINT NOT
NULL\"},"
+
"{\"id\":1,\"name\":\"b\",\"type\":\"VARCHAR(2147483647)\"},"
- +
"{\"id\":2,\"name\":\"c\",\"type\":\"VARCHAR(2147483647)\"}]]");
+ +
"{\"id\":2,\"name\":\"c\",\"type\":\"VARCHAR(2147483647)\"}]");
}
@Test