@ org.apache.flink:flink-scala_${scala.binary.version}:1.15.0, C:\Users\bk73027\Projects\FlinkDemo\flink\bk73027\Projects\FlinkDemo\flink-1.15.0\flink-connectors\flink-hadoop-compatibility\pom.xml, line 32\flink-1.15.0\flink-con
FLINK_OPT_DIR/flink-python*.jar $FLINK_LIB_DIR; fi && if [ -f ${FLINK_INSTALL_PATH}/flink-shaded-hadoop* ]; then ln -s ${FLINK_INSTALL_PATH}/flink-shaded-hadoop* $FLINK_LIB_DIR; fi && addgroup
at org.apache.flink.streaming.runtime.io.RecordWriterOutput.collect(RecordWriterOutput.java:75) ~[flink-dist:39) ~[flink-dist_2.11-1.2.0.jar:1.2.0]
at org.apache.flink.streaming.api.operators.AbstractStreamOperator(StreamFlatMap.java:47) [flink-dist_2
(Task.java:707) [flink-runtime_2.12-1.10.0.jar:1.10.0] at org.apache.flink.core.fs.FSDataInputStreamWrapper.read05:39:14.261 [flink-akka.actor.default-dis