Re: [Discuss] Some questions on flink-table-store micro benchmark

: Monday, February 27, 2023 18:02 To: dev@flink.apache.org Subject: Re: [Discuss] Some questions on flink-table-store micro benchmark Hi Yun and Shammon, > track the performance changes of the micro benchmark I think we can create a github action for this. Print results everyday. Best, Jings

Re: [Discuss] Some questions on flink-table-store micro benchmark

Hi Yun and Shammon, > track the performance changes of the micro benchmark I think we can create a github action for this. Print results everyday. Best, Jingsong On Mon, Feb 27, 2023 at 5:59 PM Shammon FY wrote: > > Hi jingsong > > Getting rid of JMH is a good idea. For the second point, how

Re: [Discuss] Some questions on flink-table-store micro benchmark

Hi jingsong Getting rid of JMH is a good idea. For the second point, how can we track the performance changes of the micro benchmark? What do you think? Best, Shammon On Mon, Feb 27, 2023 at 10:57 AM Jingsong Li wrote: > Thanks Yun. > > Another way is we can get rid of JMH, something like

Re: [Discuss] Some questions on flink-table-store micro benchmark

Thanks Yun. Another way is we can get rid of JMH, something like Spark `org.apache.spark.benchmark.Benchmark` can replace JMH. Best, Jingsong On Mon, Feb 27, 2023 at 1:24 AM Yun Tang wrote: > > Hi dev, > > I just noticed that flink-table-store had introduced the micro benchmark > module [1]

[Discuss] Some questions on flink-table-store micro benchmark

Hi dev, I just noticed that flink-table-store had introduced the micro benchmark module [1] to test the basic performance. And I have two questions here. First of all, we might not be able to keep the micro benchmark, which is based on JMH, in the main repo of flink-table-store. This is because

Re: Questions about Flink Table Store

Hi Alexander! Thanks for your interest in Flink Table Store and I'm glad to share my thoughts with you. Given that there is always a single writer to a stream, in what situations > can concurrent writes ever happen to Flink Table Store? I'm not the author of FLIP so I'm not sure what "writer"

Re: Questions about Flink Table Store

Hi, Alexander Happy to hear that you’re willing to contribute to Flink, the answer of these specific tech design/functionality questions may need to dig the code. I’m not familiar with FTS code base, but I’v CC my colleagues who are the core maintainers of FTS and maybe they can give your some

Questions about Flink Table Store

I’m Alexander from Confluent. I am new to Flink and its community. I would like to contribute to the Flink Table Store, but am missing certain details. Can someone please clarify the points mentioned below to me? - Given that there is always a single writer to a stream, in what situations

Re: Questions on flink

Hi Govindarajan, I've put some answers in-line below.. On Sat, Sep 24, 2016 at 7:32 PM, Govindarajan Srinivasaraghavan < govindragh...@gmail.com> wrote: > Hi, > > I'm working on apache flink for data streaming and I have few questions. > Any help is greatly appreciated. Thanks. > > 1) Are there

Questions on flink

Hi, I'm working on apache flink for data streaming and I have few questions. Any help is greatly appreciated. Thanks. 1) Are there any restrictions on creating tumbling windows. For example, if I want to create a tumbling window per user id for 2 secs and let’s say if I have more than 10 million

Re: Questions about flink-streaming-examples

Thanks for clarifying Marton! I was on the latest build already. However, my local maven repository contained old jars. After removing all flink-jars from my local maven repository it works! Why does maven no automatically update the local repository? -Matthias On 02/26/2015 09:20 AM,

Re: Questions about flink-streaming-examples

To update the local repository, you have to do execute the install goal. I can recommend to always do a mvn clean install On Thu, Feb 26, 2015 at 10:11 AM, Matthias J. Sax mj...@informatik.hu-berlin.de wrote: Thanks for clarifying Marton! I was on the latest build already. However, my local

Re: Questions about flink-streaming-examples

If the streaming-examples module uses the classifier tag to add the test-core dependency then we should change it into type tag as recommended by maven [1]. Otherwise it might come to build failures if the install lifecycle is not executed. The dependency import should look like: dependency

Re: Questions about flink-streaming-examples

Dear Mathias, Thanks for reporting the issue. I have successfully built flink-streaming-examples with maven, you can depend on test classes, the following in the pom does the trick: dependency groupIdorg.apache.flink/groupId artifactIdflink-streaming-core/artifactId

Re: Questions about flink-streaming-examples

Hi Matthias! Can you try mvn clean package? It package is generally preferable to compile, in my opinion. There may be a dependency through a test jar that is not properly handled when you do not execute the package goal. Stephan Am 25.02.2015 16:54 schrieb Max Michels m...@apache.org: Hi