#!/bin/bash

BIN_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
APP_DIR=$(dirname ${BIN_DIR})
LIB_DIR=${APP_DIR}/lib
ASSEMBLY_JAR_NAME=$(find ${LIB_DIR} -name hugegraph-loader*.jar)

# get hugegraph_params and engine_params
source "$BIN_DIR"/get-params.sh
get_params $*
echo "engine_params: $ENGINE_PARAMS"
echo "hugegraph_params: $HUGEGRAPH_PARAMS"

CMD=${FLINK_HOME}/bin/flink run \
  ${ENGINE_PARAMS} \
  -c com.baidu.hugegraph.loader.flink.HugeGraphFlinkCDCLoader \
  ${ASSEMBLY_JAR_NAME} ${HUGEGRAPH_PARAMS}

echo ${CMD}
exec ${CMD}