Re: Stateful Functions with Flink 1.15 and onwards

One question -- Flink 1.16 was just released a few days ago. > Should I support 1.15, or just go straight to 1.16? > > On Mon, Oct 31, 2022 at 8:49 AM Till Rohrmann > wrote: > >> Hi folks, >> >> if you can open a PR for supporting Flink 1.15 Galen, then this wo

Re: Stateful Functions with Flink 1.15 and onwards

Hi folks, if you can open a PR for supporting Flink 1.15 Galen, then this would be awesome. I've assigned you to this ticket. The next thing after merging this PR would be creating a new StateFun release. Once we have merged the PR, let's check who can help with it the fastest. Cheers, Till On

Re: [DISCUSS] DockerHub repository maintainers

Hi everyone, thanks for starting this discussion Xintong. I would volunteer as a maintainer of the flink-statefun Docker repository if you need one. Cheers, Till On Fri, May 6, 2022 at 6:22 AM Xintong Song wrote: > It seems to me we at least don't have a consensus on dropping the use of >

Change of focus

Hi everyone, I wanted to let you know that I will be less active in the community because I’ve decided to start a new chapter in my life. Hence, please don’t wonder if I might no longer be very responsive on mails and JIRA issues. It is great being part of such a great community with so many

Re: [ANNOUNCE] Flink 1.15 Feature Freeze

; > [1] https://github.com/apache/flink/pull/18058 > > On Fri, Feb 18, 2022 at 12:37 PM Till Rohrmann > wrote: > > > > Thanks for letting us know Wenlong. Since the SQL client testing hasn't > > really started yet, I think it is ok to merge this PR. > > >

Re: question about StatefunContext in golang Statefun SDK

t;>>>> would help me, at least, understand the role of the statefun context. > >>>>> > >>>>> I'm curious what you would think about an approach that kept > >>>>>> everything as-is, by default, but allowed for a separated context > and > >>>

Re: question about StatefunContext in golang Statefun SDK

ods, e.g. StatefulFunctionV2, > >> > StatefufFunctionSpecV2, StatefulFunctions.WithSpecV2, etc. Or it could > >> be > >> > done in an almost backward-compatible way, by changing the existing > >> > StatefulFunction, StatefulFunctionSpec, StatefulFu

[jira] [Created] (FLINK-26274) Test local recovery works across TaskManager process restarts

Till Rohrmann created FLINK-26274: - Summary: Test local recovery works across TaskManager process restarts Key: FLINK-26274 URL: https://issues.apache.org/jira/browse/FLINK-26274 Project: Flink

Re: question about StatefunContext in golang Statefun SDK

sCtx.Context = context.WithValue(sCtx.Context, "logger", aLogger) > >>> > } > >>> > // ... > >>> > } > >>> > ``` > >>> > > >>> > Let me know what you all think, > >>> > Austin &g

[jira] [Created] (FLINK-26271) TaskTest.testCancelTaskExceptionAfterTaskMarkedFailed

Till Rohrmann created FLINK-26271: - Summary: TaskTest.testCancelTaskExceptionAfterTaskMarkedFailed Key: FLINK-26271 URL: https://issues.apache.org/jira/browse/FLINK-26271 Project: Flink

Re: question about StatefunContext in golang Statefun SDK

access those values. Those > downstream Go functions would be called during one invocation of the > stateful function. > > On Fri, Feb 18, 2022 at 6:48 AM Till Rohrmann > wrote: > > > Hi Galen, > > > > Am I understanding it correctly, that you would like to set some va

Re: [ANNOUNCE] Apache Flink 1.13.6 released

Thanks Konstantin for being our release manager and also thanks a lot to everyone who contributed to the release! Cheers, Till On Fri, Feb 18, 2022 at 2:54 PM Johannes Moser wrote: > Thanks. Great job. > > > On 18.02.2022, at 14:36, Martijn Visser wrote: > > > > Hi Konstantin, > > > > Thanks

Re: question about StatefunContext in golang Statefun SDK

Hi Galen, Am I understanding it correctly, that you would like to set some values in the Context of function A that is then accessible in a downstream call of function B? Or would you like to set a value that is accessible once function A is called again (w/ or w/o the same id)? Cheers, Till On

Re: [ANNOUNCE] Flink 1.15 Feature Freeze

