[flink-table-store] branch master updated: [hotfix] Fix SqlParserEOFException in AlterTableCompactITCase

[lzljs3620320]

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 8d52e58  [hotfix] Fix SqlParserEOFException in AlterTableCompactITCase
8d52e58 is described below

commit 8d52e5820c379052e5df9c7dec5ec01bc32e8d6a
Author: Jane Chan <55568005+ladyfor...@users.noreply.github.com>
AuthorDate: Wed Jun 22 10:21:09 2022 +0800

    [hotfix] Fix SqlParserEOFException in AlterTableCompactITCase
    
    This closes #169
---
 .../org/apache/flink/table/store/connector/AlterTableCompactITCase.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/AlterTableCompactITCase.java
 
b/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/AlterTableCompactITCase.java
index a3b9726..a6cf81a 100644
--- 
a/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/AlterTableCompactITCase.java
+++ 
b/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/AlterTableCompactITCase.java
@@ -239,6 +239,8 @@ public class AlterTableCompactITCase extends 
FileStoreTableITCase {
             KeyValue kv = generator.next();
             if (kv.valueKind() == ValueKind.ADD) {
                 data.add(kv);
+            } else {
+                data.add(kv.replace(kv.key(), ValueKind.ADD, kv.value()));
             }
         }
         return data;