You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by bl...@apache.org on 2020/01/12 18:30:45 UTC
[flink] branch release-1.10 updated: [FLINK-15464][hive] Fix
HiveTableSourceTest::testPartitionFilterDateTimestamp for 1.x
This is an automated email from the ASF dual-hosted git repository.
bli pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.10 by this push:
new 3a13e1b [FLINK-15464][hive] Fix HiveTableSourceTest::testPartitionFilterDateTimestamp for 1.x
3a13e1b is described below
commit 3a13e1bf586b011e4018ab328190de308e1d82fd
Author: Rui Li <li...@apache.org>
AuthorDate: Fri Jan 3 14:31:29 2020 +0800
[FLINK-15464][hive] Fix HiveTableSourceTest::testPartitionFilterDateTimestamp for 1.x
closes #10757.
---
.../java/org/apache/flink/connectors/hive/HiveTableSourceTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceTest.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceTest.java
index 520b2f2..18cdea2 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceTest.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceTest.java
@@ -294,11 +294,11 @@ public class HiveTableSourceTest {
try {
hiveShell.execute("create table db1.part(x int) partitioned by (p1 date,p2 timestamp)");
HiveTestUtils.createTextTableInserter(hiveShell, "db1", "part")
- .addRow(new Object[]{1}).commit("p1=date '2018-08-08',p2=timestamp '2018-08-08 08:08:08'");
+ .addRow(new Object[]{1}).commit("p1='2018-08-08',p2='2018-08-08 08:08:08'");
HiveTestUtils.createTextTableInserter(hiveShell, "db1", "part")
- .addRow(new Object[]{2}).commit("p1=date '2018-08-09',p2=timestamp '2018-08-08 08:08:09'");
+ .addRow(new Object[]{2}).commit("p1='2018-08-09',p2='2018-08-08 08:08:09'");
HiveTestUtils.createTextTableInserter(hiveShell, "db1", "part")
- .addRow(new Object[]{3}).commit("p1=date '2018-08-10',p2=timestamp '2018-08-08 08:08:10'");
+ .addRow(new Object[]{3}).commit("p1='2018-08-10',p2='2018-08-08 08:08:10'");
TableEnvironment tableEnv = HiveTestUtils.createTableEnvWithBlinkPlannerBatchMode();
TestPartitionFilterCatalog catalog = new TestPartitionFilterCatalog(