IP-190, which was approved yesterday, but not merged before > code freeze because of CI queueing and failed by other changes. > WDYT? > > Best, > Wenlong > > On Thu, 17 Feb 2022 at 02:08, Till Rohrmann wrote: > > > Hi everyone, > > > > The deadline fo

Re: [DISCUSS] Disable "Automated Checks / Review Progress" GitHub integration

+1 to remove it. Cheers, Till On Thu, Feb 17, 2022 at 1:42 PM Martijn Visser wrote: > +1 to remove it > > On Thu, 17 Feb 2022 at 13:34, Chesnay Schepler wrote: > > > +1 to remove it. > > > > On 17/02/2022 13:31, Konstantin Knauf wrote: > > > +1 > > > > > > On Thu, Feb 17, 2022 at 1:11 PM

[jira] [Created] (FLINK-26197) Allow playground egress to keep connection open and push messages

Till Rohrmann created FLINK-26197: - Summary: Allow playground egress to keep connection open and push messages Key: FLINK-26197 URL: https://issues.apache.org/jira/browse/FLINK-26197 Project: Flink

[ANNOUNCE] Flink 1.15 Feature Freeze

Hi everyone, The deadline for merging new features for Flink 1.15 has passed. * From now on, only bug-fixes and documentation fixes / improvements are allowed to be merged into the master branch. * New features merged after this point can be reverted. If you need an exception to this rule,

Re: [ANNOUNCE] New Apache Flink Committers: Feng Wang, Zhipeng Zhang

Congratulations Feng and Zhipeng :-) Cheers, Till On Wed, Feb 16, 2022 at 2:51 PM Martijn Visser wrote: > Congratulations Feng and Zhipeng! > > Best regards, > > Martijn > https://twitter.com/MartijnVisser82 > > > On Wed, 16 Feb 2022 at 14:32, Robert Metzger wrote: > > > Hi everyone, > > > >

Re: [ANNOUNCE] New Flink PMC members: Igal Shilman, Konstantin Knauf and Yun Gao

Congratulations! Well deserved! Cheers, Till On Wed, Feb 16, 2022 at 2:51 PM Martijn Visser wrote: > Congratulations to all of you! > > Best regards, > > Martijn Visser > https://twitter.com/MartijnVisser82 > > > On Wed, 16 Feb 2022 at 14:29, Fabian Paul wrote: > > > Congrats to all three of

[jira] [Created] (FLINK-26158) Update statefun-playground examples to use playground ingress/egress

Till Rohrmann created FLINK-26158: - Summary: Update statefun-playground examples to use playground ingress/egress Key: FLINK-26158 URL: https://issues.apache.org/jira/browse/FLINK-26158 Project

[jira] [Created] (FLINK-26155) Add playground ingress/egress for cURL interaction

Till Rohrmann created FLINK-26155: - Summary: Add playground ingress/egress for cURL interaction Key: FLINK-26155 URL: https://issues.apache.org/jira/browse/FLINK-26155 Project: Flink Issue

[jira] [Created] (FLINK-26153) Add script to update README playground links for Statefun

Till Rohrmann created FLINK-26153: - Summary: Add script to update README playground links for Statefun Key: FLINK-26153 URL: https://issues.apache.org/jira/browse/FLINK-26153 Project: Flink

[jira] [Created] (FLINK-26098) TableAPI does not forward idleness configuration from DataStream

Till Rohrmann created FLINK-26098: - Summary: TableAPI does not forward idleness configuration from DataStream Key: FLINK-26098 URL: https://issues.apache.org/jira/browse/FLINK-26098 Project: Flink

Re: [DISCUSS] Release Flink 1.14.4

+1 for a 1.14.4 release. The release-1.14 branch already includes 36 fixed issues, some of them quite severe. Cheers, Till On Fri, Feb 11, 2022 at 1:23 PM Martijn Visser wrote: > Hi Konstantin, > > Thanks for opening the discussion. I think FLINK-25732 does indeed warrant > a speedy Flink

Re: Statefun async http request via RequestReplyFunctionBuilder

Hi Galen, Great to hear it :-) I've assigned you to the ticket [1]. Next you can open a PR against the repository and we will review it. [1] https://issues.apache.org/jira/browse/FLINK-25933 Cheers, Till On Tue, Feb 8, 2022 at 11:58 PM Galen Warren wrote: > I'm ready to pick this one up, I

