- but it is clear on the Javadoc.
>
> Thanks for the assistance
> Adrian
>
> -Original Message-
> From: Guozhang Wang [mailto:wangg...@gmail.com]
> Sent: 16 June 2017 20:35
> To: users@kafka.apache.org
> Subject: Re: IllegalStateException when putting to state st
for the assistance
Adrian
-Original Message-
From: Guozhang Wang [mailto:wangg...@gmail.com]
Sent: 16 June 2017 20:35
To: users@kafka.apache.org
Subject: Re: IllegalStateException when putting to state store in Transformer
implementation
Adrian,
I see. That would explain what you see, i.e. all
.build();
> > builder.addStateStore(storeSupplier);
> >
> > I can confirm though that all stack traces we have clearly originate
> > from `put()` being called from `transform()`
> >
> > Thanks
> > Adrian
> >
> > -Original Message-
ssage-
> From: Adrian McCague [mailto:adrian.mcca...@zopa.com]
> Sent: 16 June 2017 10:30
> To: users@kafka.apache.org
> Subject: RE: IllegalStateException when putting to state store in Transformer
> implementation
>
> Hi Guozhang
>
> It's just occurred to me that
June 2017 10:30
To: users@kafka.apache.org
Subject: RE: IllegalStateException when putting to state store in Transformer
implementation
Hi Guozhang
It's just occurred to me that the transformer is added to the topology like
this:
PhaseTransformer<S, E> transformer = new PhaseTransfor
16 June 2017 02:54
To: users@kafka.apache.org
Subject: Re: IllegalStateException when putting to state store in Transformer
implementation
Adrian,
I looked though the 0.10.2.1 code but I cannot nail down to any obvious places
where the processor context is set to null, which could trigger your e
(storeSupplier);
>
> I can confirm though that all stack traces we have clearly originate from
> `put()` being called from `transform()`
>
> Thanks
> Adrian
>
> -Original Message-
> From: Guozhang Wang [mailto:wangg...@gmail.com]
> Sent: 14 June 2017 21:18
&
: IllegalStateException when putting to state store in Transformer
implementation
Hello Adrian,
When you call "put()" on the windowed state store that does not specify a
timestamp, then the `timestamp()` is retrieved to use as the default timestamp.
--
public synchronized void put(f
Hello Adrian,
When you call "put()" on the windowed state store that does not specify a
timestamp, then the `timestamp()` is retrieved to use as the default
timestamp.
--
public synchronized void put(final K key, final V value) {
put(key, value, context.timestamp());
}
Hi All
We have a transformer implementation in our Kafka Streams application that
raises this exception, sometimes, when starting.
"java.lang.IllegalStateException: This should not happen as timestamp() should
only be called while a record is processed"
This happens when 'put' is called on a
10 matches
Mail list logo
