????????kafka????

hi all ??kafka??source??flink??kafka?? 1.??2.?? 1.flink??metric 2.groupIdgroup??

退订

退订

退订

退订

Re: Flink 1.10 内存问题

异步IO的Order队列打满，导致算子卡死？ Ada Luna 于2021年7月19日周一 下午2:02写道： > > 我通过反压信息观察到，这个 async wait operator > 算子上游全部出现严重反压。很有可能是这个算子死锁或者死循环等类似问题。但是我还不知道如何进一步排查。 > > "async wait operator -> (where: (=(CASE(>(ABS(Z), WaterRoseMax_5), 1, > 0), 0)), select: (ID, STID, _UTF-16LE'' AS STCD, ITEM, VAL, UNIT, >

Re: Flink 1.10 内存问题

我通过反压信息观察到，这个 async wait operator 算子上游全部出现严重反压。很有可能是这个算子死锁或者死循环等类似问题。但是我还不知道如何进一步排查。 "async wait operator -> (where: (=(CASE(>(ABS(Z), WaterRoseMax_5), 1, 0), 0)), select: (ID, STID, _UTF-16LE'' AS STCD, ITEM, VAL, UNIT, DATATIME AS DT, _UTF-16LE'2.6' AS DATAINDEX, currtime2(DATATIME,