Yes, I would say the situation is different for minor vs. patch.
Side note: in a version like 1.x.y most people in the Flink community
see x as the major version and y as the minor version. I know that this
is not proper semver and I could be wrong about how people see it. It
doesn't change an
Echo Lee created FLINK-18424:
Summary: How does standalone mode not rely on distributed state
storage
Key: FLINK-18424
URL: https://issues.apache.org/jira/browse/FLINK-18424
Project: Flink
Issue
Given that there are no compatibility guarantees for @PublicEvolving
classes I'm not sure how much value there is in basing this discussion
on their current state.
Here's the thing; if we want connectors to be compatible across
versions, then this should also work for user-defined connectors
Timo Walther created FLINK-18425:
Summary: GenericArrayData cannot convert object arrays to
primitive arrays
Key: FLINK-18425
URL: https://issues.apache.org/jira/browse/FLINK-18425
Project: Flink
Till Rohrmann created FLINK-18426:
-
Summary: Incompatible deprecated key type for registration cluster
options
Key: FLINK-18426
URL: https://issues.apache.org/jira/browse/FLINK-18426
Project: Flink
Zhang Hao created FLINK-18427:
-
Summary: Job failed under java 11
Key: FLINK-18427
URL: https://issues.apache.org/jira/browse/FLINK-18427
Project: Flink
Issue Type: Bug
Components: API
Thanks for testing the RC and the feedback Thomas. The problem with the
taskmanager options is that the old
(taskmanager.initial-registration-pause) and new options
(cluster.registration.initial-timeout) don't have the same type. The old
options have not been used for a long time (since version 1.5
I recently did change the attitude there, see for example the new
WatermarkStrategy and WatermarkGenerator and code around that. [1] [2]
I think this is up to the judgement of folks that add new APIs,
sometimes we don't know very well how things will shake out but I agree
with Chesnay that we
> /I didn't check manually but I would say this probably affects all
connectors and we shouldn't recommend people use them across different
(minor, that is 1.x) versions. For patch versions it should be fine with
our recent discussion of not breaking @PublicEvolving for patch (1.x.y)
releases.
Hi, I want to contribute to Apache Flink.
Would you please give me the permission as a contributor?
My JIRA ID is JJ GUO.
Hi Haishuai,
Welcome to the community! Currently, there are no special permissions
required to contribute to Flink. Just ping a committer if you want to
work on some JIRA ticket and someone will assign the ticket to you.
Here is some information about how to contribute to Flink [1].
[1] https://
Hi everyone,
Please review and vote on the release candidate #3 for the version 1.11.0, as
follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [1],
*
Jiangjie Qin created FLINK-18428:
Summary: StreamExecutionEnvironment#continuousSource() method
should be renamed to source()
Key: FLINK-18428
URL: https://issues.apache.org/jira/browse/FLINK-18428
Pr
Hi Zhijiang and Piotr,
Really sorry but Dawid just found an API issue in the new Source (
FLINK-18428).
If we don't fix this in release-1.11 we will have to deprecate that method
in the next release, and it would become a burden that we have to carry on
in a couple of releases. Therefore personal
Hi Zhijiang & Piotr,
Thanks for preparing RC3 and bringing up the vote.
Does the vote thread title need to be tagged by [VOTE]?
I don’t know if it’s obligatory, just saying it out.
Zhijiang 于2020年6月24日周三 下午7:49写道：
> Hi everyone,
>
> Please review and vote on the release candidate #3 for the ve
Hi Thomas,
Just one quick answer from my side about:
> * notifyCheckpointAborted needed to be implemented
> for org.apache.flink.runtime.state.CheckpointListener - can we have the
> default implementation in the interface so that users aren't forced to
> change their implementations
This is inte
Thanks for the reminder, Benchao. That is my careless of forgetting changing
the tag when copy & paste the previous announce title.
I will re-launch a separate vote email for it.
Best,
Zhijiang
--
From:Benchao Li
Send Time:2020年6月
Hi everyone,
This RC3 vote is re-launched for fixing the tag issue ([ANNOUNCE] -> [VOTE]) in
email title and adjusting the vote period (72 hours -> 48 hours)
based on the latest considerations.
Please review and vote on the release candidate #3 for the version 1.11.0, as
follows:
[ ] +1, Appro
Hi!
About the "notifyCheckpointAborted()":
When I wrote that comment, I was (apparently wrongly) assuming we were
talking about an internal interface here, because the "abort" signal
was originally only intended to cancel the async part of state backend
checkpoints.
I just realized that this is
Hi!
On 24.06.20 00:51, Thomas Weise wrote:
* -import org.apache.flink.table.api.java.StreamTableEnvironment;
+import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
This is very unfortunate yes, please see
https://github.com/apache/flink/pull/12699/files#diff-eaa874e007e88f2
Stephan Ewen created FLINK-18429:
Summary: Add default method for
CheckpointListener.notifyCheckpointAborted(checkpointId)
Key: FLINK-18429
URL: https://issues.apache.org/jira/browse/FLINK-18429
Proje
Hi, kurt, Fabian
After an offline discussion with Jark, We think that the 'PERIOD FOR
SYSTEM_TIME(operation_time)' statement might be needed now. Changelog table is
superset of insert-only table, use PRIMARY KEY and rowtime may work well in
insert-only or upsert source but has some problem in
As a reminder, the CfP for Flink Forward is open until this Sunday, June
28th.
If you've never spoken at a conference before and are thinking about
submitting, out amazing event manager Laura just wrote an article on dev.to
about why virtual conferences are the best way to get started.
[1]
https:
Stephan Ewen created FLINK-18430:
Summary: Upgrade stability to @Public for CheckpointedFunction and
CheckpointListener
Key: FLINK-18430
URL: https://issues.apache.org/jira/browse/FLINK-18430
Project:
Piotr Nowojski created FLINK-18431:
--
Summary: Provide default empty implementation of
notifyCheckpointAborted
Key: FLINK-18431
URL: https://issues.apache.org/jira/browse/FLINK-18431
Project: Flink
Hi devs,
just a heads-up that we enabled the new unaligned checkpoints by default on
all tests to battletest this new feature. We made sure that unaligned
checkpoints are mature enough for that change and waited for 1.11 to be
done. Note that this doesn't affect any setup outside of our azure buil
rinkako created FLINK-18432:
---
Summary: add open and close methods for ElasticsearchSinkFunction
interface
Key: FLINK-18432
URL: https://issues.apache.org/jira/browse/FLINK-18432
Project: Flink
Iss
Aihua Li created FLINK-18433:
Summary: 1.11 has a regression
Key: FLINK-18433
URL: https://issues.apache.org/jira/browse/FLINK-18433
Project: Flink
Issue Type: Bug
Components: API / Cor
28 matches
Mail list logo
