I have written a blogpost though its not used CEP but I hope you can apply
same thing for CEP as well.
http://dhanuka84.blogspot.com/2019/02/rule-execution-as-streaming-process.html?m=1
On Tue, 12 Feb 2019, 11:46 Dian Fu This feature has not been supported yet. There is a JIRA(
> https://issu
Regards,
> Dian
>
> 在 2019年1月24日，下午2:08，dhanuka ranasinghe 写道：
>
> Hi Dian,
>
> Thanks for the explanation. Please find the screen shot and source code
> for above mention use case. And in main issue is though I use KeyedStream ,
> parallelism not apply properly.
>
termark, i.e with
> DataStream.assignTimestampsAndWatermarks
>
> Regards,
> Dian
>
>
> 在 2019年1月23日，上午1:58，dhanuka ranasinghe 写道：
>
> patternStream
>
>
>
erator to run parallel, the input stream should
> be KeyedStream. You can refer [1] for detailed information.
>
> Regards,
> Dian
>
> [1]:
> https://ci.apache.org/projects/flink/flink-docs-master/dev/libs/cep.html#detecting-patterns
>
> > 在 2019年1月24日，上午10:18，dhan
Hi All,
I have used Flink CEP to filter some events and generate some alerts based
on certain conditions. But unfortunately doesn't print any result. I have
attached source code herewith, could you please help me on this.
package org.monitoring.stream.analytics;
me, I'd follow a hybrid approach and UNION ALL only as many
> tables as you need to avoid the code compilation exception.
>
> Best, Fabian
>
> Am Mo., 14. Jan. 2019 um 14:15 Uhr schrieb dhanuka ranasinghe <
> dhanuka.priyan...@gmail.com>:
>
>> Hi Fabian ,
>&
query will scan the
> (identical?) Kafka topic 200 times which is highly inefficient.
> You should rather use your second approach and scale the query
> appropriately.
>
> Best, Fabian
>
> Am Mo., 14. Jan. 2019 um 08:39 Uhr schrieb dhanuka ranasinghe <
> dhanuka.priyan..
mination, it is currently not possible to use
> SQL for your use case.
>
> There is thea Jira issue FLINK-9422 to improve this case [1].
>
> Best, Fabian
>
> [1] https://issues.apache.org/jira/browse/FLINK-9422
>
> Am So., 13. Jan. 2019 um 14:43 Uhr schrieb dhanuka ranasin
Hi All,
I am trying to select multiple results from Kafka and send results to Kafka
different topic using Table API. But I am getting below error. Could you
please help me on this.
Query:
SELECT TiggerID,'Rule3' as RuleName,mytime(ts) as ts1 ,
mytime(CURRENT_TIMESTAMP) as ts2 FROM dataTable WHER
der.
> - Add flink-connector-kafka_2.11-1.7.0.jar to your lib folder if you want
> to use 'universal'.
>
> Best, Hequn
>
> On Sun, Dec 23, 2018 at 8:48 PM dhanuka ranasinghe <
> dhanuka.priyan...@gmail.com> wrote:
>
>> Hi Cheng,
>>
>> I
dError.
>
> From the picture uploaded, it is strange that the jar of 1.6.1 is mixed
> with the jar of 1.7.0. It may result in class conflict problem.
> Furthermore, set flink dependency scope to provided, so that classes of
> flink will not be packaged into the user jar. It will also ca
scope to provided, so that classes of
> flink will not be packaged into the user jar. It will also cause class
> conflict problem.
>
> Best,
> Hequn
>
>
> On Fri, Dec 21, 2018 at 6:24 PM dhanuka ranasinghe <
> dhanuka.priyan...@gmail.com> wrote:
>
>> A
Add Dev Group
On Fri, Dec 21, 2018 at 6:21 PM dhanuka ranasinghe <
dhanuka.priyan...@gmail.com> wrote:
> Hi All,
>
> I have tried to read data from Kafka from Flink using Table API. It's
> working fine with Flink 1.4 but when upgrade to 1.7 given me below error. I
> h
13 matches
Mail list logo
