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/incubator-paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 11a633baa [hotfix] Enable
StreamingReadWriteTableWithKafkaLogITCase.testReadInsertOnlyChangelogFromEnormousTimestamp
(#854)
11a633baa is described below
commit 11a633baabf1b9aa8bf1d728174c8e5dc5ccefaa
Author: yuzelin <[email protected]>
AuthorDate: Mon Apr 10 16:49:11 2023 +0800
[hotfix] Enable
StreamingReadWriteTableWithKafkaLogITCase.testReadInsertOnlyChangelogFromEnormousTimestamp
(#854)
---
.../flink/StreamingReadWriteTableWithKafkaLogITCase.java | 11 +----------
1 file changed, 1 insertion(+), 10 deletions(-)
diff --git
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/StreamingReadWriteTableWithKafkaLogITCase.java
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/StreamingReadWriteTableWithKafkaLogITCase.java
index c024228a8..c028c13e6 100644
---
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/StreamingReadWriteTableWithKafkaLogITCase.java
+++
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/StreamingReadWriteTableWithKafkaLogITCase.java
@@ -24,7 +24,6 @@ import org.apache.paimon.utils.BlockingIterator;
import org.apache.flink.types.Row;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import java.util.Arrays;
@@ -58,7 +57,7 @@ import static
org.apache.paimon.flink.util.ReadWriteTableTestUtil.validateStream
public class StreamingReadWriteTableWithKafkaLogITCase extends
KafkaTableTestBase {
@BeforeEach
- public void setUp() throws Exception {
+ public void setUp() {
init(createAndRegisterTempFile("").toString());
}
@@ -1244,14 +1243,6 @@ public class StreamingReadWriteTableWithKafkaLogITCase
extends KafkaTableTestBas
.close();
}
- /**
- * TODO.
- *
- * <p>This test will fail due to: <a
- *
href="https://issues.apache.org/jira/browse/FLINK-28185";>FLINK-28185</a>. This
bug will be
- * fixed in Flink-1.16.1 and after we update flink version this case can
work.
- */
- @Disabled
@Test
public void testReadInsertOnlyChangelogFromEnormousTimestamp() throws
Exception {
List<Row> initialRecords =
