Re: Async I/O: preserve stream order for requests on key level

2023-06-20 Thread Juho Autio
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

Async I/O: preserve stream order for requests on key level

2023-06-19 Thread Juho Autio
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

[jira] [Created] (FLINK-10216) Add REGEXP_MATCH in TableAPI and SQL

2018-08-25 Thread Juho Autio (JIRA)
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

[jira] [Created] (FLINK-9335) Expose client logs via Flink UI

2018-05-11 Thread Juho Autio (JIRA)
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

[jira] [Created] (FLINK-9334) Docs to have a code snippet of Kafka partition discovery

2018-05-11 Thread Juho Autio (JIRA)
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

[jira] [Created] (FLINK-9184) Remove warning from kafka consumer docs

2018-04-16 Thread Juho Autio (JIRA)
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

[jira] [Created] (FLINK-9183) Kafka consumer docs to warn about idle partitions

2018-04-16 Thread Juho Autio (JIRA)
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

Re: How to contribute to Streaming Table API and StreamSQL

2016-10-13 Thread Juho Autio
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

[jira] [Created] (FLINK-3964) Job submission times out with recursive.file.enumeration

2016-05-24 Thread Juho Autio (JIRA)
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