Hi Mark,
the JobManager is not necessarily in charge of spinning up TaskManager
instances. It depends on the resource provider configuration you choose.
Flink differentiates between active and passive Resource Management (see
the two available implementations of ResourceManager [1]).
Active Resour
Hi,
How's JobManager bring up TaskManager in Application Mode or Session Mode? I
can’t get it even after reading source code of flink operator?
Any help will be appreciate, Thank you.
Mark
Supports operations like hudi/iceberg calls, such as savepoint/ checkpoint，
https://hudi.apache.org/docs/procedures/
CALL system.procedure_name(arg_1, arg_2, ... arg_n)
Based on the flink development platform, direct use of call sql to complete
some management operations, will be very convenient.
Hi,
We are able to disable this cancela nd upload otpion in ui.
But this is having issues with endpoints for below.
Get call for /jars to list all uploaded jars and post call
/jars/{jarid}/run are giving 404 after disabling the two flags.
Is the process of uploading jars and running a jar with spec
Hi David,
Many thanks for your reply. Two things, then:
1. If there are any chances to contribute on this, let me know
2. In the meantime, process functions FTW!
Salva
On Fri, Nov 25, 2022 at 9:21 AM David Anderson wrote:
> When it comes to event time processing and watermarks, I believe that
Hi all,
How to make flink operator as a cluster operator? And How to register it
to CVO(Cluster Version Operator)?
I didn't find any code or configure file in flink-operator's code.
Thank you.
Mark
