hi
submit job through rest api /jars/:jarid/run
my job is sql and udf , but the rest api only run one jar , udf can't run
simultaneously, View JarRunHandler code , not support classpath
so Do I have other methods to achieve?
Two jar packs together?
--
Sent from: http://apache-flink-user-ma
i delete ‘row‘ flag
it seems good looking
--
a job have two sql
source is kafka
sink is redis or other sink
Asql
select
reqIp as factorContenta,
count(*) as eCount,
60 * 60 as expire
from
kafka_source
where
uri is not null
group by
hi
i deleteflag
it seems good looking
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
hi
i deleteflag
it seems good looking
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
a job have two sql
source is kafka
sink is redis or other sink
Asql
Bsql
now only start Asql stop Bsqlsink have key 656.19.173.34
then stop Asql and savepoint hdfs now del key 656.19.173.34( if sink is
kafka Don't delete)
start Bsql from savepoint
you will find sink have key
