Hi Nishant,
On a brief look. I think this is a problem with your 2nd query:
>
> *Table2*...
> Table latestBadIps = tableEnv.sqlQuery("SELECT MAX(b_proctime) AS
> mb_proctime, bad_ip FROM BadIP ***GROUP BY bad_ip***HAVING
> MIN(b_proctime) > CURRENT_TIMESTAMP - INTERVAL '2' DAY ");
> tableEnv.regi
Hi Team,
I am trying to Join [kafka stream] and [badip stream grouped with badip]
Can someone please help me out with verifying what is wrong in
highlighted query. Am I writing the time window join query wrong with this
use case.? Or it is a bug and i should report this
what is the work around, i
