Re: Re: [VOTE] FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table

+1 (binding) Best, Shengkai Ron Liu 于2024年5月10日周五 12:07写道： > +1(binding) > > Best, > Ron > > Jark Wu 于2024年5月10日周五 09:51写道： > > > +1 (binding) > > > > Best, > > Jark > > > > On Thu, 9 May 2024 at 21:27, Lincoln Lee wrote: > > > > > +1 (binding) > > > > > > Best, > > > Lincoln Lee > > > > > >

Re: [DISCUSS] FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table

Hi, Liu. Thanks for your proposal. I have some questions about the FLIP: *WorkflowScheduler* 1. How to get the exception details if `modifyRefreshWorkflow` fails? 2. Could you give us an example about how to configure the scheduler? *SQL Gateway* 1. SqlGatewayService requires Session as the

Re: [DISCUSS][FLINK-31830] Align the Nullability Handling of ROW between SQL and TableAPI

Thanks for Jane and Sergey's proposal! +1 to correct the Table API behavior. I have one question: Is the influence only limited to the RowType? Does the Map or Array type have the same problems? Best, Shengkai [DISCUSS][FLINK-31830] Align the Nullability Handling of ROW between SQL and TableA

Re: Re: Re: Re: [DISCUSS] FLIP-392: Deprecate the Legacy Group Window Aggregation

ndow_start, > window_end(window_start and window_end is produced by WINDOW TVF). We can > use field index here and use a new Calc node to alias them to avoid field > name conflict in WindowAggregate node. > What about this idea, cc @Shengkai Fang ? > > >I would propose to re

Re: [PROPOSAL] Contribute Flink CDC Connectors project to Apache Flink

Thanks for all Flink CDC maintainers great work! Big +1. Best, Shengkai tison 于2023年12月7日周四 12:01写道： > This is very cool! +1 from my side. > > Best, > tison. > > Benchao Li 于2023年12月7日周四 11:56写道： > > > > Thank you, Leonard and all the Flink CDC maintainers. > > > > Big big +1 from me. As a

Re: Re: [DISCUSS] FLIP-392: Deprecate the Legacy Group Window Aggregation

Hi, Xuyang. Thanks for your great work. Big +1! After reading the FLIP, I have some questions. Please read the content below. 1. Support SESSION Window TVF Aggregation a. Could you give an example about the pass-through column? A session window may contain multiple rows, which value is

[jira] [Created] (FLINK-33490) Validate the name conflicts when creating view

Shengkai Fang created FLINK-33490: - Summary: Validate the name conflicts when creating view Key: FLINK-33490 URL: https://issues.apache.org/jira/browse/FLINK-33490 Project: Flink Issue Type

[jira] [Created] (FLINK-33446) SubQueryAntiJoinTest#testMultiNotExistsWithCorrelatedOnWhere_NestedCorrelation doesn't produce the correct plan

Shengkai Fang created FLINK-33446: - Summary: SubQueryAntiJoinTest#testMultiNotExistsWithCorrelatedOnWhere_NestedCorrelation doesn't produce the correct plan Key: FLINK-33446 URL: https://issues.apache.org/jira

[jira] [Created] (FLINK-33226) Forbid to drop current database

Shengkai Fang created FLINK-33226: - Summary: Forbid to drop current database Key: FLINK-33226 URL: https://issues.apache.org/jira/browse/FLINK-33226 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-32618) Remove the dependency of the flink-core in the flink-sql-jdbc-driver-bundle

Shengkai Fang created FLINK-32618: - Summary: Remove the dependency of the flink-core in the flink-sql-jdbc-driver-bundle Key: FLINK-32618 URL: https://issues.apache.org/jira/browse/FLINK-32618

[jira] [Created] (FLINK-32617) FlinkResultSetMetaData throw exception for most methods

Shengkai Fang created FLINK-32617: - Summary: FlinkResultSetMetaData throw exception for most methods Key: FLINK-32617 URL: https://issues.apache.org/jira/browse/FLINK-32617 Project: Flink

[jira] [Created] (FLINK-32616) FlinkStatement#executeQuery resource leaks when the input sql is not query