[jira] [Created] (FLINK-26014) Document how to use the working directory for faster local recoveries

Till Rohrmann created FLINK-26014: - Summary: Document how to use the working directory for faster local recoveries Key: FLINK-26014 URL: https://issues.apache.org/jira/browse/FLINK-26014 Project

[jira] [Created] (FLINK-26005) TableEnvironment.createTemporarySystemFunction cause NPE when using leftOuterLateralJoin

Till Rohrmann created FLINK-26005: - Summary: TableEnvironment.createTemporarySystemFunction cause NPE when using leftOuterLateralJoin Key: FLINK-26005 URL: https://issues.apache.org/jira/browse/FLINK-26005

[jira] [Created] (FLINK-26003) Use Jackson serialization for persisting TaskExecutor state to working directory

Till Rohrmann created FLINK-26003: - Summary: Use Jackson serialization for persisting TaskExecutor state to working directory Key: FLINK-26003 URL: https://issues.apache.org/jira/browse/FLINK-26003

Re: [DISCUSS] Checkpointing (partially) failing jobs

aling cannot happen until PR1 and PR2 are aligned with CPs. > > Best > -Yuan > > > > > > > > On Mon, Feb 7, 2022 at 4:17 PM Till Rohrmann wrote: > > > Hi everyone, > > > > Yuan and Gen could you elaborate why rescaling is a problem if

Re: [DISCUSS] Checkpointing (partially) failing jobs

Hi everyone, Yuan and Gen could you elaborate why rescaling is a problem if we say that separate pipelined regions can take checkpoints independently? Conceptually, I somehow think that a pipelined region that is failed and cannot create a new checkpoint is more or less the same as a pipelined

Re: [DISCUSS] FLIP-211: Kerberos delegation token framework

ter and > > that > > > Flink processes can talk to to obtain the tokens. > > > > > > Ok, so we declare that users who try to use delegation tokens in Flink > is > > > dead end code and not supported, right? Then this must be explicitely > >

Re: [DISCUSS] FLIP-211: Kerberos delegation token framework

es. > >> > This is a relatively huge attack surface. Now the main intention is: > >> > * Instead of propagating keytab file to all nodes propagate a TGS > which > >> has > >> > limited lifetime (more secure) > >> > * Do the TGS generation in

Re: [DISCUSS] Move Flink website to privacy friendly Analytics solution

INK-25863 > > On Fri, 14 Jan 2022 at 18:55, David Morávek > wrote: > > > +1, thanks for driving this Martijn > > > > On Fri 14. 1. 2022 at 15:01, Chesnay Schepler > wrote: > > > > > +1 > > > > > > On 14/01/2022 14:47, Till Rohrm

Re: [DISCUSS] FLIP-211: Kerberos delegation token framework

se at all) > * We send tokens right after container creation with > "updateDelegationTokens" > Not sure which one is more realistic to do since I'm not involved the new > feature. > WDYT? > > > On Thu, Feb 3, 2022 at 3:09 PM Till Rohrmann wrote: > >> Hi everyone, >> >&g

Re: [DISCUSS] FLIP-211: Kerberos delegation token framework

Hi everyone, Sorry for joining this discussion late. I also did not read all responses in this thread so my question might already be answered: Why does Flink need to be involved in the propagation of the tokens? Why do we need explicit RPC calls in the Flink domain? Isn't this something the

[jira] [Created] (FLINK-25941) KafkaSinkITCase.testAbortTransactionsAfterScaleInBeforeFirstCheckpoint fails on AZP

Till Rohrmann created FLINK-25941: - Summary: KafkaSinkITCase.testAbortTransactionsAfterScaleInBeforeFirstCheckpoint fails on AZP Key: FLINK-25941 URL: https://issues.apache.org/jira/browse/FLINK-25941

[jira] [Created] (FLINK-25940) pyflink/datastream/tests/test_data_stream.py::StreamingModeDataStreamTests::test_keyed_process_function_with_state failed on AZP

Till Rohrmann created FLINK-25940: - Summary: pyflink/datastream/tests/test_data_stream.py::StreamingModeDataStreamTests::test_keyed_process_function_with_state failed on AZP Key: FLINK-25940 URL: https

