Hi Team,
I have Flink 1.8.1 and hadoop open source 3.2.0 . My flink jobs run
without issues on HDP 2.5.3 version. when run on hadoop open source 3.2.0
encountering the below mentioned exception .
I have set hadoop
export HADOOP_CONF_DIR=/etc/hadoop/conf
export HADOOP_CLASSPATH=`hadoop classpath`
Hi ,
One of my flink applications needs to get and put records from HBASE for
every event while processing in real time . When there are less events the
application process without any issues. when the number of events
increases we start hitting with the below mentioned exception .Can these
excepti
ould need to upgrade to a more recent Flink version.
>
> Best,
> Matthias
>
> [1]
> https://flink.apache.org/news/2020/07/06/release-1.11.0.html#important-changes
> [2] https://issues.apache.org/jira/browse/FLINK-11086
>
> On Mon, May 3, 2021 at 3:05 PM Ragini Manjaiah
> wrot
Hi Team,
I am trying to submit a flink job of version 1.11.3 . The actual
application is developed in flink 1.8.1.
Since the Hadoop cluster is 3.2.0 apache I downloaded flink 1.11.3 (
flink-1.11.3-bin-scala_2.11.tgz) and tried to submit the job.
while submitting facing the below mentioned excepti
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:288)
On Tue, May 4, 2021 at 11:47 AM Ragini Manjaiah
wrote:
> Thank you for the clarification.
>
> On Mon, May 3, 2021 at 6:57 PM Matthias Pohl
> wrote:
>
>> Hi Ragini,
>> this is a dependency version issue. F
Hi ,
I am surfacing when submitting flink from intellij IDE . what cloud the
issues. Do need to change the scala version
flink 1.11.3
scala 2.11
Exception in thread "main" java.lang.NoSuchMethodError:
scala.Function1.$init$(Lscala/Function1;)V
at
scala.concurrent.java8.FuturesConvertersImpl$CF.(
The scala version is same across the pom file . 2.11
On Fri, May 7, 2021 at 5:06 PM Chesnay Schepler wrote:
> It looks like you have different scala versions on the classpath. Please
> check that all your dependencies use the same scala version.
>
> On 5/7/2021 1:25 PM, Ragini Ma
] \- org.springframework:spring-jcl:jar:5.0.9.RELEASE:test
On Fri, May 7, 2021 at 5:58 PM Chesnay Schepler wrote:
> Can you show us the dependency tree of your project?
> (If you are using maven, run "mvn dependency:tree")
>
> On 5/7/2021 2:15 PM, Ragini Manjaiah wrote:
>
&g
gt; [INFO] | +- org.apache.kafka:kafka_2.12:jar:5.5.1-ccs:compile
>
> [INFO] +- io.confluent:kafka-schema-registry:jar:5.5.1:compile
> [INFO] | | \-
> com.kjetland:mbknor-jackson-jsonschema_2.12:jar:1.0.39:compile
>
> On 5/7/2021 2:47 PM, Ragini Manjaiah wrote:
>
> Hi ,
>
Hi ,
I am facing the below issue while processing streaming events. In what
scenarios hit with java.lang.Exception: Could not complete the stream
element. can please help me here . The job fails after this exception is hit
2021-07-13 13:24:58,781 INFO
org.apache.flink.runtime.executiongraph.Exec
ong an asynchronous request may take
>> before it is considered failed. This parameter guards against dead/failed
>> requests.
>
>
> Regards,
> Rahul
>
> On Wed, Jul 14, 2021 at 9:29 AM Ragini Manjaiah
> wrote:
>
>> Hi ,
>> I am facing the below iss
when I try to run flink .1.13 application encountering the below mentioned
issue. what dependency I am missing . can you please help me
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in
[jar:file:/Users/z004t01/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.1
2, which is no longer supported. Can you
> try getting rid of the slf4j-log4j12 dependency?
>
> Best,
> D.
>
> On Tue, Sep 14, 2021 at 1:51 PM Ragini Manjaiah
> wrote:
>
>> when I try to run flink .1.13 application encountering the below
>> mentioned issue. what
fy the exclusion.
>
> Best,
> D.
>
> On Tue, Sep 14, 2021 at 2:15 PM Ragini Manjaiah
> wrote:
>
>> Hi David,
>> please find my pom.xml . where I have excluded the slf4j-log4j12
>> dependency . even after excluding encountering this issue
>>
HI,
In what scenarios we hit with *java.lang.OutOfMemoryError: Java heap space
while publishing to kafka . I hit with this exception and a resolution
added property *.setProperty("security.protocol","SSL");in the flink
application.
Later I started encountering org.apache.kafka.common.errors.Timeou
drastically to 30 TPS. What are the things I need to look into in such a
situation? There are no exceptions caught . how to check the bottle neck
area . can some throw some light on this.
Thanks & Regards
Ragini Manjaiah
s, input data distribution, async mode or sync mode lookup.
>
> [1]
> https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/monitoring/back_pressure/
>
> Best,
> JING ZHANG
>
> Ragini Manjaiah 于2021年9月27日周一 下午2:05写道：
>
>> Hi ,
>> I have a flink real t
Hi Sanket,
I have a similar use case. how are you measuring the time for Async1`
function to return the result and external api call
On Wed, Sep 29, 2021 at 10:47 AM Sanket Agrawal
wrote:
> Hi @Piotr Nowojski ,
>
>
>
> Thank you for replying back. Yes, first async is taking between 1300-1500
>
Hi Soumen,
I want to unsubscribe from this mailing list.
Thanks & Regards
Ragini Manjaiah
On Fri, Feb 3, 2023 at 4:07 PM Soumen Choudhury wrote:
>
>
> --
> Regards
> Soumen Choudhury
> Cell : +91865316168
> mail to : sou@gmail.com
>
Unsubscribe
On Tue, Jul 4, 2023 at 1:33 PM Bauddhik Anand wrote:
> Unsubscribe
>
20 matches
Mail list logo
