Skip to content

Commit

Permalink
[hotfix][e2e] Fix docker invocation in mesos tests
Browse files Browse the repository at this point in the history
  • Loading branch information
rmetzger committed Feb 12, 2020
1 parent 0fc54dc commit 719e8c3
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Expand Up @@ -29,7 +29,7 @@ TEST_PROGRAM_JAR=$END_TO_END_DIR/flink-cli-test/target/PeriodicStreamingJob.jar

function submit_job {
local output_path=$1
docker exec -it mesos-master bash -c "${FLINK_DIR}/bin/flink run -d -p 1 ${TEST_PROGRAM_JAR} --durationInSecond ${DURATION} --outputPath ${output_path}" \
docker exec mesos-master bash -c "${FLINK_DIR}/bin/flink run -d -p 1 ${TEST_PROGRAM_JAR} --durationInSecond ${DURATION} --outputPath ${output_path}" \
| grep "Job has been submitted with JobID" | sed 's/.* //g' | tr -d '\r'
}

Expand Down
Expand Up @@ -31,6 +31,6 @@ mkdir -p "${TEST_DATA_DIR}"

start_flink_cluster_with_mesos

docker exec -it mesos-master nohup bash -c "${FLINK_DIR}/bin/flink run -p 1 ${TEST_PROGRAM_JAR} ${INPUT_ARGS} --output ${OUTPUT_LOCATION}"
docker exec mesos-master nohup bash -c "${FLINK_DIR}/bin/flink run -p 1 ${TEST_PROGRAM_JAR} ${INPUT_ARGS} --output ${OUTPUT_LOCATION}"

check_result_hash "Mesos WordCount test" "${OUTPUT_LOCATION}" "${RESULT_HASH}"

0 comments on commit 719e8c3

Please sign in to comment.