[jira] [Created] (FLINK-25939) PyFlink YARN per-job on Docker test fails on AZP because it could not acquire all required slots

Till Rohrmann created FLINK-25939: - Summary: PyFlink YARN per-job on Docker test fails on AZP because it could not acquire all required slots Key: FLINK-25939 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-25938) SynchronousCheckpointITCase.taskDispatcherThreadPoolAllowsForSynchronousCheckpoints fails on AZP

Till Rohrmann created FLINK-25938: - Summary: SynchronousCheckpointITCase.taskDispatcherThreadPoolAllowsForSynchronousCheckpoints fails on AZP Key: FLINK-25938 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-25937) SQL Client end-to-end test e2e fails on AZP

Till Rohrmann created FLINK-25937: - Summary: SQL Client end-to-end test e2e fails on AZP Key: FLINK-25937 URL: https://issues.apache.org/jira/browse/FLINK-25937 Project: Flink Issue Type

Re: Off for a week starting Friday

Thanks for letting us know Etienne. Have a nice time off :-) Cheers, Till On Wed, Feb 2, 2022 at 3:56 PM Etienne Chauchot wrote: > Hi all, > > I'll be off for a week starting Friday afternoon so I might be > unresponsive on ongoing PRs/tickets. > > Best > > Etienne. > >

[jira] [Created] (FLINK-25925) JobMasterTest.testJobMasterAcceptsExcessSlotsWhenJobIsRestarting

Till Rohrmann created FLINK-25925: - Summary: JobMasterTest.testJobMasterAcceptsExcessSlotsWhenJobIsRestarting Key: FLINK-25925 URL: https://issues.apache.org/jira/browse/FLINK-25925 Project: Flink

[jira] [Created] (FLINK-25922) KinesisFirehoseSinkITCase hangs on AZP

Till Rohrmann created FLINK-25922: - Summary: KinesisFirehoseSinkITCase hangs on AZP Key: FLINK-25922 URL: https://issues.apache.org/jira/browse/FLINK-25922 Project: Flink Issue Type: Bug

[ANNOUNCE] Apache Flink Stateful Functions 3.2.0 released

The Apache Flink community is very happy to announce the release of Apache Flink Stateful Functions 3.2.0. Stateful Functions is an API that simplifies building distributed stateful applications. It's based on functions with persistent state that can interact dynamically with strong consistency

[jira] [Created] (FLINK-25899) Add Java connected components example to flink-statefun-playground

Till Rohrmann created FLINK-25899: - Summary: Add Java connected components example to flink-statefun-playground Key: FLINK-25899 URL: https://issues.apache.org/jira/browse/FLINK-25899 Project: Flink

[jira] [Created] (FLINK-25898) Add README.md to flink-statefun/statefun-sdk-js

Till Rohrmann created FLINK-25898: - Summary: Add README.md to flink-statefun/statefun-sdk-js Key: FLINK-25898 URL: https://issues.apache.org/jira/browse/FLINK-25898 Project: Flink Issue Type

[RESULT][VOTE] Apache Flink Stateful Functions 3.2.0, release candidate #1

Hi everyone, I am pleased to announce that we have unanimously approved this release: There are 5 approving votes, 3 of which are binding: - Mingmin Xu (non-binding) - Igal Shilman (binding) - Seth Wiesman (non-binding) - Tzu-Li Tai (binding) - Till Rohrmann (binding) There are no disapproving

Re: [VOTE] Apache Flink Stateful Functions 3.2.0, release candidate #1

Thanks a lot for the votes everyone! We have reached the required number of binding votes :-) I will close the vote now and post the result as a separate email. Cheers, Till On Sat, Jan 29, 2022 at 5:29 PM Till Rohrmann wrote: > +1 (binding) > > - verified checksums and signatures

Re: [Consulting] Should a Flink class loader be a singleton?

Hi Zhiping, I am pulling in Timo who knows the sql client probably best. He might be able to help you. In general, this sounds like a bug to me. Maybe you can provide us with the full stack trace and maybe even the debug logs of the failing run. Cheers, Till On Sun, Jan 30, 2022 at 4:21 AM

[jira] [Created] (FLINK-25893) ResourceManagerServiceImpl's lifecycle can lead to exceptions

