n.
> > > I think 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
,
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/datastream
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
r the 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/types/#a
;
> > 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. But from my
> side, I prefer to follow Hive/Spark.
> >
> > BTW: the quer
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
10 matches
Mail list logo