Hi Avi,
Good to hear that!
Cheers,
Kostas
On Mon, Mar 25, 2019 at 3:37 PM Avi Levi wrote:
> Thanks, I'll check it out. I got a bit confused with the Ingesting time
> equals to null in tests but all is ok now , I appreciate that
>
> On Mon, Mar 25, 2019 at 1:01 PM Kostas Kloudas wrote:
>
>> Hi
Thanks, I'll check it out. I got a bit confused with the Ingesting time
equals to null in tests but all is ok now , I appreciate that
On Mon, Mar 25, 2019 at 1:01 PM Kostas Kloudas wrote:
> Hi Avi,
>
> Just to verify your ITCase, I wrote the following dummy example and it
> seems to be "working"
Hi Avi,
Just to verify your ITCase, I wrote the following dummy example and it
seems to be "working" (ie. I can see non null timestamps and timers firing).
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
env.setStreamTimeCharacteristic(TimeCharacteristic.In
Any idea what should I do to overcome this?
On Wed, Mar 20, 2019 at 7:17 PM Avi Levi wrote:
> Hi Andrey,
> I am testing a Filter operator that receives a key from the stream and
> checks if it is a new one or not. if it is new it keeps it in state and
> fire a timer all that is done using the Pr
Hi Avi,
do you use processing time timer
(timerService().registerProcessingTimeTimer)?
why do you need ingestion time? do you set TimeCharacteristic.IngestionTime?
Best,
Andrey
On Tue, Mar 19, 2019 at 1:11 PM Avi Levi wrote:
> Hi,
> Our stream is not based on time sequence and we do not use ti
Hi,
Our stream is not based on time sequence and we do not use time based
operations. we do want to clean the state after x days hence we fire timer
event. My problem is that our unit test fires the event immediately (there
is no ingestion time) how can I inject ingestion time ?
Cheers
Avi