Till Rohrmann created FLINK-25893: - Summary: ResourceManagerServiceImpl's lifecycle can lead to exceptions Key: FLINK-25893 URL: https://issues.apache.org/jira/browse/FLINK-25893 Project: Flink

Re: [VOTE] Apache Flink Stateful Functions 3.2.0, release candidate #1

> > > > > > > > On Thu, Jan 27, 2022 at 8:20 PM Mingmin Xu wrote: > > > > > > > +1 (non-binding) > > > > > > > > - verified checksum and signatures > > > > - build from source code > > > > - v

Re: Looking for Maintainers for Flink on YARN

Thanks a lot for volunteering 刘建刚. The easiest is probably to search for issues that have the component "Deployment / YARN" assigned. Cheers, Till On Sat, Jan 29, 2022 at 4:20 AM 刘建刚 wrote: > Hello, I would like to maintain the yarn component. In our company, we are > using yarn to schedule

Re: [VOTE] Deprecate Per-Job Mode in Flink 1.15

+1 (binding) Cheers, Till On Fri, Jan 28, 2022 at 4:57 PM Gabor Somogyi wrote: > +1 (non-binding) > > We're intended to make tests when FLINK-24897 > is fixed. > In case of further issues we're going to create further jiras. > > BR, > G > > >

[jira] [Created] (FLINK-25855) DefaultDeclarativeSlotPool rejects offered slots when the job is restarting

Till Rohrmann created FLINK-25855: - Summary: DefaultDeclarativeSlotPool rejects offered slots when the job is restarting Key: FLINK-25855 URL: https://issues.apache.org/jira/browse/FLINK-25855

[jira] [Created] (FLINK-25849) Differentiate TaskManager sessions

Till Rohrmann created FLINK-25849: - Summary: Differentiate TaskManager sessions Key: FLINK-25849 URL: https://issues.apache.org/jira/browse/FLINK-25849 Project: Flink Issue Type: Sub-task

Re: [ANNOUNCE] flink-shaded 15.0 released

Thanks a lot for driving this release Chesnay! Cheers, Till On Thu, Jan 27, 2022 at 10:33 AM Francesco Guardiani < france...@ververica.com> wrote: > Thanks Chesnay for this! > > FG > > On Mon, Jan 24, 2022 at 11:20 AM David Morávek wrote: > > > That's a great news Chesnay, thanks for driving

[jira] [Created] (FLINK-25831) ExecutionVertex.getLatestPriorAllocation fails if there is an unsuccessful restart attempt

Till Rohrmann created FLINK-25831: - Summary: ExecutionVertex.getLatestPriorAllocation fails if there is an unsuccessful restart attempt Key: FLINK-25831 URL: https://issues.apache.org/jira/browse/FLINK-25831

[jira] [Created] (FLINK-25829) Do not deploy empty statefun-sdk-js jar

Till Rohrmann created FLINK-25829: - Summary: Do not deploy empty statefun-sdk-js jar Key: FLINK-25829 URL: https://issues.apache.org/jira/browse/FLINK-25829 Project: Flink Issue Type

[jira] [Created] (FLINK-25828) build_stateful_functions.sh can fail if target contains source or javadoc jar

Till Rohrmann created FLINK-25828: - Summary: build_stateful_functions.sh can fail if target contains source or javadoc jar Key: FLINK-25828 URL: https://issues.apache.org/jira/browse/FLINK-25828

Re: [VOTE] Apache Flink Stateful Functions 3.2.0, release candidate #1

-go/v3.2.0-rc1. Cheers, Till On Tue, Jan 25, 2022 at 10:49 PM Till Rohrmann wrote: > Hi everyone, > > Please review and vote on the release candidate #1 for the version 3.2.0 > of Apache Flink Stateful Functions, as follows: > > [ ] +1, Approve the release > [ ] -1, Do no

[jira] [Created] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP

Till Rohrmann created FLINK-25819: - Summary: NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP Key: FLINK-25819 URL: https://issues.apache.org/jira/browse/FLINK-25819

[jira] [Created] (FLINK-25817) FLIP-201: Persist local state in working directory

Till Rohrmann created FLINK-25817: - Summary: FLIP-201: Persist local state in working directory Key: FLINK-25817 URL: https://issues.apache.org/jira/browse/FLINK-25817 Project: Flink Issue

[VOTE] Apache Flink Stateful Functions 3.2.0, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 3.2.0 of Apache Flink Stateful Functions, 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

