Re: Choice of time characteristic and performance

Thanks for you guidance Robert! Do you think disabling watermarking would help in terms of a slight performance boost in such scenarios? Bob -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Choice of time characteristic and performance

I was wondering if the choice of time characteristic (ingestion, processing or event time) makes a difference to the performance of a job that isn't using windowing or process functions. For example, in such a job is it advisable to disable auto wartermarking and use the default? Or is this in comb

Re: How to verify what maxParallelism is set to?

I agree that a way to introspect the effective current value would be a great observability tool for sanity checking. Fabian, do you know if a ticket was ever created? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: entrypoint for executing job in task manager

Please see FLINK-14184 which should fully support such use cases in the future. Feel free to vote for it if you believe it would help your use case. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: User metrics outside tasks

I too think this would be a useful capability for the job manager to be able to send metrics easily. Sometimes additional compute responsibilities are placed in the job manager and having a convenient way to add telemetry data into a metrics stream would be very useful. -- Sent from: http://apac

Re: entrypoint for executing job in task manager

Hi Steven, Curious how you solved this for you use case. Did you ever find a satisfactory approach? Thanks in advance, Bob -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Missing support for `TestStreamEnvironment#executeAsync`

e filed a JIRA issue for fixing this problem [1]. > > [1] https://issues.apache.org/jira/browse/FLINK-21693 > <https://urldefense.com/v3/__https://issues.apache.org/jira/browse/FLINK-21693__;!!PwKahg!vmZiCgmovUl2NR7HnLKGIDXkpYpfIEt2D1cL9RBAEByJiPoqwjDPC2CThEDnTyzx$> > > Cheers,

Missing support for `TestStreamEnvironment#executeAsync`

Hi all, I have been trying to test a Flink 1.11 streaming job using the `DataStreamUtils#collect` utility against a `MiniCluster` based test. However, I noticed an issue when doing so. `TestStreamEnvironment` does not implement `executeAsync`. Thus when `DataStreamUtils#collect` is called, it inv