config-parser-utils.sh 1.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445
  1. #!/usr/bin/env bash
  2. ################################################################################
  3. # Licensed to the Apache Software Foundation (ASF) under one
  4. # or more contributor license agreements. See the NOTICE file
  5. # distributed with this work for additional information
  6. # regarding copyright ownership. The ASF licenses this file
  7. # to you under the Apache License, Version 2.0 (the
  8. # "License"); you may not use this file except in compliance
  9. # with the License. You may obtain a copy of the License at
  10. #
  11. # http://www.apache.org/licenses/LICENSE-2.0
  12. #
  13. # Unless required by applicable law or agreed to in writing, software
  14. # distributed under the License is distributed on an "AS IS" BASIS,
  15. # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16. # See the License for the specific language governing permissions and
  17. # limitations under the License.
  18. ################################################################################
  19. USAGE="Usage: config-parser-utils.sh FLINK_CONF_DIR FLINK_BIN_DIR FLINK_LIB_DIR [dynamic args...]"
  20. if [ "$#" -lt 3 ]; then
  21. echo "$USAGE"
  22. exit 1
  23. fi
  24. source "$2"/bash-java-utils.sh
  25. setJavaRun "$1"
  26. ARGS=("${@:1}")
  27. result=$(updateAndGetFlinkConfiguration "${ARGS[@]}")
  28. if [[ $? -ne 0 ]]; then
  29. echo "[ERROR] Could not get configurations properly, the result is :"
  30. echo "$result"
  31. exit 1
  32. fi
  33. CONF_FILE="$1/flink-conf.yaml"
  34. if [ ! -e "$1/flink-conf.yaml" ]; then
  35. CONF_FILE="$1/config.yaml"
  36. fi;
  37. # Output the result
  38. echo "${result}" > "$CONF_FILE";