I also tried different settings for *yarn.per-job-cluster.include-user-jar*
and *classloader.resolve-order*
But none of them worked.
Leon
On Wed, Nov 30, 2022 at 11:17 PM Leon Xu wrote:
> Hi Biao,
>
> Thanks for getting back to me.
> Here's the command I used:
>
> /usr/bin/flink run-application
Hi Biao,
Thanks for getting back to me.
Here's the command I used:
/usr/bin/flink run-application -t yarn-application \
-Dtaskmanager.numberOfTaskSlots=1 \
-Djobmanager.memory.process.size=4096m \
-Dtaskmanager.memory.process.size=4096m \
-Dyarn.application.name=backup-enriched-ev
Hi Leon,
Can you share your full command for submission?
Best,
Biao Geng
Leon Xu 于2022年12月1日周四 06:27写道：
> Hi Flink Users,
>
> We ran into java.lang.ClassCastException after moving the flink job from
> session mode to application mode.
>
>
> *java.lang.ClassCastException: class [B cannot be ca
Hi Flink Users,
We ran into java.lang.ClassCastException after moving the flink job from
session mode to application mode.
*java.lang.ClassCastException: class [B cannot be cast to class
java.lang.String ([B and java.lang.String are in module java.base of loader
'bootstrap') at
com.xyz.common.io
Hi Lucas!
The Flink kubernetes integration itself is responsible for mounting the
configmap and overwriting the entrypoint not the operator. Therefore this
is not something we can easily change from the operator side. However I
think we are looking at the problem from the wrong side and there may
Hello folks,
Not sure if this is the best list for this, sorry if it isn't. I'd
appreciate some pointers :-)
When using flink-kubernetes-operator [1], docker-entrypoint.sh [2] goes
through several failures to write into $FLINK_HOME/conf/. We believe this
is due to this volume being mounted from a
There's no way to /disable/ the UI. (But you could cut out the
javascript stuff from the flink-dist jar)
I'm curious why you'd want that though; since it works against the REST
API it provides a strict subset of the REST API functionality.
On 30/11/2022 16:25, Berkay Polat wrote:
Hi Chesnay,
Hi Chesnay,
I have a similar question on this topic. Is there an option to disable the
frontend altogether but still use REST APIs?
Thanks
On Wed, Nov 30, 2022 at 1:37 AM Chesnay Schepler wrote:
> There's no way to disable the jar submission in the UI but have it still
> work via the REST API.
Hi,
I'm creating a session job using FlinkOperator. The CRD as follows:
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# dist
That’s great, thanks Márton!
--
Ben Roberts
From: Márton Balassi
Date: Tuesday, 29 November 2022 at 18:55
To: Roberts, Ben (Senior Developer)
Cc: user@flink.apache.org
Subject: [EXTERNAL] Re: Flink 1.15.3 Docker image
Done, please let me know if you see anything unexpected.
On Tue, Nov 29, 20
There's no way to disable the jar submission in the UI but have it still
work via the REST API.
On 30/11/2022 06:16, naga sudhakar wrote:
After disabling the cancel, submit flags facing issues with below api
calls.
1) /jars giving 404
2) /jars/upload
3) /jars/{jarid}/run
Is there any config
Thanks!
On Wed, Nov 30, 2022, 00:37 Danny Cranmer wrote:
> Hello,
>
> By default the sink will not fail, the underlying connector has a flag
> "failOnError" which defaults to false. Unfortunately this cannot be set for
> Flink 1.14 in the Table API, however in 1.15 it can via
> 'sink.fail-on-err
Hello,
By default the sink will not fail, the underlying connector has a flag
"failOnError" which defaults to false. Unfortunately this cannot be set for
Flink 1.14 in the Table API, however in 1.15 it can via
'sink.fail-on-error: true'
Thanks
On Wed, Nov 30, 2022 at 5:41 AM Dan Hill wrote:
>
13 matches
Mail list logo
