t; Filter -> Map -> Map -> where: (AND(>=(_C2, 50),
<=(_C2, 60))), select: (_C1, _C2, _C3, _C4, _C5, _C6, _C7, _C8, _C9, _C10,
_C11, _C12, _C13, _C14, _C15) -> to:
Row200110,848sun.misc.Launcher$AppClassLoader @ 0x7f91bc253cb0true
sourcesink.kafka.consumer09.KafkaConsumerThread @ 0x7f91f84e9938
Kafka 0.9 Fetcher for Source: Custom Source -> Map -> Filter -> Map -> from:
(C1, C2, C3, C4, C5, C6, C7, C8, C9, C10, C11, C12, C13, C14, C15, C16, C17,
C18, C19, C20, CIRROSTREAM_YY_SINK_37) -> select: (C1, C2, C3, C4, C5, C6, C7,
C8, C9, C10, C11, C12, C13, C14, C15, C16, C17, C18, C19, C20) -> to: Row ->
Map -> Sink: cirrostream_yy_job_37_6
(8/8)272106,120org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders$ChildFirstClassLoader
@ 0x7f91f8518d70true
org.apache.flink.streaming.runtime.io.StreamRecordWriter$OutputFlusher @
0x7f922c650b10 ยป
OutputFlusher for Source: Custom Source -> Map -> Filter -> Map -> from:
(\u6bd4__DH\u5b8c\u8d5bBUGJIBHBKAA\u4f60\u597dISDUIAAASDHUAHSH\u4e0d\u662fFFR\u6211\u7684\u54271232AA___SWID___HAHAHAHA\u8c01\u53eb\u6211,
ABC) -> where:
(LIKE(\u6bd4__DH\u5b8c\u8d5bBUGJIBHBKAA\u4f60\u597dISDUIAAASDHUAHSH\u4e0d\u662fFFR\u6211\u7684\u54271232AA___SWID___HAHAHAHA\u8c01\u53eb\u6211,
_UTF-16LE'%117111')), select:
(\u6bd4__DH\u5b8c\u8d5bBUGJIBHBKAA\u4f60\u597dISDUIAAASDHUAHSH\u4e0d\u662fFFR\u6211\u7684\u54271232AA___SWID___HAHAHAHA\u8c01\u53eb\u6211)
-> to: Row200103,048sun.misc.Launcher$AppClassLoader @ 0x7f91bc253cb0true
pengcheng...@bonc.com.cn
Hi,
Why are some slots unavailable?
My cluster model is standalone,and high-availability mode is zookeeper.
task.cancellation.timeout: 0
some slots are not be available,when job is not running.
pengcheng...@bonc.com.cn
