Hi!

This change aligns with how newer Flink 1.16+ versions handle application
job ids. There are some good reasons for doing this please see:
https://issues.apache.org/jira/browse/FLINK-19358
https://issues.apache.org/jira/browse/FLINK-29109

If you want to go back to the old behaviour you need to manually set the
following flinkConfiguration:
$internal.pipeline.job-id: 00000000000000000000000000000000

Cheers,
Gyula

On Thu, Oct 13, 2022 at 8:55 AM Evgeniy Lyutikov <eblyuti...@avito.ru>
wrote:

> Hi everyone
>
> After updating kuberneter operator to version 1.2.0 noticed that it
> started generating jobid for all deployments.
>
> 2022-10-13 06:18:30,724 o.a.f.k.o.c.FlinkDeploymentController [INFO
> ][infojob/infojob] Starting reconciliation
> 2022-10-13 06:18:30,725 o.a.f.k.o.l.AuditUtils         [INFO
> ][infojob/infojob] >>> Status | Info    | CREATED         | The resource
> was created in Kubernetes but not yet handled by the operator
> 2022-10-13 06:18:30,726 o.a.f.k.o.c.FlinkConfigManager [INFO
> ][infojob/infojob] Generating new config
> 2022-10-13 06:18:30,729 o.a.f.k.o.r.d.AbstractFlinkResourceReconciler
> [INFO ][infojob/infojob] Deploying for the first time
> 2022-10-13 06:18:30,755 o.a.f.k.o.l.AuditUtils         [INFO
> ][infojob/infojob] >>> Status | Info    | UPGRADING       | The resource is
> being upgraded
> 2022-10-13 06:18:30,755 o.a.f.k.o.r.d.ApplicationReconciler [INFO
> ][infojob/infojob] Assigning JobId override to
> ebae6c825b86db4790e34d443655a410
> 2022-10-13 06:18:30,779 o.a.f.k.o.l.AuditUtils         [INFO
> ][infojob/infojob] >>> Status | Info    | UPGRADING       | The resource is
> being upgraded
> 2022-10-13 06:18:30,795 o.a.f.k.o.l.AuditUtils         [INFO
> ][infojob/infojob] >>> Event  | Info    | SUBMIT          | Starting
> deployment
> 2022-10-13 06:18:30,795 o.a.f.k.o.s.AbstractFlinkService [INFO
> ][infojob/infojob] Deploying application cluster
> 2022-10-13 06:18:30,801 o.a.f.k.o.s.NativeFlinkService [INFO
> ][infojob/infojob] Deploying application cluster
> 2022-10-13 06:18:30,801 o.a.f.c.d.a.c.ApplicationClusterDeployer [INFO
> ][infojob/infojob] Submitting application in 'Application Mode'.
>
> How to disable this behavior?
> We are using Flink 1.14.4 and upgrade mode = 'last-state'
>
>
>
>
>
> * ------------------------------ *“This message contains confidential
> information/commercial secret. If you are not the intended addressee of
> this message you may not copy, save, print or forward it to any third party
> and you are kindly requested to destroy this message and notify the sender
> thereof by email.
> Данное сообщение содержит конфиденциальную информацию/информацию,
> являющуюся коммерческой тайной. Если Вы не являетесь надлежащим адресатом
> данного сообщения, Вы не вправе копировать, сохранять, печатать или
> пересылать его каким либо иным лицам. Просьба уничтожить данное сообщение и
> уведомить об этом отправителя электронным письмом.”
>

Reply via email to