From a6bf6b8d7b24bf91e104f18ffac6745d2d373586 Mon Sep 17 00:00:00 2001 From: dygao2 Date: Mon, 19 Jun 2023 17:44:47 +0800 Subject: [PATCH] [Bug][Fix-265] flink configuration did not actually take effect --- .../worker/handler/ConfigureServiceHandler.java | 5 +++++ .../strategy/AbstractHandlerStrategy.java | 17 +++++++++++++++++ 2 files changed, 22 insertions(+) diff --git a/datasophon-worker/src/main/java/com/datasophon/worker/handler/ConfigureServiceHandler.java b/datasophon-worker/src/main/java/com/datasophon/worker/handler/ConfigureServiceHandler.java index 336bb327..0949bf48 100644 --- a/datasophon-worker/src/main/java/com/datasophon/worker/handler/ConfigureServiceHandler.java +++ b/datasophon-worker/src/main/java/com/datasophon/worker/handler/ConfigureServiceHandler.java @@ -155,6 +155,11 @@ public ExecResult configure(Map> cofigFileMap, } else { FreemakerUtils.generateConfigFile(generators, configs, decompressPackageName); } + }else{ + String packagePath = Constants.INSTALL_PATH + Constants.SLASH + decompressPackageName + Constants.SLASH; + String outputFile = + packagePath + generators.getOutputDirectory() + Constants.SLASH + generators.getFilename(); + FileUtil.writeUtf8String("",outputFile); } execResult.setExecOut("configure success"); logger.info("configure success"); diff --git a/datasophon-worker/src/main/java/com/datasophon/worker/strategy/AbstractHandlerStrategy.java b/datasophon-worker/src/main/java/com/datasophon/worker/strategy/AbstractHandlerStrategy.java index 5dddcb42..faaeefdf 100644 --- a/datasophon-worker/src/main/java/com/datasophon/worker/strategy/AbstractHandlerStrategy.java +++ b/datasophon-worker/src/main/java/com/datasophon/worker/strategy/AbstractHandlerStrategy.java @@ -1,3 +1,20 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + package com.datasophon.worker.strategy; import com.datasophon.worker.utils.TaskConstants;