Shengkai Fang created FLINK-32616: - Summary: FlinkStatement#executeQuery resource leaks when the input sql is not query Key: FLINK-32616 URL: https://issues.apache.org/jira/browse/FLINK-32616 Project

Re: [DISCUSS] FLIP-316: Introduce SQL Driver

same as YARN setups. We could make follow-up discussions > in the jira > tickets. > > Best, > Paul Lam > > 2023年6月12日 15:29，Shengkai Fang 写道： > > > > If it’s the case, I’m good with introducing a new module and making SQL > Driver > > an internal class and a

Re: [DISCUSS] FLIP-316: Introduce SQL Driver

ability is useful for > > Java or Stream API applications. Maybe this is even a non-goal to your > FLIP > > since you are focusing on the driver entrypoint. > > > > Jark mentioned some optimizations: > > > > This allows SQLGateway to leverage some metadata c

[jira] [Created] (FLINK-32299) Upload python jar when sql contains python udf jar

Shengkai Fang created FLINK-32299: - Summary: Upload python jar when sql contains python udf jar Key: FLINK-32299 URL: https://issues.apache.org/jira/browse/FLINK-32299 Project: Flink Issue

Re: [DISCUSS] FLIP-316: Introduce SQL Driver

Hi. Paul. Thanks for your update and the update makes me understand the design much better. But I still have some questions about the FLIP. > For SQL Gateway, only DMLs need to be delegated to the SQL server > Driver. I would think about the details and update the FLIP. Do you have some > ideas

Re: [DISCUSS] FLIP-316: Introduce SQL Driver

Thanks for the proposal. The Application mode is very important to Flink SQL. But I have some questions about the FLIP: 1. The FLIP does not specify the kind of SQL that will be submitted with the application mode. I believe only a portion of the SQL will be delegated to the SqlRunner. 2. Will

Re: [ANNOUNCE] New Apache Flink PMC Member - Qingsheng Ren

Congratulations, Qingsheng! Best regards, Shengkai Qingsheng Ren 于2023年4月24日周一 19:53写道： > Thank you all! I'm so honored and happy to work with all contributors in > the Apache Flink community. Let's make Flink better together! > > Cheers, > Qingsheng > > On Mon, Apr 24, 2023 at 3:39 PM Jing

Re: [ANNOUNCE] New Apache Flink PMC Member - Leonard Xu

Congratulations, Leonard! Best regards, Shengkai Zakelly Lan 于2023年4月24日周一 15:36写道： > Congratulations, Leonard! > > > Best regards, > Zakelly > > On Mon, Apr 24, 2023 at 3:25 PM Jing Ge > wrote: > > > > Congrats! Leonard! > > > > > > > > Best regards, > > > > Jing > > > > On Mon, Apr 24,

Re: [DISCUSS] FLIP-292: Support configuring state TTL at operator level for Table API & SQL programs

Hi, Jane. Thanks for driving this FLIP and this feature are very useful to many users. But I have two problems about the FLIP: 1. How the Gateway users use this feature? As far as I know, the EXEUCTE PLAN only supports local file right now. Is it possible to extend this syntax to allow for

[jira] [Created] (FLINK-31403) CliClientITCase print unexpected border when printing explain results

Shengkai Fang created FLINK-31403: - Summary: CliClientITCase print unexpected border when printing explain results Key: FLINK-31403 URL: https://issues.apache.org/jira/browse/FLINK-31403 Project

[jira] [Created] (FLINK-31175) Fix link doesn't work in hive_reaad_write doc

Shengkai Fang created FLINK-31175: - Summary: Fix link doesn't work in hive_reaad_write doc Key: FLINK-31175 URL: https://issues.apache.org/jira/browse/FLINK-31175 Project: Flink Issue Type

[jira] [Created] (FLINK-31137) SQL Client doesn't print results for SHOW CREATE TABLE/DESC in hive dialect

Shengkai Fang created FLINK-31137: - Summary: SQL Client doesn't print results for SHOW CREATE TABLE/DESC in hive dialect Key: FLINK-31137 URL: https://issues.apache.org/jira/browse/FLINK-31137

[jira] [Created] (FLINK-31136) SQL Client Gateway mode should not read read execution config

