Tzu-Li (Gordon) Tai created FLINK-16395:
---
Summary: Mention OkHttp in NOTICE file of
statefun-flink-distribution
Key: FLINK-16395
URL: https://issues.apache.org/jira/browse/FLINK-16395
Project
Tzu-Li (Gordon) Tai created FLINK-16312:
---
Summary: Stateful Function's HttpFunction falls into endless loop
resending 0-sized batch requests
Key: FLINK-16312
URL: https://issues.apache.org/jira/browse/FLINK
Tzu-Li (Gordon) Tai created FLINK-16311:
---
Summary: PersistedAppendingBuffer state primitive has incorrect
contracts for view() method
Key: FLINK-16311
URL: https://issues.apache.org/jira/browse/FLINK-16311
Tzu-Li (Gordon) Tai created FLINK-16310:
---
Summary: Javadoc of AppendingState.get() contradicts with behavior
of UserFacingListState
Key: FLINK-16310
URL: https://issues.apache.org/jira/browse/FLINK-16310
Tzu-Li (Gordon) Tai created FLINK-16274:
---
Summary: Add typed builder methods for setting dynamic
configuration on StatefulFunctionsAppContainers
Key: FLINK-16274
URL: https://issues.apache.org/jira/browse
Tzu-Li (Gordon) Tai created FLINK-16272:
---
Summary: Move Stateful Functions end-to-end test framework classes
to common module
Key: FLINK-16272
URL: https://issues.apache.org/jira/browse/FLINK-16272
Tzu-Li (Gordon) Tai created FLINK-16254:
---
Summary: Support -p/--parallelism option for
StatefulFunctionsClusterEntryPoint
Key: FLINK-16254
URL: https://issues.apache.org/jira/browse/FLINK-16254
Tzu-Li (Gordon) Tai created FLINK-16159:
---
Summary: Add simple end-to-end test for Stateful Functions
Key: FLINK-16159
URL: https://issues.apache.org/jira/browse/FLINK-16159
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-16124:
---
Summary: Add a AWS Kinesis Stateful Functions Ingress
Key: FLINK-16124
URL: https://issues.apache.org/jira/browse/FLINK-16124
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-16112:
---
Summary: KafkaDeserializationSchema#isEndOfStream is ill-defined
Key: FLINK-16112
URL: https://issues.apache.org/jira/browse/FLINK-16112
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-15969:
---
Summary: Do not multiplex both PersistedValue and PersistedTable
with a single MapState state handle
Key: FLINK-15969
URL: https://issues.apache.org/jira/browse
Tzu-Li (Gordon) Tai created FLINK-15957:
---
Summary: Document the release process for Stateful Functions in
the community wiki
Key: FLINK-15957
URL: https://issues.apache.org/jira/browse/FLINK-15957
Tzu-Li (Gordon) Tai created FLINK-15945:
---
Summary: Remove MULTIPLEX_FLINK_STATE config from Stateful
Functions
Key: FLINK-15945
URL: https://issues.apache.org/jira/browse/FLINK-15945
Project
Tzu-Li (Gordon) Tai created FLINK-15931:
---
Summary: Add utility scripts / tooling for releasing Stateful
Functions
Key: FLINK-15931
URL: https://issues.apache.org/jira/browse/FLINK-15931
Project
Tzu-Li (Gordon) Tai created FLINK-15930:
---
Summary: Setup Stateful Function's Spotless plugin to check
Javadoc violations to comply with Maven Javadoc plugin
Key: FLINK-15930
URL: https://issues.apache.org
Tzu-Li (Gordon) Tai created FLINK-15910:
---
Summary: Add NOTICE files for Stateful Functions
Key: FLINK-15910
URL: https://issues.apache.org/jira/browse/FLINK-15910
Project: Flink
Issue
Tzu-Li (Gordon) Tai created FLINK-15899:
---
Summary: Stateful Functions root POM should use the ASF parent POM
Key: FLINK-15899
URL: https://issues.apache.org/jira/browse/FLINK-15899
Project
Tzu-Li (Gordon) Tai created FLINK-15898:
---
Summary: Make Stateful Functions release-ready
Key: FLINK-15898
URL: https://issues.apache.org/jira/browse/FLINK-15898
Project: Flink
Issue
Tzu-Li (Gordon) Tai created FLINK-15874:
---
Summary: Setup Travis cron job for Stateful Functions
documentation build
Key: FLINK-15874
URL: https://issues.apache.org/jira/browse/FLINK-15874
Tzu-Li (Gordon) Tai created FLINK-15851:
---
Summary: JDK 8 and 11 CI build pipeline for Stateful Functions
with Azure Pipelines
Key: FLINK-15851
URL: https://issues.apache.org/jira/browse/FLINK-15851
Tzu-Li (Gordon) Tai created FLINK-15850:
---
Summary: Setup CI for Stateful Functions with Azure Pipelines
Key: FLINK-15850
URL: https://issues.apache.org/jira/browse/FLINK-15850
Project: Flink
Tzu-Li (Gordon) Tai created FLINK-15842:
---
Summary: Building Stateful Functions with JDK 11 fails due to
outdated Spotbugs version
Key: FLINK-15842
URL: https://issues.apache.org/jira/browse/FLINK-15842
Tzu-Li (Gordon) Tai created FLINK-15839:
---
Summary: Revisit Stateful Functions KafkaIngressBuilder properties
resolution logic
Key: FLINK-15839
URL: https://issues.apache.org/jira/browse/FLINK-15839
+1 (binding)
Cheers,
Gordon
On Fri, Jan 31, 2020 at 2:16 PM Jingsong Li wrote:
> +1 (non-binding)
>
> Official docker support really looks good to me.
>
> Best,
> Jingsong Lee
>
> On Fri, Jan 31, 2020 at 12:55 AM aihua li wrote:
>
> > +1 (non-binding)
> >
> > > 2020年1月30日 下午7:36，Igal Shilman
Tzu-Li (Gordon) Tai created FLINK-15821:
---
Summary: Allow configuring Kafka partition / topic discovery in
StateFun Kafka ingress
Key: FLINK-15821
URL: https://issues.apache.org/jira/browse/FLINK-15821
Tzu-Li (Gordon) Tai created FLINK-15820:
---
Summary: Allow disabling / enabling auto offset committing to
Kafka in StateFun Kafka ingress
Key: FLINK-15820
URL: https://issues.apache.org/jira/browse/FLINK
Tzu-Li (Gordon) Tai created FLINK-15819:
---
Summary: Add more StateFun Kafka ingress features that are already
available in FlinkKafkaConsumer
Key: FLINK-15819
URL: https://issues.apache.org/jira/browse/FLINK
Tzu-Li (Gordon) Tai created FLINK-15818:
---
Summary: Add Kafka ingress startup position config to YAML support
Key: FLINK-15818
URL: https://issues.apache.org/jira/browse/FLINK-15818
Project
+1 (binding)
- checked signatures and hashes
- built from source (mvn clean package, Scala 2.12)
- ran e2e tests locally
- checked new dependencies for licenses, no new ones were included since
1.9.1
- ran Kafka example with local cluster
- quickstart worked without errors, logs looked good
-
Tzu-Li (Gordon) Tai created FLINK-15770:
---
Summary: Stateful Functions State Processor module artifact id is
not named correctly
Key: FLINK-15770
URL: https://issues.apache.org/jira/browse/FLINK-15770
Tzu-Li (Gordon) Tai created FLINK-15769:
---
Summary: Allow configuring offset startup positions for Stateful
Functions Kafka Ingress
Key: FLINK-15769
URL: https://issues.apache.org/jira/browse/FLINK-15769
Congratulations :)
On Thu, Jan 23, 2020, 5:07 PM Yadong Xie wrote:
> Well deserved!
>
> Yangze Guo 于2020年1月23日周四 下午5:06写道：
>
> > Congratulations!
> >
> > Best,
> > Yangze Guo
> >
> >
> > On Thu, Jan 23, 2020 at 4:59 PM Stephan Ewen wrote:
> > >
> > > Hi all!
> > >
> > > We are announcing that
Tzu-Li (Gordon) Tai created FLINK-15729:
---
Summary: Table planner dependency instructions for executing in
IDE is vague
Key: FLINK-15729
URL: https://issues.apache.org/jira/browse/FLINK-15729
Hi Izual,
Thanks for reporting this! I'm also forwarding this to the user mailing
list, as that is the more suitable place for this question.
I think the usability of the State Processor API in Scala is indeed
something that hasn’t been looked at closely yet.
On Tue, Jan 21, 2020 at 8:12 AM
+1 (binding)
Gordon
On Tue, Oct 22, 2019, 10:58 PM Zhijiang
wrote:
> +1 (non-binding)
>
> Best,
> Zhijiang
>
>
> --
> From:Zhu Zhu
> Send Time:2019 Oct. 22 (Tue.) 16:33
> To:dev
> Subject:Re: [VOTE] Accept Stateful Functions
Tzu-Li (Gordon) Tai created FLINK-13847:
---
Summary: Update release scripts to also update docs/_config.yml
Key: FLINK-13847
URL: https://issues.apache.org/jira/browse/FLINK-13847
Project: Flink
The Apache Flink community is very happy to announce the release of Apache
Flink 1.9.0, which is the latest major release.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data streaming
applications.
The release is
/244/files#diff-0cc840a590f5cab2485934278134c9baR291
On Thu, Aug 22, 2019 at 10:03 AM Chesnay Schepler
wrote:
> Are we also releasing python artifacts for 1.9?
>
> On 21/08/2019 19:23, Tzu-Li (Gordon) Tai wrote:
> > I'm happy to announce that we have unanimously approved
y
> > >>>>> urgent attention.
> > >>>>>
> > >>>>> (2) The Metric Fetcher floods the log with error messages when a
> > >>>>> TaskManager is lost.
> > >>>>> There are many exceptions be
Hi Dyana,
Regarding your question on the Chinese docs:
Since the Chinese counterparts for the Kinesis connector documentation
isn't translated yet (see docs/dev/connectors/kinesis.zh.md), for now you
can simply just sync whatever changes you made to the English doc to the
Chinese one as well.
rom source: OK (8u102)
> > - binary release
> > - no examples appear to be missing
> > - started a cluster; WebUI reachable, example ran successfully
> > - checked README.md file and found nothing unexpected
> >
> > Best Regards,
> > Yu
> >
> >
Vote thread for RC3 has been started:
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/VOTE-Apache-Flink-1-9-0-release-candidate-3-td31988.html
On Mon, Aug 19, 2019 at 6:32 PM Tzu-Li (Gordon) Tai
wrote:
> Thanks for the comments and fast fixes.
>
> @Becket Qin I've quick
Hi all,
Release candidate #3 for Apache Flink 1.9.0 is now ready for your review.
Please review and vote on release candidate #3 for version 1.9.0, as
follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is
I fear a lot of small issues will
> > > rush in
> > > >> and destabilize the candidate again, meaning we have to do another
> > > larger
> > > >> testing effort.
> > > >>
> > > >>
> > > >>
> > > >> On
+1
On Sun, Aug 18, 2019 at 4:30 PM Stephan Ewen wrote:
> +1
>
> On Sun, Aug 18, 2019 at 3:31 PM Till Rohrmann
> wrote:
>
> > +1
> >
> > On Fri, Aug 16, 2019 at 4:54 PM Yu Li wrote:
> >
> > > Hi All,
> > >
> > > Since we have reached a consensus in the discussion thread [1], I'd
> like
> > to
Hi Rishindra,
Thanks for the pull request. I've left a comment on it.
Cheers,
Gordon
On Mon, Aug 19, 2019 at 10:16 AM Till Rohrmann wrote:
> Hi Rishindra,
>
> I've pulled in Gordon who has worked on the Elasticsearch connector. He
> might be able to review the PR.
>
> Cheers,
> Till
>
> On
> > >
> > > > > > >
> > > > > > > On Thu, Aug 15, 2019 at 7:49 PM Jark Wu
> > wrote:
> > > > > > >
> > > > > > > > Hi Bowen,
> > > > > > > >
> > > > > &
+1 to start a VOTE for this FLIP.
Given the properties of this new state backend and that it will exist as a
new module without touching the original heap backend, I don't see a harm
in including this.
Regarding design of the feature, I've already mentioned my comments in the
original discussion
> >
> > > Best,
> > > Kurt
> > >
> > >
> > > On Thu, Aug 15, 2019 at 6:19 PM Kurt Young wrote:
> > >
> > >> Hi Gordon & Timo,
> > >>
> > >> Thanks for the feedback, and I agree with it. I wi
>
> >>>>>>>> I noticed the PubSub example jar is not included in the examples/
> >> dir
> >>>>>> of
> >>>>>>>> flink-dist. I've created
> >>>>>>> https://issues.apache.org/jira/browse/FLINK-137
Tzu-Li (Gordon) Tai created FLINK-13720:
---
Summary: Include asm-commons in flink-shaded-asm
Key: FLINK-13720
URL: https://issues.apache.org/jira/browse/FLINK-13720
Project: Flink
Issue
+1
On Tue, Aug 13, 2019, 12:31 PM Hequn Cheng wrote:
> +1 (non-binding)
>
> Thanks a lot for driving this! Good job. @Becket Qin >
>
> Best, Hequn
>
> On Tue, Aug 13, 2019 at 6:26 PM Stephan Ewen wrote:
>
> > +1
> >
> > On Tue, Aug 13, 2019 at 12:22 PM Maximilian Michels
> > wrote:
> >
> > >
> > > > > Best,
>> > > > > > > > > >
>> > > > > > > > > > Dawid
>> > > > > > > > > >
>> > > > > > > > > > On 11/08/2019 19:31, Gyula Fóra wrote:
>>
Hi all,
Release candidate #2 for Apache Flink 1.9.0 is now ready for your review.
This is the first voting candidate for 1.9.0, following the preview
candidates RC0 and RC1.
Please review and vote on release candidate #2 for version 1.9.0, as
follows:
[ ] +1, Approve the release
[ ] -1, Do not
Hi,
Just as a reminder, I think we should not focus here on discussing whether
or not time-based releases is a suitable release model for us.
That doesn’t seem to be the original intent of this thread, and is
therefore more suited for a separate discussion with the community,
especially taking
chive.1008284.n3.nabble.com/PREVIEW-Apache-Flink-1-9-0-release-candidate-1-td31233.html
>
>
> On Tue, Jul 30, 2019 at 2:36 PM Tzu-Li (Gordon) Tai
> wrote:
>
> > Hi Biao,
> >
> > Thanks for working on FLINK-9900. The ticket is already assigned to you
> > now.
r on in 1.10.x.
> > > - FLINK-12858: Potential distributed deadlock in case of synchronous
> > > savepoint failure [5]
> > >
> > > The above is the critical path for moving forward with an RC1 for
> > official
> > > voting.
> > > A
Hi,
I don't think there were any discussions recently in the community on
accessing Flink working / runtime state using SQL.
However, there were some other discussions for this on persisted state in
savepoints or checkpoints, mainly through the use of the recently merged
State Processor API [1].
rowse/FLINK-13371
> [3] https://issues.apache.org/jira/browse/FLINK-13350
> [4]
>
> http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Support-temporary-tables-in-SQL-API-td30831.html
> [5] https://issues.apache.org/jira/browse/FLINK-12858
>
> On Tue, Jul
Tzu-Li (Gordon) Tai created FLINK-13489:
---
Summary: Heavy deployment end-to-end test fails on Travis with TM
heartbeat timeout
Key: FLINK-13489
URL: https://issues.apache.org/jira/browse/FLINK-13489
Tzu-Li (Gordon) Tai created FLINK-13488:
---
Summary: flink-python fails to build on Travis due to
PackagesNotFoundError
Key: FLINK-13488
URL: https://issues.apache.org/jira/browse/FLINK-13488
Tzu-Li (Gordon) Tai created FLINK-13487:
---
Summary:
TaskExecutorPartitionLifecycleTest.testPartitionReleaseAfterReleaseCall failed
on Travis
Key: FLINK-13487
URL: https://issues.apache.org/jira/browse/FLINK
Tzu-Li (Gordon) Tai created FLINK-13486:
---
Summary:
AsyncDataStreamITCase.testOrderedWaitUsingAnonymousFunction instable on Travis
Key: FLINK-13486
URL: https://issues.apache.org/jira/browse/FLINK-13486
Tzu-Li (Gordon) Tai created FLINK-13484:
---
Summary: ConnectedComponents end-to-end test instable with
NoResourceAvailableException
Key: FLINK-13484
URL: https://issues.apache.org/jira/browse/FLINK-13484
Tzu-Li (Gordon) Tai created FLINK-13483:
---
Summary: PrestoS3FileSystemITCase.testDirectoryListing fails on
Travis
Key: FLINK-13483
URL: https://issues.apache.org/jira/browse/FLINK-13483
Project
-Support-temporary-tables-in-SQL-API-td30831.html
[5] https://issues.apache.org/jira/browse/FLINK-12858
On Tue, Jul 16, 2019 at 5:26 AM Tzu-Li (Gordon) Tai
wrote:
> Update: RC0 for 1.9.0 has been created. Please see [1] for the preview
> source / binary releases and Maven artifacts.
>
-Li (Gordon) Tai
wrote:
> Hi Flink devs,
>
> As previously announced by Kurt [1], the release branch for 1.9.0 has been
> cut [2] and we've now started the testing phase for this release, as well
> as resolving remaining blockers.
>
> I want to quickly provide an overview
Hi Flink devs,
RC0 for Apache Flink 1.9.0 has been created. This has all the artifacts
that we would typically have for a release, except for a source code tag
and a PR for the release announcement.
This preview-only RC is created only to drive the current testing efforts,
and no official vote
Hi Flink devs,
As previously announced by Kurt [1], the release branch for 1.9.0 has been
cut [2] and we've now started the testing phase for this release, as well
as resolving remaining blockers.
I want to quickly provide an overview of our progress here.
Also, over the course of the testing
Done.
Thanks for the reminder and help with the Jenkins deployment setup!
Cheers,
Gordon
On Mon, Jul 15, 2019 at 3:54 PM Chesnay Schepler wrote:
> Please also setup the 1.9 travis cron branch.
>
> On 15/07/2019 09:46, Chesnay Schepler wrote:
> > It is documented in the release guide that a
Hi,
There is already document available for 1.9-SNAPSHOT [1].
The documentation for the official stable release will not be finalized
until 1.9 is actually released. Feature freeze for 1.9.0 is happening this
week, so ideally this should be available near end of July.
Cheers,
Gordon
[1]
Tzu-Li (Gordon) Tai created FLINK-13095:
---
Summary: Provide an easy way to read / bootstrap window state
using the State Processor API
Key: FLINK-13095
URL: https://issues.apache.org/jira/browse/FLINK-13095
Tzu-Li (Gordon) Tai created FLINK-13094:
---
Summary: Provide an easy way to read / bootstrap timers using the
State Processor API
Key: FLINK-13094
URL: https://issues.apache.org/jira/browse/FLINK-13094
Tzu-Li (Gordon) Tai created FLINK-13093:
---
Summary: Provide an easy way to modify max parallelism using the
State Processor API
Key: FLINK-13093
URL: https://issues.apache.org/jira/browse/FLINK-13093
pache.org/news/2019/07/02/release-1.8.1.html
>>>
>>> The full release notes are available in Jira:
>>>
>>> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12345164
>>>
>>> We would like to thank all contributors of the Apache Flink community
>>> who made this release possible!
>>>
>>> Great thanks to @Tzu-Li (Gordon) Tai 's offline
>>> kind help!
>>>
>>> Regards,
>>> Jincheng
>>>
>>
>
+1 (binding)
- checked signatures and hashes
- built from source without skipping tests (without Hadoop, Scala 2.12)
- no new dependencies were added since 1.8.0
- ran the end-to-end tests locally once, and in a loop specifically for
Kafka tests (to cover FLINK-11987)
- announcement PR for
tures that are actively developed.
> >> If
> >>> the completion of those features don't leave enough time for us to
> >>> integrate, then our work can potentially go beyond the proposed date.
> >>>
> >>> Just wanted to point out such a d
+1 to enforcing lazy majority voting for future FLIPs, starting from FLIPs
that are still currently under discussion (by the time we've agreed on the
FLIP voting process).
My two cents concerning "what should and shouldn't be a FLIP":
I can understand Chesnay's argument about how some FLIPs,
lism
> for savepoints? This is a very common scenario.
> But from my understanding, it needs to do a lot of trivial thing to achieve
> it under current API.
>
> Best,
> Jark
>
>
> On Wed, 5 Jun 2019 at 10:52, Tzu-Li (Gordon) Tai
> wrote:
>
> > On Wed, Jun 5, 2019
Hi Chance,
Welcome to the community! I've gave you contributor permissions in JIRA.
Cheers,
Gordon
On Sat, Jun 22, 2019 at 12:36 AM Chance Li wrote:
> Hi Guys,
>I want to contribute to Apache Flink. Would you please give me
> contributor permission? My JIRA ID: Chance Li, email:
Congratulations Jincheng, great to have you on board :)
Cheers,
Gordon
On Tue, Jun 25, 2019, 11:31 AM Terry Wang wrote:
> Congratulations Jincheng!
>
> > 在 2019年6月24日，下午11:08，Robert Metzger 写道：
> >
> > Hi all,
> >
> > On behalf of the Flink PMC, I'm happy to announce that Jincheng Sun is
>
Hi devs,
Per the feature discussions for 1.9.0 [1], I hereby announce the official
feature freeze for Flink 1.9.0 to be on June 28. A release feature branch
for 1.9 will be cut following that date.
We’re roughly one week away from this date, but please keep in mind that we
still shouldn’t rush
going well, i will spend some time to keep track of them.
> > > > >
> > > > > [1]
> > > > >
> > > >
> > >
> >
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-32%3A+Restructure+flink-table+for+futu
le
>
> Aljoscha
>
> > On 17. Jun 2019, at 14:05, Congxian Qiu wrote:
> >
> > +1 from my side.
> > Best,
> > Congxian
> >
> >
> > Tzu-Li (Gordon) Tai 于2019年6月17日周一 上午10:20写道：
> >
> >> Hi Flink devs,
> >>
> >> I w
Hi all,
Just a few observations from the MODERATE emails I receive as a moderator
of the user-zh@ mailing list:
- About at least once every day, there would be someone trying to
incorrectly subscribe to user-zh@ via the user-zh@ address, and not
user-zh-subscribe@. Maybe there is something
Hi Flink devs,
I want to officially start a voting thread to formally adopt FLIP-41 [1].
There are two relevant discussions threads for this feature [2] [3].
The voting time will end on June 19th 17:00 CET.
Cheers,
Gordon
[1]
as. With the above in mind, however, this
> >> becomes “Add support for choosing the snapshot format for
> >> stop-with-savepoint”. It should not be stop-with-checkpoint, because
> >> checkpoints are something that the system manages and not something that
> >> the user shoul
o
> create a new JIRA ticket, assign to yourself, and work on it. As a
> committer, I'll be happy to help move this effort forward, and we can seek
> help from other experts in kinesis connector like @Tzu-Li (Gordon) Tai
> when needed.
>
> The task should include, but not limited
members of the community would be nice here.
Cheers,
Gordon
On Wed, May 29, 2019 at 11:45 AM Tzu-Li (Gordon) Tai
wrote:
> I also should point out something that I forgot to mention in the initial
> post:
> Stefan has helped a lot in understanding the current status of state
> backe
y valuable new additional and we should try and not
> get stuck on trying to design the perfect solution for everything
>
> > On 4. Jun 2019, at 13:24, Tzu-Li (Gordon) Tai
> wrote:
> >
> > +1 to renaming it as State Processing API and adding it under the
> > flink-l
+1 to renaming it as State Processing API and adding it under the
flink-libraries module.
I also think we can start with the development of the feature. From the
feedback so far, it seems like we're in a good spot to add in at least the
initial version of this API, hopefully making it ready for
Hi Richard,
Schema evolution for data types that are used as keys is not allowed
because, potentially, if the schema of the key changes, hash codes of keys
may also change and can break partitioning for internal state managed by
Flink.
There are of course some evolution scenarios that would not
Hi Pengfei!
I've added you to the JIRA with contributor permissions.
Welcome to the Flink community!
Cheers,
Gordon
On Fri, May 31, 2019 at 9:07 PM Pengfei Li wrote:
> Hi Guys,
>
> I want to contribute to Apache Flink. Would you please give me the
> permission as a contributor? Thanks.
>
> My
@Piotr
Yes, we're aiming this for the 1.9 release. This was also mentioned in the
recent 1.9 feature discussion thread [1].
[1]
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Features-for-Apache-Flink-1-9-0-td28701.html
On Fri, May 31, 2019 at 4:34 PM Piotr Nowojski
The name "Savepoint Connector" might indeed be not that good, as it doesn't
point out the fact that with the current design, all kinds of snapshots
(savepoint / full or incremental checkpoints) can be read.
@Paul
That would be a very valid requirement. Querying the list of existing
operator ids
Hi Yu,
+1 to move forward with efforts to add this feature.
As mentioned in the document as well as some offline discussions, from my
side the only comments I have are related to how we snapshot the off-heap
key groups.
I think a recent discussion I posted about savepoint format unification for
I also should point out something that I forgot to mention in the initial
post:
Stefan has helped a lot in understanding the current status of state
backends and also participated a lot in design choices for the FLIP :)
On Wed, May 29, 2019 at 5:02 AM Tzu-Li (Gordon) Tai
wrote:
> Hi Flink d
Hi Flink devs,
Congxian, Kostas, and I have recently been discussing to unify the binary
formats for keyed state in savepoints, which would allow for more
operational flexibility such as swapping state backends across restores.
As part of this FLIP, another main proposal is to start allowing
Hi Jincheng,
Thanks for starting the discussion.
+1 to have a 1.8.1, given there are some critical bugs fixed already
(including regressions such as FLINK-12301).
I've also added https://issues.apache.org/jira/browse/FLINK-11107 as a
potential blocker for 1.8.1.
Will make sure this gets merged
, whether or not the date sounds reasonable given the current status
of the ongoing efforts.
Please let me know what you think!
Cheers,
Gordon
On Mon, May 27, 2019 at 5:40 PM Tzu-Li (Gordon) Tai
wrote:
> @Hequn @Jincheng
>
> Thanks for bringing up FLIP-29 to attention.
> As previous
301 - 400 of 802 matches
Mail list logo
