[
https://issues.apache.org/jira/browse/FLINK-24206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414046#comment-17414046
]
Xintong Song commented on FLINK-24206:
--------------------------------------
[~syhily],
The changes in the PR look good to me. However, shouldn't the PR be opened
against the master branch?
Usually, contributors only need to open PRs against the master branch. If the
commits need to be ported to other branches, the committers can do that while
closing the PR.
Exceptions are:
* If the problem that the PR tries to fix only exist in the release branches,
but not in the master branch, the PR should be opened against only the release
branches.
* If the PR opened against the master branch can not be directly applied to the
release branches, or if we are unsure about the changes and wants to trigger CI
tests on the release branches, the PR should be opened against the release
branches in addition to the master branch.
> PulsarSourceITCase fails with "Consumer not found"
> --------------------------------------------------
>
> Key: FLINK-24206
> URL: https://issues.apache.org/jira/browse/FLINK-24206
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
> Affects Versions: 1.14.0, 1.15.0
> Reporter: Dawid Wysakowicz
> Assignee: Yufan Sheng
> Priority: Major
> Labels: pull-request-available, test-stability
> Fix For: 1.14.0, 1.15
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=23732&view=logs&j=fc5181b0-e452-5c8f-68de-1097947f6483&t=995c650b-6573-581c-9ce6-7ad4cc038461&l=24650
> {code}
> Sep 08 05:08:35 Caused by: org.apache.flink.runtime.JobException: Recovery is
> suppressed by NoRestartBackoffTimeStrategy
> Sep 08 05:08:35 at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:228)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:218)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:209)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:679)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444)
> Sep 08 05:08:35 at sun.reflect.GeneratedMethodAccessor39.invoke(Unknown
> Source)
> Sep 08 05:08:35 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> Sep 08 05:08:35 at java.lang.reflect.Method.invoke(Method.java:498)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
> Sep 08 05:08:35 at
> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
> Sep 08 05:08:35 at
> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
> Sep 08 05:08:35 at
> scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
> Sep 08 05:08:35 at
> scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
> Sep 08 05:08:35 at
> akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
> Sep 08 05:08:35 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
> Sep 08 05:08:35 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
> Sep 08 05:08:35 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
> Sep 08 05:08:35 at akka.actor.Actor.aroundReceive(Actor.scala:537)
> Sep 08 05:08:35 at akka.actor.Actor.aroundReceive$(Actor.scala:535)
> Sep 08 05:08:35 at
> akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
> Sep 08 05:08:35 at
> akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
> Sep 08 05:08:35 at akka.actor.ActorCell.invoke(ActorCell.scala:548)
> Sep 08 05:08:35 at
> akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
> Sep 08 05:08:35 at akka.dispatch.Mailbox.run(Mailbox.scala:231)
> Sep 08 05:08:35 at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
> Sep 08 05:08:35 at
> java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
> Sep 08 05:08:35 at
> java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
> Sep 08 05:08:35 at
> java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
> Sep 08 05:08:35 at
> java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
> Sep 08 05:08:35 Caused by:
> org.apache.pulsar.client.api.PulsarClientException$BrokerMetadataException:
> Consumer not found
> Sep 08 05:08:35 at
> org.apache.pulsar.client.api.PulsarClientException.unwrap(PulsarClientException.java:987)
> Sep 08 05:08:35 at
> org.apache.pulsar.client.impl.PulsarClientImpl.close(PulsarClientImpl.java:658)
> Sep 08 05:08:35 at
> org.apache.flink.connector.pulsar.source.reader.source.PulsarSourceReaderBase.close(PulsarSourceReaderBase.java:83)
> Sep 08 05:08:35 at
> org.apache.flink.connector.pulsar.source.reader.source.PulsarOrderedSourceReader.close(PulsarOrderedSourceReader.java:170)
> Sep 08 05:08:35 at
> org.apache.flink.streaming.api.operators.SourceOperator.close(SourceOperator.java:324)
> Sep 08 05:08:35 at
> org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141)
> Sep 08 05:08:35 at
> org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127)
> Sep 08 05:08:35 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1020)
> Sep 08 05:08:35 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:864)
> Sep 08 05:08:35 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:752)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)
> Sep 08 05:08:35 at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
> Sep 08 05:08:35 at java.lang.Thread.run(Thread.java:748)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
