Hi Allison,
The PIPELINE_FIXED_JOB_ID configuration option is not intended for public
use. IIUC, the only way to manually specify the jobId is submitting a job
through the JAR RUN REST API, where you can provide the jobId in the
request body (
https://nightlies.apache.org/flink/flink-docs-master/d
Hi,
I was wondering if there is any way to manually set the jobID for the jobGraph.
I noticed that there is a configuration for PIPELINE_FIXED_JOB_ID, but there
doesn't seem to be a way to set it via config with the
StreamingJobGraphGenerator.java. Would appreciate any assistance if anyone has
Hello,
I am using iceberg-flink-runtime lib (1.17-1.4.0) and running the following
code to read an iceberg table in BATCH mode.
var source = FlinkSource
.forRowData()
.streaming(false)
.env(execEnv)
.tableLoader(tableLoader)
.limit((long) operation.getLimit())
.filters(bui
Hi Feng,
I'm using flink-connector-kafka 3.0.1-1.17. I see that 1.17 is affected, but
the ticket is marked as fixed so I'm not sure if that is actually the issue.
Best,
Irakli
From: Feng Jin
Sent: 12 March 2024 18:28
To: Keshelava, Irakli
Cc: user@flink.apache.
Hi, Meng.
I think you can follow this jira[1] and ping the creator about the latest
progress.
[1] https://issues.apache.org/jira/browse/FLINK-34491
--
Best！
Xuyang
At 2024-03-13 04:02:09, "Meng, Ping via user" wrote:
Hi,
The latest Flink 1.18.1 with Java 17 support is in beta
