Re: [DISCUSS] Release new FRocksDB

+1 , I agree to open a 7.x branch to study whether the new version of rocksdb has brought something new changes Yun Tang 于2022年12月20日周二 12:47写道： > +1 to have a new FrocksDB release and thanks for the effors. > > For FLINK-24932, we planned to upgrade to RocksDB-6.29.x to support Apple > ARM chip

Re: [DISCUSS] Release Flink 1.16.1

Hi Martijn, FLINK-30116 After merge.Flink Web Ui Configuration Can't show it,I checked the data returned by the back end and there is no problem, but there is an error in the front end, as shown in the picture below, can someone take a look befor

[DISCUSS] Add Flink Web3 Connector

Web3 is very hot. But you could search GitHub open source blockchain explorer, the most stars project is blockscout, https://github.com/blockscout/blockscout which use Elixir as a parallel engine to sync block from blockchain node into a file(CSV forma

Re: [DISCUSS] Release new FRocksDB

+1 to have a new FrocksDB release and thanks for the effors. For FLINK-24932, we planned to upgrade to RocksDB-6.29.x to support Apple ARM chips. However, we found another performance regression between 6.20.3 and 6.29.5 [1]. That’s why we still stay in the 6.20.3 branch. Since we already decid

[jira] [Created] (FLINK-30457) Introduce period compaction to FRocksDB

Yun Tang created FLINK-30457: Summary: Introduce period compaction to FRocksDB Key: FLINK-30457 URL: https://issues.apache.org/jira/browse/FLINK-30457 Project: Flink Issue Type: Improvement

Re: [VOTE] FLIP-275: Support Remote SQL Client Based on SQL Gateway

