Matthias Pohl created FLINK-30893:
-
Summary: Replace not specifying a driver in Minikube by something
else
Key: FLINK-30893
URL: https://issues.apache.org/jira/browse/FLINK-30893
Project: Flink
Feng Wang created FLINK-30892:
-
Summary: Clean codes for memory and tests
Key: FLINK-30892
URL: https://issues.apache.org/jira/browse/FLINK-30892
Project: Flink
Issue Type: Improvement
Shammon created FLINK-30891:
---
Summary: Introduce Preconditions for table store
Key: FLINK-30891
URL: https://issues.apache.org/jira/browse/FLINK-30891
Project: Flink
Issue Type: Sub-task
Yanfei Lei created FLINK-30890:
--
Summary: Backup codespeed‘s data regularly
Key: FLINK-30890
URL: https://issues.apache.org/jira/browse/FLINK-30890
Project: Flink
Issue Type: Sub-task
Junrui Li created FLINK-30889:
-
Summary: Rename the configuration key SPECULATIVE_ENABLED.
Key: FLINK-30889
URL: https://issues.apache.org/jira/browse/FLINK-30889
Project: Flink
Issue Type: Bug
+1
Best,
Leonard
> On Feb 3, 2023, at 9:49 AM, Dong Lin wrote:
>
> +1
>
> On Thu, Feb 2, 2023 at 9:31 PM Hang Ruan wrote:
>
>> Hi all,
>>
>> Thanks for all the help about this FLIP. Now let's start the vote again.
>> Based on the discussion[1], we have come to a consensus, so I would like t
+1
On Thu, Feb 2, 2023 at 9:31 PM Hang Ruan wrote:
> Hi all,
>
> Thanks for all the help about this FLIP. Now let's start the vote again.
> Based on the discussion[1], we have come to a consensus, so I would like to
> start a vote on FLIP-274: Introduce metric group for
> OperatorCoordinator[2].
Xu created FLINK-30888:
--
Summary: Flink Doc(zh version) has misspelled words
Key: FLINK-30888
URL: https://issues.apache.org/jira/browse/FLINK-30888
Project: Flink
Issue Type: Bug
Reporter:
Hello,
I have a Kafka producer and a Kafka consumer that produces and consumes
multiple data respectively. You can think of two data sets here. Both
datasets have a similar structure but carry different data.
I want to implement a Table API to join two Kafka streams while I
consume them. For exam
I fully agree that in-place scaling is a much harder problem which is
out of the scope for now. My primary concern here is to be able to
rescale with upfront reservation of resources before restarting the
job, so the job doesn't get stuck in case of resource constraints.
> Unused slots: If the max
> If I understand correctly, the adaptive scheduler currently does a
full job restart. Is there any work planned to enable in-place rescaling
with the adaptive scheduler?
Nothing concrete. Sure, it's on a wishlist, but it'd require significant
changes to how the runtime works.
Rescaling statef
+1
Op do 2 feb. 2023 om 16:22 schreef Chesnay Schepler :
>
> +1
>
> On 02/02/2023 15:43, Jark Wu wrote:
> > +1
> >
> > Best,
> > Jark
> >
> > On Thu, 2 Feb 2023 at 21:31, Hang Ruan wrote:
> >
> >> Hi all,
> >>
> >> Thanks for all the help about this FLIP. Now let's start the vote again.
> >> Base
+1
On 02/02/2023 15:43, Jark Wu wrote:
+1
Best,
Jark
On Thu, 2 Feb 2023 at 21:31, Hang Ruan wrote:
Hi all,
Thanks for all the help about this FLIP. Now let's start the vote again.
Based on the discussion[1], we have come to a consensus, so I would like to
start a vote on FLIP-274: Introduc
+1
Best,
Jark
On Thu, 2 Feb 2023 at 21:31, Hang Ruan wrote:
> Hi all,
>
> Thanks for all the help about this FLIP. Now let's start the vote again.
> Based on the discussion[1], we have come to a consensus, so I would like to
> start a vote on FLIP-274: Introduce metric group for
> OperatorCoord
Hi all,
Thanks for all the help about this FLIP. Now let's start the vote again.
Based on the discussion[1], we have come to a consensus, so I would like to
start a vote on FLIP-274: Introduce metric group for OperatorCoordinator[2].
The vote will last for at least 72 hours (Feb 8th at 11:00 GMT)
Martijn Visser created FLINK-30887:
--
Summary: CI workflow for externalized connectors doesn't cache
Flink's binary download
Key: FLINK-30887
URL: https://issues.apache.org/jira/browse/FLINK-30887
Pro
Ari Huttunen created FLINK-30886:
Summary: Content area is too narrow to show all content
Key: FLINK-30886
URL: https://issues.apache.org/jira/browse/FLINK-30886
Project: Flink
Issue Type: Bu
Hi all,
+1 for the overall proposal. My feedback matches with what Matthias
has already provided earlier.
Best regards,
Martijn
Op di 31 jan. 2023 om 19:01 schreef Matthias Pohl
:
>
> Thanks for the effort you put into this discussion, Yanfei.
>
> For me, the regression tests are similar to tes
Hi everyone,
All issues about FLIP-274 have been resolved and consensus has been
reached. If there are no further problems, we plan to start the voting
thread.
Thanks a lot for participating in the vote discussion. Special thanks
to @Chesnay
Schepler and @Jark Wu , their
suggestions and discussi
Juntao Hu created FLINK-30885:
-
Summary: Optional group pattern starts with non-optional looping
pattern get wrong result on followed-by
Key: FLINK-30885
URL: https://issues.apache.org/jira/browse/FLINK-30885
yuanfenghu created FLINK-30884:
--
Summary: GetTable from Flink catalog should be judged whether it
is a sink table
Key: FLINK-30884
URL: https://issues.apache.org/jira/browse/FLINK-30884
Project: Flink
Matthias Pohl created FLINK-30883:
-
Summary: Missing JobID caused the k8s e2e test to fail
Key: FLINK-30883
URL: https://issues.apache.org/jira/browse/FLINK-30883
Project: Flink
Issue Type: B
Jingsong Lee created FLINK-30882:
Summary: Introduce partition.expiration-time to automatically
delete expired partitions
Key: FLINK-30882
URL: https://issues.apache.org/jira/browse/FLINK-30882
Projec
+1 on improving the scheduler docs.
> They never shared a base class since day 1. Are you maybe mixing up the
> AdaptiveScheduler and AdaptiveBatchScheduler?
@Chesnay: Indeed, I had mixed this up. DefaultScheduler and
AdaptiveScheduler only share the SchedulerNG interface while the
DefaultSchedu
Matthias Pohl created FLINK-30881:
-
Summary: Crictl/Minikube version mismatch causes errors in k8s
setup
Key: FLINK-30881
URL: https://issues.apache.org/jira/browse/FLINK-30881
Project: Flink
Looks good from my side.
On 01/02/2023 13:27, Hang Ruan wrote:
Hi all,
I make a mistake about the default value of the scope format
JobManagerOperatorScopeFormat. It should be
.jobmanager...
I have fixed it in the FLIP.
And the variables (task id and task name) have been added to the list.
Be
João Boto created FLINK-30880:
-
Summary: [Connectors/Jdbc] Update flink to 1.16.1
Key: FLINK-30880
URL: https://issues.apache.org/jira/browse/FLINK-30880
Project: Flink
Issue Type: Improvement
Matthias Pohl created FLINK-30879:
-
Summary: KafkaShuffleITCase failed with multiple test failures due
to a TimeoutException while creating topics
Key: FLINK-30879
URL: https://issues.apache.org/jira/browse/FLINK-
Matthias Pohl created FLINK-30878:
-
Summary: KubernetesHighAvailabilityRecoverFromSavepointITCase
fails due to a deadlock
Key: FLINK-30878
URL: https://issues.apache.org/jira/browse/FLINK-30878
Projec
Yun Gao created FLINK-30877:
---
Summary: Add support for @Before / @After for JUnit 4 and 5
Key: FLINK-30877
URL: https://issues.apache.org/jira/browse/FLINK-30877
Project: Flink
Issue Type: Sub-task
Yunhong Zheng created FLINK-30876:
-
Summary: Fix ResetTransformationProcessor don't reset the
transformation of ExecNode in BatchExecMultiInput.rootNode
Key: FLINK-30876
URL: https://issues.apache.org/jira/browse/
31 matches
Mail list logo
