ands) - 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 sto
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
;
> >
> > 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.co
e-
> 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 t
: 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 the transformer is added to the topology like
this:
PhaseTransformer transformer = new PhaseTran
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 excepti
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
> To: users@kafka.apache.org
&g
t: Re: 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
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 s
10 matches
Mail list logo