Shengkai Fang created FLINK-31136: - Summary: SQL Client Gateway mode should not read read execution config Key: FLINK-31136 URL: https://issues.apache.org/jira/browse/FLINK-31136 Project: Flink

[jira] [Created] (FLINK-31132) Set sink.parallelism doesn't work for Hive table

Shengkai Fang created FLINK-31132: - Summary: Set sink.parallelism doesn't work for Hive table Key: FLINK-31132 URL: https://issues.apache.org/jira/browse/FLINK-31132 Project: Flink Issue

Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin

Congratulations! Best, Shengkai Danny Cranmer 于2023年2月17日周五 18:42写道： > Congrats and welcome to the team! > > > On Fri, Feb 17, 2023 at 10:03 AM Benchao Li wrote: > > > Congratulations, Dong! > > > > Lincoln Lee 于2023年2月17日周五 17:42写道： > > > > > Congratulations, Dong! > > > > > > Best, > > >

Re: [ANNOUNCE] New Apache Flink Committer - Weijie Guo

Congratulations! Best, Shengkai Feng Jin 于2023年2月14日周二 14:21写道： > Congratulations! Weijie > > Best, > Feng > > On Tue, Feb 14, 2023 at 2:19 PM Leonard Xu wrote: > > > > Congratulations! Weijie > > > > Best, > > Leonard >

Re: [ANNOUNCE] New Apache Flink Committer - Jing Ge

Congratulations! Best, Shengkai Yanfei Lei 于2023年2月15日周三 10:08写道： > Congratulations, Jing Ge ! > > Best regards, > Yanfei > > yuxia 于2023年2月15日周三 09:34写道： > > > > Congratulations, Jing Ge ! > > > > Best regards, > > Yuxia > > > > - 原始邮件 - > > 发件人: "Jark Wu" > > 收件人: "dev" > > 发送时间:

Re: Confusion about some overlapping functionality of SupportsProjectionPushDown and SupportsReadingMetadata

Hi, Ran. I think it's a little difficult to split the rule into two parts. Because the ProjectDown and ReadingMetadata both need to reorder the fields. The ReadingMetadata requires the metadata columns to be at the last and the ProjectPushDown now is responsible to reorder the columns as the user

Re: [Discuss] :Introduce Catalog dynamic registration in flink catalog manager.

Hi Feng. I think your idea is very interesting! 1. I just wonder after initializing the Catalog, will the Session reuse the same Catalog instance or build a new one for later usage? If we reuse the same Catalog, I think it's more like lazy initialization. I am a little prone to rebuild a new one

[jira] [Created] (FLINK-30970) Fix SQL Client doc still uses old style output

Shengkai Fang created FLINK-30970: - Summary: Fix SQL Client doc still uses old style output Key: FLINK-30970 URL: https://issues.apache.org/jira/browse/FLINK-30970 Project: Flink Issue Type

[jira] [Created] (FLINK-30925) Add docs for the SQL Client gateway mode

Shengkai Fang created FLINK-30925: - Summary: Add docs for the SQL Client gateway mode Key: FLINK-30925 URL: https://issues.apache.org/jira/browse/FLINK-30925 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-30868) Revert to use LongSerializer for seralization in the TimeIndicatorTypeInfo

Shengkai Fang created FLINK-30868: - Summary: Revert to use LongSerializer for seralization in the TimeIndicatorTypeInfo Key: FLINK-30868 URL: https://issues.apache.org/jira/browse/FLINK-30868 Project

[jira] [Created] (FLINK-30840) Fix resource leak when creating Executor

Shengkai Fang created FLINK-30840: - Summary: Fix resource leak when creating Executor Key: FLINK-30840 URL: https://issues.apache.org/jira/browse/FLINK-30840 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-30827) Improve the SQL Client code structure

Shengkai Fang created FLINK-30827: - Summary: Improve the SQL Client code structure Key: FLINK-30827 URL: https://issues.apache.org/jira/browse/FLINK-30827 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-30819) Fix history file records incomplete statement sets

Shengkai Fang created FLINK-30819: - Summary: Fix history file records incomplete statement sets Key: FLINK-30819 URL: https://issues.apache.org/jira/browse/FLINK-30819 Project: Flink Issue

