diff --git a/flink-cyber/cyber-jobs/src/main/resources/scripts/cs-load-enrich b/flink-cyber/cyber-jobs/src/main/resources/scripts/cs-load-enrich index a1b1e5f8d..5329f44ba 100644 --- a/flink-cyber/cyber-jobs/src/main/resources/scripts/cs-load-enrich +++ b/flink-cyber/cyber-jobs/src/main/resources/scripts/cs-load-enrich @@ -90,18 +90,19 @@ fi ship_enrichment_file=() configure_enrich_file=$enrichment_file -if [ "$enrichment_file" == hdfs* ]; then +hdfs_regex='hdfs.*' +if ! [[ "$enrichment_file" =~ $hdfs_regex ]]; then if [ -f "$enrichment_file" ]; then ship_enrichment_file+=("-y" "$enrichment_file") configure_enrich_file=$(basename "$enrichment_file") else - echo "ERROR: $0 Enrichment file $enrichment_file does not exist" >&2 + echo "ERROR: $0 Enrichment file '$enrichment_file' does not exist" >&2 exit 1 fi else hdfs dfs -test -f "$enrichment_file" if [ "$?" -ne 0 ]; then - echo "ERROR: $0 Enrichment file $enrichment_file does not exist" >&2 + echo "ERROR: $0 Enrichment file '$enrichment_file' does not exist" >&2 exit 1 fi fi