[jira] [Created] (FLINK-9147) PrometheusReporter jar does not include Prometheus dependencies

Till Rohrmann created FLINK-9147: Summary: PrometheusReporter jar does not include Prometheus dependencies Key: FLINK-9147 URL: https://issues.apache.org/jira/browse/FLINK-9147 Project: Flink

[jira] [Created] (FLINK-9146) 1.4 more than local cannot start submitting

abel-sun created FLINK-9146: --- Summary: 1.4 more than local cannot start submitting Key: FLINK-9146 URL: https://issues.apache.org/jira/browse/FLINK-9146 Project: Flink Issue Type: Bug Co

Re: Multi-stream question

Thanks for the Tuple suggestion, I may use that. I was asking about building a custom operator (just an idea). I have since decided I can decompose the problem into pairs of streams and emit a stream to the next CoFlatMap to get the result I need. Now to see if the idea works ... Michael >

Re: Multi-stream question

Hi Michael, There isn’t an operator that takes three (or more) streams, AFAIK. There is a CoFlatMapFunction that takes two different streams in, which could be used for some types of joins. Streaming joins are (typically) windowed (bounded), by time/count/something, so if you can maintain the

Re: Multi-stream question

In my case I have more elaborate logic to select data from the streams. They are not all the same logical type, though I may be able to represent them as the same Java type. My main question is whether it is technically feasible to have a single operator that takes multiple streams as input.