Skip to content

[#6302] refactor:Optimize Flink connector properties converter #12100

[#6302] refactor:Optimize Flink connector properties converter

[#6302] refactor:Optimize Flink connector properties converter #12100

Triggered via pull request January 23, 2025 14:29
Status Cancelled
Total duration 3m 25s
Artifacts 1

backend-integration-test.yml

on: pull_request
changes
4s
changes
Matrix: BackendIT-on-pr
Matrix: BackendIT-on-push
Waiting for pending jobs
Fit to window
Zoom out
Zoom in

Annotations

6 errors and 2 warnings
BackendIT-on-pr (linux/amd64, 17, h2, embedded) / JDK17-embedded-h2: task ':flink-connector:flink:spotlessJavaCheck'#L1
Execution failed for task ':flink-connector:flink:spotlessJavaCheck': The following files had format violations: src/main/java/org/apache/gravitino/flink/connector/PropertiesConverter.java @@ -50,7 +50,7 @@ ······if·(gravitinoKey·!=·null)·{ ········gravitinoProperties.put(gravitinoKey,·entry.getValue()); ······}·else·if·(!entry.getKey().startsWith(FLINK_PROPERTY_PREFIX))·{ -········gravitinoProperties.put(FLINK_PROPERTY_PREFIX+entry.getKey(),·entry.getValue()); +········gravitinoProperties.put(FLINK_PROPERTY_PREFIX·+·entry.getKey(),·entry.getValue()); ······}·else·{ ········gravitinoProperties.put(entry.getKey(),·entry.getValue()); ······} src/test/java/org/apache/gravitino/flink/connector/hive/TestHivePropertiesConverter.java @@ -33,38 +33,38 @@ ··@test ··public·void·testToGravitinoCatalogProperties()·{ ····Configuration·configuration·= -············Configuration.fromMap( -····················ImmutableMap.of( -····························"hive-conf-dir", -····························"src/test/resources/flink-tests", -····························"flink.bypass.key", -····························"value", -····························HiveConf.ConfVars.METASTOREURIS.varname, -····························"thrift://127.0.0.1:9084")); +········Configuration.fromMap( +············ImmutableMap.of( +················"hive-conf-dir", +················"src/test/resources/flink-tests", +················"flink.bypass.key", +················"value", +················HiveConf.ConfVars.METASTOREURIS.varname, +················"thrift://127.0.0.1:9084")); ····Map<String,·String>·properties·=·CONVERTER.toGravitinoCatalogProperties(configuration); ····Assertions.assertEquals(3,·properties.size()); ····Assertions.assertEquals( -············"src/test/resources/flink-tests", -············properties.get("flink.bypass.hive-conf-dir"), -············"This·will·add·the·prefix"); +········"src/test/resources/flink-tests", +········properties.get("flink.bypass.hive-conf-dir"), +········"This·will·add·the·prefix"); ····Assertions.assertEquals( -············"value",·properties.get("flink.bypass.key"),·"The·prefix·have·already·existed"); +········"value",·properties.get("flink.bypass.key"),·"The·prefix·have·already·existed"); ····Assertions.assertEquals( -············"thrift://127.0.0.1:9084", -············properties.get(HiveConstants.METASTORE_URIS), -············"The·key·is·converted·to·Gravitino·Config"); +········"thrift://127.0.0.1:9084", +········properties.get(HiveConstants.METASTORE_URIS), +········"The·key·is·converted·to·Gravitino·Config"); ... (19 more lines that didn't fit) Violations also present in: src/test/java/org/apache/gravitino/flink/connector/integration/test/hive/FlinkHiveCatalogIT.java src/test/java/org/apache/gravitino/flink/connector/integration/test/iceberg/FlinkIcebergCatalogIT.java src/test/java/org/apache/gravitino/flink/connector/integration/test/paimon/FlinkPaimonCatalogIT.java src/test/java/org/apache/gravitino/flink/connector/paimon/TestPaimonPropertiesConverter.java 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.doExe
BackendIT-on-pr (linux/amd64, 17, h2, embedded) / JDK17-embedded-h2
Process completed with exit code 1.
BackendIT-on-pr (linux/amd64, 17, mysql, deploy) / JDK17-deploy-mysql
FailFast: cancelling since parallel instance has failed
BackendIT-on-pr (linux/amd64, 17, mysql, deploy) / JDK17-deploy-mysql
The operation was canceled.
BackendIT-on-pr (linux/amd64, 17, postgresql, deploy) / JDK17-deploy-postgresql
FailFast: cancelling since parallel instance has failed
changes
ubuntu-latest pipelines will use ubuntu-24.04 soon. For more details, see https://github.com/actions/runner-images/issues/10636
BackendIT-on-pr (linux/amd64, 17, h2, embedded) / JDK17-embedded-h2
ubuntu-latest pipelines will use ubuntu-24.04 soon. For more details, see https://github.com/actions/runner-images/issues/10636

Artifacts

Produced during runtime
Name Size
integrate-test-reports-17-embedded-h2
3.58 KB