some slots are not be available,when job is not running

[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

some slots are not be available,when job is not running

[pengcheng...@bonc.com.cn]

> 
where: (LIKE(C1, _UTF-16LE'22%')), select: (C1, C2, C3, C4, C5, C6, C7, C8, C9, 
C10) -> to: Row -> Map -> Sink: cirrostream_yy_job_38 
(5/8)272121,232org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders$ChildFirstClassLoader
 @ 0x7f98d010true
akka.dispatch.MonitorableThreadFactory$AkkaForkJoinWorkerThread @ 
0x7f91bd02dd20 »
flink-akka.remote.default-remote-dispatcher-50192115,720sun.misc.Launcher$AppClassLoader
 @ 0x7f91bc253cb0false
org.apache.flink.streaming.runtime.io.StreamRecordWriter$OutputFlusher @ 
0x7f922c650cd8 »
OutputFlusher for Map -> 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: 
Row200111,048sun.misc.Launcher$AppClassLoader @ 0x7f91bc253cb0true
org.apache.flink.streaming.runtime.io.StreamRecordWriter$OutputFlusher @ 
0x7f922a650a20 »
OutputFlusher for Map -> 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: 
Row200111,048sun.misc.Launcher$AppClassLoader @ 0x7f91bc253cb0true
org.apache.flink.streaming.runtime.io.StreamRecordWriter$OutputFlusher @ 
0x7f9227000540 »
OutputFlusher for Map -> 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: 
Row200111,048sun.misc.Launcher$AppClassLoader @ 0x7f91bc253cb0true
org.apache.flink.streaming.runtime.io.StreamRecordWriter$OutputFlusher @ 
0x7f91c1001628 »
OutputFlusher for Map -> 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: 
Row200111,048sun.misc.Launcher$AppClassLoader @ 0x7f91bc253cb0true
org.apache.flink.streaming.runtime.io.StreamRecordWriter$OutputFlusher @ 
0x7f91bd04a4d8 »
OutputFlusher for Map -> 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: 
Row200111,048sun.misc.Launcher$AppClassLoader @ 0x7f91bc253cb0true
org.apache.flink.streaming.runtime.io.StreamRecordWriter$OutputFlusher @ 
0x7f91eb000200 »
OutputFlusher for Map -> 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
org.apache.flink.streaming.runtime.io.StreamRecordWriter$OutputFlusher @ 
0x7f91bd039360 »
OutputFlusher for Map -> 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