我有一个Java接口,有一个简化的定义 public interface JavaInterface {}
public interface Bar { } 在scala中,我试图对列表执行flatMap操作,但得到的关于scala.collection.mutable.Buffer我可以用下面的Scala代码得到相同的编译错误: import ja
我正在尝试使用Java8中的spark 2.1.0进行flatMapJavaDStream<String> words = lines.flatMap(x -> Arrays.asList(x.split(" ")).iterator());Error:(31, 25) java: method flatMap in class org.apache.sp
这对我来说是有意义的,因为它试图建立一个庞大的列表来记忆所有这些IO和Promise对象。
下面是堆栈跟踪:[error] at scalaz.Free.flatMap正如huynhjl所建议的(我使用nadavwr关于分析堆转储的建议进行了验证),consume导致每个膨胀的ZipEntry都保存在内存