address comment

apache · Mar 5, 2021 · a34809a · a34809a
1 parent b20bcbb
commit a34809a
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...link-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectITCase.java b/...link-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectITCase.java
@@ -68,7 +68,7 @@
 import static org.apache.flink.table.api.EnvironmentSettings.DEFAULT_BUILTIN_DATABASE;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertNotSame;
+import static org.junit.Assert.assertNotEquals;
 import static org.junit.Assert.assertSame;
 import static org.junit.Assert.assertTrue;
 
@@ -115,7 +115,8 @@ public void testPluggableParser() {
  assertSame(parser, tableEnvInternal.getParser());
  // switching dialect will result in a new parser
  tableEnvInternal.getConfig().setSqlDialect(SqlDialect.DEFAULT);
- assertNotSame(parser, tableEnvInternal.getParser());
+ assertNotEquals(
+ parser.getClass().getName(), tableEnvInternal.getParser().getClass().getName());
  }
 
  @Test