Dian Fu created FLINK-26919:
---
Summary: Table API program compiles field with "Cannot resolve
field [a], input field list:[EXPR$0]"
Key: FLINK-26919
URL: https://issues.apache.org/jira/browse/FLINK-26919
Hi everyone,
We (Jiangjie Qin, Yun Gao, Zhipeng Zhang, Weibo Zhao, Yunfeng Zhou and
myself) would like to make the following minor API change to this FLIP.
We will update Stage's Java doc to say the following, which changed the
load(..) first parameter type from StreamExecutionEnvironment to
Jingsong Lee created FLINK-26918:
Summary: Add documentation build to Github Actions
Key: FLINK-26918
URL: https://issues.apache.org/jira/browse/FLINK-26918
Project: Flink
Issue Type:
Hi Devs,
I just want to give you heads up regarding a significant issue Matyas found
around the last-state upgrade mode:
https://issues.apache.org/jira/browse/FLINK-26916
Long story short, the last-state mode does not actually upgrade the job,
only the job/taskmanagers. The fix is non-trivial to
Gyula Fora created FLINK-26917:
--
Summary: Enforce Kubernetes HA during validation for last-state
mode
Key: FLINK-26917
URL: https://issues.apache.org/jira/browse/FLINK-26917
Project: Flink
Matyas Orhidi created FLINK-26916:
-
Summary: The Operator Ignores job related changes (jar,
parallelism) during last-state upgrades
Key: FLINK-26916
URL: https://issues.apache.org/jira/browse/FLINK-26916
Aitozi created FLINK-26915:
--
Summary: Extend the Reconciler and Observer interface
Key: FLINK-26915
URL: https://issues.apache.org/jira/browse/FLINK-26915
Project: Flink
Issue Type: Improvement
+1 non-binding, thanks for the great efforts and look forward to the
release!
Chenya
On Tue, Mar 29, 2022 at 2:10 AM Gyula Fóra wrote:
> Hi everyone,
>
> Please review and vote on the release candidate #2 for the version 0.1.0 of
> Apache Flink Kubernetes Operator,
> as follows:
> [ ] +1,
Ad. 1 What do you mean here? It will be deleted once the new job created
`state.checkpoints.num-retained` checkpoints and the original one is not
needed anymore. This is expected. The way CLAIM works is basically that
the restored checkpoint is subject to regular Flink's cleaning procedure.
> -原始邮件-
> 发件人: "Timo Walther"
> 发送时间: 2022-03-24 17:09:38 (星期四)
> 收件人: dev@flink.apache.org
> 抄送:
> 主题: Re: 回复：Re:[DISCUSS] FLIP-214 Support Advanced Function DDL
>
> Hi Ron,
>
> thanks for opening this discussion and proposing a FLIP. This feature
> has been requested multiple
> -原始邮件-
> 发件人: "Martijn Visser"
> 发送时间: 2022-03-24 16:18:14 (星期四)
> 收件人: dev
> 抄送:
> 主题: Re: Re: 回复：Re:[DISCUSS] FLIP-214 Support Advanced Function DDL
>
> Hi Ron,
>
> Thanks for creating the FLIP. You're talking about both local and remote
> resources. With regards to remote
Yang Wang created FLINK-26914:
-
Summary: Notice files improvements in flink-kubernetes-operator
Key: FLINK-26914
URL: https://issues.apache.org/jira/browse/FLINK-26914
Project: Flink
Issue Type:
As there was already a discussion in the doc, I'll just summarize my
opinions here on the proposed execution of this FLIP.
I think we should rather avoid exposing internal details, which I consider
Calcite to be part of, but rather reuse what we already have to define an
AST from Table API, which
Jingsong Lee created FLINK-26913:
Summary: Add ITCase for computed column and watermark
Key: FLINK-26913
URL: https://issues.apache.org/jira/browse/FLINK-26913
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-26912:
-
Summary: EventTimeWindowCheckpointingITCase.testTumblingTimeWindow
failed on azure
Key: FLINK-26912
URL: https://issues.apache.org/jira/browse/FLINK-26912
Jingsong Lee created FLINK-26911:
Summary: Introduce parallelism setter for table store
Key: FLINK-26911
URL: https://issues.apache.org/jira/browse/FLINK-26911
Project: Flink
Issue Type:
Hi, I found old checkpoints will not be deleted in claim mode in two cases:
1. set state.checkpoints.num-retained to num bigger than 1
2. restore from legacy mode which produces some retained checkpoints
In above cases, we only claim the last checkpoint in the claim mode so that
only the last
Sebastian Mattheis created FLINK-26910:
--
Summary: flink-benchmarks build fails on Apple M1 silicon
Key: FLINK-26910
URL: https://issues.apache.org/jira/browse/FLINK-26910
Project: Flink
Hi everyone,
Please review and vote on the release candidate #2 for the version 0.1.0 of
Apache Flink Kubernetes Operator,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
**Release Overview**
As an overview, the release consists of
Liu created FLINK-26909:
---
Summary: Support AdaptiveBatch when parallelism is -1 from Cli
Key: FLINK-26909
URL: https://issues.apache.org/jira/browse/FLINK-26909
Project: Flink
Issue Type: Improvement
Hi devs,
I am cancelling this vote, and will prepare a new RC with the notice fixes
included.
Thanks,
Gyula
On Tue, Mar 29, 2022 at 7:42 AM Gyula Fóra wrote:
> Thank you all for the input, let’s consider this a blocker.
>
> As soon as we have the NOTICE fix , I will prepare the new RC.
>
>
WangMinChao created FLINK-26908:
---
Summary: HA job cannot to restarting
Key: FLINK-26908
URL: https://issues.apache.org/jira/browse/FLINK-26908
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26907:
---
Summary: RMQSourceITCase failed on azure due to
ContainerLaunchException: Container startup failed
Key: FLINK-26907
URL: https://issues.apache.org/jira/browse/FLINK-26907
Liu created FLINK-26906:
---
Summary: Spelling error for AdaptiveBatch in elastic_scaling.md
Key: FLINK-26906
URL: https://issues.apache.org/jira/browse/FLINK-26906
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-26905:
--
Summary: Re-add FlinkDeploymentList and FlinkSessionJobList classes
Key: FLINK-26905
URL: https://issues.apache.org/jira/browse/FLINK-26905
Project: Flink
Issue
Dong Lin created FLINK-26904:
Summary: Update load(...) of all Stage subclasses to use
StreamTableEnvironment
Key: FLINK-26904
URL: https://issues.apache.org/jira/browse/FLINK-26904
Project: Flink
26 matches
Mail list logo
