Ingo Bürk created FLINK-23537:
-
Summary: Easy way to append metadata to deserialized row data for
connector implementations
Key: FLINK-23537
URL: https://issues.apache.org/jira/browse/FLINK-23537
Ingo Bürk created FLINK-23536:
-
Summary: Documentation of DeserializationSchema#deserialize is
incorrect
Key: FLINK-23536
URL: https://issues.apache.org/jira/browse/FLINK-23536
Project: Flink
Hi,
Thanks for the thorough explanation. I was basing my information on the
info you see you click on the question mark behind 'Priority' when you
create a ticket [1].
Given the documented ticket priorities, I would vote for renaming Minor to
Normal and set that as the default priority.
Thanks,
tim yu created FLINK-23535:
--
Summary: The value of option high-availability.cluster-id in
flink-conf.yaml is replaced improperly
Key: FLINK-23535
URL: https://issues.apache.org/jira/browse/FLINK-23535
Dawid Wysakowicz created FLINK-23534:
Summary: Banned dependencies in flink-statebackend-changelog
Key: FLINK-23534
URL: https://issues.apache.org/jira/browse/FLINK-23534
Project: Flink
Dawid Wysakowicz created FLINK-23533:
Summary: Split InputSelection into public and internal parts
Key: FLINK-23533
URL: https://issues.apache.org/jira/browse/FLINK-23533
Project: Flink
Dawid Wysakowicz created FLINK-23532:
Summary: Unify stop-with-savepoint w drain and w/o drain
Key: FLINK-23532
URL: https://issues.apache.org/jira/browse/FLINK-23532
Project: Flink
Thanks Becket.
I added the interface and also clarified the switching modes under "Basic
Idea" based on your feedback on the PR.
On Wed, Jul 28, 2021 at 5:56 PM Becket Qin wrote:
> +1 (binding)
>
> Thanks for driving the effort. It is good to see the long effort to be
> closed.
> BTW, it seems
tartarus created FLINK-23531:
Summary: Allow skip everytime change log for row-time deduplicate
mini-batch
Key: FLINK-23531
URL: https://issues.apache.org/jira/browse/FLINK-23531
Project: Flink
FLIP-150 is accepted with the following binding votes:
Arvid Heise
Thomas Weise
Stephan Ewen
Becket Qin
Thanks everyone for reviewing and voting!
Thomas
On Wed, Jul 28, 2021 at 5:56 PM Becket Qin wrote:
> +1 (binding)
>
> Thanks for driving the effort. It is good to see the long effort to
+1 (binding)
Thanks for driving the effort. It is good to see the long effort to be
closed.
BTW, it seems the SourceSwitchContext API is not in the FLIP wiki, can we
add that?
On Wed, Jul 28, 2021 at 8:57 PM Stephan Ewen wrote:
> +1 (binding)
>
> Would be good to move this across the finish
Dawid Wysakowicz created FLINK-23530:
Summary:
JoinITCase.testJoinOnCustomTypeInputWithKeyExtractorAndTupleInputWithKeyFieldSelector
fails on Azure
Key: FLINK-23530
URL:
Hi everyone,
well that escalated quickly :) Let me share some more background. This is
our current definition for the priorities (from
https://cwiki.apache.org/confluence/display/FLINK/Flink+Jira+Process).
*Blocker* - infrastructure failures, bugs that block us from releasing
*Critical* - test
+1 (binding)
Would be good to move this across the finish line.
It seems this thread is held up mainly by formalities at this point.
On Fri, Jul 2, 2021 at 4:27 AM Israel Ekpo wrote:
> +1 (non-binding)
>
> On Thu, Jul 1, 2021 at 6:45 PM Elkhan Dadashov
> wrote:
>
> > +1 (non-binding)
> >
> >
Caizhi Weng created FLINK-23529:
---
Summary: Add Flink 1.13 & 1.14 MigrationVersion
Key: FLINK-23529
URL: https://issues.apache.org/jira/browse/FLINK-23529
Project: Flink
Issue Type: Improvement
Piotr Nowojski created FLINK-23528:
--
Summary: stop-with-savepoint can fail with FlinkKinesisConsumer
Key: FLINK-23528
URL: https://issues.apache.org/jira/browse/FLINK-23528
Project: Flink
Piotr Nowojski created FLINK-23527:
--
Summary: Clarify `SourceFunction#cancel()` contract about
interrupting
Key: FLINK-23527
URL: https://issues.apache.org/jira/browse/FLINK-23527
Project: Flink
Dawid Wysakowicz created FLINK-23526:
Summary: py36-cython: commands failed on Azure
Key: FLINK-23526
URL: https://issues.apache.org/jira/browse/FLINK-23526
Project: Flink
Issue Type:
Hi Becket,
I have updated the PR according to your suggestion (note that this commit
contains the removal of the previous approach) [1]. Here are my
observations:
1. Adding the type of RecordMetadata to emitRecord would require adding
another type parameter to RecordEmitter and SourceReaderBase.
Dawid Wysakowicz created FLINK-23525:
Summary: Docker command fails on Azure: Exit code 137 returned
from process: file name '/usr/bin/docker'
Key: FLINK-23525
URL:
Dawid Wysakowicz created FLINK-23524:
Summary: AdaptiveSchedulerClusterITCase fails on Azure
Key: FLINK-23524
URL: https://issues.apache.org/jira/browse/FLINK-23524
Project: Flink
Issue
zhihao zhang created FLINK-23522:
Summary: Fix typo `TAble` -> `Table`
Key: FLINK-23522
URL: https://issues.apache.org/jira/browse/FLINK-23522
Project: Flink
Issue Type: Bug
zhihao zhang created FLINK-23523:
Summary: Fix typo `TAble` -> `Table`
Key: FLINK-23523
URL: https://issues.apache.org/jira/browse/FLINK-23523
Project: Flink
Issue Type: Bug
23 matches
Mail list logo
