Hi,
I have a jar file which aims to submit multiple Flink Stream jobs. When the
program submits the first one successfully to the Flink, my program can't
submit the second one even it can't go to the second code line.
How can I fix this problem to submit different stream jobs at regular
Hi,
I can't see the running Flink job from Eclipse on Flink dashboard even I can
see the running Flink jobs if I run jar file from Flink CLI or submit from
Flink dashboard.
Regards.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi
I would ask about the command for running sql-client.sh
These commands don't work
./sql-client.sh OR ./flink sql-client
Regards.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Thanks, Fabian.
The problem was incorrect java path. Now, everything works fine.
I would ask about the command for running sql-client.sh
These commands don't work
./sql-client.sh OR ./flink sql-client
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi,
I am using Flink 1.4.2 and I can't see my running jobs on Flink we
dashboard.
I downloaded Flink 1.5 and 1.6, I received this message when I tried to send
my arguments like this
--topic sensor --bootstrap.servers localhost:9092 --zookeeper.connect
localhost:2181 --group.id
Thanks a lot.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi,
I would like to know the amount of heap memory currently used (in bytes) of
a specific job which runs on Flink cluster.
Regards.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi All,
I have one stream is consumed by FlinkKafkaConsumer which will be joined
with another stream for defined window size such as
Time.milliseconds(1). How can I change window size during runtime to
Time.milliseconds(2)?
Stream1.join(Stream2)
Thanks very much.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi All,
I have a GPS stream consumed by FlinkKafkaConsumer which contains a set of
GPSs of different users. I need to count a number of users per a specific
window of this stream.
Could anyone help me, a part of my code is below
// read data from Kafka
DataStream
Thanks very much. Now it works fine.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Thanks very much. Now it works fine.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi All,
Kindly, could I ask about running multiple jars for different stream jobs in
a cluster? Since I have two jars,
1- jar 1 joins stream1⋈ stream2
2- jar 2 joins stream1⋈ stream3
I submitted the first one and it works fine, when I tried to submit the
second one, it failed. When I go to
Hi All,
Kindly, could I ask about running multiple jars for different stream jobs in
a cluster? Since I have two jars, each one joins different data streams. I
submitted the first one and it works fine, when I tried to submit the second
one, it failed. When I go to running tab i.e.
Hi All,
Kindly, could I ask about running multiple jars for different stream jobs in
a cluster? Since I have two jars, each one joins different data streams. I
submitted the first one and it works fine, when I tried to submit the second
one, it failed. When I go to running tab i.e.
Hi,
I have a problem when running streaming Flink from jar file using CLI, the
program works fine if it runs from IDE?
The main exception is [1]
When I search for this exception, I tried to solve it by adding akka
dependencies to my pom.xml file as [2] and maven shaded plugin for jar
execution
Hi,
I have a jar file that subscribes streaming data from Kafka and then
executes some Flink queries. When the program runs locally, it works fine.
But, when I run the jar file, I got these exceptions which sound that
akka.stream.materializer causes the problem, I added akka.stream
thanks Stefan.
I subscribed the streaming data from Kafka and I did some queries using
Flink.
I need to store some of the results into a static source.
So, which is better data source can I define by Kafka source within Flink
API MongoDB or Postgresql.
Thanks again.
--
Sent from:
Hi all,
Kindly, I want to save streaming data which subscribed from Kafka into a
static data source. Which is better /MongoDB or PostgreSQL.
Radhya.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi all,
Could you help me, I joined two streams and then I tried to write the
results to CSV file. But I found the CSV file is empty even the join
function is called when I used use print instead of write
** here empty file
ProximityStream.join(gpsStream)
Hi,
Could you help me if I want to do aggregations of two joined streams such as
AVG
FirstStream.join(SecondStream)
.where(new FirstKeySelector())
.equalTo(new SecondKeySelector())
Yes I totally agree Shuyi Chen, if anyone has an example which does the
pipeline streaming processing (Kafka-Flink-SQL), it will be useful for all
of us.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Thanks Timo. I will go over there.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi,
Could any one help me by providing some sample java code which Flink
subscribes data data from kafka and then doing SQL queries using SQL APIs.
Also, what are the compatible versions for java/kafka/flink.
Since, I am beginner and there are many exceptions in my code
public class
24 matches
Mail list logo
