Hi Jark and other PMC members!
Сould you give me access to the editing of the confluence page with
FLIP-221 [1]? I would like to make small changes that were mentioned
in discussion of this FLIP. My login is 'smiralexan' [2]. Thanks in
advance!
Best regards,
Alexander
[1]
https://cwiki.apache.o
tc.
Best regards,
Alexander
чт, 19 мая 2022 г. в 14:50, Александр Смирнов :
>
> Hi Qingsheng and Jark,
>
> 1. Builders vs 'of'
> I understand that builders are used when we have multiple parameters.
> I suggested them because we could add parameters later. To prevent
>
I'm fine with defining cache config options in the framework.
>> A candidate place to put is FactoryUtil which also includes
>> "sink.parallelism", "format" options.
>>
>> Best,
>> Jark
>>
>>
>> On Wed, 18 May 2022 at
and I’ll update the FLIP. Hope we can
> finalize our proposal soon!
>
> Best,
>
> Qingsheng
>
>
> > On May 17, 2022, at 13:46, Александр Смирнов wrote:
> >
> > Hi Qingsheng and devs!
> >
> > I like the overall design of updated FLIP, however I have severa
e but we don't have a clear plan for that.
> >
> >Thanks again for the discussion on this FLIP and looking forward to
> >cooperating with you after we finalize the design and interfaces!
> >
> >[1]
> >https://cwiki.apache.org/confluence/display/FLINK/FLIP-221+Ab
>
> I think it's fine to use InputFormat&SourceFunction, as they are not
> deprecated, otherwise, we have to introduce another function
> similar to them which is meaningless. We need to plan FLIP-27 source
> integration ASAP before InputFormat & SourceFunction are dep
introduce new features for old interfaces.
>
> Best regards,
>
> Martijn
>
> On Thu, 12 May 2022 at 06:19, Александр Смирнов
> wrote:
>
> > Hi Jark!
> >
> > Sorry for the late response. I would like to make some comments and
> > clarify my points.
> &g
to implement their own cache). But
> >> most
> >> > probably it might be solved by creating more different cache strategies
> >> and
> >> > a wider set of configurations.
> >> >
> >> > All these points are much closer to the schema propose
t; the cache implementation as a part of TableFunction, and we could provide
> some helper classes (CachingTableFunction, AllCachingTableFunction,
> CachingAsyncTableFunction) to developers and regulate metrics of the cache.
> Also, I made a POC[2] for your reference.
>
> Lookin
new public interfaces. Everything else remains an
> implementation of Table runtime. That means we can easily incorporate the
> optimization potential that Alexander pointed out later.
>
> @Alexander unfortunately, your architecture is not shared. I don't know the
> solution to shar
Hi Qingsheng! My name is Alexander, I'm not a committer yet, but I'd
really like to become one. And this FLIP really interested me.
Actually I have worked on a similar feature in my company’s Flink
fork, and we would like to share our thoughts on this and make code
open source.
I think there is a
Hi, devs. I recently joined the community and I'm trying to understand the
project module by module. I've noticed that in FlinkKafkaProducer (
*https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProd
Hello, flink community! I recently joined the community and I'm trying to
understand the project module by module. I've noticed that in
FlinkKafkaProducer (
*https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/
Hello everyone! I would like to start contributing, but I have some
problems with it. There are small number of tasks with label
"newbie/starter" and so on. The most of tasks are just proposals, not a
task in general sense. Can anyone help with finding some bugs/improvements
with start level in fli
Hi, everyone. Could you give me corresponding rights? Jira name: Salatich
Best regards,
Aleksandr Salatich
response*, sorry
чт, 14 февр. 2019 г. в 14:42, Александр :
> Hello. Thanks for your responsible.
> I use 3.5.2 version of maven, but also i tried 3.2.5 (as guide
> recommended) but it has no effect.
> I try to build 5e8e00b46369cfcbe0ccd8eb664da07ce3c9d1bf -it's a last
> com
Hello. Thanks for your responsible.
I use 3.5.2 version of maven, but also i tried 3.2.5 (as guide recommended)
but it has no effect.
I try to build 5e8e00b46369cfcbe0ccd8eb664da07ce3c9d1bf -it's a last
commit in master branch.
чт, 14 февр. 2019 г. в 13:32, Robert Metzger :
> Hey Aleksandr,
>
>
Hello everyone! I've just joined to flink contributing community and have
some problems like:
1. I can't do 'mvn clean package' in project on local machine because of
error:
*[ERROR] Failed to execute goal on project flink-dist_2.11: Could not
resolve dependencies for project
org.apache.flink:fli
18 matches
Mail list logo
