[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536404#comment-17536404 ] Yuan Zhu commented on FLINK-27191: -- I'm so familiar with hadoop proxy schema. In my mind, the ProxyUser

[jira] [Comment Edited] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525021#comment-17525021 ] Yuan Zhu edited comment on FLINK-27191 at 4/20/22 2:17 PM: --- [~luoyuxia] Your

[jira] [Comment Edited] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525021#comment-17525021 ] Yuan Zhu edited comment on FLINK-27191 at 4/20/22 2:17 PM: --- [~luoyuxia] Your

[jira] [Comment Edited] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525021#comment-17525021 ] Yuan Zhu edited comment on FLINK-27191 at 4/20/22 2:16 PM: --- [~luoyuxia] Your

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525021#comment-17525021 ] Yuan Zhu commented on FLINK-27191: -- [~luoyuxia] Your analysis is right. I miss it.   But there may be

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525019#comment-17525019 ] Yuan Zhu commented on FLINK-27191: -- [~luoyuxia] I check it again and your analysis is right.  >

[jira] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191 ] Yuan Zhu deleted comment on FLINK-27191: -- was (Author: straw): [~luoyuxia] I check it again and your analysis is right.  > Support multi kerberos-enabled Hive clusters >

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522028#comment-17522028 ] Yuan Zhu commented on FLINK-27191: -- There are some static fields, such like

[jira] [Comment Edited] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522028#comment-17522028 ] Yuan Zhu edited comment on FLINK-27191 at 4/14/22 2:44 AM: --- There are some

[jira] [Comment Edited] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521544#comment-17521544 ] Yuan Zhu edited comment on FLINK-27191 at 4/13/22 8:40 AM: --- If user run a

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521544#comment-17521544 ] Yuan Zhu commented on FLINK-27191: -- If user run a kerberos-disabled cluster and access to a

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521408#comment-17521408 ] Yuan Zhu commented on FLINK-27191: -- Then how do we deal with the concurrency of UGI's invoking in TM

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521189#comment-17521189 ] Yuan Zhu commented on FLINK-27191: -- I'm very happy to contribute. > Support multi kerberos-enabled

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521188#comment-17521188 ] Yuan Zhu commented on FLINK-27191: -- But when job starts running, Hive source need to connect

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520931#comment-17520931 ] Yuan Zhu commented on FLINK-27191: -- Hi, [~luoyuxia]. Do you have any idea to deal with it? I have been

[jira] [Closed] (FLINK-26954) Support Kafka bounded read in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-26954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Zhu closed FLINK-26954. Resolution: Duplicate > Support Kafka bounded read in TableAPI > -- >

[jira] [Commented] (FLINK-26954) Support Kafka bounded read in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-26954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515208#comment-17515208 ] Yuan Zhu commented on FLINK-26954: -- Yes, you are right. Sorry for my mistake. > Support Kafka bounded

[jira] [Commented] (FLINK-26954) Support Kafka bounded read in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-26954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515204#comment-17515204 ] Yuan Zhu commented on FLINK-26954: -- Hi, [~MartijnVisser], I'm interested in this ticket, can you assign

[jira] [Created] (FLINK-26954) Support Kafka bounded read in TableAPI

Yuan Zhu created FLINK-26954: Summary: Support Kafka bounded read in TableAPI Key: FLINK-26954 URL: https://issues.apache.org/jira/browse/FLINK-26954 Project: Flink Issue Type: Improvement

[jira] [Comment Edited] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions

