Yea, it goes through many events from this input before the exception is
thrown. I don’t know how the input schema can change though, as the input is
always producing objects from the same class.
From: JING ZHANG
Sent: Thursday, August 12, 2021 10:22 PM
To: Nathan Yu
Cc: user@flink.apache.org
Hi Yu,
The exception is thrown after processing some input data instead of at the
beginning of the input, right?
Is there any possible that input schema has updated?
Nathan Yu 于2021年8月13日周五 上午8:38写道：
> · Using local environment:
> StreamExecutionEnvironment.createLocalEnvironment()
>
> ·
Hi Megha,
Event window would be triggered after the watermark passed the end of
window. Would you please check the watermark value on the Flink UI.
Best,
JING ZHANG
Megha Gandhi 于2021年8月13日周五 上午2:33写道：
>
>
> On Aug 12, 2021, at 11:31 AM, Megha Gandhi wrote:
>
> Hi
> This is my flink app code
>
* Using local environment:
StreamExecutionEnvironment.createLocalEnvironment()
*Event is a POJO class, with int, double, enum, and String fields
*Unfortunately it's hard for me to reproduce in a small example, as it
seems to occur after 10e6+ events.
*Using flin
> On Aug 12, 2021, at 11:31 AM, Megha Gandhi wrote:
>
> Hi
> This is my flink app code
> DataStream input = createSourceFromStaticConfig(env);
> // Map it to a json
> ObjectMapper jsonParser = new ObjectMapper();
> DataStream> inputStream = input.map(value -> {
> // Parse the JSON
>
Hi Paul,
I'm very happy to hear that.😀,
Paul Lam 于2021年8月12日周四 下午3:17写道：
> Hi JING,
>
> Thanks for your inputs! It helps a lot.
>
> Best,
> Paul Lam
>
> 2021年8月12日 13:13，JING ZHANG 写道：
>
> Hi Paul,
> There are Table hints and Query hints.
> Query hints are on the way, there is a JIRA to track t
Thank you both!
Looks much better and hopefully works!
Daniel.
On Thu, Aug 12, 2021 at 10:35 AM Schwalbe Matthias <
matthias.schwa...@viseca.ch> wrote:
> Good morning Daniel,
>
>
>
> … so my guess was not the cause of your problem 😊, anyway it seems like
> you always want to use your LogSession
Good morning Daniel,
… so my guess was not the cause of your problem 😊, anyway it seems like you
always want to use your LogSessionProducer with Session?
In that case you could drop the generics from the class like this:
class LogSessionProducer(schema: SerializationSchema[Session], props:
Prop
Hi JING,
Thanks for your inputs! It helps a lot.
Best,
Paul Lam
> 2021年8月12日 13:13，JING ZHANG 写道：
>
> Hi Paul,
> There are Table hints and Query hints.
> Query hints are on the way, there is a JIRA to track this issue [3]. AFAIK,
> the issue is almost close to submit a pull request now.
>
>
