HI,
I am using Flink Task manager and Job Manager as docker containers.
Strangely, I find the jobs to disappear from the web portal after some
time. The jobs don't move to the failed state either. Any pointers will be
really helpful. Not able to get a clue from the logs.
Kindly let me know if I n
Thanks,I'm not sure I understand this, what I need is to have single a process
subscribing multiple kafka topics, and have a switch clause for different
topics in my SinkFunction, did you I need to change the way how the kafka
producer to produce the message? Any pointer to code samples will be
Hello,
Is there a way to apply the AsyncFunction to connected streams like in a
CoFlatMap?
I would like to connect streams from different types and process one of them
based on the state
created by the other in an asynchronous fashion.
Regards,
Pedro Chaves
-
Best Regards,
Pedro Chaves
--
Thank you! Hoping to see Lambda support added back in soon as well.
Regards,
David
On Mon, Jun 12, 2017 at 1:57 PM, Kostas Kloudas wrote:
> Done.
>
> On Jun 12, 2017, at 12:24 PM, Ted Yu wrote:
>
> Can you add link to this thread in the JIRA ?
>
> Cheers
>
> On Mon, Jun 12, 2017 at 3:15 AM, K
HI,
I have a use case were I need to build a global window with custom trigger.
I would like to reference this window across my flink jobs. Is there a
possibility that the global window can be referenced?
Regards,
Vijay Raajaa GS