Re: [DISCUSS] Stateful Functions 3.2.0 release?

Quick update: Igal has resolved the last outstanding ticket [1]. [1] https://issues.apache.org/jira/browse/FLINK-25775 Cheers, Till On Tue, Jan 25, 2022 at 9:56 AM Till Rohrmann wrote: > Thanks everyone. I will start creating the artifacts. > > Cheers, > Till > > On Mon, Ja

Re: [DISCUSS] Host StatefulFunction JavaScript SDK on npm

Alright, I hope that we could resolve all mentioned concerns. If not, then please speak up. I will try to set up a npm account for the Flink project. Cheers, Till On Mon, Jan 24, 2022 at 4:40 PM Till Rohrmann wrote: > Reading the description of the ticket again, I think the comment mi

[jira] [Created] (FLINK-25806) Remove legacy high availability services

Till Rohrmann created FLINK-25806: - Summary: Remove legacy high availability services Key: FLINK-25806 URL: https://issues.apache.org/jira/browse/FLINK-25806 Project: Flink Issue Type

Re: [DISCUSS] Stateful Functions 3.2.0 release?

eers, > > Igal. > > > > On Mon, Jan 24, 2022 at 4:13 PM Seth Wiesman > wrote: > > > > > +1 > > > > > > These are already a useful set of features to release to our users. > > > > > > Seth > > > > > > On Mon,

Re: [DISCUSS] Host StatefulFunction JavaScript SDK on npm

tions/requirements for (secondary) distribution > channels listed anywhere (which is actually rather surprising). > > On 24/01/2022 16:19, Till Rohrmann wrote: > > Looking at the linked official release documentation, I think this > comment > > is no longer valid. Moreover, I cannot

Re: [DISCUSS] Host StatefulFunction JavaScript SDK on npm

ion for the comment in the ticket then? > > On 24/01/2022 16:07, Till Rohrmann wrote: > > I am not sure whether this is really a problem. There are other Apache > > projects that publish their artifacts on npm already [1, 2]. > > > > Also on the official rel

Re: [DISCUSS] Host StatefulFunction JavaScript SDK on npm

+1 from me to providing this on the npm registry to make > > it an easy installation for developers. > > > > > > Best > > Ingo > > > > On 24.01.22 15:37, Till Rohrmann wrote: > >> Hi everyone, > >> > >> I would like to sta

[DISCUSS] Stateful Functions 3.2.0 release?

Hi everyone, We would like to kick off a new StateFun release 3.2.0. The new release will include the new JavaScript SDK and some useful major features: * JavaScript SDK [1] * Flink version upgrade to 1.14.3 [2] * Support different remote functions module names [3] * Allow creating custom

[DISCUSS] Host StatefulFunction JavaScript SDK on npm

Hi everyone, I would like to start a discussion about hosting StatefulFunction's JavaScript SDK [1] on npm. With the upcoming Statefun 3.2.0 release, the JavaScript SDK will be officially supported. In order for users to easily use this SDK, it would be very convenient if we make this dependency

Re: [DISCUSS] Releasing Flink 1.13.6

+1 for the 1.13.6 release and thanks for volunteering Konstantin. Cheers, Till On Mon, Jan 24, 2022 at 2:57 PM Konstantin Knauf wrote: > Thanks for starting the discussion and +1 to releasing. > > I am happy to manage the release aka learn how to do this. > > Cheers, > > Konstantin > > On Mon,

[jira] [Created] (FLINK-25775) Document JavaScript SDK

Till Rohrmann created FLINK-25775: - Summary: Document JavaScript SDK Key: FLINK-25775 URL: https://issues.apache.org/jira/browse/FLINK-25775 Project: Flink Issue Type: Improvement

Re: [VOTE] FLIP-203: Incremental savepoints

+1 (binding) Cheers, Till On Mon, Jan 24, 2022 at 9:57 AM Piotr Nowojski wrote: > Hi, > > As there seems to be no further questions about the FLIP-203 [1] I would > propose to start a voting thread for it. > > For me there are still two unanswered questions, whether we want to support > schema

Re: [VOTE] FLIP-211: Kerberos delegation token framework

