Hello!
When we use flink version 1.14 to commit tasks to kubernetes, we get an error
using Session mode. The following error is reported some time after the task is
submitted .
2023-04-18 17:23:56,818 INFO
org.apache.flink.client.program.rest.RestClusterClient
[] - Submitting job 'FlinkStreamApp_Deploy_LPYZZM_0418'
(0a5b3a4cc3c1957f4a26d8ce9dcbdec9).
2023-04-18 17:23:56,833 DEBUG org.apache.flink.runtime.rest.RestClient
[] -
Sending request of class class
org.apache.flink.runtime.rest.messages.job.JobSubmitRequestBody to
10.213.116.48:31181/v1/jobs
2023-04-18 17:23:56,934 DEBUG
org.apache.flink.shaded.netty4.io.netty.util.ResourceLeakDetector [] -
-Dorg.apache.flink.shaded.netty4.io.netty.leakDetection.level: simple
2023-04-18 17:23:56,934 DEBUG
org.apache.flink.shaded.netty4.io.netty.util.ResourceLeakDetector [] -
-Dorg.apache.flink.shaded.netty4.io.netty.leakDetection.targetRecords: 4
2023-04-18 17:23:56,948 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.AbstractByteBuf [] -
-Dorg.apache.flink.shaded.netty4.io.netty.buffer.checkAccessible: true
2023-04-18 17:23:56,948 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.AbstractByteBuf [] -
-Dorg.apache.flink.shaded.netty4.io.netty.buffer.checkBounds: true
2023-04-18 17:23:56,950 DEBUG
org.apache.flink.shaded.netty4.io.netty.util.ResourceLeakDetectorFactory [] -
Loaded default ResourceLeakDetector:
org.apache.flink.shaded.netty4.io.netty.util.ResourceLeakDetector@263c66c9
2023-04-18 17:23:57,003 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator [] -
-Dio.netty.allocator.numHeapArenas: 2
2023-04-18 17:23:57,004 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator [] -
-Dio.netty.allocator.numDirectArenas: 2
2023-04-18 17:23:57,004 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator [] -
-Dio.netty.allocator.pageSize: 8192
2023-04-18 17:23:57,004 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator [] -
-Dio.netty.allocator.maxOrder: 11
2023-04-18 17:23:57,004 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator [] -
-Dio.netty.allocator.chunkSize: 16777216
2023-04-18 17:23:57,004 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator [] -
-Dio.netty.allocator.smallCacheSize: 256
2023-04-18 17:23:57,004 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator [] -
-Dio.netty.allocator.normalCacheSize: 64
2023-04-18 17:23:57,004 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator [] -
-Dio.netty.allocator.maxCachedBufferCapacity: 32768
2023-04-18 17:23:57,004 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator [] -
-Dio.netty.allocator.cacheTrimInterval: 8192
2023-04-18 17:23:57,004 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator [] -
-Dio.netty.allocator.cacheTrimIntervalMillis: 0
2023-04-18 17:23:57,004 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator [] -
-Dio.netty.allocator.useCacheForAllThreads: true
2023-04-18 17:23:57,004 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator [] -
-Dio.netty.allocator.maxCachedByteBuffersPerChunk: 1023
2023-04-18 17:23:57,018 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufUtil [] -
-Dio.netty.allocator.type: pooled
2023-04-18 17:23:57,018 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufUtil [] -
-Dio.netty.threadLocalDirectBufferSize: 0
2023-04-18 17:23:57,018 DEBUG
org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufUtil [] -
-Dio.netty.maxThreadLocalCharBufferSize: 16384
2023-04-18 17:23:57,048 DEBUG
org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelId [] -
-Dio.netty.processId: 3096 (auto-detected)
2023-04-18 17:23:57,051 DEBUG
org.apache.flink.shaded.netty4.io.netty.util.NetUtil
[] - -Djava.net.preferIPv4Stack: false
2023-04-18 17:23:57,052 DEBUG
org.apache.flink.shaded.netty4.io.netty.util.NetUtil
[] - -Djava.net.preferIPv6Addresses: false
2023-04-18 17:23:57,056 DEBUG
org.apache.flink.shaded.netty4.io.netty.util.NetUtilInitializations [] -
Loopback interface: lo (lo, 127.0.0.1)
2023-04-18 17:23:57,057 DEBUG
org.apache.flink.shaded.netty4.io.netty.util.NetUtil
[] - /proc/sys/net/core/somaxconn: 128
2023-04-18 17:23:57,059 DEBUG
org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelId [] -
-Dio.netty.machineId: 66:b9:79:ff:fe:8c:b9:d3 (auto-detected)
2023-04-18 17:23:57,175 DEBUG
org.apache.flink.shaded.netty4.io.netty.util.Recycler
[] - -Dio.netty.recycler.maxCapacityPerThread: 4096
2023-04-18 17:23:57,176 DEBUG
org.apache.flink.shaded.netty4.io.netty.util.Recycler
[] - -Dio.netty.recycler.maxSharedCapacityFactor: 2
2023-04-18 17:23:57,176 DEBUG
org.apache.flink.shaded.netty4.io.netty.util.Recycler
[] - -Dio.netty.recycler.linkCapacity: 16
2023-04-18 17:23:57,176 DEBUG
org.apache.flink.shaded.netty4.io.netty.util.Recycler
[] - -Dio.netty.recycler.ratio: 8
2023-04-18 17:23:57,176 DEBUG
org.apache.flink.shaded.netty4.io.netty.util.Recycler
[] - -Dio.netty.recycler.delayedQueue.ratio: 8
java.util.concurrent.CompletionException:
org.apache.flink.runtime.rest.ConnectionIdleException: Channel became idle.
at
java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326)
~[?:1.8.0_342]
at
java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338)
~[?:1.8.0_342]
at
java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:925)
~[?:1.8.0_342]
at
java.util.concurrent.CompletableFuture$UniRelay.tryFire(CompletableFuture.java:913)
~[?:1.8.0_342]
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
[?:1.8.0_342]
at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
[?:1.8.0_342]
at
org.apache.flink.runtime.rest.RestClient$ClientHandler.userEventTriggered(RestClient.java:642)
[flink-dist_2.11-1.14.4.1.jar:1.14.4.1]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeUserEventTriggered(AbstractChannelHandlerContext.java:346)
[flink-dist_2.11-1.14.4.1.jar:1.14.4.1]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.invokeUserEventTriggered(AbstractChannelHandlerContext.java:332)
[flink-dist_2.11-1.14.4.1.jar:1.14.4.1]
at
org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannelHandlerContext.fireUserEventTriggered(AbstractChannelHandlerContext.java:324)
[flink-dist_2.11-1.14.4.1.jar:1.14.4.1]
at
org.apache.flink.shaded.netty4.io.netty.handler.timeout.IdleStateHandler.channelIdle(IdleStateHandler.java:371)
[flink-dist_2.11-1.14.4.1.jar:1.14.4.1]
at
org.apache.flink.shaded.netty4.io.netty.handler.timeout.IdleStateHandler$ReaderIdleTimeoutTask.run(IdleStateHandler.java:504)
[flink-dist_2.11-1.14.4.1.jar:1.14.4.1]
at
org.apache.flink.shaded.netty4.io.netty.handler.timeout.IdleStateHandler$AbstractIdleTask.run(IdleStateHandler.java:476)
[flink-dist_2.11-1.14.4.1.jar:1.14.4.1]
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
[flink-dist_2.11-1.14.4.1.jar:1.14.4.1]
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:170)
[flink-dist_2.11-1.14.4.1.jar:1.14.4.1]
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
[flink-dist_2.11-1.14.4.1.jar:1.14.4.1]
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
[flink-dist_2.11-1.14.4.1.jar:1.14.4.1]
at
org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
[flink-dist_2.11-1.14.4.1.jar:1.14.4.1]
at
org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
[flink-dist_2.11-1.14.4.1.jar:1.14.4.1]
at
org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
[flink-dist_2.11-1.14.4.1.jar:1.14.4.1]
at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342]
Caused by: org.apache.flink.runtime.rest.ConnectionIdleException: Channel
became idle.
... 15 more
2023-04-18 17:24:09,155 DEBUG org.apache.flink.runtime.rest.RestClient
[] -
Sending request of class class
org.apache.flink.runtime.rest.messages.job.JobSubmitRequestBody to
10.213.116.48:31181/v1/jobs
????????????
1639467...@qq.com
