在我的本地环境中,当我向Flink (v1.0.3)提交一个新作业时,我得到了这个错误。
原因: org/apache/flink/streaming/runtime/operators/CheckpointCommitter at org.apache.flink.streaming.connectors.cassandra.CassandraSink.addSink(CassandraSink.java:164) at com.xxx.yyy.sample.backend.flink.AAAAA.main(AAAAA.java:99) at sun.reflect.NativeMethod
我正在尝试为Apache导入scala流扩展,正如中所解释的那样
但是,我的ScalaIDE发出了以下消息:对象扩展不是包org.apache.flink.streaming.api.scala的成员
我使用Scala2.11和Flink 1.0.1。
以下是我的导入语句:导入org.apache.flink.streaming.api.scala.extensions._
这是我的pom.xml:
<!--
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agr
我有下面的for-loop,它循环遍历所有需要复制的给定源代码。
for i in "${sources[@]}"; do
exclude="--exclude 'exclude_folder/exclude_file'"
rsync -az $exclude $i $destination
done
但是,排除选项不起作用。
for i in "${sources[@]}"; do
exclude="--exclude 'exclude_folder/exclude_file'&