the topic info.");text =
env.fromElements(WordCountData.WORDS);Please guide me how to fix this error.
I also tried to use FlinkKafkaConsumer09, but not successful.Thank
you.Looking forward;Syed
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
mvn, it installs these modules but changes are not updated
in already build binaries.
Please guide me how can I do this.
Kind regards;
syed
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
DeAR Fabian;
THANKS FOR YOUR ANSWER!
I tried to build the flink again, but after several tries I am still facing
the same error.
Is there any other alternative to resolve the dependencies to successfully
build the flink?
Kind Regards;
Syed
--
Sent from: http://apache-flink-user-mailing-list
e.flink.client.cli.CliFrontend.main(CliFrontend.java:1126)
Caused by: java.lang.ClassNotFoundException:
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer
at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at java.lang.ClassLoader.loadClass(ClassLoader.j
ing latest maven, and afterward, as per instruction at
the flink github page https://github.com/apache/flink
<https://github.com/apache/flink> , I also tried via maven 3.1.1, but the
same error.
Please guide me how to fix this issue.
Best Regards
Syed
--
Sent from: http://apache-flink-use
nly use [
/enableCheckpointing(1000)/]
Kind regards;
Syed
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
I am already using jdk 1.8.
I have searched a lot over internet regarding how to fix this issue, but did
not get the solution.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi
I am trying to build flink 1.3.3 from source using IntelliJ IDEA Ultimate
2019.1 IDE. When I build the project, I am receiving the following error
*java package sun.misc does not exist*
I am using the instruction to Importing Flink into an IDE available at this
link
https://ci.apache.org/pro
I am facing the *java.lang.NoClassDefFoundError:
com/twitter/hbc/httpclient/auth/Authentication*
error when running the tweeter example.
The example works well with the sample data, but I am unable to run it with
real tweet data.
Please guide me how to fix this issue. I am running Flink 1.3.2.
Tha
Hi;
I am facing the following IO exception while running a simple wordcount
application.
*IOException: Size of the state is larger than the maximum permitted
memory-backed state. Size=34521369 , maxSize=5242880 . Consider using a
different state backend, like the File System State backend.*
I hav
I am new to the flink environment and looking to analyze the triggering of
checkpoints. I am looking to trigger non-periodic checkpoints such that
checkpoint intervals are not of equal length, but not sure how can I do this
in Flink.
My specific query is;
(1) How can I trigger non-periodic chec
Hi
I am new to the flink world, and trying to understand. Currently, I am using
Flink 1.3.2 on a small cluster of 4 nodes,
I have configured checkpoint directory at HDFS, and run streaming word count
example with my own custom input file of 63M entries,
I enabled checkpoint every one second {/env
Hi
Could someone share the 1.4 release timeline. I intend to use the Kafka 11
connector.
Thanks
Moiz
actly-once Kafka producer that will come with Kafka
> 0.11 connector, you should be able to use 0.10 connector to read
> (exactly-once) and write (at-least-once) to Kafka 0.11.
>
> Piotrek
>
> > On 12 Oct 2017, at 10:44, Syed Moizuddin wrote:
> >
> > Hi,
> >
>
Hi,
I was just wondering if I could use the Kafka 11 connector on 1.3.
If there are dependencies, then what would be the timeframe for 1.4 release
Thanks
Moiz
15 matches
Mail list logo