[ https://issues.apache.org/jira/browse/FLINK-26938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515121#comment-17515121 ] Yuan Zhu edited comment on FLINK-26938 at 3/31/22, 7:21 AM: I think it will

[jira] [Commented] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions

[ https://issues.apache.org/jira/browse/FLINK-26938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515121#comment-17515121 ] Yuan Zhu commented on FLINK-26938: -- I think it will happen with other sources if only the num of

[jira] [Commented] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions

[ https://issues.apache.org/jira/browse/FLINK-26938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515113#comment-17515113 ] Yuan Zhu commented on FLINK-26938: -- I have reproduce it locally. I found that switchedSources in

[jira] [Commented] (FLINK-25409) Add cache metric to LookupFunction

[ https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512210#comment-17512210 ] Yuan Zhu commented on FLINK-25409: -- Hi, [~martijnvisser], [~jingzhang], [~wenlong.lwl]. I have

[jira] [Commented] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'

[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503331#comment-17503331 ] Yuan Zhu commented on FLINK-26437: -- [~jark] Thanks for your advice. [~arindbha], you can try as [~jark]

[jira] [Commented] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'

[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500459#comment-17500459 ] Yuan Zhu commented on FLINK-26437: -- In my local env(wsl-ubuntu-20.04), I can run "sql-client.sh

[jira] [Updated] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'

[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Zhu updated FLINK-26437: - Attachment: image-2022-03-03-10-03-50-763.png > Cannot discover a connector using option:

[jira] [Commented] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'

[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500215#comment-17500215 ] Yuan Zhu commented on FLINK-26437: -- How do you submit your sql? Are you using sql client locally? >

[jira] [Commented] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'

[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500105#comment-17500105 ] Yuan Zhu commented on FLINK-26437: -- You can try add [hadoop

[jira] [Comment Edited] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'

[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500105#comment-17500105 ] Yuan Zhu edited comment on FLINK-26437 at 3/2/22, 12:28 PM: You can try

[jira] [Commented] (FLINK-26437) Cannot discover a connector using option: 'connector'='jdbc'

[ https://issues.apache.org/jira/browse/FLINK-26437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499843#comment-17499843 ] Yuan Zhu commented on FLINK-26437: -- Do you have

[jira] [Comment Edited] (FLINK-25409) Add cache metric to LookupFunction

[ https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493621#comment-17493621 ] Yuan Zhu edited comment on FLINK-25409 at 2/17/22, 3:08 AM: Hi, all. Sorry

[jira] [Commented] (FLINK-25409) Add cache metric to LookupFunction

[ https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493621#comment-17493621 ] Yuan Zhu commented on FLINK-25409: -- Hi, all. Sorry for my late reply. As discussion before, I make a

[jira] [Commented] (FLINK-25529) java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table

[ https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491959#comment-17491959 ] Yuan Zhu commented on FLINK-25529: -- Replacing orc-core-1.5.6 with orc-core-1.5.6-nohive will invoke

[jira] [Commented] (FLINK-25529) java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table

[ https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491547#comment-17491547 ] Yuan Zhu commented on FLINK-25529: -- [~luoyuxia] You are right that there is no orc-core classes in

[jira] [Commented] (FLINK-25529) java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table

[ https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17488779#comment-17488779 ] Yuan Zhu commented on FLINK-25529: -- [~luoyuxia] I try hive-exec-2.2.0.jar. It will cause Exception:

[jira] [Commented] (FLINK-18779) Support the SupportsFilterPushDown interface for LookupTableSource

[ https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17487402#comment-17487402 ] Yuan Zhu commented on FLINK-18779: -- Hi [~godfreyhe] , I have fixed the conflicts of this pr. Since it

[jira] [Commented] (FLINK-25529) java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table

[ https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486799#comment-17486799 ] Yuan Zhu commented on FLINK-25529: -- [~luoyuxia] If I add the hive-exec-2.1.1.jar and

[jira] [Commented] (FLINK-25529) java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table

[ https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478638#comment-17478638 ] Yuan Zhu commented on FLINK-25529: -- Hi, [~luoyuxia] , thanks for your attention. My hive version is

[jira] [Created] (FLINK-25529) java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table

Yuan Zhu created FLINK-25529: Summary: java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table Key: FLINK-25529 URL:

[jira] [Comment Edited] (FLINK-25409) Add cache metric to LookupFunction

[ https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463553#comment-17463553 ] Yuan Zhu edited comment on FLINK-25409 at 12/22/21, 3:06 AM: - In 1.14.2,

[jira] [Commented] (FLINK-25409) Add cache metric to LookupFunction

[ https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463553#comment-17463553 ] Yuan Zhu commented on FLINK-25409: -- In 1.14.2, neglecting some private LookupFunctions outside of

[jira] [Created] (FLINK-25409) Add cache metric to LookupFunction

Yuan Zhu created FLINK-25409: Summary: Add cache metric to LookupFunction Key: FLINK-25409 URL: https://issues.apache.org/jira/browse/FLINK-25409 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-23687) Add Sql query hint to enable LookupJoin shuffle by join key of left input

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463526#comment-17463526 ] Yuan Zhu commented on FLINK-23687: -- [~jingzhang]  {quote}Could you add the cache metric in connector of

[jira] [Closed] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Zhu closed FLINK-25336. Resolution: Not A Bug > Kafka connector compatible problem in Flink sql >

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460562#comment-17460562 ] Yuan Zhu commented on FLINK-25336: -- [~MartijnVisser]  [~JasonLee] Thanks for your help. I get it. >

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460493#comment-17460493 ] Yuan Zhu commented on FLINK-25336: -- [~MartijnVisser] Thanks. Then what you provided is the

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460431#comment-17460431 ] Yuan Zhu commented on FLINK-25336: -- [~JasonLee] Why not make it configurable to support more versions?

[jira] [Updated] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Zhu updated FLINK-25336: - Docs Text: (was: Kafka connector compatible problem in Flink sql) > Kafka connector compatible

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460391#comment-17460391 ] Yuan Zhu commented on FLINK-25336: -- Hi, [~becket_qin]. What's the purpose here? Can we make

[jira] [Commented] (FLINK-25336) Kafka connector compatible problem in Flink sql

[ https://issues.apache.org/jira/browse/FLINK-25336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460387#comment-17460387 ] Yuan Zhu commented on FLINK-25336: -- The cause of this exception is invoked by the logic in 

[jira] [Created] (FLINK-25336) Kafka connector compatible problem in Flink sql

Yuan Zhu created FLINK-25336: Summary: Kafka connector compatible problem in Flink sql Key: FLINK-25336 URL: https://issues.apache.org/jira/browse/FLINK-25336 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-25262) Support to send data to lookup table for KeyGroupStreamPartitioner way for SQL

[ https://issues.apache.org/jira/browse/FLINK-25262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458120#comment-17458120 ] Yuan Zhu commented on FLINK-25262: -- I think this was proposed before. > Support to send data to

[jira] [Commented] (FLINK-23687) Add Sql query hint to enable LookupJoin shuffle by join key of left input

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452159#comment-17452159 ] Yuan Zhu commented on FLINK-23687: -- At the same time, I suggest adding an option to toggle the cache

[jira] [Commented] (FLINK-23687) Add Sql query hint to enable LookupJoin shuffle by join key of left input

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452135#comment-17452135 ] Yuan Zhu commented on FLINK-23687: -- [~jingzhang] I am willing to review, but I may not have the

[jira] [Commented] (FLINK-23687) Add Sql query hint to enable LookupJoin shuffle by join key of left input

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451860#comment-17451860 ] Yuan Zhu commented on FLINK-23687: -- hi, [~jingzhang] . I'm interested in this ticket, could you assign

[jira] [Comment Edited] (FLINK-18779) Support the SupportsFilterPushDown interface for LookupTableSource

[ https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451536#comment-17451536 ] Yuan Zhu edited comment on FLINK-18779 at 12/1/21, 6:35 AM: Hi, [~twalthr]

[jira] [Commented] (FLINK-18779) Support the SupportsFilterPushDown interface for LookupTableSource

[ https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451536#comment-17451536 ] Yuan Zhu commented on FLINK-18779: -- Hi, [~twalthr] ,[~lzljs3620320], [~matriv], [~slinkydeveloper].

[jira] [Comment Edited] (FLINK-18779) Support the SupportsFilterPushDown interface for LookupTableSource

[ https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451536#comment-17451536 ] Yuan Zhu edited comment on FLINK-18779 at 12/1/21, 6:31 AM: Hi, [~twalthr]

[jira] [Commented] (FLINK-18779) Support the SupportsFilterPushDown interface for LookupTableSource

[ https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17433831#comment-17433831 ] Yuan Zhu commented on FLINK-18779: -- Hi [~jark] , I am interested in this jira. I can fix Shengkai