[hotfix][style] format code

bearlly · Aug 18, 2021 · 7f995f0 · 7f995f0
1 parent 0fc0611
commit 7f995f0
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/...linkx-connector-hive/src/main/java/com/dtstack/flinkx/connector/hive/util/HiveDbUtil.java b/...linkx-connector-hive/src/main/java/com/dtstack/flinkx/connector/hive/util/HiveDbUtil.java
@@ -127,7 +127,9 @@ private static Connection getConnectionWithKerberos(
 
         UserGroupInformation ugi;
         try {
-            ugi = KerberosUtil.loginAndReturnUgi(conf.get(KerberosUtil.KEY_PRINCIPAL_FILE), principal, keytabFileName);
+            ugi =
+                    KerberosUtil.loginAndReturnUgi(
+                            conf.get(KerberosUtil.KEY_PRINCIPAL_FILE), principal, keytabFileName);
         } catch (Exception e) {
             throw new RuntimeException("Login kerberos error:", e);
         }

diff --git a/flinkx-core/src/main/java/com/dtstack/flinkx/util/DataSyncFactoryUtil.java b/flinkx-core/src/main/java/com/dtstack/flinkx/util/DataSyncFactoryUtil.java
@@ -54,7 +54,9 @@ public static SourceFactory discoverSource(SyncConf config, StreamExecutionEnvir
             Set<URL> urlList =
                     PluginUtil.getJarFileDirPath(
                             pluginName,
-                            config.getPluginRoot() + File.separatorChar + ConstantValue.CONNECTOR_DIR_NAME,
+                            config.getPluginRoot()
+                                    + File.separatorChar
+                                    + ConstantValue.CONNECTOR_DIR_NAME,
                             null);
             urlList.addAll(
                     PluginUtil.getJarFileDirPath(
@@ -120,7 +122,9 @@ public static SinkFactory discoverSink(SyncConf config) {
             Set<URL> urlList =
                     PluginUtil.getJarFileDirPath(
                             pluginName,
-                            config.getPluginRoot() + File.separatorChar + ConstantValue.CONNECTOR_DIR_NAME,
+                            config.getPluginRoot()
+                                    + File.separatorChar
+                                    + ConstantValue.CONNECTOR_DIR_NAME,
                             null);
             urlList.addAll(
                     PluginUtil.getJarFileDirPath(