[
https://issues.apache.org/jira/browse/FLINK-40516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18110195#comment-18110195
]
Taranpreet Kaur commented on FLINK-40516:
-----------------------------------------
Hi [~wangyang0918], [~gyfora] and [~xtsong],
As you people have a lot more expertise in this area, please provide a
resolution for this issue.
I have provided the following configurations in conf.yaml:
*jobManagerConfig:*
pekko.ask.timeout: "120s"
client.timeout: "120s"
state.checkpoints.num-retained: 1
metrics.internal.query-service.port: "6126" # ← PIN the metric query
service
*taskManagerConfig:*
taskmanager.data.port: "6121" # ← PIN the data shuffle port
metrics.internal.query-service.port: "6126"
still seeing random ports in the jobmanger and taskmanger, details are provided
below:
in jobmanager:
bash-4.4$ ss -nap | grep LISTEN
tcp LISTEN 0 50 *:9249
*:* users:(("java",pid=224,fd=271))
tcp LISTEN 0 4096 *:8081
*:* users:(("java",pid=224,fd=293))
tcp LISTEN 0 4096 *:6123
*:* users:(("java",pid=224,fd=265))
tcp LISTEN 0 1000 *:6124
*:* users:(("java",pid=224,fd=268))
tcp LISTEN 0 4096 *:{*}35669{*}
*:* users:(("java",pid=224,fd=286))
in taskmanager:
bash-4.4$ ss -nap |grep LISTEN
tcp LISTEN 0 50 *:9249
*:* users:(("java",pid=358,fd=277))
tcp LISTEN 0 4096 *:{*}41355{*}
*:* users:(("java",pid=358,fd=300))
tcp LISTEN 0 4096 *:6121
*:* users:(("java",pid=358,fd=313))
tcp LISTEN 0 4096 *:6122
*:* users:(("java",pid=358,fd=275))
Thanks in advance
> Needed to support network policy in Jobmanager and Task Manager
> ---------------------------------------------------------------
>
> Key: FLINK-40516
> URL: https://issues.apache.org/jira/browse/FLINK-40516
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Configuration
> Reporter: Taranpreet Kaur
> Priority: Major
>
> Problem:
> On trying to introduce network policy in jobmanager and taskmanager on
> deploying it on Kubernetes environment, but analysed that random ports are
> being opened even after setting ports in flink configuration.
> Support needed for:
> how to support network policy between Taskmanager and Jobmanager on specific
> ports in Kubernetes environment
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
