Github user stczwd commented on the issue:
https://github.com/apache/spark/pull/22575
> How should we do if we wanna join two kafka stream and sink the result to
another stream?
`insert into kafka_sql_out select stream t1.value from (select cast(value
as string), timestamp as time1 from kafka_sql_in1) as t1 inner join (select
cast(value as string), timestamp as time2 from kafka_sql_in2) as t2 on time1 >=
time2 and time1 <= time2 + interval 10 seconds where t1.value == t2.value`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
