The assigned slot
container_e10_1579661300080_0005_01_02_0 was removed.
你上面的是 taskmanager.err，需要的是 taskmanager.log
Best,
tison.
郑 洁锋 于2020年1月23日周四 下午10:22写道：
> 之前挂过 后面启动的时候 是checkpoints的文件丢了？ 你是这个意思吗？
>
>
> zjfpla...@hotmail.com
>
> 发件人： zhisheng&l
ssigned slot
container_e10_1579661300080_0005_01_02_0 was removed.
应该是你作业之前挂过了
郑 洁锋 于2020年1月22日周三 上午11:16写道：
> 大家好，
>flink on yarn任务启动时，发现报错了The assigned slot
> container_e10_1579661300080_0005_01_02_0 was removed.
>环境：flink1.8.1，cdh5.14.2，kafka0.10，jdk1.8.0_241
>
> flink版本为1.8.1，yarn上的
d.
那你看下 TM 那台机器上的 TM 日志，从 JM 端来看 TM 曾经成功起来过并注册了自己，你看看 TM 是怎么挂的或者别的什么情况
Best,
tison.
郑 洁锋 于2020年1月22日周三 上午11:54写道：
> TM没有起来，服务器本身内存cpu都是够的，还很空闲
>
>
> zjfpla...@hotmail.com
>
> 发件人： tison<mailto:wander4...@gmail.com>
> 发送时间： 2020-01
Best,
tison.
郑 洁锋 于2020年1月22日周三 上午11:16写道：
> 大家好，
>flink on yarn任务启动时，发现报错了The assigned slot
> container_e10_1579661300080_0005_01_02_0 was removed.
>环境：flink1.8.1，cdh5.14.2，kafka0.10，jdk1.8.0_241
>
> flink版本为1.8.1，yarn上的日志：
>
> 20/01/22 11:07:
大家好，
flink on yarn任务启动时，发现报错了The assigned slot
container_e10_1579661300080_0005_01_02_0 was removed.
环境：flink1.8.1，cdh5.14.2，kafka0.10，jdk1.8.0_241
flink版本为1.8.1，yarn上的日志：
20/01/22 11:07:53 INFO entrypoint.ClusterEntrypoint:
niCluster 就是一个集群，是一个内部的部署模式，跟 standalone
是平行的概念。我看不懂你要干什么，但是就你的问题来说，我上面说了，就是你 MiniCluster new 出来之后没
start。但我不确定这个是不是你要的效果，MiniCluster 和 standalone 是平行的两种东西。
Best,
tison.
郑 洁锋 于2020年1月16日周四 下午2:27写道：
> 因为我这边看他是standalone，然后看到flink官方文档里面部署模式也有standalone模式
因为我这边看他是standalone，然后看到flink官方文档里面部署模式也有standalone模式，所以按照那个模式部署后来尝试
zjfpla...@hotmail.com
发件人： 郑 洁锋<mailto:zjfpla...@hotmail.com>
发送时间： 2020-01-16 14:24
收件人： user-zh<mailto:user-zh@flink.apache.org>
主题： Re: Re: MiniCluster问题
这是完整的到启动的代码
:30写道：
> 跟集群无关
> Best,
> tison.
>
>
> tison 于2020年1月16日周四 下午1:30写道：
>
>> 1. 这是个内部实现类，文档是一个问题，但最好不要直接依赖
>>
>> 2. ？你截图的代码片段在哪？我看是你自己代码创建使用的啊
>>
>> Best,
>> tison.
>>
>>
>> 郑 洁锋 于2020年1月16日周四 下午1:18写道：
&
ster 要 start 啊（x
Best,
tison.
郑 洁锋 于2020年1月16日周四 上午11:38写道：
> MiniCluster代码执行过程中报错：
>
> SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
> SLF4J: Defaulting to no-operation (NOP) logger implementation
> SLF4J: See http://www.slf4j.org/codes.html#Stat
MiniCluster代码执行过程中报错：
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further
details.
Exception in thread "main" java.lang.IllegalStateException:
境变量的，也可以尝试一下：https://ci.apache.org/projects/flink/flink-docs-master/ops/config.html#configuration-runtime-environment-variables
郑 洁锋 mailto:zjfpla...@hotmail.com>> 于2020年1月15日周三
上午11:34写道：
Hi，
我们使用了TDH中的yarn（hadoop2.7，jdk1.7），原先使用spark的时候，也遇到过jdk版本最低1.8的情况，我们是通过如下方式解决的（考虑到现场公用TDH集群不能更改）：
Hi，
我们使用了TDH中的yarn（hadoop2.7，jdk1.7），原先使用spark的时候，也遇到过jdk版本最低1.8的情况，我们是通过如下方式解决的（考虑到现场公用TDH集群不能更改）：
spark-submit中可以通过添加参数 --conf
"spark.yarn.appMasterEnv.JAVA_HOME=/usr/java/jdk1.8.0_25/" --conf
"spark.executorEnv.JAVA_HOME=/usr/java/jdk1.8.0_25/"来指定当前spark任务特定在yarn中执行时的jdk目录
Hi，
Is there a way to use asynchronous io to query the database in the
process of cep?
zjfpla...@hotmail.com
13 matches
Mail list logo