[jira] [Created] (FLINK-30816) Fix Sql Client always uses the packaged highests version to connect to gateway

Shengkai Fang created FLINK-30816: - Summary: Fix Sql Client always uses the packaged highests version to connect to gateway Key: FLINK-30816 URL: https://issues.apache.org/jira/browse/FLINK-30816

[jira] [Created] (FLINK-30811) Fix sql gateway can not stop job correctly

Shengkai Fang created FLINK-30811: - Summary: Fix sql gateway can not stop job correctly Key: FLINK-30811 URL: https://issues.apache.org/jira/browse/FLINK-30811 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30810) Rework the CliClientITCase to extend AbstractSqlGatewayStatementITCase

Shengkai Fang created FLINK-30810: - Summary: Rework the CliClientITCase to extend AbstractSqlGatewayStatementITCase Key: FLINK-30810 URL: https://issues.apache.org/jira/browse/FLINK-30810 Project

[jira] [Created] (FLINK-30692) Introduce embedded session manager to support REMOVE JAR

Shengkai Fang created FLINK-30692: - Summary: Introduce embedded session manager to support REMOVE JAR Key: FLINK-30692 URL: https://issues.apache.org/jira/browse/FLINK-30692 Project: Flink

[jira] [Created] (FLINK-30691) Sql Client supports to specify endpoint address

Shengkai Fang created FLINK-30691: - Summary: Sql Client supports to specify endpoint address Key: FLINK-30691 URL: https://issues.apache.org/jira/browse/FLINK-30691 Project: Flink Issue Type

[jira] [Created] (FLINK-30675) Decompose printing logic from Executor

Shengkai Fang created FLINK-30675: - Summary: Decompose printing logic from Executor Key: FLINK-30675 URL: https://issues.apache.org/jira/browse/FLINK-30675 Project: Flink Issue Type: Sub

Re: [VOTE] FLIP-279 Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode

+1(binding) Best, Shengkai Jark Wu 于2023年1月12日周四 19:22写道： > +1 (binding) > Thank you for driving this effort. > > Best, > Jark > > > 2023年1月9日 15:46，Jing Ge 写道： > > > > Hi, > > > > I'd like to start a vote on FLIP-279 Unified the max display column width > > for SqlClient and Table APi in

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

Congratulations, Lincoln! Best, Shengkai liu ron 于2023年1月12日周四 09:48写道： > Congratulations, Lincoln! > > Best > > Yu Li 于2023年1月12日周四 09:22写道： > > > Congratulations, Lincoln! > > > > Best Regards, > > Yu > > > > > > On Wed, 11 Jan 2023 at 21:17, Martijn Visser > > wrote: > > > > >

[jira] [Created] (FLINK-30554) Remove useless session id in the Sql Client Executor

Shengkai Fang created FLINK-30554: - Summary: Remove useless session id in the Sql Client Executor Key: FLINK-30554 URL: https://issues.apache.org/jira/browse/FLINK-30554 Project: Flink Issue

Re: [DISCUSS] FLIP-280: Introduce a new explain mode to provide SQL advice

Sorry for the missing answer about the configuration of the Analyzer. Users may don't need to configure this with SQL statements. In the SQL Gateway, users can configure the endpoints with the option `sql-gateway.endpoint.type` in the flink-conf. Best, Shengkai Shengkai Fang 于2023年1月3日周二 12:26写

Re: [DISCUSS] FLIP-280: Introduce a new explain mode to provide SQL advice

Hi, Jane. Thanks for bringing this to the discussion. I have some questions about the FLIP: 1. `PlanAnalyzer#analyze` uses the FlinkRelNode as the input. Could you share some thoughts about the motivation? In my experience, users mainly care about 2 things when they develop their job: a. Why

[jira] [Created] (FLINK-30497) Introduce TableChange to represent DROP change

Shengkai Fang created FLINK-30497: - Summary: Introduce TableChange to represent DROP change Key: FLINK-30497 URL: https://issues.apache.org/jira/browse/FLINK-30497 Project: Flink Issue Type

[jira] [Created] (FLINK-30496) Introduce TableChange to represent MODIFY change

