+1 （non-binding)
Best,
Junrui
Lijie Wang 于2024年4月12日周五 12:43写道：
> +1 (binding)
>
> Thanks for driving.
>
> Best,
> Lijie
>
> Zakelly Lan 于2024年4月12日周五 11:08写道：
>
> > +1 non-binding
> >
> >
> > Best,
> > Zakelly
> >
> > On Fri, Apr 12, 2024 at 11:05 AM Yuepeng Pan
> > wrote:
> >
> > > Hi Rui,
Hi priya ,
I can help you with adding table api support and add patch for it . Let me
know if that works for you to add it as part of this flip .
Thank you
Bests,
Samrat
On Fri, 12 Apr 2024 at 3:11 AM, Dhingra, Priya
wrote:
> Hi Ahmed,
>
> Thanks for reviewing it. I have updated the FLIP
+1 (binding)
Thanks for driving.
Best,
Lijie
Zakelly Lan 于2024年4月12日周五 11:08写道：
> +1 non-binding
>
>
> Best,
> Zakelly
>
> On Fri, Apr 12, 2024 at 11:05 AM Yuepeng Pan
> wrote:
>
> > Hi Rui,
> >
> > Thanks for driving it!
> > +1 (non-binding)
> > Best,
> > Yuepeng Pan
> >
> > At 2024-04-12
Hello Venkata krishnan,
I think the term "semantic inconsistency" defined by
jobmanager.adaptive-batch-scheduler.max-parallelism refers to maintaining a
uniform upper limit on parallelism across all vertices within a job. As the
source vertices are part of the global execution graph, they should
Hongshun Wang created FLINK-35093:
-
Summary: Postgres source connector support SPECIFIC_OFFSETS start
up mode from an existed replication slot.
Key: FLINK-35093
URL:
+1 non-binding
Best,
Zakelly
On Fri, Apr 12, 2024 at 11:05 AM Yuepeng Pan wrote:
> Hi Rui,
>
> Thanks for driving it!
> +1 (non-binding)
> Best,
> Yuepeng Pan
>
> At 2024-04-12 10:31:19, "Yanfei Lei" wrote:
> >Hi Rui,
> >
> >Thanks for driving it!
> >
> >+1 (binding)
> >
> >Hangxiang Yu
Hi Rui,
Thanks for driving it!
+1 (non-binding)
Best,
Yuepeng Pan
At 2024-04-12 10:31:19, "Yanfei Lei" wrote:
>Hi Rui,
>
>Thanks for driving it!
>
>+1 (binding)
>
>Hangxiang Yu 于2024年4月12日周五 10:26写道：
>>
>> +1 (binding)
>>
>> On Fri, Apr 12, 2024 at 10:22 AM Jinzhong Li
>> wrote:
>>
>> > +1
Hi Rui,
Thanks for driving it!
+1 (binding)
Hangxiang Yu 于2024年4月12日周五 10:26写道：
>
> +1 (binding)
>
> On Fri, Apr 12, 2024 at 10:22 AM Jinzhong Li
> wrote:
>
> > +1 (non binding)
> >
> > Bests,
> > Jinzhong
> >
> > On Thu, Apr 11, 2024 at 7:26 AM Muhammet Orazov
> > wrote:
> >
> > > Hey
+1 (binding)
On Fri, Apr 12, 2024 at 10:22 AM Jinzhong Li
wrote:
> +1 (non binding)
>
> Bests,
> Jinzhong
>
> On Thu, Apr 11, 2024 at 7:26 AM Muhammet Orazov
> wrote:
>
> > Hey Rui,
> >
> > +1 (non-binding).
> >
> > Thanks for driving it!
> >
> > Best,
> > Muhammet
> >
> > On 2024-04-10
Xiqian YU created FLINK-35092:
-
Summary: Add integrated test for Doris sink pipeline connector
Key: FLINK-35092
URL: https://issues.apache.org/jira/browse/FLINK-35092
Project: Flink
Issue Type:
+1 (non binding)
Bests,
Jinzhong
On Thu, Apr 11, 2024 at 7:26 AM Muhammet Orazov
wrote:
> Hey Rui,
>
> +1 (non-binding).
>
> Thanks for driving it!
>
> Best,
> Muhammet
>
> On 2024-04-10 04:36, Rui Fan wrote:
> > Hi devs,
> >
> > Thank you to everyone for the feedback on FLIP-441: Show
> >
sanqingleo created FLINK-35091:
--
Summary: Incorrect Warning msg in JM when use influxdb
Key: FLINK-35091
URL: https://issues.apache.org/jira/browse/FLINK-35091
Project: Flink
Issue Type:
Hi Xuannan,
> Regarding the new classes, we propose updating the
> `ConfigOptionsDocGenerator` to throw an exception and fail the build
> if it detects any new class missing the proper annotation in the
> future.
Thanks for your feedback, it sounds good to me.
Best,
Rui
On Fri, Apr 12, 2024 at
Xiqian YU created FLINK-35090:
-
Summary: Doris sink fails to create table when database does not
exist
Key: FLINK-35090
URL: https://issues.apache.org/jira/browse/FLINK-35090
Project: Flink
Xuannan Su created FLINK-35089:
--
Summary: Two input AbstractStreamOperator may throw NPE when
receiving RecordAttributes
Key: FLINK-35089
URL: https://issues.apache.org/jira/browse/FLINK-35089
Project:
+1 (binding)
On Wed, Apr 10, 2024 at 4:34 AM Jing Ge wrote:
> +1(binding)
>
> Best regards,
> Jing
>
> On Tue, Apr 9, 2024 at 8:54 PM Feng Jin wrote:
>
> > +1 (non-binding)
> >
> > Best,
> > Feng
> >
> > On Tue, Apr 9, 2024 at 5:56 PM gongzhongqiang >
> > wrote:
> >
> > > +1 (non-binding)
> >
Hi Ahmed,
Thanks for reviewing it. I have updated the FLIP again.
On your question of concerns on adding Table API support right now, the only
reason I don't want to commit for it is that I am really not sure about the
effort it involves and how to do/test it since I never worked with Table
Gentle bump on this question. cc @Becket Qin as well.
Regards
Venkata krishnan
On Tue, Mar 12, 2024 at 10:11 PM Venkatakrishnan Sowrirajan <
vsowr...@asu.edu> wrote:
> Thanks for the response Lijie and Junrui. Sorry for the late reply. Few
> follow up questions.
>
> > Source can actually
Hello DEV!
I am currently working on issue [1].
The contribution consists in migrating the batch SQL test from a bash
implementation to a Java one.
After a couple of rounds of review we agreed to proceed by removing the
existing deprecations due to how the source table is generated.
The main
elon_X created FLINK-35088:
--
Summary: watermark alignment maxAllowedWatermarkDrift and
updateInterval param need check
Key: FLINK-35088
URL: https://issues.apache.org/jira/browse/FLINK-35088
Project: Flink
Hi Yunfeng,
Thank you for the prompt action on resolving this bug. I have compiled the
latest Flink ML source code and can confirm the problem has indeed been solved.
Regarding the second bug relating to the IterationListener interface, it seems
that the methods in the IterationListener
Grzegorz Kołakowski created FLINK-35081:
---
Summary: CompileException when watermark definition contains
coalesce and to_timestamp built-in functions
Key: FLINK-35081
URL:
Thanks Priya
the FLIP now looks much better, I would move out some of the implementation
details . Just highlight how the writer actually uses the client (the
subitRequestEntries part) and how the Sink itself exposes its API to users
(the Sink & builder part), other parts should not be part of the
Grzegorz Kołakowski created FLINK-35080:
---
Summary: Allow to specify additional pushdown filter in table
properties
Key: FLINK-35080
URL: https://issues.apache.org/jira/browse/FLINK-35080
Xiqian YU created FLINK-35079:
-
Summary: MongoConnector failed to resume token when current
collection removed
Key: FLINK-35079
URL: https://issues.apache.org/jira/browse/FLINK-35079
Project: Flink
Muhammet Orazov created FLINK-35078:
---
Summary: Include Flink CDC pipeline connector sub-modules in the
CI runs
Key: FLINK-35078
URL: https://issues.apache.org/jira/browse/FLINK-35078
Project: Flink
26 matches
Mail list logo