+1(binding) Best, Shengkai yu zelin 于2022年12月14日周三 20:41写道： > Hi, all, > > Thanks for all your feedbacks so far. Through the discussion on this > thread[1], I think we have came to a consensus, so I’d like to start a > vote on FLIP-275[2]. > > The vote will last for at least 72 hours (Dec 19th,

Re: [DISCUSS] FLIP-275: Support Remote SQL Client Based on SQL Gateway

Hi, zelin. Thanks for your update. LGTM. Best, Shengkai yu zelin 于2022年12月20日周二 11:00写道： > Hi all, > > Recently I have received some feedbacks about the REST Endpoint > modification. The main point > is use ‘ResultSet’ as a part of FetchResultsResponseBody’ is not > convenient for serializatio

Re: [DISCUSS] FLIP-275: Support Remote SQL Client Based on SQL Gateway

Hi all, Recently I have received some feedbacks about the REST Endpoint modification. The main point is use ‘ResultSet’ as a part of FetchResultsResponseBody’ is not convenient for serialization and deserialization. So I think it’s better to introduce a new ‘ResultInfo’ to carry the data. The ‘

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

Congratulations, Godfrey and Xingbo! Best, Shengkai Hang Ruan 于2022年12月18日周日 18:41写道： > Congratulations, Godfrey and Xingbo! > > Jun Qin 于2022年12月17日周六 03:52写道： > > > Congratulations to both of you, Godfrey and Xingbo! > > > > > On Nov 25, 2022, at 1:29 AM, Dong Lin wrote: > > > > > > Congrat

Re: [DISCUSS] FLIP-266: Simplify network memory configurations for TaskManager

Thanks for the proposal, Yuxin. +1 for the proposed changes. I think these are indeed helpful usability improvements. Best, Xintong On Mon, Dec 19, 2022 at 3:36 PM Yuxin Tan wrote: > Hi, devs, > > I'd like to start a discussion about FLIP-266: Simplify network memory > configurations for Ta

Re: [DISCUSS] FLIP-276: Data Consistency of Streaming and Batch ETL in Flink and Table Store

Hi Piotr, Thanks for your syncing. I will update the FLIP later and keep this discussion open. Looking forward to your feedback, thanks Best, Shammon On Mon, Dec 19, 2022 at 10:45 PM Piotr Nowojski wrote: > Hi Shammon, > > I've tried to sync with Timo, David Moravek and Dawid Wysakowicz abou

[jira] [Created] (FLINK-30456) OLM Bundle Description Version Problems

James Busche created FLINK-30456: Summary: OLM Bundle Description Version Problems Key: FLINK-30456 URL: https://issues.apache.org/jira/browse/FLINK-30456 Project: Flink Issue Type: Bug

Re: [VOTE] Release flink-connector-opensearch, release candidate #1

+1 (binding) Release looks good. 1. Downloaded the source archive release staged at https://dist.apache.org/repos/dist/dev/flink/flink-connector-opensearch-1.0.0-rc1/ 2. Verified the signature 3. Inspect extracted source code for binaries 4. Compiled the source code 5. Verified license files / he

Re: [VOTE] Release flink-connector-pulsar, release candidate #5

Hello all, +1 (binding) - Verified signatures and checksums - Source artifact does not contain binaries - Reviewed web PR - Contents of Maven repo looks good - Tag is present in Github - Verified NOTICE file - Built source Thanks, Danny On Mon, Dec 19, 2022 at 1:57 PM Dawid Wysakowicz wrote:

Re: [VOTE] Release flink-connector-rabbitmq, release candidate #1

Hello Martijn, +1 (binding) - Verified signatures and hashes - Contents of Maven repository looks good - Tag exists in repository - Release notes look good - Reviewed web CR - Source archive does not contain any binaries - Built from source - Verified NOTICE file and licenses Thanks, On Tue, De

[jira] [Created] (FLINK-30455) Avoid "cleaning" of java.lang.String in ClosureCleaner

Gunnar Morling created FLINK-30455: -- Summary: Avoid "cleaning" of java.lang.String in ClosureCleaner Key: FLINK-30455 URL: https://issues.apache.org/jira/browse/FLINK-30455 Project: Flink Is

Re: [VOTE] Release flink-connector-jdbc, release candidate #2

+1 (binding) * verified signatures and checksums * built from sources * the PR looks good * the artifacts to be published look fine * checked files diff to the 1.16.0 release tag Best, Dawid On 19/12/2022 12:17, Sergey Nuyanzin wrote: +1 (non-binding) - Validated hashes and signature -

Re: [DISCUSS] FLIP-276: Data Consistency of Streaming and Batch ETL in Flink and Table Store

Hi Shammon, I've tried to sync with Timo, David Moravek and Dawid Wysakowicz about this subject. We have only briefly chatted and exchanged some thoughts/ideas, but unfortunately we were not able to finish the discussions before the holiday season/vacations. Can we get back to this topic in Januar

[jira] [Created] (FLINK-30454) Inconsistent class hierarchy in TaskIOMetricGroup

Gunnar Morling created FLINK-30454: -- Summary: Inconsistent class hierarchy in TaskIOMetricGroup Key: FLINK-30454 URL: https://issues.apache.org/jira/browse/FLINK-30454 Project: Flink Issue T

Re: [DISCUSS] Release new FRocksDB

+1 to have a new FRocksDB release. Thanks Yanfei and all for the efforts! Best Regards, Yu On Fri, 16 Dec 2022 at 17:02, Martijn Visser wrote: > Hi Yanfei, > > Big +1 for adding ARM support. It would be great to be able to get tests to > pass on Mac M1s. > > Best regards, > > Martijn > > On Mo

Re: [VOTE] Release flink-connector-pulsar, release candidate #5

+1 (binding) * verified signatures and checksums * built from sources * checked notice files * the PR looks good * the artifacts to be published look fine Best, Dawid On 15/12/2022 16:41, Martijn Visser wrote: Hi everyone, Please review and vote on the release candidate #5 for the versio

[jira] [Created] (FLINK-30453) Fix 'can't find CatalogFactory' error when using FLINK sql-client to add table store bundle jar

yuzelin created FLINK-30453: --- Summary: Fix 'can't find CatalogFactory' error when using FLINK sql-client to add table store bundle jar Key: FLINK-30453 URL: https://issues.apache.org/jira/browse/FLINK-30453

Re: [VOTE] Release flink-connector-jdbc, release candidate #2

+1 (non-binding) - Validated hashes and signature - Verified that no binaries exist in the source archive - Build from sources with Maven - Verified licenses one nitpick: it seems a link to the tag is broken (number 5) I guess it should be this one https://github.com/apache/flink-connector-jdbc/r

Re: [VOTE] Release flink-connector-opensearch, release candidate #1

+1 (non-binding) - Validated hashes and signature - Verified that no binaries exist in the source archive - Build from sources with Maven - Verified licenses On Sat, Dec 17, 2022 at 8:34 AM Martijn Visser wrote: > Hi Danny, > > +1 (binding) > > - Validated hashes > - Verified signature > - Veri

Re: Confluent Kafka connector for protobuf format

Hi Krish, Thanks for reaching out! I've assigned the ticket to you and also granted you access to create a FLIP. Best regards, Martijn On Sat, Dec 17, 2022 at 9:52 PM Krish Narukulla wrote: > Hi Team, > > I have written a connector for confluent kafka for protobuf and tested it > internally.

Re: [DISCUSS] FLIP-278: Hybrid Source Connector

a mistake, childSources.get(sourceIndex).setStartTimetamp(switchedTimestamp); Ran Tao 于2022年12月19日周一 16:10写道： > Hi, John. thanks for your comments. > About question-2 the "handoff" is using for switching next source > seamlessly. but it's an option. Not every hybrid source job need to using > th

Re: [DISCUSS] FLIP-278: Hybrid Source Connector

Hi, John. thanks for your comments. About question-2 the "handoff" is using for switching next source seamlessly. but it's an option. Not every hybrid source job need to using this mode. The hybrid source sql or table need to implement two ways like DataStream api below. One for fixed position, u