Hi Junfan, For FLIP votes, the votes of committers and PMC members are binding. All other votes are non-binding. More details for Flink's voting process can be found here [1]. [1] https://cwiki.apache.org/confluence/display/FLINK/Flink+Bylaws#FlinkBylaws-Voting Cheers, Till On Fri, Jan 21,

[jira] [Created] (FLINK-25772) GCS filessystem fails license checker

Till Rohrmann created FLINK-25772: - Summary: GCS filessystem fails license checker Key: FLINK-25772 URL: https://issues.apache.org/jira/browse/FLINK-25772 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables fails on AZP

Till Rohrmann created FLINK-25771: - Summary: CassandraConnectorITCase.testRetrialAndDropTables fails on AZP Key: FLINK-25771 URL: https://issues.apache.org/jira/browse/FLINK-25771 Project: Flink

[jira] [Created] (FLINK-25753) KafkaTableITCase.testStartFromGroupOffsetsLatest fails on AZP

Till Rohrmann created FLINK-25753: - Summary: KafkaTableITCase.testStartFromGroupOffsetsLatest fails on AZP Key: FLINK-25753 URL: https://issues.apache.org/jira/browse/FLINK-25753 Project: Flink

[jira] [Created] (FLINK-25749) YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP

Till Rohrmann created FLINK-25749: - Summary: YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP Key: FLINK-25749 URL: https://issues.apache.org/jira/browse/FLINK-25749 Project: Flink

[jira] [Created] (FLINK-25747) UdfStreamOperatorCheckpointingITCase hangs on AZP

Till Rohrmann created FLINK-25747: - Summary: UdfStreamOperatorCheckpointingITCase hangs on AZP Key: FLINK-25747 URL: https://issues.apache.org/jira/browse/FLINK-25747 Project: Flink Issue

[RESULT][VOTE] FLIP-201: Persist local state in working directory

Hi everyone, I am happy to announce that FLIP-201 [1] has been accepted by this vote [2]. * Etienne Chauchot (non-binding) * Till Rohrmann (binding) * Matthias Pohl (binding) * Chesnay Schepler (binding) * David Moravek (non-binding) * Yang Wang (binding) [1] https://cwiki.apache.org/confluence

Re: [VOTE] FLIP-201: Persist local state in working directory

gt; > >> Cheers, > > > >> Till > > > >> > > > >> On Mon, Jan 10, 2022 at 2:30 PM Etienne Chauchot < > > echauc...@apache.org> > > > >> wrote: > > > >> > > > >>> +1 > > > >>> > >

Re: [ANNOUNCE] Apache Flink 1.14.3 released

Thanks a lot for being our release manager Thomas and Martijn and to everyone who contributed to this release :-) Cheers, Till On Thu, Jan 20, 2022 at 12:23 PM David Morávek wrote: > Congrats! Thanks Thomas & Martijn for driving the release and to everyone > that contributed to it. > > Best, >

[jira] [Created] (FLINK-25709) GlueSchemaRegistryAvroKinesisITCase fails on AZP

Till Rohrmann created FLINK-25709: - Summary: GlueSchemaRegistryAvroKinesisITCase fails on AZP Key: FLINK-25709 URL: https://issues.apache.org/jira/browse/FLINK-25709 Project: Flink Issue

[jira] [Created] (FLINK-25708) Upgrade Flink dependency to 1.14.3

Till Rohrmann created FLINK-25708: - Summary: Upgrade Flink dependency to 1.14.3 Key: FLINK-25708 URL: https://issues.apache.org/jira/browse/FLINK-25708 Project: Flink Issue Type: Improvement

Re: [VOTE] Release flink-shaded 15.0, release candidate #2

+1 (binding) * Checked checksums and signatures * Looked at the diff between this RC and 14.0 and everything looked good Cheers, Till On Wed, Jan 19, 2022 at 2:30 PM Piotr Nowojski wrote: > +1 (binding) > > I checked the diff between 14.0..15.0-rc2, and 15.0-rc1..15.0-rc2, and > didn't find

Re: [VOTE] Creating external connector repositories

+1 Cheers, Till On Wed, Jan 19, 2022 at 4:01 PM Timo Walther wrote: > +1 (binding) > > Regards, > Timo > > On 19.01.22 14:47, Martijn Visser wrote: > > Hi everyone, > > > > I'd like to start a vote on creating external repositories [1]. Since the > > thread is fairly long, I've also previously