Shengkai Fang created FLINK-30496: - Summary: Introduce TableChange to represent MODIFY change Key: FLINK-30496 URL: https://issues.apache.org/jira/browse/FLINK-30496 Project: Flink Issue

[jira] [Created] (FLINK-30495) Introduce TableChange to represents ADD change

Shengkai Fang created FLINK-30495: - Summary: Introduce TableChange to represents ADD change Key: FLINK-30495 URL: https://issues.apache.org/jira/browse/FLINK-30495 Project: Flink Issue Type

[jira] [Created] (FLINK-30494) Introduce TableChange to represents table option modification

Shengkai Fang created FLINK-30494: - Summary: Introduce TableChange to represents table option modification Key: FLINK-30494 URL: https://issues.apache.org/jira/browse/FLINK-30494 Project: Flink

[jira] [Created] (FLINK-30493) FLIP 273: Improve the Catalog API to Support ALTER TABLE syntax

Shengkai Fang created FLINK-30493: - Summary: FLIP 273: Improve the Catalog API to Support ALTER TABLE syntax Key: FLINK-30493 URL: https://issues.apache.org/jira/browse/FLINK-30493 Project: Flink

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

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

want to start the vote > on Thursday. > >> > >> > >> Best, > >> Yu Zelin > >> > >>> 2022年12月13日 16:23，yu zelin yuzelin@gmail.com>> 写道： > >>> > >>> Hi, Timo, > >>> > >>> Thanks f

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: > > > > > >

[jira] [Created] (FLINK-30416) Add configureSession REST API in the SQL Gateway

Shengkai Fang created FLINK-30416: - Summary: Add configureSession REST API in the SQL Gateway Key: FLINK-30416 URL: https://issues.apache.org/jira/browse/FLINK-30416 Project: Flink Issue

[RESULT][VOTE] FLIP-273: Improve the Catalog API to Support ALTER TABLE syntax

