is only executed once the
> in-flight request completes. The futures are constructed in such a way that
> they maintain the map properly after completing.
>
>
> On Mon, Jun 19, 2023 at 10:55 AM Juho Autio
> wrote:
>
> > I need to make some slower external requests in par
I need to make some slower external requests in parallel, so Async I/O
helps greatly with that. However, I also need to make the requests in a
certain order per key. Is that possible with Async I/O?
The documentation[1] talks about preserving the stream order of
results, but it doesn't discuss the
Juho Autio created FLINK-10216:
--
Summary: Add REGEXP_MATCH in TableAPI and SQL
Key: FLINK-10216
URL: https://issues.apache.org/jira/browse/FLINK-10216
Project: Flink
Issue Type: Sub-task
Juho Autio created FLINK-9335:
-
Summary: Expose client logs via Flink UI
Key: FLINK-9335
URL: https://issues.apache.org/jira/browse/FLINK-9335
Project: Flink
Issue Type: Improvement
Juho Autio created FLINK-9334:
-
Summary: Docs to have a code snippet of Kafka partition discovery
Key: FLINK-9334
URL: https://issues.apache.org/jira/browse/FLINK-9334
Project: Flink
Issue Type
Juho Autio created FLINK-9184:
-
Summary: Remove warning from kafka consumer docs
Key: FLINK-9184
URL: https://issues.apache.org/jira/browse/FLINK-9184
Project: Flink
Issue Type: Sub-task
Juho Autio created FLINK-9183:
-
Summary: Kafka consumer docs to warn about idle partitions
Key: FLINK-9183
URL: https://issues.apache.org/jira/browse/FLINK-9183
Project: Flink
Issue Type: Sub
Hi Fabian!
Is this the feature that will also add windowed aggregates to streaming SQL:
https://issues.apache.org/jira/browse/FLINK-4557 (Table API Stream
Aggregations)?
You wrote:
> However for the 1.2 release, it we plan to focus on the streaming
> Table API and Stream SQL to add support for w
Juho Autio created FLINK-3964:
-
Summary: Job submission times out with recursive.file.enumeration
Key: FLINK-3964
URL: https://issues.apache.org/jira/browse/FLINK-3964
Project: Flink
Issue Type