fix

apache · Aug 15, 2024 · 543268b · 543268b
1 parent 62fb053
commit 543268b
Show file tree

Hide file tree

Showing 6 changed files with 18 additions and 16 deletions.
diff --git a/...che/doris/flink/autoci/DorisTestBase.java → ...org/apache/doris/flink/DorisTestBase.java b/...che/doris/flink/autoci/DorisTestBase.java → ...org/apache/doris/flink/DorisTestBase.java
@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package org.apache.doris.flink.autoci;
+package org.apache.doris.flink;
 
 import org.apache.flink.api.common.JobID;
 import org.apache.flink.api.common.JobStatus;

diff --git a/...ink/autoci/itcase/DorisCatalogITCase.java → ...ris/flink/catalog/DorisCatalogITCase.java b/...ink/autoci/itcase/DorisCatalogITCase.java → ...ris/flink/catalog/DorisCatalogITCase.java
@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package org.apache.doris.flink.autoci.itcase;
+package org.apache.doris.flink.catalog;
 
 import org.apache.flink.table.api.DataTypes;
 import org.apache.flink.table.api.EnvironmentSettings;
@@ -40,8 +40,7 @@
 import org.apache.flink.util.CollectionUtil;
 
 import com.google.common.collect.Lists;
-import org.apache.doris.flink.autoci.DorisTestBase;
-import org.apache.doris.flink.catalog.DorisCatalog;
+import org.apache.doris.flink.DorisTestBase;
 import org.apache.doris.flink.cfg.DorisConnectionOptions;
 import org.junit.Assert;
 import org.junit.Before;
@@ -184,6 +183,13 @@ public void setup()
         catalog.createTable(new ObjectPath(TEST_DB, TEST_TABLE_SINK_GROUPBY), createTable(), true);
     }
 
+    @Test
+    @Ignore
+    public void testQueryFenodes() {
+        String actual = catalog.queryFenodes();
+        assertEquals(getFenodes(), actual);
+    }
+
     @Test
     public void testListDatabases() {
         List<String> actual = catalog.listDatabases();

diff --git a/.../flink/autoci/itcase/DorisSinkITCase.java → ...che/doris/flink/sink/DorisSinkITCase.java b/.../flink/autoci/itcase/DorisSinkITCase.java → ...che/doris/flink/sink/DorisSinkITCase.java
@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package org.apache.doris.flink.autoci.itcase;
+package org.apache.doris.flink.sink;
 
 import org.apache.flink.api.common.JobID;
 import org.apache.flink.api.common.RuntimeExecutionMode;
@@ -26,11 +26,10 @@
 import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
-import org.apache.doris.flink.autoci.DorisTestBase;
+import org.apache.doris.flink.DorisTestBase;
 import org.apache.doris.flink.cfg.DorisExecutionOptions;
 import org.apache.doris.flink.cfg.DorisOptions;
 import org.apache.doris.flink.cfg.DorisReadOptions;
-import org.apache.doris.flink.sink.DorisSink;
 import org.apache.doris.flink.sink.DorisSink.Builder;
 import org.apache.doris.flink.sink.batch.DorisBatchSink;
 import org.apache.doris.flink.sink.writer.serializer.SimpleStringSerializer;

diff --git a/...nk/autoci/itcase/SchemaManagerITCase.java → ...link/sink/schema/SchemaManagerITCase.java b/...nk/autoci/itcase/SchemaManagerITCase.java → ...link/sink/schema/SchemaManagerITCase.java
@@ -15,17 +15,16 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package org.apache.doris.flink.autoci.itcase;
+package org.apache.doris.flink.sink.schema;
 
-import org.apache.doris.flink.autoci.DorisTestBase;
+import org.apache.doris.flink.DorisTestBase;
 import org.apache.doris.flink.catalog.doris.DataModel;
 import org.apache.doris.flink.catalog.doris.FieldSchema;
 import org.apache.doris.flink.catalog.doris.TableSchema;
 import org.apache.doris.flink.cfg.DorisOptions;
 import org.apache.doris.flink.exception.IllegalArgumentException;
 import org.apache.doris.flink.rest.models.Field;
 import org.apache.doris.flink.rest.models.Schema;
-import org.apache.doris.flink.sink.schema.SchemaChangeManager;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;

diff --git a/...link/autoci/itcase/DorisSourceITCase.java → ...doris/flink/source/DorisSourceITCase.java b/...link/autoci/itcase/DorisSourceITCase.java → ...doris/flink/source/DorisSourceITCase.java
@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package org.apache.doris.flink.autoci.itcase;
+package org.apache.doris.flink.source;
 
 import org.apache.flink.api.common.RuntimeExecutionMode;
 import org.apache.flink.api.common.eventtime.WatermarkStrategy;
@@ -25,12 +25,11 @@
 import org.apache.flink.types.Row;
 import org.apache.flink.util.CloseableIterator;
 
-import org.apache.doris.flink.autoci.DorisTestBase;
+import org.apache.doris.flink.DorisTestBase;
 import org.apache.doris.flink.cfg.DorisOptions;
 import org.apache.doris.flink.cfg.DorisStreamOptions;
 import org.apache.doris.flink.datastream.DorisSourceFunction;
 import org.apache.doris.flink.deserialization.SimpleListDeserializationSchema;
-import org.apache.doris.flink.source.DorisSource;
 import org.junit.Assert;
 import org.junit.Test;
 

diff --git a/...DorisRowDataJdbcLookupFunctionITCase.java → ...DorisRowDataJdbcLookupFunctionITCase.java b/...DorisRowDataJdbcLookupFunctionITCase.java → ...DorisRowDataJdbcLookupFunctionITCase.java
@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-package org.apache.doris.flink.autoci.itcase;
+package org.apache.doris.flink.table;
 
 import org.apache.flink.table.api.DataTypes;
 import org.apache.flink.table.data.GenericRowData;
@@ -26,10 +26,9 @@
 import org.apache.flink.util.Collector;
 
 import com.google.common.cache.Cache;
-import org.apache.doris.flink.autoci.DorisTestBase;
+import org.apache.doris.flink.DorisTestBase;
 import org.apache.doris.flink.cfg.DorisLookupOptions;
 import org.apache.doris.flink.cfg.DorisOptions;
-import org.apache.doris.flink.table.DorisRowDataJdbcLookupFunction;
 import org.junit.Before;
 import org.junit.Test;