[#3515] feat(flink-connector): Support flink iceberg catalog #18383
sunxiaojianAnnotations
6 errors and 3 warnings
|
build (17):
task ':flink-connector:flink:spotlessJavaCheck'#L1
Execution failed for task ':flink-connector:flink:spotlessJavaCheck':
The following files had format violations:
src/test/java/org/apache/gravitino/flink/connector/integration/test/FlinkEnvIT.java
@@ -19,7 +19,6 @@
package·org.apache.gravitino.flink.connector.integration.test;
import·com.google.common.base.Preconditions;
-import·com.google.common.collect.ImmutableMap;
import·com.google.common.collect.Lists;
import·com.google.errorprone.annotations.FormatMethod;
import·com.google.errorprone.annotations.FormatString;
src/test/java/org/apache/gravitino/flink/connector/integration/test/hive/FlinkHiveCatalogIT.java
@@ -593,23 +593,23 @@
······String·schemaName,
······Consumer<org.apache.gravitino.Catalog>·action,
······boolean·dropSchema)·{
-······Preconditions.checkNotNull(catalog);
-······Preconditions.checkNotNull(schemaName);
-······try·{
-··········tableEnv.useCatalog(catalog.name());
-··········if·(!catalog.asSchemas().schemaExists(schemaName))·{
-··············catalog
-······················.asSchemas()
-······················.createSchema(
-······························schemaName,·null,·ImmutableMap.of("location",·warehouse·+·"/"·+·schemaName));
-··········}
-··········tableEnv.useDatabase(schemaName);
-··········action.accept(catalog);
-······}·finally·{
-··········if·(dropSchema)·{
-··············catalog.asSchemas().dropSchema(schemaName,·true);
-··········}
+····Preconditions.checkNotNull(catalog);
+····Preconditions.checkNotNull(schemaName);
+····try·{
+······tableEnv.useCatalog(catalog.name());
+······if·(!catalog.asSchemas().schemaExists(schemaName))·{
+········catalog
+············.asSchemas()
+············.createSchema(
+················schemaName,·null,·ImmutableMap.of("location",·warehouse·+·"/"·+·schemaName));
+······}
+······tableEnv.useDatabase(schemaName);
+······action.accept(catalog);
+····}·finally·{
+······if·(dropSchema)·{
+········catalog.asSchemas().dropSchema(schemaName,·true);
······}
+····}
··}
··@OverRide
Run './gradlew :flink-connector:flink:spotlessApply' to fix these violations.
at com.diffplug.gradle.spotless.SpotlessCheck.performAction(SpotlessCheck.java:111)
at com.diffplug.gradle.spotless.SpotlessCheck.performAction(SpotlessCheck.java:53)
at org.gradle.internal.reflect.JavaMethod.invoke(JavaMethod.java:125)
at org.gradle.api.internal.project.taskfactory.StandardTaskAction.doExecute(StandardTaskAction.java:58)
at org.gradle.api.internal.project.taskfactory.StandardTaskAction.execute(StandardTaskAction.java:51)
at org.gradle.api.internal.project.taskfactory.StandardTaskAction.execute(StandardTaskAction.java:29)
at org.gradle.api.internal.tasks.execution.TaskExecution$3.run(TaskExecution.java:248)
at org.gradle.internal.operations.DefaultBuildOperationRunner$1.execute(DefaultBuildOperationRunner.java:29)
at org.gradle.internal.operations.DefaultBuildOperationRunner$1.execute(DefaultBuildOperationRunner.java:26)
at org.gradle.internal.operations.DefaultBuildOperationRunner$2.execute(DefaultBuildOperationRunner.java:66)
at org.gradle.internal.operations.DefaultBuildOperationRunner$2.execute(DefaultBuildOperationRunner.java:59)
at org.gradle.internal.operations.DefaultBuildOperationRunner.execute(DefaultBuildOperationRunner.java:157)
at org.gradle.internal.operations.DefaultBuildOperationRunner.execute(DefaultBuildOperationRunner.java:59)
at org.gradle.internal.operations.Defaul
|
|
build (17)
Process completed with exit code 1.
|
|
build (8)
The job was canceled because "_17" failed.
|
|
build (8)
The operation was canceled.
|
|
build (11)
The job was canceled because "_17" failed.
|
|
build (11)
The operation was canceled.
|
|
changes
ubuntu-latest pipelines will use ubuntu-24.04 soon. For more details, see https://github.com/actions/runner-images/issues/10636
|
|
build (17)
ubuntu-latest pipelines will use ubuntu-24.04 soon. For more details, see https://github.com/actions/runner-images/issues/10636
|
|
build (17)
No files were found with the provided path: build/reports
catalogs/**/*.log
catalogs/**/*.tar. No artifacts will be uploaded.
|