Hi Enric,
I guess getting the metrics[1] might be helpful for you.
You can query the numRecordsOut metric by Metrics Reporter[2] or REST API[3].
Best,
Jiabao
[1] https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/ops/metrics/
[2]
Hi??Team??
I was wondering how to get flink accumulated sink record count(just like the
flink UI displays),any help would be appreciated.
Hi
i adding a new sink that was not exists in the graph
1. stop with save point
2. run the the new graph with the new sink operator ( from save point)
in this case the job stuck in initializing forever because cant complete
transaction ( on the new operator , kafka topic)
i dont understand how
Hi nick
If you want to modify the sink operator , I think you can modify the uid of
the operator to avoid restoring the state that does not belong to it.
Best,
Feng
On Thu, Jan 25, 2024 at 1:19 AM nick toker wrote:
> hi
>
> i didn't found anything in the log
> but i found that it happened
hi
i didn't found anything in the log
but i found that it happened when i add a new sink operator
and because i work with checkpoints the flink can't finish the transaction
( the new topic in kafka not part of the transaction before i added the new
sink operator)
so i must cancel the job to
Hi Deepti,
For the lifecycle of Flink 1.x version and more information about Flink
2.0, pls refer to Flink RoadMap[1] and this discussion thread[2].
Flink 1.18 currently has experimental support for Java17[3].
[1] https://flink.apache.org/what-is-flink/roadmap/
[2]
Hi,
About the lifecycle of Flink 1.x, you can follow this mail thread[1].
And Java 17 has been supported in FLINK-1.18 [2].
[1] https://lists.apache.org/thread/qvw66of180t3425pnqf2mlx042zhlgnn
[2]
https://flink.apache.org/2023/10/24/announcing-the-release-of-apache-flink-1.18/
--
Best！
Hello Team,
Can you please let me know the lifecycle for Flink 1.x versions? Also does any
version supports Java17?
Regards,
Deepti Sharma