(no-binding), Jing Ge(no-binding), Shengkai Fang(binding) There were no votes against it. Best, Shengkai [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-273%3A+Improve+the+Catalog+API+to+Support+ALTER+TABLE+syntax

Re: [VOTE] FLIP-273: Improve Catalog API to Support ALTER TABLE syntax

- > > > > > 发件人: "Yaroslav Tkachenko" > > > > > 收件人: "dev" > > > > > 发送时间: 星期五, 2022年 12 月 02日 上午 12:27:24 > > > > > 主题: Re: [VOTE] FLIP-273: Improve Catalog API to Support ALTER TABLE > > > > syntax > > > > > &

[VOTE] FLIP-273: Improve Catalog API to Support ALTER TABLE syntax

Hi All, Thanks for all the feedback so far. Based on the discussion[1] we seem to have a consensus, so I would like to start a vote on FLIP-273. The vote will last for at least 72 hours (Dec 5th at 13:00 GMT, excluding weekend days) unless there is an objection or insufficient votes. Best,

Re: [DISCUSS] FLIP-273: Improve Catalog API to Support ALTER TABLE syntax

Hi, Considering there has been no response for a long time, I want to start the vote on Thursday. Best, Shengkai Jingsong Li 于2022年11月24日周四 15:20写道： > Thanks for the update! > > Looks good to me. > > Best, > Jingsong > > On Thu, Nov 24, 2022 at 3:07 PM Shengkai

Re: SQL Gateway and SQL Client

Hi, Jim and Alexey. We have written the proposal[1]. It would be appreciated if you can give us some feedback. Best, Shengkai [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-275%3A+Support+Remote+SQL+Client+Based+on+SQL+Gateway yu zelin 于2022年11月24日周四 12:06写道： > Hi Jim, > Sorry

Re: [DISCUSS] FLIP-273: Improve Catalog API to Support ALTER TABLE syntax

Hi, Jingsong. Thanks for your feedback! > Can we define classes at once so that the connector can be fully implemented, but we will not pass changes of the nested column. It's hard to achieve this. If a new need comes, we will add a new kind of TableChange. But I think the current proposal

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

Congratulations, Godfrey and Xingbo! Best, Shengkai Shuo Cheng 于2022年11月24日周四 10:56写道： > Congratulations, Godfrey and Xingbo! > > Best, > Shuo > > On Wed, Nov 23, 2022 at 12:19 PM Dian Fu wrote: > > > Hi everyone, > > > > On behalf of the Apache Flink PMC, I'm very happy to announce that >

[DISCUSS] FLIP-273: Improve Catalog API to Support ALTER TABLE syntax

Hi, dev. I want to start a discussion about the FLIP-273: Improve Catalog API to Support ALTER TABLE syntax[1]. The motivation of the FLIP is the current Catalog API is difficult for some Catalog to alter the table. For example, the Catalog only exposes void alterTable(ObjectPath tablePath,

Re: SQL Gateway and SQL Client

In that case, being able to pass headers would allow for > additional options / features. > > I see several PRs from Yu Zelin. Is there a first one to review? > > Cheers, > > Jim > > On Thu, Nov 10, 2022 at 9:42 PM Shengkai Fang wrote: > > > Hi, Jim. > >

Re: SQL Gateway and SQL Client

edback. > > The doc is at: > > > https://docs.google.com/document/d/14cS4VBSamMUnlM_PZuK6QKLfriUuQU51iqET5oiYy_c/edit?usp=sharing > > > > > 2022年11月7日 11:19，Shengkai Fang 写道： > > > > > > Hi, all. Sorry for the late reply. > > > > &g

Re: SQL Gateway and SQL Client

etc. It would be much > appreciated! > > -Jamie Grier > > > On 2022/10/28 06:06:49 Shengkai Fang wrote: > > Hi. > > > > > Is there a possibility for us to get engaged and at least introduce > > initial changes to support authentication/authorizatio

[jira] [Created] (FLINK-29875) Can not find JobConf when using Hive Connector

Shengkai Fang created FLINK-29875: - Summary: Can not find JobConf when using Hive Connector Key: FLINK-29875 URL: https://issues.apache.org/jira/browse/FLINK-29875 Project: Flink Issue Type

Re: [ANNOUNCE] Apache Flink 1.16.0 released

Congratulations! Best, Shengkai Hangxiang Yu 于2022年10月31日周一 09:38写道： > Congratulations! > Thanks Chesnay, Martijn, Godfrey & Xingbo for managing the release. > > On Fri, Oct 28, 2022 at 7:35 PM Jing Ge wrote: > > > Congrats! > > > > On Fri, Oct 28, 2022 at 1:22 PM 任庆盛 wrote: > > > >>

Re: SQL Gateway and SQL Client

about it or some draft design? > > Thanks, > Alexey > > > On Fri, Oct 21, 2022 at 1:13 AM Shengkai Fang wrote: > >> Sorry for the late response. >> >> In the next version(Flink 1.17), we plan to support the SQL Client to >> submit the statement to t

[jira] [Created] (FLINK-29734) Support authentication in the Flink SQL Gateway

Shengkai Fang created FLINK-29734: - Summary: Support authentication in the Flink SQL Gateway Key: FLINK-29734 URL: https://issues.apache.org/jira/browse/FLINK-29734 Project: Flink Issue Type

Re: SQL Gateway and SQL Client

Sorry for the late response. In the next version(Flink 1.17), we plan to support the SQL Client to submit the statement to the Flink SQL Gateway. The FLINK-29486 is the first step to remove the usage of the `Parser` in the client side, which

Re: Utilizing Kafka headers in Flink Kafka connector

hi. You can use SQL API to parse or write the header in the Kafka record[1] if you are using Flink SQL. Best, Shengkai [1] https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/kafka/#available-metadata Yaroslav Tkachenko 于2022年10月13日周四 02:21写道： > Hi, > > You can

[jira] [Created] (FLINK-29229) Fix HiveServer2 Endpoint doesn't support execute statements in sync mode

Shengkai Fang created FLINK-29229: - Summary: Fix HiveServer2 Endpoint doesn't support execute statements in sync mode Key: FLINK-29229 URL: https://issues.apache.org/jira/browse/FLINK-29229 Project

[jira] [Created] (FLINK-29228) Align the schema of the HiveServer2 getMetadata with JDBC

Shengkai Fang created FLINK-29228: - Summary: Align the schema of the HiveServer2 getMetadata with JDBC Key: FLINK-29228 URL: https://issues.apache.org/jira/browse/FLINK-29228 Project: Flink

[jira] [Created] (FLINK-29188) The option `sql-gateway.endpint.hiveserver2.catalog.hive-conf-dir` should be requried

Shengkai Fang created FLINK-29188: - Summary: The option `sql-gateway.endpint.hiveserver2.catalog.hive-conf-dir` should be requried Key: FLINK-29188 URL: https://issues.apache.org/jira/browse/FLINK-29188

[jira] [Created] (FLINK-29185) Failed to execute USING JAR in Hive Dialect

Shengkai Fang created FLINK-29185: - Summary: Failed to execute USING JAR in Hive Dialect Key: FLINK-29185 URL: https://issues.apache.org/jira/browse/FLINK-29185 Project: Flink Issue Type

[jira] [Created] (FLINK-29184) SQL Gateway should remove the downloaded resources

Shengkai Fang created FLINK-29184: - Summary: SQL Gateway should remove the downloaded resources Key: FLINK-29184 URL: https://issues.apache.org/jira/browse/FLINK-29184 Project: Flink Issue

[jira] [Created] (FLINK-29152) Describe statement resutls is different from the Hive

Shengkai Fang created FLINK-29152: - Summary: Describe statement resutls is different from the Hive Key: FLINK-29152 URL: https://issues.apache.org/jira/browse/FLINK-29152 Project: Flink

[jira] [Created] (FLINK-29151) SHOW CREATE TABLE doesn't work for Hive dialect

Shengkai Fang created FLINK-29151: - Summary: SHOW CREATE TABLE doesn't work for Hive dialect Key: FLINK-29151 URL: https://issues.apache.org/jira/browse/FLINK-29151 Project: Flink Issue Type

[jira] [Created] (FLINK-29148) Add docs for SQL Gateway

Shengkai Fang created FLINK-29148: - Summary: Add docs for SQL Gateway Key: FLINK-29148 URL: https://issues.apache.org/jira/browse/FLINK-29148 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29118) Remove default_catalog in the HiveServer2 Endpoint

Shengkai Fang created FLINK-29118: - Summary: Remove default_catalog in the HiveServer2 Endpoint Key: FLINK-29118 URL: https://issues.apache.org/jira/browse/FLINK-29118 Project: Flink Issue

[jira] [Created] (FLINK-29073) [FLIP-91] Support SQL Gateway(Part 2)

Shengkai Fang created FLINK-29073: - Summary: [FLIP-91] Support SQL Gateway(Part 2) Key: FLINK-29073 URL: https://issues.apache.org/jira/browse/FLINK-29073 Project: Flink Issue Type: New

[jira] [Created] (FLINK-29000) Support python UDF in the SQL Gateway

Shengkai Fang created FLINK-29000: - Summary: Support python UDF in the SQL Gateway Key: FLINK-29000 URL: https://issues.apache.org/jira/browse/FLINK-29000 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-28954) Release Testing: Verify HiveServer2 Endpoint

Shengkai Fang created FLINK-28954: - Summary: Release Testing: Verify HiveServer2 Endpoint Key: FLINK-28954 URL: https://issues.apache.org/jira/browse/FLINK-28954 Project: Flink Issue Type

[jira] [Created] (FLINK-28953) Release Testing: Verify FLIP-91 SQL Gateway

Shengkai Fang created FLINK-28953: - Summary: Release Testing: Verify FLIP-91 SQL Gateway Key: FLINK-28953 URL: https://issues.apache.org/jira/browse/FLINK-28953 Project: Flink Issue Type

[jira] [Created] (FLINK-28938) Fix HiveServer2 Endpoint can not set variable correctly

Shengkai Fang created FLINK-28938: - Summary: Fix HiveServer2 Endpoint can not set variable correctly Key: FLINK-28938 URL: https://issues.apache.org/jira/browse/FLINK-28938 Project: Flink

[jira] [Created] (FLINK-28937) Add doc for SqlGateway

Shengkai Fang created FLINK-28937: - Summary: Add doc for SqlGateway Key: FLINK-28937 URL: https://issues.apache.org/jira/browse/FLINK-28937 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28936) Fix RSET endpoint can not serialize CHAR(0)

Shengkai Fang created FLINK-28936: - Summary: Fix RSET endpoint can not serialize CHAR(0) Key: FLINK-28936 URL: https://issues.apache.org/jira/browse/FLINK-28936 Project: Flink Issue Type

[jira] [Created] (FLINK-28851) Allow to GetTypeInfo in the HiveServer2 Endpoint

Shengkai Fang created FLINK-28851: - Summary: Allow to GetTypeInfo in the HiveServer2 Endpoint Key: FLINK-28851 URL: https://issues.apache.org/jira/browse/FLINK-28851 Project: Flink Issue

[jira] [Created] (FLINK-28793) Allow to GetInfo for HiveServer2 Endpoint

Shengkai Fang created FLINK-28793: - Summary: Allow to GetInfo for HiveServer2 Endpoint Key: FLINK-28793 URL: https://issues.apache.org/jira/browse/FLINK-28793 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-28723) Support json format to serialize the MapData when its key is not STRING

Shengkai Fang created FLINK-28723: - Summary: Support json format to serialize the MapData when its key is not STRING Key: FLINK-28723 URL: https://issues.apache.org/jira/browse/FLINK-28723 Project

[jira] [Created] (FLINK-28633) Allow to GetTables in the HiveServer2 Endpoint

Shengkai Fang created FLINK-28633: - Summary: Allow to GetTables in the HiveServer2 Endpoint Key: FLINK-28633 URL: https://issues.apache.org/jira/browse/FLINK-28633 Project: Flink Issue Type

[jira] [Created] (FLINK-28632) Allow to GetColumns/GetTableTypes/GetPrimaryKeys in the HiveServer2 Endpoint

Shengkai Fang created FLINK-28632: - Summary: Allow to GetColumns/GetTableTypes/GetPrimaryKeys in the HiveServer2 Endpoint Key: FLINK-28632 URL: https://issues.apache.org/jira/browse/FLINK-28632

[jira] [Created] (FLINK-28630) Allow to GetSchemas in the HiveServer2 Endpoint

Shengkai Fang created FLINK-28630: - Summary: Allow to GetSchemas in the HiveServer2 Endpoint Key: FLINK-28630 URL: https://issues.apache.org/jira/browse/FLINK-28630 Project: Flink Issue Type

[jira] [Created] (FLINK-28631) Allow to GetFunctions in the HiveServer2 Endpoint

Shengkai Fang created FLINK-28631: - Summary: Allow to GetFunctions in the HiveServer2 Endpoint Key: FLINK-28631 URL: https://issues.apache.org/jira/browse/FLINK-28631 Project: Flink Issue

[jira] [Created] (FLINK-28629) Allow to getCatalogs in the HiveServer2 Endpoint

Shengkai Fang created FLINK-28629: - Summary: Allow to getCatalogs in the HiveServer2 Endpoint Key: FLINK-28629 URL: https://issues.apache.org/jira/browse/FLINK-28629 Project: Flink Issue

Re: [VOTE] FLIP-240: Introduce "ANALYZE TABLE" Syntax

+1 Best, Shengkai Jingsong Li 于2022年6月28日周二 10:05写道： > +1 > > Best, > Jingsong > > On Fri, Jun 24, 2022 at 11:08 PM godfrey he wrote: > > > > Hi everyone, > > > > Thanks for all the feedback so far. Based on the discussion[1] we seem > > to have consensus, so I would like to start a vote on

[jira] [Created] (FLINK-28238) Fix unstable testCancelOperationAndFetchResultInParallel

Shengkai Fang created FLINK-28238: - Summary: Fix unstable testCancelOperationAndFetchResultInParallel Key: FLINK-28238 URL: https://issues.apache.org/jira/browse/FLINK-28238 Project: Flink

[jira] [Created] (FLINK-28164) Introduce utilities API for REST endpint

Shengkai Fang created FLINK-28164: - Summary: Introduce utilities API for REST endpint Key: FLINK-28164 URL: https://issues.apache.org/jira/browse/FLINK-28164 Project: Flink Issue Type: Sub

  1   2   3   >