perkinls / flink-local-train Goto Github PK

您好，我在使用您代码的过程中，异步io导致一些问题，频繁报错，所以想咨询一下您。
Exception in thread "Thread-13" java.lang.NoClassDefFoundError: io/vertx/core/file/FileSystemException at io.vertx.core.file.impl.FileSystemImpl.deleteInternal(FileSystemImpl.java:615) at io.vertx.core.file.impl.FileSystemImpl.deleteRecursive(FileSystemImpl.java:223) at io.vertx.core.impl.FileResolver.deleteCacheDir(FileResolver.java:328) at io.vertx.core.impl.FileResolver.lambda$setupCacheDir$1(FileResolver.java:317) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.ClassNotFoundException: io.vertx.core.file.FileSystemException at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders$ChildFirstClassLoader.loadClass(FlinkUserCodeClassLoaders.java:129)

主要是想问下有哪些key

练手项目没必须再搭建kafka, 线上切换数据源也简单

WordCount案例：Java 点进去直接报错了，看不了😭

如标题：在scala->stream->LateDataSideOut侧输出这个例子中 reduceData.print() 和 reduceData.getSideOutput(lateOutputTag).print()没有输出结果。但是我在reduce方法中println是可以的，以及将 .allowedLateness(Time.seconds(10)) 和.sideOutputLateData(lateOutputTag)这两个方法注释之后是可以的，kafaka的数据（用的是上一个版本的例子）如下：
{"number":"5","name":"aaaa5","time":1579598108768}
{"number":"3","name":"aaaa3","time":1579598108768}
{"number":"5","name":"aaaa5","time":1579598108768}

您的项目中关于自己的博客地址失效跳转到其他地址了