已有0人关注此标签
Flink 运行一段时间后报错
作者： panpanpa123
131人浏览
0人回答
t-2cef9f5c52247f757f677c1592279fb65f096544-78ffcb691eed1982c6e6833f3b5b5872 from master/127.0.0.1:338782019-06-13 19:22…
flink用IDEA本地运行可以读取HDFS数据，然后把项目打包提交到flink集群，无法读取HDFS数据，出现以下错误，这是为何？
作者： 八戒八戒2333
319人浏览
1人回答
The program finished with the following exception: org.apache.flink.client.program.ProgramInvocationException: Job fa…
flink在执行job时checkpoint报错
作者： 雅拓
203人浏览
1人回答
Flink版本是1.8standardalone cluster模式3台机器执行的时候一直出hdfs权限错误，查看了hdfs目录权限好像是没问题 AsynchronousException{java.lang.Exception: Cou…
flink的空指针异常
作者： 游客dzclyts7d3ubw
310人浏览
1人回答
java.lang.RuntimeException at org.apache.flink.streaming.runtime.io.RecordWriterOutput.pushToRecordWriter(RecordWriterO…
flink消费kafka报错 Couldn't retrieve the JobExecutionResult from the JobManager
作者： guicai
390人浏览
0人回答
Starting execution of programSubmitting job with JobID: aca099531abda417700799ace53e0fbd. Waiting for job completion. …
cloudera manage flink 提交任务失败
作者： 游客ln3vfnpek3fvg
306人浏览
0人回答
在cloudera manage上面安装Flink，每台机器启动都有YarnSessionClusterEntrypoint进程，提交任务的时候，报错Caused by: java.util.concurrent.CompletionEx…
so找不到
作者： 游客aqpqenklvwob2
532人浏览
1人回答
android application里面的代码：@Override public void onCreate() { super.onCreate(); QupaiHttpFinal.getInstance().init…
问大家一个问题 关于redis的 ： 每次数据写入之后 没过多久redis 就自动给我删除了 是为什么 keys* 之后只有 runtime 和caches 这两个key
作者： 李博 bluemind
2025人浏览
10人回答
很烦躁啊 测试环境下的机器上的redis一点问题都没有 软件都是我搭的 应该是没有问题的 也是最近才出现这个问题 之前就没遇到过
blink使用streaming的runtime实现batch，效率会降低吗？
作者： apache_flink
261人浏览
2人回答
转自钉钉群21789141：blink 使用 streaming 的 runtime 实现 batch，效率会降低吗？
flink 类型转换,scala 继承map接口后,报java.lang.ClassCastException
作者： 灰灰fly
460人浏览
1人回答
类型: case class RIchMap(data:Map[String,Any] = Map()) extends Map[String, Any] with GenMap[String, Any] with Serializabl…
blink使用streaming的runtime实现batch，效率会降低吗？
作者： 赵慧
278人浏览
1人回答
转自钉钉群21789141：blink使用streaming的runtime实现batch，效率会降低吗？
视频点播视频上传 CreateUploadVideoRequest 本地不报错，部署到服务器就报错
作者： shellyzhu
1274人浏览
1人回答
未能加载文件或程序集“System.Runtime, Version=4.1.0.0, Culture=neutral, PublicKeyToken=b03f5f7f11d50a3a”或它的某一个依赖项。找到的程序集清单定义与程序集引用…
当在Docker容器中运行时，高I / O Java进程始终在JavaThread中获得信号11 SIGSEGV
作者： k8s小能手
342人浏览
1人回答
有没有人能够使用不同的硬件和不同的JRE版本在JRE上一致地复制SIGSEGV？注意（可能很重要）：我在Kubernetes上部署的Docker容器中运行该进程。 示例错误： A fatal error has been detected…
Flink collector.collect 是报Buffer pool is destroyed.
作者： ryan_wfa
1161人浏览
2人回答
使用的是事件时间java.lang.RuntimeException: Buffer pool is destroyed. at org.apache.flink.streaming.runtime.io.RecordWriterOutp…
Flink 执行checkpoint报错
作者： 冷丰
541人浏览
1人回答
flink 程序不开启checkpoint运行正常,开启checkpoint报: AsynchronousException{java.lang.Exception: Could not materialize checkpoint 18…
Flink 从Checkpoint恢复失败
作者： 冷丰
1326人浏览
1人回答
import java.util.Properties import org.apache.flink.api.common.serialization.SimpleStringSchema import org.apache.flink…
如何使用两个日期过滤数据框？
作者： 社区小助手
290人浏览
1人回答
我有一个场景，其中dataframe具有data_date，如下所示 root |-- data_date: timestamp (nullable = true) +-------------------+ | d…
当yarn崩溃时恢复Flink
作者： flink小助手
1131人浏览
1人回答
我正在EMR上运行一个Yarn3节点集群（1个Master 2 Core节点）。我使用的是1.6.0。我启用了检查指向（rocksdb），写入S3。检查指向似乎在其他测试中正常工作。在主节点上Yarn崩溃的情况下，我无法从最后一个检查点恢…
OrcTableSource是否支持S3文件系统？
作者： flink小助手
407人浏览
1人回答
我使用OrcTableSource从云对象存储（IBM COS）获取Orc文件时遇到了一些麻烦，代码片段如下所示： OrcTableSource soORCTableSource = OrcTableSource.builder() //…
Flink with Elasticsearch 6.0.0 Sink没有这种方法错误批量处理。
作者： 社区小助手
601人浏览
1人回答
用elasticsearch（版本是6.0.0）接收器构建一个flink流式字数统计演示。得到了跟随错误。这似乎是依赖性的冲突。 Exception in thread "main" org.apache.flink.runtime.cl…
