Re: Cannot terminate query on KSQL

2020-04-17 Thread Federico D'Ambrosio “fedexist”
u could re-post this question here: > https://github.com/confluentinc/ksql/issues. > > Cheers, > Guozhang > > > On Fri, Apr 17, 2020 at 8:57 AM Federico D'Ambrosio > wrote: > >> So, I tried with another query which hangs and I get this, after its >> corr

Re: Cannot terminate query on KSQL

2020-04-17 Thread Federico D'Ambrosio
look into? Thank you, Il giorno ven 17 apr 2020 alle ore 11:22 Federico D'Ambrosio < fedex...@gmail.com> ha scritto: > Looking back at the ksql-stream logs: > > I find for a query I'm trying to terminate this line: > > [2020-04-17 09:17:52,502] I

Re: Cannot terminate query on KSQL

2020-04-17 Thread Federico D'Ambrosio
tdown state*, wait to complete shutdown (org.apache.kafka.streams.KafkaStreams:849) and it just stays there, without any more information. Restarting the server apparently doesn't help. Il giorno ven 17 apr 2020 alle ore 11:07 Federico D'Ambrosio < fedex...@gmail.com> ha scritto: >

Cannot terminate query on KSQL

2020-04-17 Thread Federico D'Ambrosio
INATE command from KSQL cli just hangs without any feedback. Ksql log is not much helpful, really just showing the POST request being sent. How should we proceed? Is there anyway to force deletion of a query/stream? What could be causing this issue? Thank you, Federico D'Ambrosio

Re: KSQL UDFs with structs as parameters, structs as output

2020-03-02 Thread Federico D'Ambrosio
ented? I cannot find any example on this. 2. Is it possible to unnest a Struct field? I cannot find any reference on this and since there would be quite a bit of different topics, I really don't want to specify manually an additional stream with SELECT AS SELECT as strct->f

KSQL UDFs with structs as parameters, structs as output

2020-03-02 Thread Federico D'Ambrosio
m to find any in the official documentation. Thank you very much for your help, Federico D'Ambrosio