Martijn Visser created FLINK-30257:
--
Summary: SqlClientITCase#testMatchRecognize failed
Key: FLINK-30257
URL: https://issues.apache.org/jira/browse/FLINK-30257
Project: Flink
Issue Type: Bug
Xuannan Su created FLINK-30258:
--
Summary: PyFlink supports closing loop back server
Key: FLINK-30258
URL: https://issues.apache.org/jira/browse/FLINK-30258
Project: Flink
Issue Type: Improvement
Ran Tao created FLINK-30259:
---
Summary: Using flink Preconditions Util instead of uncertain
Assert keyword to do checking
Key: FLINK-30259
URL: https://issues.apache.org/jira/browse/FLINK-30259
Project: Flin
Maximilian Michels created FLINK-30260:
--
Summary: FLIP-271: Autoscaling
Key: FLINK-30260
URL: https://issues.apache.org/jira/browse/FLINK-30260
Project: Flink
Issue Type: New Feature
From: Renjie Liu
Date: Tuesday, November 1, 2022 at 15:13
To: u...@flink.apache.org
Subject: Why streaming over agg not supporting ranged upper boundary?
Hi, flink community:
Per the doc here
https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/table/sql/queries/over-agg/#range
Hi @Martijn
Thanks for your comments, and I'd like to reply to them
1. It sounds good to me, I'll update the content structure in FLIP later
and give the problems first.
2. "Each ETL job creates snapshots with checkpoint info on sink tables in
Table Store" -> That reads like you're proposing th
Matthias Pohl created FLINK-30261:
-
Summary: PartiallyFinishedSourcesITCase.test timed out while
waiting for tasks to finish
Key: FLINK-30261
URL: https://issues.apache.org/jira/browse/FLINK-30261
Pro
Matthias Pohl created FLINK-30262:
-
Summary: UpsertKafkaTableITCase failed when starting the container
because waiting for a port timed out
Key: FLINK-30262
URL: https://issues.apache.org/jira/browse/FLINK-30262
I'm happy to announce that we have unanimously approved this release.
There are 5 approving votes, 3 of which are binding:
* Etienne
* Dawid (binding)
* Martijjn (binding)
* Danny (binding)
* Ryan
There are no disapproving votes.
Thanks everyone!
On 25/11/2022 10:31, Chesnay Schepler wrote:
Hi
Shammon created FLINK-30263:
---
Summary: Introduce schemas table to table store
Key: FLINK-30263
URL: https://issues.apache.org/jira/browse/FLINK-30263
Project: Flink
Issue Type: New Feature
Yes, the StreamingFileSink is not affected.
Best,
Fabian
Xin Hao created FLINK-30264:
---
Summary: Set session job status to FAILED if already have retried
max attempts
Key: FLINK-30264
URL: https://issues.apache.org/jira/browse/FLINK-30264
Project: Flink
+1 (binding)
Thanks for the FLIP!
On Thu, Dec 1, 2022 at 12:20 PM Shengkai Fang wrote:
> Hi All,
>
> Thanks for all the feedback so far. Based on the discussion[1] we seem
> to have a consensus, so I would like to start a vote on FLIP-273.
>
> The vote will last for at least 72 hours (Dec 5th a
Hi Gen,
Thanks for the suggestions!
Regarding how to implement the per-region RestartBackoffTimeStrategy as
proposed previously, I think your approach works well.
Here are more details:
- Keep the RestartBackoffTimeStrategy interface API unchanged and only
change its semantics, such that all str
Gabor Somogyi created FLINK-30265:
-
Summary: Turn on debug logs for k8s operator e2e tests in CI when
tests failing
Key: FLINK-30265
URL: https://issues.apache.org/jira/browse/FLINK-30265
Project: Fli
Maximilian Michels created FLINK-30266:
--
Summary: Recovery reconciliation loop fails if no checkpoint has
been created yet
Key: FLINK-30266
URL: https://issues.apache.org/jira/browse/FLINK-30266
Hello,
let me clarify the title first.
In the original proposal for the connector externalization we said that
an externalized connector has to exist in parallel with the version
shipped in the main Flink release for 1 cycle.
For example, 1.16.0 shipped with the elasticsearch connector, but
Martijn Visser created FLINK-30267:
--
Summary: PyFlink YARN per-job on Docker test failed because it
could not build hadoop image
Key: FLINK-30267
URL: https://issues.apache.org/jira/browse/FLINK-30267
+1 (non-binding).
Looking forward to it!
On Thu, Dec 1, 2022 at 5:06 AM Dong Lin wrote:
> +1 (binding)
>
> Thanks for the FLIP!
>
> On Thu, Dec 1, 2022 at 12:20 PM Shengkai Fang wrote:
>
> > Hi All,
> >
> > Thanks for all the feedback so far. Based on the discussion[1] we seem
> > to have a co
Hello,
+1
I was thinking the same. With regard to the cut off date I would be
inclined to be more aggressive and say feature freeze for 1.17. Users do
not *need* to migrate for 1.16.
Thanks
On Thu, 1 Dec 2022, 15:01 Chesnay Schepler, wrote:
> Hello,
>
> let me clarify the title first.
>
> In
Hi!
I think this would be a good idea. I was wondering that could we include the
hbase connector to this group as well? The externalization PR [1] should be in
a good shape now and Dec 9th as a release date sounds doable.
WDYT?
[1] https://github.com/apache/flink-connector-hbase/pull/2
Best,
Hi Danny,
+1 (non-binding)
- Checked release notes
- Verified hashes & signature
- Build the source with Maven
- Verified tag is present
- Verified web PR
- Verified streaming sink writes to DynamoDB
Best regards, Yuri Gusev
On 2022/11/28 16:42:42 Danny Cranmer wrote:
> Hi everyone,
> Please r
Gyula Fora created FLINK-30268:
--
Summary: HA metadata and other cluster submission related errors
should not throw DeploymentFailedException
Key: FLINK-30268
URL: https://issues.apache.org/jira/browse/FLINK-30268
Hi Danny, +1 (non-binding)
- Checked release notes
- Verified hashes & signature
- Build the source with Maven
- Verified tag is present
- Verified web PR
- Verified streaming sink writes to DynamoDB
Best regards, Yuri Gusev
On 2022/11/28 16:42:42 Danny Cranmer wrote:
> Hi everyone,
> Please rev
Hello devs,
I'd like to revive this discussion. There is also a ticket about this effort
for some time [1] and this thing also affects us as well. Right now we have a
custom solution that is similar to "environment variables", but it only can be
used in parts of our downstream product. The main
Hello Chesney,
The overall plan sounds good! Just to double check, is Dec 9th the proposed
cutoff date for the release of those externalized connectors?
Also, will we reserve time for users to verify that the drop-in replacement
from Flink 1.16 to those externalized connectors can work as expecte
+1 (non-binding)
Best regards,
Yuxia
- 原始邮件 -
发件人: "Yaroslav Tkachenko"
收件人: "dev"
发送时间: 星期五, 2022年 12 月 02日 上午 12:27:24
主题: Re: [VOTE] FLIP-273: Improve Catalog API to Support ALTER TABLE syntax
+1 (non-binding).
Looking forward to it!
On Thu, Dec 1, 2022 at 5:06 AM Dong Lin wrote:
+1 (non-binding)
Best,
Paul Lam
> 2022年12月2日 09:17，yuxia 写道：
>
> +1 (non-binding)
>
> Best regards,
> Yuxia
>
> - 原始邮件 -
> 发件人: "Yaroslav Tkachenko"
> 收件人: "dev"
> 发送时间: 星期五, 2022年 12 月 02日 上午 12:27:24
> 主题: Re: [VOTE] FLIP-273: Improve Catalog API to Support ALTER TABLE syntax
>
>
Shammon created FLINK-30269:
---
Summary: Validate table name for metadata table
Key: FLINK-30269
URL: https://issues.apache.org/jira/browse/FLINK-30269
Project: Flink
Issue Type: Sub-task
C
Yunhong Zheng created FLINK-30270:
-
Summary: FlinkJoinToMultiJoinRule incorrectly combines Left/Right
outer join to MultiJoin
Key: FLINK-30270
URL: https://issues.apache.org/jira/browse/FLINK-30270
Pr
Jingsong Lee created FLINK-30271:
Summary: Introduce Table.copy from dynamic options
Key: FLINK-30271
URL: https://issues.apache.org/jira/browse/FLINK-30271
Project: Flink
Issue Type: Improve
Jingsong Lee created FLINK-30272:
Summary: Introduce a Predicate Visitor
Key: FLINK-30272
URL: https://issues.apache.org/jira/browse/FLINK-30272
Project: Flink
Issue Type: Improvement
32 matches
Mail list logo
