Store.
Looking forward to feedback on that proposal.
Best,
Matthias
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-270%3A+Repeatable+Cleanup+of+Checkpoints
[2]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-194%3A+Introduce+the+JobResultStore
On Wed, Sep 28, 2022 at 4:07 PM Mat
Thanks for bringing that up. FLINK-29638-1.15 and FLINK-29638-1.16 are
definitely pushed accidentally. Sorry for missing that. I will delete
those.
Not sure whether there was some intention behind the *gha* branches because
the effort on that Github Actions is kind of paused right now. But I guess,
Matthias Pohl created FLINK-29755:
-
Summary: PulsarSourceUnorderedE2ECase.testSavepoint failed because
of missing TaskManagers
Key: FLINK-29755
URL: https://issues.apache.org/jira/browse/FLINK-29755
> Additionally, having code that hasn't been touch for a while increases
the risk of it
Sorry about this incomplete confusing sentence. I was about to remove it
when accidentally pushing the shortcut for sending the message out to the
mailing list.
On Tue, Oct 25, 2022 at 10:18 AM Matth
I guess upgrading the minimal version should also mean cleaning up the
codebase, i.e. removing code segments that have been around to allow
support for older versions. The overall goal should be to improve the Flink
codebase in my opinion. Considering what David said in the old thread about
Hadoop
I agree that leaving everything as is would be the best option. I also tend
to lean towards option 4 as a fallback for the reasons already mentioned.
I'm still not a big fan of the Github issues. But that's probably only
because I'm used to the look-and-feel and the workflows of Jira. I see
certain
+1 (non-binding)
* Downloaded artifacts
* Verified checksums/GPG signatures
* Compared checkout with provided sources
* Verified pom file versions
* Went over NOTICE file/pom files changes without finding anything
suspicious
* Build Flink from sources
* Deployed standalone session cluster and ran
Thanks for starting the discussion about Flink 1.17. I would be interested
in helping out around the release as well.
Best,
Matthias
On Thu, Oct 20, 2022 at 12:07 PM Xintong Song wrote:
> Thanks for kicking this off.
>
> +1 for the proposed timeline.
>
> Also +1 for Qingsheng, Leonard and Marti
gt;
> > >
>
> > > Best,
>
> > > Yun Gao
>
> > >
>
> > >
>
> > >
>
> > >
>
> > > [1] https://issues.apache.org/jira/browse/FLINK-27518 <
>
> > https://issues.apache.org/jira/browse/FLI
+1 (binding) after reading through the discussion thread
On Wed, Oct 19, 2022 at 3:29 AM Maximilian Michels wrote:
> +1 (binding)
>
> On Mon, Oct 17, 2022 at 6:41 AM Márton Balassi
> wrote:
>
> > +1 (binding)
> >
> > On Mon, Oct 17, 2022 at 3:39 PM Martijn Visser >
> > wrote:
> >
> > > Hi ever
neration
> > I created a draft PR to underline my proposal [1]. The PR doesn't cover
> all
> > the relevant tests, yet. I'd like to get feedback from anyone who has
> done
> > minor releases in the past (CC'ing Yun Gao since he did this task for
> Flink
> > 1.
till not migrated (since
> they require a bit more work).
>
> I'm looking forward to feedback.
> Best,
> Matthias
>
> [1] https://github.com/apache/flink/pull/20954
>
> On Wed, Oct 5, 2022 at 11:42 AM Matthias Pohl
> wrote:
>
> > Hi everyone,
> > I
ll not migrated (since
they require a bit more work).
I'm looking forward to feedback.
Best,
Matthias
[1] https://github.com/apache/flink/pull/20954
On Wed, Oct 5, 2022 at 11:42 AM Matthias Pohl
wrote:
> Hi everyone,
> I started looking into the migration test data generation after I got
Matthias Pohl created FLINK-29671:
-
Summary: Kubernetes e2e test fails during test initialization
Key: FLINK-29671
URL: https://issues.apache.org/jira/browse/FLINK-29671
Project: Flink
Issue
Hi Jie Han,
welcome to the community. Just a little side note: These kinds of questions
are more suitable to be asked in the user mailing list. The dev mailing
list is rather used for discussing feature development or project-related
topics. See [1] for further details.
About your question: The st
Matthias Pohl created FLINK-29642:
-
Summary: MySqlCatalogITCase.testWithoutCatalogDB
Key: FLINK-29642
URL: https://issues.apache.org/jira/browse/FLINK-29642
Project: Flink
Issue Type: Bug
Matthias Pohl created FLINK-29641:
-
Summary:
SortMergeResultPartitionReadSchedulerTest.testCreateSubpartitionReader
Key: FLINK-29641
URL: https://issues.apache.org/jira/browse/FLINK-29641
Project
Ok, a bit of back-and-forth reading. :-D Thanks for the example. It sounds
reasonable.
+1 (binding)
On Thu, Oct 13, 2022 at 8:33 PM Chesnay Schepler wrote:
> I will write this all down in the wiki once the vote is over, but here
> are some example.
>
>
> Let's start out with a happy-case scenar
+1 Agree, good idea!
On Thu, Oct 13, 2022 at 2:52 PM Jing Ge wrote:
> +1 good idea!
>
> On Thu, Oct 13, 2022 at 2:42 PM Yang Wang wrote:
>
> > +1 for increasing the visibility of flink-kubernetes-operator.
> >
> > Best,
> > Yang
> >
> > Thomas Weise 于2022年10月13日周四 07:49写道：
> >
> > > +1
> > >
>
Matthias Pohl created FLINK-29622:
-
Summary: KerberosDelegationTokenManager fails to load
DelegationTokenProvider due to NoClassDefFoundError in various tests
Key: FLINK-29622
URL: https://issues.apache.org/jira
Matthias Pohl created FLINK-29618:
-
Summary: YARNSessionFIFOSecuredITCase.testDetachedMode timed out
in Azure CI
Key: FLINK-29618
URL: https://issues.apache.org/jira/browse/FLINK-29618
Project: Flink
Matthias Pohl created FLINK-29594:
-
Summary: RMQSourceITCase.testMessageDelivery timed out
Key: FLINK-29594
URL: https://issues.apache.org/jira/browse/FLINK-29594
Project: Flink
Issue Type
Matthias Pohl created FLINK-29576:
-
Summary:
SourceNAryInputChainingITCase.testDirectSourcesOnlyExecution failed
Key: FLINK-29576
URL: https://issues.apache.org/jira/browse/FLINK-29576
Project: Flink
Congratulations, Danny! :-)
On Mon, Oct 10, 2022 at 9:24 AM Samrat Deb wrote:
> congratulations Danny!
>
> On Mon, 10 Oct 2022 at 12:43 PM, Ahmed Hamdy wrote:
>
> > Congratulations Danny!
> > Ahmed
> >
> > On Mon, 10 Oct 2022, 08:12 Teoh, Hong,
> > wrote:
> >
> > > Congratulations Danny!
> >
Matthias Pohl created FLINK-29533:
-
Summary: Add proper table style to Flink website
Key: FLINK-29533
URL: https://issues.apache.org/jira/browse/FLINK-29533
Project: Flink
Issue Type: Bug
Thanks Jiabao.
+1 (binding)
On Fri, Sep 30, 2022 at 11:22 AM Martijn Visser
wrote:
> Thanks Jiabao!
> +1 (binding)
>
> Cheers, Martijn
>
> On Fri, Sep 30, 2022 at 11:04 AM jiabao.sun .invalid>
> wrote:
>
> > Hi everyone,
> >
> >
> > Thanks for all your feedback for FLIP-262[1]: MongoDB Connecto
Hi everyone,
I started looking into the migration test data generation after I got
confused about it in the context of the 1.16.0-rc1 voting process [1]. The
release manager needs to do some manual work around adding test data for
certain tests after the release is finalized (see item 15 in the "Ch
WordCount example in batch
and streaming: Nothing suspicious in log files found
On Fri, Sep 30, 2022 at 3:56 PM Matthias Pohl
wrote:
> Ok, I was wrong. The step is actually documented at the end of the Flink
> release documentation [1] in item 15) in the "Checklist to declare th
apache.org/confluence/display/FLINK/Creating+a+Flink+Release
[2] https://issues.apache.org/jira/browse/FLINK-29485
On Fri, Sep 30, 2022 at 3:50 PM Matthias Pohl
wrote:
> Probably, my expectations were wrong here: I expected that we want to test
> the compatibility in these tests between differen
japicmp reference).
>
> On 30/09/2022 15:32, Matthias Pohl wrote:
> > Looking into the git history, there are numerous locations that need to
> be
> > updated in the release-1.16 branch. Yun Gao did a few commits around that
> > topic (da9e6be..6f69f4e). But these changes we
part of the release steps [1]. It feels like it should be part of the
section where we create the release branch. But cannot find the pointer.
[1]
https://cwiki.apache.org/confluence/display/FLINK/Creating+a+Flink+Release
On Fri, Sep 30, 2022 at 2:47 PM Matthias Pohl
wrote:
> -1 (non-bind
-1 (non-binding)
Hi Xingbo,
I just noticed that we haven't updated the current Flink version in
TypeSerializerUpgradeTest. It is missing in the release-1.16 branch and on
master. That means that the serialization tests are not executed for Flink
1.16. See FLINK-29485 [1].
[1] https://issues.apach
Matthias Pohl created FLINK-29485:
-
Summary: TypeSerializerUpgradeTestBase doesn't use
FlinkVersions.current()
Key: FLINK-29485
URL: https://issues.apache.org/jira/browse/FLINK-29485
Project:
Hi everyone,
I’d like to start a discussion on repeatable cleanup of checkpoint data. In
FLIP-194 [1] we introduced repeatable cleanup of HA data along the
introduction of the JobResultStore component. The goal was to make Flink
being in charge of cleanup for the data it owns. The Flink cluster sh
Matthias Pohl created FLINK-29452:
-
Summary: RetryOnExceptionExtensionTest is implemented in a way
that doesn't allow the successful execution of individual tests
Key: FLINK-29452
URL: https://issues.apach
+1 (non-binding)
* downloaded the artifacts
* compiled from source
* verified checksums
* verified versions included in the release
There has been a new version swagger-core 2.2.3 released [1] (in contrast
to 2.2.2 which we use in the 16.0 release). The only relevant thing I
noticed was the upgra
Matthias Pohl created FLINK-29415:
-
Summary: InitializationFailure when recovering from a checkpoint
in Application Mode leads to the cleanup of all HA data
Key: FLINK-29415
URL: https://issues.apache.org/jira
+1 That sounds like a good idea. Does it make sense to add a validation
step to prevent new configuration parameters from running into the same
issue (with whitelisting the existing ones)?
Matthias
On Thu, Sep 22, 2022 at 6:35 AM Yun Tang wrote:
> +1
>
> This is the prerequisite to help us to i
Matthias Pohl created FLINK-29336:
-
Summary: SubtaskState#discardState swallows exceptions
Key: FLINK-29336
URL: https://issues.apache.org/jira/browse/FLINK-29336
Project: Flink
Issue Type
Matthias Pohl created FLINK-29335:
-
Summary: OperatorSubtaskState swallows exception
Key: FLINK-29335
URL: https://issues.apache.org/jira/browse/FLINK-29335
Project: Flink
Issue Type: Sub
Matthias Pohl created FLINK-29334:
-
Summary: StateHandleStore#releaseAndTryRemoveAll is not used and
can be removed
Key: FLINK-29334
URL: https://issues.apache.org/jira/browse/FLINK-29334
Project
Matthias Pohl created FLINK-29326:
-
Summary: EndOfDataDecoderException observed when uploading a jar
Key: FLINK-29326
URL: https://issues.apache.org/jira/browse/FLINK-29326
Project: Flink
+1 Thanks for proposing that, Chesnay. I guess, it's a good idea to reduce
efforts around documenting by removing duplicated content.
On Fri, Sep 16, 2022 at 11:56 AM Chesnay Schepler
wrote:
> Hello,
>
> The current FLIP overview page [1] is kind of a mess and inconvenient to
> modify. It requir
Yes, thanks for pushing this Xingbo.
+1 (non-binding)
* Signatures look good
* Checked out source code from git repository using the tag and diffed it
with the provided sources
* Build source code
* Reviewed flink-web PR
* Started session cluster and submitted WordCount example in batch and
strea
Matthias Pohl created FLINK-29253:
-
Summary: DefaultJobmanagerRunnerRegistry#localCleanupAsync calls
close instead of closeAsync
Key: FLINK-29253
URL: https://issues.apache.org/jira/browse/FLINK-29253
Congratulations, Caizhi!
On Fri, Sep 9, 2022 at 3:50 PM Yun Tang wrote:
> Congratulations Caizhi, well deserved!
>
> Best
> Yun Tang
>
> From: Martijn Visser
> Sent: Friday, September 9, 2022 17:27
> To: dev@flink.apache.org
> Subject: Re: [ANNOUNCE] New Apache
Congrats, Martijn! Indeed, well deserved :-)
On Fri, Sep 9, 2022 at 5:10 PM tison wrote:
> Congrats! Well deserved.
>
> Best,
> tison.
>
>
> Timo Walther 于2022年9月9日周五 23:08写道：
>
> > Hi everyone,
> >
> > I'm very happy to announce that Martijn Visser has joined the Flink PMC!
> >
> > Martijn has
Matthias Pohl created FLINK-29245:
-
Summary: Remove RetryRule
Key: FLINK-29245
URL: https://issues.apache.org/jira/browse/FLINK-29245
Project: Flink
Issue Type: Bug
Components
Matthias Pohl created FLINK-29223:
-
Summary: Missing debug output for when filtering JobGraphs based
on their persisted JobResult
Key: FLINK-29223
URL: https://issues.apache.org/jira/browse/FLINK-29223
Matthias Pohl created FLINK-29198:
-
Summary: RetryExtension doesn't make the test fail if the retries
are exhausted
Key: FLINK-29198
URL: https://issues.apache.org/jira/browse/FLINK-29198
Pr
Matthias Pohl created FLINK-29173:
-
Summary: Upgrade curator
Key: FLINK-29173
URL: https://issues.apache.org/jira/browse/FLINK-29173
Project: Flink
Issue Type: Improvement
+1 for bringing this into a consistent state. Thanks, Chesnay.
nit: There's a conflict between this FLIP-254 and the FLIP-254 on the redis
streams connector.
On Wed, Aug 31, 2022 at 2:52 PM Chesnay Schepler wrote:
> * backport to 1.14/1.15
>
> On 31/08/2022 14:45, Chesnay Schepler wrote:
> > @Y
Thanks for bringing this up, Chesnay. Can you elaborate a bit more on what
you mean when referring to Alpine as being "not as user-friendly"? Doesn't
it come with the same issue that switching to CentOS comes with that we
have to update our scripts (I'm thinking of apt in particular)? Or what
else
Congratulations & welcome! :-)
Matthias
On Sun, Aug 21, 2022 at 5:42 AM Yuan Mei wrote:
> Congratulations Junhan!
>
> Best,
> Yuan
>
> On Sat, Aug 20, 2022 at 2:11 PM Danny Cranmer
> wrote:
>
> > Congratulations Junhan! Welcome to the team.
> >
> > On Sat, 20 Aug 2022, 03:01 yuxia, wrote:
> >
Congrats & welcome to the team! :-)
Matthias
On Sun, Aug 21, 2022 at 5:41 AM Yuan Mei wrote:
> Congratulations, Lijie!
>
> Best,
> Yuan
>
> On Sat, Aug 20, 2022 at 2:12 PM Danny Cranmer
> wrote:
>
> > Congratulations Lijie! Welcome to the team.
> >
> > On Sat, 20 Aug 2022, 03:25 Yun Tang, wro
I'm gonna revive this one here. I guess, having a dedicated OpenSearch
connector makes sense considering that the ElasticSearch project drifts away...
Thanks for looking into it Andriy.
+1 (binding)
On 2022/07/28 08:18:20 Martijn Visser wrote:
> Hi Andy,
>
> For future threads, it's best to st
Hi Conrad,
thanks for reaching out to the community with your proposal. I looked
through FLIP-257 [1]. Your motivation sounds interesting. Can you elaborate
a bit more on the concrete use-cases you have in mind? How do these match
the user-cases of the two favored execution modes, i.e. Flink's Sess
Matthias Pohl created FLINK-28902:
-
Summary: FileSystemJobResultStoreTestInternal is a unit test
that's not following the unit test naming convents
Key: FLINK-28902
URL: https://issues.apache.org/jira/b
Matthias Pohl created FLINK-28078:
-
Summary:
ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers
runs into timeout
Key: FLINK-28078
URL: https://issues.apache.org/jira/browse
Matthias Pohl created FLINK-28077:
-
Summary: KeyedStateCheckpointingITCase.testWithMemoryBackendSync
runs into timeout
Key: FLINK-28077
URL: https://issues.apache.org/jira/browse/FLINK-28077
Project
Matthias Pohl created FLINK-28076:
-
Summary: CI runs keep getting stuck
Key: FLINK-28076
URL: https://issues.apache.org/jira/browse/FLINK-28076
Project: Flink
Issue Type: Bug
Affects
Matthias Pohl created FLINK-28024:
-
Summary: Azure worker stops operating due to log files becoming
too big
Key: FLINK-28024
URL: https://issues.apache.org/jira/browse/FLINK-28024
Project: Flink
Thanks for driving the Slack channel efforts and setting everything up. :-)
I'm wondering whether we should extend the Slack space to also have a
channel dedicated for CI builds to enable the release managers to monitor
CI builds on master and the release branches through the Apache Flink Slack
wo
ystems - but I will
> retry to get the logs Monday morning, CEST.
>
> Sorry for the delay. I hope this heads up helps.
>
> Best, Peter
>
> Matthias Pohl > schrieb am Fr., 22. Apr. 2022, 17:44:
>
> > An issue was reported on the user ML [1] by Peter (CC) that was
Matthias Pohl created FLINK-27382:
-
Summary: Make Job mode wait with cluster shutdown until the
cleanup is done
Key: FLINK-27382
URL: https://issues.apache.org/jira/browse/FLINK-27382
Project: Flink
Matthias Pohl created FLINK-27383:
-
Summary: Make Application mode wait with cluster shutdown until
cleanup is done
Key: FLINK-27383
URL: https://issues.apache.org/jira/browse/FLINK-27383
Project
An issue was reported on the user ML [1] by Peter (CC) that was observed on
rc4. We couldn't find any blocker based on the description so far. But it
doesn't explain the entire problem the user is describing, though. We're
still waiting for the logs to investigate the cause of the JobMaster not
ter
Matthias Pohl created FLINK-27355:
-
Summary: JobManagerRunnerRegistry.localCleanupAsync does not call
the JobManagerRunner.close method repeatedly
Key: FLINK-27355
URL: https://issues.apache.org/jira/browse/FLINK
Matthias Pohl created FLINK-27354:
-
Summary: JobMaster still processes requests while terminating
Key: FLINK-27354
URL: https://issues.apache.org/jira/browse/FLINK-27354
Project: Flink
Issue
Matthias Pohl created FLINK-27204:
-
Summary: FileSystemJobResultStore should operator on the ioExecutor
Key: FLINK-27204
URL: https://issues.apache.org/jira/browse/FLINK-27204
Project: Flink
Matthias Pohl created FLINK-27165:
-
Summary: Benchmark test
SerializationFrameworkMiniBenchmarks#serializerHeavyString became unstable
Key: FLINK-27165
URL: https://issues.apache.org/jira/browse/FLINK-27165
Matthias Pohl created FLINK-27140:
-
Summary: Move JobResultStore dirty entry creation into ioExecutor
Key: FLINK-27140
URL: https://issues.apache.org/jira/browse/FLINK-27140
Project: Flink
Matthias Pohl created FLINK-27053:
-
Summary: IncrementalRemoteKeyedStateHandle.discardState swallows
errors
Key: FLINK-27053
URL: https://issues.apache.org/jira/browse/FLINK-27053
Project: Flink
Matthias Pohl created FLINK-27052:
-
Summary:
FsCompletedCheckpointStorageLocation.disposeStorageLocation doesn't expose
errors properly (not processing the return value)
Key: FLINK-27052
URL:
Matthias Pohl created FLINK-27051:
-
Summary: CompletedCheckpoint.DiscardObject.discard is not
idempotent
Key: FLINK-27051
URL: https://issues.apache.org/jira/browse/FLINK-27051
Project: Flink
Matthias Pohl created FLINK-27050:
-
Summary: TestingDispatcher.Builder instantiates a RPCSystem
without shutting it down
Key: FLINK-27050
URL: https://issues.apache.org/jira/browse/FLINK-27050
Matthias Pohl created FLINK-27033:
-
Summary: YARNITCase failed due to OOM
Key: FLINK-27033
URL: https://issues.apache.org/jira/browse/FLINK-27033
Project: Flink
Issue Type: Bug
Matthias Pohl created FLINK-27032:
-
Summary: PyFlink end-to-end test failed due to str object not
having expected attribute _j_expr
Key: FLINK-27032
URL: https://issues.apache.org/jira/browse/FLINK-27032
Matthias Pohl created FLINK-27031:
-
Summary: ChangelogRescalingITCase.test failed due to
IllegalStateException
Key: FLINK-27031
URL: https://issues.apache.org/jira/browse/FLINK-27031
Project: Flink
Matthias Pohl created FLINK-27030:
-
Summary: RpcEndpointTest.testCancelScheduledTask failed
Key: FLINK-27030
URL: https://issues.apache.org/jira/browse/FLINK-27030
Project: Flink
Issue Type
Matthias Pohl created FLINK-26990:
-
Summary:
BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByTime
failed
Key: FLINK-26990
URL: https://issues.apache.org/jira/browse/FLINK
Matthias Pohl created FLINK-26987:
-
Summary: ZooKeeperStateHandleStore.getAllAndLock ends up in a
infinite loop if there's an entry marked for deletion that's not cleaned up, yet
Key: FLINK-26987
Matthias Pohl created FLINK-26984:
-
Summary: HistoryServer archiving is not retried
Key: FLINK-26984
URL: https://issues.apache.org/jira/browse/FLINK-26984
Project: Flink
Issue Type
Matthias Pohl created FLINK-26976:
-
Summary: HistoryServer archiving is not idempotent
Key: FLINK-26976
URL: https://issues.apache.org/jira/browse/FLINK-26976
Project: Flink
Issue Type: Bug
Matthias Pohl created FLINK-26957:
-
Summary: FileSystemJobResultStore calls flush on an already closed
OutputStream
Key: FLINK-26957
URL: https://issues.apache.org/jira/browse/FLINK-26957
Project
Matthias Pohl created FLINK-26809:
-
Summary: ChangelogStorageMetricsTest.testAttemptsPerUpload failed
Key: FLINK-26809
URL: https://issues.apache.org/jira/browse/FLINK-26809
Project: Flink
Matthias Pohl created FLINK-26798:
-
Summary: JobMaster.testJobFailureWhenTaskExecutorHeartbeatTimeout
failed due to missing Execution
Key: FLINK-26798
URL: https://issues.apache.org/jira/browse/FLINK-26798
Matthias Pohl created FLINK-26789:
-
Summary:
RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed
Key: FLINK-26789
URL: https://issues.apache.org/jira/browse/FLINK-26789
Project
Matthias Pohl created FLINK-26773:
-
Summary: ResourceManager leader election can a reconnect while
shutting down the JobMaster
Key: FLINK-26773
URL: https://issues.apache.org/jira/browse/FLINK-26773
Matthias Pohl created FLINK-26750:
-
Summary: HA cluster cleanup not complete
Key: FLINK-26750
URL: https://issues.apache.org/jira/browse/FLINK-26750
Project: Flink
Issue Type: Bug
Matthias Pohl created FLINK-26742:
-
Summary: DefaultCompletedCheckpointStore.shutdown does not clean
the checkpoints atomically
Key: FLINK-26742
URL: https://issues.apache.org/jira/browse/FLINK-26742
Matthias Pohl created FLINK-26741:
-
Summary: CheckpointIDCounter.shutdown should expose errors
asynchronously
Key: FLINK-26741
URL: https://issues.apache.org/jira/browse/FLINK-26741
Project: Flink
Matthias Pohl created FLINK-26740:
-
Summary: KubernetesCheckpointIDCounter operates even when not
running
Key: FLINK-26740
URL: https://issues.apache.org/jira/browse/FLINK-26740
Project: Flink
Matthias Pohl created FLINK-26695:
-
Summary: Fabric8FlinkKubeClient.deleteConfigMap doesn't
necessarily fail if the deletion didn't succeed
Key: FLINK-26695
URL: https://issues.apache.org/jira/browse/F
Matthias Pohl created FLINK-26691:
-
Summary: pyflink failed with quite a few connection refused errors
Key: FLINK-26691
URL: https://issues.apache.org/jira/browse/FLINK-26691
Project: Flink
Matthias Pohl created FLINK-26690:
-
Summary: DefaultJobGraphStore.globalCleanup does not trigger the
cleanup when retrying the cleanup after a failover
Key: FLINK-26690
URL: https://issues.apache.org/jira/browse
Matthias Pohl created FLINK-26684:
-
Summary: Build failure in
ChangelogPeriodicMaterializationITCase.testFailedMaterialization due to
NoSuchFileException
Key: FLINK-26684
URL: https://issues.apache.org/jira
Matthias Pohl created FLINK-26673:
-
Summary:
ChangelogPeriodicMaterializationITCase.testNonMaterialization failed on master
Key: FLINK-26673
URL: https://issues.apache.org/jira/browse/FLINK-26673
Matthias Pohl created FLINK-26652:
-
Summary: Failing to cleanup a job should not fail the flink cluster
Key: FLINK-26652
URL: https://issues.apache.org/jira/browse/FLINK-26652
Project: Flink
Matthias Pohl created FLINK-26630:
-
Summary: EmbeddedHaServices is not made for recovery on a single
instance
Key: FLINK-26630
URL: https://issues.apache.org/jira/browse/FLINK-26630
Project: Flink
701 - 800 of 947 matches
Mail list logo
