Weihua Hu created FLINK-31832:
-
Summary: Add benchmarks for end to end restarting tasks
Key: FLINK-31832
URL: https://issues.apache.org/jira/browse/FLINK-31832
Project: Flink
Issue Type: Improve
+1 (no-binding)
Best,
Hang
Shammon FY 于2023年4月18日周二 13:33写道：
> +1 (no-binding)
>
> Best,
> Shammon FY
>
> On Tue, Apr 18, 2023 at 12:56 PM Jacky Lau wrote:
>
> > +1 (no-binding)
> >
> > Best,
> > Jacky Lau
> >
> > Jingsong Li 于2023年4月18日周二 11:57写道：
> >
> > > +1
> > >
> > > On Tue, Apr 18, 202
Sergey Nuyanzin created FLINK-31831:
---
Summary:
TaskManagerDisconnectOnShutdownITCase.testTaskManagerProcessFailure is unstable
Key: FLINK-31831
URL: https://issues.apache.org/jira/browse/FLINK-31831
+1 (no-binding)
Best,
Shammon FY
On Tue, Apr 18, 2023 at 12:56 PM Jacky Lau wrote:
> +1 (no-binding)
>
> Best,
> Jacky Lau
>
> Jingsong Li 于2023年4月18日周二 11:57写道：
>
> > +1
> >
> > On Tue, Apr 18, 2023 at 9:39 AM Aitozi wrote:
> > >
> > > +1
> > >
> > > Best,
> > > Aitozi
> > >
> > > ron 于2023
Are there any next steps here?
On Mon, Apr 3, 2023, 12:46 PM Galen Warren wrote:
> Thanks for bringing this up.
>
> I'm currently using Statefun, and I've made a few small code contributions
> over time. All of my PRs have been merged into master and most have been
> released, but a few haven't
+1 (no-binding)
Best,
Jacky Lau
Jingsong Li 于2023年4月18日周二 11:57写道：
> +1
>
> On Tue, Apr 18, 2023 at 9:39 AM Aitozi wrote:
> >
> > +1
> >
> > Best,
> > Aitozi
> >
> > ron 于2023年4月18日周二 09:18写道：
> > >
> > > +1
> > >
> > >
> > > > -原始邮件-
> > > > 发件人: "Lincoln Lee"
> > > > 发送时间: 2023-04-
+1
On Tue, Apr 18, 2023 at 9:39 AM Aitozi wrote:
>
> +1
>
> Best,
> Aitozi
>
> ron 于2023年4月18日周二 09:18写道：
> >
> > +1
> >
> >
> > > -原始邮件-
> > > 发件人: "Lincoln Lee"
> > > 发送时间: 2023-04-18 09:08:08 (星期二)
> > > 收件人: dev@flink.apache.org
> > > 抄送:
> > > 主题: Re: [VOTE] FLIP-302: Support TRUNC
lincoln lee created FLINK-31830:
---
Summary: Coalesce on nested fields with different nullabilities
will get wrong plan
Key: FLINK-31830
URL: https://issues.apache.org/jira/browse/FLINK-31830
Project: Fli
It makes sense to support operator parallelism.
But just FYI, for sink, you can use sink.parallelism[1] to set sink
parallelism.
[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/filesystem/#sink-parallelism
Best regards,
Yuxia
- 原始邮件 -
发件人: "ron9 liu"
+1
Best,
Aitozi
ron 于2023年4月18日周二 09:18写道：
>
> +1
>
>
> > -原始邮件-
> > 发件人: "Lincoln Lee"
> > 发送时间: 2023-04-18 09:08:08 (星期二)
> > 收件人: dev@flink.apache.org
> > 抄送:
> > 主题: Re: [VOTE] FLIP-302: Support TRUNCATE TABLE statement in batch mode
> >
> > +1 (binding)
> >
> > Best,
> > Lincoln Le
Hi, Green
Thanks for driving this discussion, in batch mode we have the Adaptive
Batch Scheduler which automatically derives operator parallelism based on
data volume at runtime, so we don't need to care about the parallelism.
However, in stream mode, currently, Flink SQL can only set the parallel
lincoln lee created FLINK-31829:
---
Summary: Conversion to relational algebra failed to preserve
datatypes' nullabilities
Key: FLINK-31829
URL: https://issues.apache.org/jira/browse/FLINK-31829
Project:
Hi, all.
I started a vote for this FLIP[1], please vote there[2] or ask additional
questions here[3].
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-302%3A+Support+TRUNCATE+TABLE+statement+in+batch+mode
[2] https://lists.apache.org/thread/fosvz0zcyfn6bp6vz2oxl45vq9qhkn2v
[3] https://l
+1
> -原始邮件-
> 发件人: "Lincoln Lee"
> 发送时间: 2023-04-18 09:08:08 (星期二)
> 收件人: dev@flink.apache.org
> 抄送:
> 主题: Re: [VOTE] FLIP-302: Support TRUNCATE TABLE statement in batch mode
>
> +1 (binding)
>
> Best,
> Lincoln Lee
>
>
> yuxia 于2023年4月17日周一 23:54写道：
>
> > Hi all.
> >
> > Thanks f
+1 (binding)
Best,
Lincoln Lee
yuxia 于2023年4月17日周一 23:54写道：
> Hi all.
>
> Thanks for all the feedback on FLIP-302: Support TRUNCATE TABLE statement
> in batch mode [1].
> Based on the discussion [2], we have come to a consensus, so I would like
> to start a vote.
>
> The vote will last for at
Vladimir Matveev created FLINK-31828:
Summary: List field in a POJO data stream results in table program
compilation failure
Key: FLINK-31828
URL: https://issues.apache.org/jira/browse/FLINK-31828
Hi,
Sorry for chiming in late.
I'm not so sure that exposing ExecutionConfig / ReadExecutionConfig
directly through Sink#InitContext is the right thing to do.
1. A lot of the read-only getter methods on ExecutionConfig are irrelevant
for sinks. Expanding the scope of the InitContext interface wi
Hello! +1 (non-binding)
I've validated the source for the RC1:
flink-connector-rabbitmq-3.0.1-src.tgz
* The sha512 checksum is OK.
* The source file is signed correctly.
* The signature A5F3BCE4CBE993573EC5966A65321B8382B219AF is found in the
KEYS file, and on https://keys.openpgp.org
* The sourc
HI, welcome. Here is my invitation link.
https://join.slack.com/t/apache-flink/shared_invite/zt-1tbdyh3aa-8pWXQDw2PXKreTCk6sV9Tg
Best regards,
Yuxia
- 原始邮件 -
发件人: "Madhur Pyasi"
收件人: "dev"
发送时间: 星期日, 2023年 4 月 16日 上午 5:03:07
主题: Need Help with Slack Invite Link
Hello Flink Community,
I
Hi Madhur,
Could you try this invitation link:
https://join.slack.com/t/apache-flink/shared_invite/zt-1ta0su2np-lCCV6xD7XeKjwQuHMOTBIA
I'll also prepare a PR to update the Flink's doc. BTW, the invitation link
would expire in 30 days, which means we have to manually update the doc[1] each
mon
Hi all.
Thanks for all the feedback on FLIP-302: Support TRUNCATE TABLE statement in
batch mode [1].
Based on the discussion [2], we have come to a consensus, so I would like
to start a vote.
The vote will last for at least 72 hours unless there is an objection or
insufficient votes.
[1]:
Zhanghao Chen created FLINK-31827:
-
Summary: Incorrect estimation of the target data rate of a vertex
when only a subset of its upstream vertex's output is consumed
Key: FLINK-31827
URL: https://issues.apache.org/
Zhanghao Chen created FLINK-31826:
-
Summary: Incorrect estimation of the target data rate of a vertex
when only a subset of its upstream vertex's output is consumed
Key: FLINK-31826
URL: https://issues.apache.org/
We can let the `InitContext` return `ExecutionConfig` in the interface.
However, a `ReadableExecutionConfig` implementation should be returned
so that exceptions will be thrown if users tries to modify the
`ExecutionConfig`.
We can rework all the setters of `ExecutionConfig` to internally invoke a
Hi, Madhur,
I create a new invite link
https://join.slack.com/t/apache-flink/shared_invite/zt-1t4khgllz-Fm1CnXzdBbUchBz4HzJCAg
. Hope it is useful.
Best,
Hang
Madhur Pyasi 于2023年4月16日周日 05:03写道：
> Hello Flink Community,
> I am trying to use the slack invite to join the Flink workspace but the
Thanks Dong for driving this release.
+1 (binding)
- verify signatures and checksums
- pip install apache-flink-ml source package and run simple example
- download source code and build from source code
- review release notes
Best,
Xingbo
Guowei Ma 于2023年4月14日周五 15:54写道：
> Hi Dong,
>
> Thanks
Sergey Nuyanzin created FLINK-31825:
---
Summary: Stopping minikube fails with timeout
Key: FLINK-31825
URL: https://issues.apache.org/jira/browse/FLINK-31825
Project: Flink
Issue Type: Bug
leishuiyu created FLINK-31824:
-
Summary: flink sql TO_TIMESTAMP error
Key: FLINK-31824
URL: https://issues.apache.org/jira/browse/FLINK-31824
Project: Flink
Issue Type: Bug
Components:
Sergey Nuyanzin created FLINK-31823:
---
Summary:
RestHandlerConfigurationTest.testWebRescaleFeatureFlagWithReactiveMode is
unstable
Key: FLINK-31823
URL: https://issues.apache.org/jira/browse/FLINK-31823
Hi Alexey,
I would argue that it's not a problem from Flink's source code, the problem
was that Scala introduced a binary incompatible change in Scala 2.12.8. If
Flink wanted to allow an upgrade, it would mean breaking snapshot
compatibility. That's why Flink is still bound to be used with Scala
2
Feng Jin created FLINK-31822:
Summary: Support configure maxRows when fetch result
Key: FLINK-31822
URL: https://issues.apache.org/jira/browse/FLINK-31822
Project: Flink
Issue Type: Improvement
hanqing created FLINK-31821:
---
Summary: FlinkSQL set parallelism for each operator.
Key: FLINK-31821
URL: https://issues.apache.org/jira/browse/FLINK-31821
Project: Flink
Issue Type: New Feature
xingyuan cheng created FLINK-31820:
--
Summary: Support data source sub-database and sub-table
Key: FLINK-31820
URL: https://issues.apache.org/jira/browse/FLINK-31820
Project: Flink
Issue Type
Hi Zhu,
Thanks for you time for reviewing this.
Extending ´ExecutionConfig´ will allow to modify the values in the config (this
is what we want to prevent with Option2)
To extend the ExecutionConfig is not simpler to do Option1 (expose
ExecutionConfig directly).
Regards
On 2023/04/03 09:42
Yuan Kui created FLINK-31819:
Summary: Add document for using watermark advanced functions in sql
Key: FLINK-31819
URL: https://issues.apache.org/jira/browse/FLINK-31819
Project: Flink
Issue Type
> they require additional hop to serialize Scala objects
This doesn't necessarily mean that we need a Scala API, because a beefed
up type extraction could also solve this.
> This single committer is now with us and ready to maintain it in open
source. The best situation to be :-)
Have you c
Hi Madhur,
Thanks for reaching out. The Slack invite link has been refreshed, you
should be able to join now via https://flink.apache.org/community/
Best regards,
Martijn
On Sat, Apr 15, 2023 at 11:03 PM Madhur Pyasi wrote:
> Hello Flink Community,
> I am trying to use the slack invite to joi
Hi Alexey,
> Taking into account my Scala experience for the last 8 years, I predict
these wrappers will eventually be abandoned, unless such a Scala library is
a part of some bigger community like ASF.
For the past couple of years, there have been no maintainers for Scala in
the Flink community.
Hello everyone,
I want to start the vote for FLIP-304: Pluggable Failure Enrichers [1] --
discussed as part of [2].
FLIP-304 introduces a pluggable interface allowing users to add custom
logic and enrich failures with custom metadata labels.
The vote will last for at least 72 hours (Thursday, 2
39 matches
Mail list logo
