[ 
https://issues.apache.org/jira/browse/FLINK-30244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641092#comment-17641092
 ] 

AlexHu commented on FLINK-30244:
--------------------------------

Sorry, now I have given more details about my problem. 

> When task using udf/udtf with jni, on k8s session the old TM will shut down 
> and create new TM or the task will fail
> -------------------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-30244
>                 URL: https://issues.apache.org/jira/browse/FLINK-30244
>             Project: Flink
>          Issue Type: Bug
>          Components: Deployment / Kubernetes
>    Affects Versions: 1.15.3
>            Reporter: AlexHu
>            Priority: Major
>         Attachments: image-2022-11-30-14-47-50-923.png
>
>
> We face a problem when we try to use flink on k8s to execute task with 
> udf/udtf. When we finished or canceled a job and submit a same job, the old 
> TM will be not reachable and restart. Why the TM have to be restart? In 
> session mode, the TM should be reused by JM. Moreover, if we off restart 
> strategy, this task will fail.
> !image-2022-11-30-14-47-50-923.png!



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to