问题可能出在被省略的部分，检查一下最底层的 caused by
Thanks,
Biao /'bɪ.aʊ/
On Sun, 29 Sep 2019 at 13:17, <18612537...@163.com> wrote:
> 我看过这个我不是这个问题，作业没有设置水印，作业可以正常运行，最近可能是运行一天多会报这个异常
>
> 发自我的 iPhone
>
> > 在 2019年9月29日，上午11:49，Wesley Peng 写道：
> >
> > Hello,
> >
> > May this article match your issue?
> > https://b
同一个 TM 中，相同 job 的 subtask 会共享一个 classloader
Thanks,
Biao /'bɪ.aʊ/
On Sat, 28 Sep 2019 at 09:30, Ever <439674...@qq.com> wrote:
> 有一个job有2个task，每个task分别有3个subtask(并行度为3), 如下图所示。
>
> 每个subtask会占用一个taskslot， 但是同一个job的不同task的subtask可以共享同一个taskslot，
> 所以这里应该是一个taskslot会有2个subtask。
> 那么这两个share同一个ta
我看过这个我不是这个问题，作业没有设置水印，作业可以正常运行，最近可能是运行一天多会报这个异常
发自我的 iPhone
> 在 2019年9月29日，上午11:49，Wesley Peng 写道：
>
> Hello,
>
> May this article match your issue?
> https://blog.csdn.net/qq_41910230/article/details/90411237
>
> regards.
>
>> On Sun, Sep 29, 2019 at 10:33 AM allan <18612537...@163.com> wro
大家好：
我的flink代码打包的jar包是放到了hdfs上面，但是当我在flink中用命令行执行的时候，flink本地是否只能解析本地jar包？不能解析到hdfs上面的jar包？
我把jar包下载到服务器本地后，就可以执行成功了
我的命令是：
./bin/flink run -yid application_1567652112073_0001 -p 6 -yj
hdfs://ysec-storage/flink/runJar/business-security-1.0-SNAPSHOT.jar --appId
act_test
返回的结果是：
S
Hello,
May this article match your issue?
https://blog.csdn.net/qq_41910230/article/details/90411237
regards.
On Sun, Sep 29, 2019 at 10:33 AM allan <18612537...@163.com> wrote:
> Hi，
>
> 最近发现作业一直在报错，我的窗口是一分钟的窗口。这是什么原因，谁能帮助一下？flink版本1.6 ,错误如下：
>
>
>
> TimerException{org.apache.flink.streaming.r
Hi,
mysql 维表的 DDL 和 源表/结果表 的 DDL 是一样的。 例如下面这个 DDL 的声明，rates 在 flink sql 中既可以作为
source 也可以是 sink，也可以是维表。
CREATE TABLE rates (
currency VARCHAR,
rate BIGINT
) WITH (
'connector.type' = 'jdbc', -- 使用 jdbc connector
'connector.url' = 'jdbc:mysql://localhost:3306/flink-test', -- jdbc u
Hi，
最近发现作业一直在报错，我的窗口是一分钟的窗口。这是什么原因，谁能帮助一下？flink版本1.6 ,错误如下：
TimerException{org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException:
Could not forward element to next operator}
at
org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService$TriggerTask.run