Re: [VOTE] Moving connectors from Flink to external connector repositories

+1 (binding) Cheers, Till On Wed, Jan 19, 2022 at 3:58 PM Timo Walther wrote: > +1 (binding) > > I think this will speed up connector evolution and core development > experience. > > Regards, > Timo > > On 19.01.22 14:47, Martijn Visser wrote: > > Hi everyone, > > > > I'd like to start a vote

Re: How to use TableEnvironment in multiple thread environments

atalogs through an external hive meta store? > > BR > - Chang > > > Till Rohrmann 于2022年1月17日周一 17:26写道： > > > Hi Chang, > > > > Yes, I think this would make most sense to do. > > > > Cheers, > > Till > > > > On Mon, Jan 17, 2

[jira] [Created] (FLINK-25698) Elasticsearch7DynamicSinkITCase.testWritingDocuments fails on AZP

Till Rohrmann created FLINK-25698: - Summary: Elasticsearch7DynamicSinkITCase.testWritingDocuments fails on AZP Key: FLINK-25698 URL: https://issues.apache.org/jira/browse/FLINK-25698 Project: Flink

[jira] [Created] (FLINK-25691) ElasticsearchSinkITCase.testElasticsearchSink fails on AZP

Till Rohrmann created FLINK-25691: - Summary: ElasticsearchSinkITCase.testElasticsearchSink fails on AZP Key: FLINK-25691 URL: https://issues.apache.org/jira/browse/FLINK-25691 Project: Flink

Re: How to use TableEnvironment in multiple thread environments

Hi Chang, Yes, I think this would make most sense to do. Cheers, Till On Mon, Jan 17, 2022 at 9:13 AM Chang Chen wrote: > IIUC, TableEnvironment isn't thread-safe, since it contains some internal > states, for example, PlannerContext that has RelOptCluster used to optimize > SQL. > > So do I

[jira] [Created] (FLINK-25675) UnalignedCheckpointCompatibilityITCase.test hangs on AZP

Till Rohrmann created FLINK-25675: - Summary: UnalignedCheckpointCompatibilityITCase.test hangs on AZP Key: FLINK-25675 URL: https://issues.apache.org/jira/browse/FLINK-25675 Project: Flink

[jira] [Created] (FLINK-25674) CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP

Till Rohrmann created FLINK-25674: - Summary: CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink fails on AZP Key: FLINK-25674 URL: https://issues.apache.org/jira/browse/FLINK-25674

[jira] [Created] (FLINK-25673) AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond hangs on AZP

Till Rohrmann created FLINK-25673: - Summary: AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond hangs on AZP Key: FLINK-25673 URL: https://issues.apache.org/jira/browse/FLINK-25673

Re: [DISCUSS] Move Flink website to privacy friendly Analytics solution

Hi Martijn, big +1 for this effort. Thanks a lot for pushing this initiative forward! Cheers, Till On Fri, Jan 14, 2022 at 11:49 AM Konstantin Knauf wrote: > Hi Martijn, > > I think this is a great initiative. Thank you for pursuing this. It allows > us to > > a) generate better insights into

[jira] [Created] (FLINK-25633) CPUResourceTest does not work with German Locale

Till Rohrmann created FLINK-25633: - Summary: CPUResourceTest does not work with German Locale Key: FLINK-25633 URL: https://issues.apache.org/jira/browse/FLINK-25633 Project: Flink Issue

Re: [VOTE] Release 1.14.3, release candidate #1

+1 (binding) - Verified checksums and signatures - Build from source and ran StateMachineExample - Reviewed the flink-web PR - Verified that there were no other dependency changes than testcontainer, japicmp-plugin and log4j. Cheers, Till On Wed, Jan 12, 2022 at 9:58 AM Yun Tang wrote: > +1

Re: [VOTE] FLIP-206: Support PyFlink Runtime Execution in Thread Mode

+1 (binding) Cheers, Till On Wed, Jan 12, 2022 at 11:07 AM Wei Zhong wrote: > +1(binding) > > Best, > Wei > > > 2022年1月12日 下午5:58，Xingbo Huang 写道： > > > > Hi all, > > > > I would like to start the vote for FLIP-206[1], which was discussed and > > reached a consensus in the discussion

  1   2   3   4   5   6   7   8   9   10   >