Hi, Xingbo Thanks for reporting it.
After confirming with Dian Fu and Ferenc Csaky, the duplicated name is as expected, it's a new feature, more detail can see[1]. 1. https://issues.apache.org/jira/browse/FLINK-38130 Best, Ron Ron Liu <ron9....@gmail.com> 于2025年7月23日周三 10:15写道: > Hi, Fred > > >>> I'm currently experimenting with a local build of Flink 2.1.0-rc1 and > a local build of the Flink Kafka Connector 4.0.0. While building the Flink > Kafka Connector, I encountered an issue: the static method > DataTypeUtils::stripRowPrefix(...) appears to have been removed from the > Flink codebase. > > Was this removal intentional? And if so, does the Flink Kafka Connector > still need to be updated to reflect this change? > > > The method `DataTypeUtils::stripRowPrefix` is removed in PR[1] by timo. > This is a normal codebase change, we should update the flink dependency in > Kafka connector after Flink 2.1 release. > > > >>> Also, I'm curious, what is the typical process for releasing a new > version of Flink? Do the Flink Connectors receive a new release as part of > that process as well? > > I've followed the community rule to create a Jira ticket[2] to track the > Flink connector version upgrade for Flink 2.1. After Flink 2.1 release, we > should push the connector flink version update to 2.1.0. > > Reference: > 1. https://issues.apache.org/jira/browse/FLINK-38090 > 2. https://issues.apache.org/jira/browse/FLINK-38031 > > Best, > Ron > > > Teunissen, F.G.J. (Fred) <fred.teunis...@ing.com.invalid> 于2025年7月23日周三 > 02:27写道: > >> Hi Ron, >> >> I'm currently experimenting with a local build of Flink 2.1.0-rc1 and a >> local build of the Flink Kafka Connector 4.0.0. While building the Flink >> Kafka Connector, I encountered an issue: the static method >> DataTypeUtils::stripRowPrefix(...) appears to have been removed from the >> Flink codebase. >> >> Was this removal intentional? And if so, does the Flink Kafka Connector >> still need to be updated to reflect this change? >> >> Also, I'm curious, what is the typical process for releasing a new >> version of Flink? Do the Flink Connectors receive a new release as part of >> that process as well? >> >> Best regards, >> Fred Teunissen >> >> >> >> Sent from Outlook for Mac >> >> From: Ron Liu <ron9....@gmail.com> >> Date: Monday, 21 July 2025 at 15:41 >> To: dev <dev@flink.apache.org> >> Subject: [VOTE] Release 2.1.0, release candidate #1 >> >> Hi everyone, >> >> Please review and vote on the release candidate #1 for the version 2.1.0, >> >> as follows: >> >> [ ] +1, Approve the release >> >> [ ] -1, Do not approve the release (please provide specific comments) >> >> >> The complete staging area is available for your review, which includes: >> >> * JIRA release notes [1], and the pull request adding release note for >> >> users [2] >> >> * the official Apache source release and binary convenience releases to be >> >> deployed to dist.apache.org [3], which are signed with the key with >> >> fingerprint 7A14EF9AD986EF0D56B2E73F6AF817E6C59EC690 [4], >> >> * all artifacts to be deployed to the Maven Central Repository [5], >> >> * source code tag "release-2.1.0-rc1" [6], >> >> * website pull request listing the new release and adding announcement >> blog >> post [7]. >> >> >> The vote will be open for at least 72 hours. It is adopted by majority >> >> approval, with at least 3 PMC affirmative votes. >> >> >> [1] >> >> https://eur02.safelinks.protection.outlook.com/?url=https%3A%2F%2Fissues.apache.org%2Fjira%2Fsecure%2FReleaseNote.jspa%3Fversion%3D12355556%26styleName%3D%26projectId%3D12315522&data=05%7C02%7CFred.Teunissen%40ing.com%7C67081242186c4ccab0bb08ddc85c49f4%7C587b6ea13db94fe1a9d785d4c64ce5cc%7C0%7C0%7C638887020892715361%7CUnknown%7CTWFpbGZsb3d8eyJFbXB0eU1hcGkiOnRydWUsIlYiOiIwLjAuMDAwMCIsIlAiOiJXaW4zMiIsIkFOIjoiTWFpbCIsIldUIjoyfQ%3D%3D%7C0%7C%7C%7C&sdata=ZhJEsCpsEOqSsyJsYpvcuiHTDwssXosVwH7z0tMFoAI%3D&reserved=0 >> < >> https://issues.apache.org/jira/secure/ReleaseNote.jspa?version=12355556&styleName=&projectId=12315522 >> > >> >> [2] >> https://eur02.safelinks.protection.outlook.com/?url=https%3A%2F%2Fgithub.com%2Fapache%2Fflink%2Fpull%2F26778&data=05%7C02%7CFred.Teunissen%40ing.com%7C67081242186c4ccab0bb08ddc85c49f4%7C587b6ea13db94fe1a9d785d4c64ce5cc%7C0%7C0%7C638887020892746994%7CUnknown%7CTWFpbGZsb3d8eyJFbXB0eU1hcGkiOnRydWUsIlYiOiIwLjAuMDAwMCIsIlAiOiJXaW4zMiIsIkFOIjoiTWFpbCIsIldUIjoyfQ%3D%3D%7C0%7C%7C%7C&sdata=MBlK5xiSr8EsFsT%2FC4jNNmE03Q%2BZ7CHXagV7aWLL43o%3D&reserved=0 >> <https://github.com/apache/flink/pull/26778> >> >> [3] >> https://eur02.safelinks.protection.outlook.com/?url=https%3A%2F%2Fdist.apache.org%2Frepos%2Fdist%2Fdev%2Fflink%2Fflink-2.1.0-rc1%2F&data=05%7C02%7CFred.Teunissen%40ing.com%7C67081242186c4ccab0bb08ddc85c49f4%7C587b6ea13db94fe1a9d785d4c64ce5cc%7C0%7C0%7C638887020892770985%7CUnknown%7CTWFpbGZsb3d8eyJFbXB0eU1hcGkiOnRydWUsIlYiOiIwLjAuMDAwMCIsIlAiOiJXaW4zMiIsIkFOIjoiTWFpbCIsIldUIjoyfQ%3D%3D%7C0%7C%7C%7C&sdata=urS5WYETrJbAhqNv1Zu%2Bt2vpJfMc8fz8ot27bDomak0%3D&reserved=0 >> <https://dist.apache.org/repos/dist/dev/flink/flink-2.1.0-rc1/> >> >> [4] >> https://eur02.safelinks.protection.outlook.com/?url=https%3A%2F%2Fdist.apache.org%2Frepos%2Fdist%2Frelease%2Fflink%2FKEYS&data=05%7C02%7CFred.Teunissen%40ing.com%7C67081242186c4ccab0bb08ddc85c49f4%7C587b6ea13db94fe1a9d785d4c64ce5cc%7C0%7C0%7C638887020892793671%7CUnknown%7CTWFpbGZsb3d8eyJFbXB0eU1hcGkiOnRydWUsIlYiOiIwLjAuMDAwMCIsIlAiOiJXaW4zMiIsIkFOIjoiTWFpbCIsIldUIjoyfQ%3D%3D%7C0%7C%7C%7C&sdata=YoQSU1oKQZTQC1kjc6rX%2FQdjmZX6BDpjbFXjAlXBfIE%3D&reserved=0 >> <https://dist.apache.org/repos/dist/release/flink/KEYS> >> >> [5] >> https://eur02.safelinks.protection.outlook.com/?url=https%3A%2F%2Frepository.apache.org%2Fcontent%2Frepositories%2Forgapacheflink-1839%2F&data=05%7C02%7CFred.Teunissen%40ing.com%7C67081242186c4ccab0bb08ddc85c49f4%7C587b6ea13db94fe1a9d785d4c64ce5cc%7C0%7C0%7C638887020892815066%7CUnknown%7CTWFpbGZsb3d8eyJFbXB0eU1hcGkiOnRydWUsIlYiOiIwLjAuMDAwMCIsIlAiOiJXaW4zMiIsIkFOIjoiTWFpbCIsIldUIjoyfQ%3D%3D%7C0%7C%7C%7C&sdata=8qEtqI8ssyHTEOJfzCAX%2BZK%2BuWyWZWDAFLKsBv64QFs%3D&reserved=0 >> <https://repository.apache.org/content/repositories/orgapacheflink-1839/> >> >> [6] >> https://eur02.safelinks.protection.outlook.com/?url=https%3A%2F%2Fgithub.com%2Fapache%2Fflink%2Freleases%2Ftag%2Frelease-2.1.0-rc1&data=05%7C02%7CFred.Teunissen%40ing.com%7C67081242186c4ccab0bb08ddc85c49f4%7C587b6ea13db94fe1a9d785d4c64ce5cc%7C0%7C0%7C638887020892836012%7CUnknown%7CTWFpbGZsb3d8eyJFbXB0eU1hcGkiOnRydWUsIlYiOiIwLjAuMDAwMCIsIlAiOiJXaW4zMiIsIkFOIjoiTWFpbCIsIldUIjoyfQ%3D%3D%7C0%7C%7C%7C&sdata=bz23jWdh7PsRe1J18%2Ff%2BAhRCdlxUV9Da9L7RIcEq1ks%3D&reserved=0 >> <https://github.com/apache/flink/releases/tag/release-2.1.0-rc1> >> >> [7] >> https://eur02.safelinks.protection.outlook.com/?url=https%3A%2F%2Fgithub.com%2Fapache%2Fflink-web%2Fpull%2F800&data=05%7C02%7CFred.Teunissen%40ing.com%7C67081242186c4ccab0bb08ddc85c49f4%7C587b6ea13db94fe1a9d785d4c64ce5cc%7C0%7C0%7C638887020892857927%7CUnknown%7CTWFpbGZsb3d8eyJFbXB0eU1hcGkiOnRydWUsIlYiOiIwLjAuMDAwMCIsIlAiOiJXaW4zMiIsIkFOIjoiTWFpbCIsIldUIjoyfQ%3D%3D%7C0%7C%7C%7C&sdata=K9jX985XWCT%2FflAXQT4WZO80%2FBYZTy%2FzV8ZY%2FG%2BOWcs%3D&reserved=0 >> <https://github.com/apache/flink-web/pull/800> >> >> Best, >> Ron >> >> ----------------------------------------------------------------- >> ATTENTION: >> The information in this e-mail is confidential and only meant for the >> intended recipient. If you are not the intended recipient, don't use or >> disclose it in any way. Please let the sender know and delete the message >> immediately. >> ----------------------------------------------------------------- >> >