Hi community,
When customers are iterating on the Flink SQL pipelines, we have discovered
a couple of state incompatible changes that we believe could be state
compatible and would allow working with stateful Flink SQL pipeline easier.
Today some of these incompatibility issues can be addressed b
Eric Xiao created FLINK-37240:
-
Summary: Changing column nullability throws
StateMigrationException in a SQL pipeline with a JOIN
Key: FLINK-37240
URL: https://issues.apache.org/jira/browse/FLINK-37240
Hi Sergio,
Can you update the Phase 1 Google Doc's sharing permissions? I also believe
the link in the FLIP leads to an internal Apple tool:
https://quip-apple.com/account/login?next=https%3A%2F%2Fquip-apple.com%2F7BpiAdeZ7Ow3
On Tue, Jan 14, 2025 at 12:15 PM Sergio Chong Loo
wrote:
> FLIP-503:
Hi Yuepeng Pan,
This would be a very useful feature to have in OSS. One question I have
that wasn't outlined in the FLIP or I may have missed it was -
How/Where would we store the history of these scaling events? Is there an
existing pattern for storing such information in other parts of Flink th
Hey Taher,
To answer question 2 and 3 - per the flink documentation[1] in-flight
requests are stored in checkpoints and only the unsent records will be sent
when recovering from a failure.
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/operators/asyncio/#fault-tolerance-
hink it's reasonable to add ''setMaxParallelism" for DataStreamSink.
> > >
> > > +1
> > >
> > > Best,
> > > Weihua
> > >
> > >
> > > On Sat, Apr 22, 2023 at 3:20 AM eric xiao
> wrote:
> > >
>
Eric Xiao created FLINK-31941:
-
Summary: Not backwards compatible naming for some kubernetes
resources
Key: FLINK-31941
URL: https://issues.apache.org/jira/browse/FLINK-31941
Project: Flink
Best,
Eric Xiao
[1] https://issues.apache.org/jira/browse/FLINK-31873
[2]
https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/elastic_scaling/#configuration
[3]
https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datas
Eric Xiao created FLINK-31873:
-
Summary: Add setMaxParallelism to the DataStreamSink Class
Key: FLINK-31873
URL: https://issues.apache.org/jira/browse/FLINK-31873
Project: Flink
Issue Type: Bug
-L114
On Fri, Oct 28, 2022 at 10:17 PM yuxia wrote:
> `ARRAY`/ `INT ARRAY` is for declaring data type in DDL like `create
> table t1(a INT ARRAY)`.
>
> Best regards,
> Yuxia
>
> - 原始邮件 -----
> 发件人: "eric xiao"
> 收件人: "dev"
> 发送时间: 星期六, 2
Eric Xiao created FLINK-29837:
-
Summary: SQL API does not expose the RowKind of the Row for
processing Changelogs
Key: FLINK-29837
URL: https://issues.apache.org/jira/browse/FLINK-29837
Project: Flink
e keyword 'INT' at line 1, column 8.
Was expecting one of:
"ABS" ...
"ALL" ...
"ARRAY" ...
"AVG" ...
"CARDINALITY" ...
Am I missing something?
[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/t
1), None)]
> > +- OneRowRelation
> > `
> >
> >
> > Seems it's hard to decide which data type Flink should use. I'm
> insterested in the reason why you would like to use Integer type.
> > I haven't cheked whether the sql stardard specifies it. Bu
Hi,
I would like to propose a solution to this JIRA issue. I looked at the
comments and there was some guidance around where in the code we should
update to allow for this behaviour. But I believe there are still two
questions that remain open:
1. Is this expected behaviour (i.e. users should
Eric Xiao created FLINK-29498:
-
Summary: Flink Async I/O Retry Strategies Do Not Work for Scala
AsyncDataStream API
Key: FLINK-29498
URL: https://issues.apache.org/jira/browse/FLINK-29498
Project: Flink
15 matches
Mail list logo
