Re: Very long launch of the Flink application in BATCH mode

Hi Shammon, When I set log.level=DEBUG I have no more logs except *2023-06-21 14:51:30,921 DEBUG org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Trigger heartbeat request.* Job freezes on stream graph generation. In STREAMING mode the job starts fast without same probl

Flink Kubernetes Application freezes in BATCH mode

understand the cause of this problem and how to fix it. Thank you in advance! Best regards, Vladislav Keda. flink-k8s-app.log Description: Binary data

Re: Default Log4j properties in Native Kubernetes

Hi all again! Please tell me if you can answer my question, thanks. --- Best Regards, Vladislav Keda пт, 16 июн. 2023 г. в 16:12, Vladislav Keda < vladislav.k...@glowbyteconsulting.com>: > Hi all! > > Is it possible to change Flink* log4j-console.properties* in Native &g

Default Log4j properties in Native Kubernetes

not work (k8s gives me an exception that the log4j* files are write-locked because there is a configmap over them). Is there another way to change log4j* files? Thank you very much in advance! Best Regards, Vladislav Keda #!/usr/bin/env bash # shellcheck disable=SC2034 LOG4J_CLI_PROPERTIES_PATH

Flink Interval Joins

r all registered timers to fire during checkpoints? P.S. Maybe you can send the internals of SQL interval join implementation in Java/Scala. --- Best Regards, Vladislav Keda

Re: Resources configuration on Kubernetes Session Cluster

Thanks, Gyula! Best Regards, Vladislav Keda. вт, 2 авг. 2022 г., 12:41 Gyula Fóra : > Hi Vladislav! > > I am afraid there is no way to specify resources independently for jobs > within a session cluster currently in Flink. > > For this I suggest using the Application Mode

Resources configuration on Kubernetes Session Cluster

nk jobs on cluster and set up specific configuration parameters for jobs using *org.apache.flink.client.program.rest.RestClusterClient* Flink version - 1.13.6. --- Best Regards, Vladislav Keda

Re: Creating Flink SQL Row with named fields

Thanks a lot! --- Best Regards, Vladislav Keda чт, 3 февр. 2022 г. в 12:13, Francesco Guardiani : > Hi, > > Unfortunately at the moment, creating a row with named fields is not > possible from the ROW constructor. > > One solution could be to wrap it in a cast, like: CAS

Creating Flink SQL Row with named fields

lQuery(TableEnvironmentImpl.java:704) at ru.glowbyte.streaming.core.operators.internal.sql.SqlDrivenOperator.sqlQuery(SqlDrivenOperator.java:159) ... 59 more* How can I set the name for the field? Flink version - 1.13.3. --- Best Regards, Vladislav Keda

Re: RestClusterClient locks file after calling `submitJob(JobGraph)` method on Windows OS

Thanks, I missed the fact that this issue was created early. вс, 13 сент. 2020 г., 14:58 Chesnay Schepler : > This is a known issue: https://issues.apache.org/jira/browse/FLINK-9844 > > On 9/11/2020 8:34 PM, Vladislav Keda wrote: > > Hi Flink Community, > > I was trying to

RestClusterClient locks file after calling `submitJob(JobGraph)` method on Windows OS

ter calling the `submitJob(JobGraph)` method, the jar file remains unclosed. Is it a bug or not? Maybe I'm doing something wrong? --- Kind Regards Vladislav Keda