The program is to read the unordered records from a log file, and to print
the record in order. But it doesn't change the order, is there anything
wrong in my code? Can anyone give me an example?
This is my program:
Note: the class Tokenizer is to transfer the log to four parts. Like this:
terDataStream("Syslogs", messages, "time, user,
process, msg");
Table result = tableEnv.sql(
"SELECT STREAM msg FROM Syslogs WHERE msg LIKE '%system%'"
);
TableSink sink = new CsvTableSink("/home/jiecx
For an operator, the input stream is faster than its output stream, so its
input buffer will block the previous operator's output thread that transfers
the data to this operator. Right?
Do the Flink and the Spark both handle the backpressure by blocking the
thread? So what's the difference between
