Re: Can't create a savepoint with State Processor API

Yep, that works! Many thanks David, really appreciate it! -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Can't create a savepoint with State Processor API

Hi everyone, I'm looking for a way to modify state inside an operator in Flink. I found State Processor API that allows to modify savepoints, which looks great. But I can't

Re: How to create an empty test stream

> method, start an empty loop? But I don't understand the meaning of starting > a stream pipeline without generating data. > > Best, > Vino > > Dmitry Minaev 于2019年10月24日周四 上午6:16写道： > >> Hi everyone, >> >> I have a pipeline where I union several streams.

How to create an empty test stream

Hi everyone, I have a pipeline where I union several streams. I want to test it and don't want to populate one of the streams. I'm usually creating streams with: DataStreamTestBase.createTestStreamWith(event).close(); The above statement creates a stream and puts the `event` inside. But in my

FileNotFoundException on starting the job

Hi everyone, I'm having an issue when restarting a job in Flink. I'm doing a simple stop with savepoint and then start from the savepoint. Savepoints are stored in a separate folder, there is no configuration for "/tmp" folder in my setup. There is only 1 task manager and parallelism is 1. I'm

Re: cannot find TwoInputStreamOperatorTestHarness after upgrade to Flink 1.6.0

oInputStreamOperatorTestHarness.java > [2]: https://github.com/apache/flink/tree/release-1.6.0 > > Thanks, vino. > > Dmitry Minaev 于2018年8月12日周日 下午1:16写道： > >> Hi everyone, >> >> I'm working to upgrade my environment to Flink v.1.6.0 and I'm facing an >&g

cannot find TwoInputStreamOperatorTestHarness after upgrade to Flink 1.6.0

Hi everyone, I'm working to upgrade my environment to Flink v.1.6.0 and I'm facing an issue. We're using TwoInputStreamOperatorTestHarness in our tests and after upgrade to 1.6.0 my project compilation fails with "cannot find symbol TwoInputStreamOperatorTestHarness". I've reproduced the problem

No activity but checkpoints are failing and backpressure is high

/1T9FqY8faWHmJOPdMC0MunxxFRQbAVDjd/view?usp=sharing I would very much appreciate any advice to help me solve the problem. Thank you, Dmitry Minaev -- -- Dmitry

minPauseBetweenCheckpoints for failed checkpoints

fails by timeout? Thank you! -- Kind regards, Dmitry Minaev CONFIDENTIALITY NOTICE: This e-mail and any files attached may contain confidential information of Five9 and/or its affiliated entities. Access by the intended recipient only is authorized. Any liability