У меня есть java-программа Flink, которая производит 2 вывода, которые я хочу записать в файл. Я использую для этого OpenCSV 4.0, и он работает хорошо. Допустим, выходной файл должен быть x, y, где x и y — два выхода. Я получаю этот вывод, когда запускаю эту программу из IntelliJ IDE.
Это код для записи файла CSV
if(write_into_csv && is_job_finished){
String fileName = "/Users/amar/Desktop/out/join.csv";
CSVWriter writer = new CSVWriter(new FileWriter("/Users/amar/Desktop/out/join.csv",true));
writer.writeNext(new String[]{Integer.toString(WindowLength_join__ms), Integer.toString(number_of_joined_events)});
writer.close();
} //if(write_into_csv)
Вывод этой программы
Поскольку мне нужно запускать эту программу несколько раз, поэтому я создал файл bash, который запускает файл jar несколько раз, а затем запускает файл python для создания графиков. Во всяком случае, проблема в том, что в случае файла bash вывод выглядит примерно так
Почему второе значение равно нулю?
Содержимое файла bash
#! /bin/bash
clear
jarpath="/Users/amar/Documents/ThesisCode/CEP_Architectures/Mobile_CEP/classes/artifacts/cep_monitoring_jar/cep-monitoring.jar"
flinkpath="/usr/local/Cellar/apache-flink/1.3.2/"
result_file_path="/Users/amar/PycharmProjects/untitled/join_graph.py"
# $flinkpath./bin/historyserver.sh start
for i in {1..3}
do
$flinkpath./bin/flink run $jarpath 500
$flinkpath./bin/flink run $jarpath 1000
$flinkpath./bin/flink run $jarpath 2000
# $flinkpath./bin/flink run $jarpath 2500
# $flinkpath./bin/flink run $jarpath 3000
# $flinkpath./bin/flink run $jarpath 3500
# $flinkpath./bin/flink run $jarpath 4000
done
# $flinkpath./bin/historyserver.sh stop
python $result_file_path
echo "program is complete"
fileName
, но не используете его в следующей строке? - person choroba   schedule 11.11.2017number_of_joined_events
? - person choroba   schedule 11.11.2017