Hi Flavio， If you would like to use have a UI to register data sources, run flink sql and preview the sql result, then you can use zeppelin directly. You can check the tutorial here, 1) Get started https://link.medium.com/oppqD6dIg5 <https://t.co/PTouUYYTrv?amp=1> 2) Batch https://link.medium.com/3qumbwRIg5 <https://t.co/Yo9QAY0Joj?amp=1> 3) Streaming https:// link.medium.com/RBHa2lTIg5 <https://t.co/sUapN40tvI?amp=1> 4) Advanced usage https://link.medium.com/CAekyoXIg5 <https://t.co/MXolULmafZ?amp=1>
And here's one article shared by someone else about how to use flink on zeppelin. https://medium.com/@abdelkrim.hadjidj/event-driven-supply-chain-for-crisis-with-flinksql-be80cb3ad4f9 Besides that, Zeppelin provides rest api which you can use to integarte with other system, but it is not standard jdbc protocol. http://zeppelin.apache.org/docs/0.9.0-preview1/usage/rest_api/notebook.html And I am doing more improvement recently, I will reveal more details in next week's flink forward. https://www.flink-forward.org/sf-2020/conference-program#it%E2%80%99s-finally-here--python-on-flink---flink-on-zeppelin Flavio Pompermaier <pomperma...@okkam.it> 于2020年4月16日周四 下午8:24写道： > Basically we want to give a UI to the user to register its data sources > (i.e. catalogs in the Flink world), preview them (SELECT * LIMIT 100 for > example) but, in the case of JDBC catalogs, also to see relationships and > triggers. > We don't want to reimplement the wheel so we would like to reuse and > contribute to Flink as much as possible (since then in the batch jobs we > use Flink and we don't like to do the same work twice..). > In this way we can contribute to Flink if something is missing in the SQL > Gateway. However I don't know how to extend the existing stuff (for example > if I want table relationships and triggers).. > > Best, > Flavio > > On Thu, Apr 16, 2020 at 1:38 PM godfrey he <godfre...@gmail.com> wrote: > >> Hi Flavio, >> >> Since 1.11(master), Flink supports "CREATE CATALOG ..." [1], >> we can use this statement create catalog dynamically. >> >> Currently, Catalog[2] dose not supports any operations on TRIGGER. >> Flink can't also use such info now. What's your user scenario? >> >> [1] https://issues.apache.org/jira/browse/FLINK-15349 >> [2] >> https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/catalogs.html#catalog-api >> >> Best, >> Godfrey >> >> Flavio Pompermaier <pomperma...@okkam.it> 于2020年4月16日周四 下午6:16写道： >> >>> Hi Godfrey, >>> I'd like to use the SQL gateway as a data proxy in our architecture. >>> However, catalogs in our use case are not know at configuration time.. >>> is there a way to permit to register a JDBC catalog (for example when I >>> want to connect to a Postgres database)? >>> What if I want to add SHOW TRIGGERS? Do you think it could be >>> interesting? >>> >>> On Thu, Apr 16, 2020 at 10:55 AM godfrey he <godfre...@gmail.com> wrote: >>> >>>> Hi Flavio, >>>> >>>> We prose FLIP-91[1] to support SQL Gateway at the beginning of this >>>> year. >>>> After a long discussion, we reached an agreement that >>>> SQL Gateway is an eco-system under ververia as first step.[2] >>>> Which could help SQL Gateway move forward faster. >>>> Now we almost finish first version development, some users are trying >>>> it out. >>>> Any suggestions are welcome! >>>> >>>> [1] >>>> https://docs.google.com/document/d/1DKpFdov1o_ObvrCmU-5xi-VrT6nR2gxq-BbswSSI9j8/edit?ts=5e4cd711#heading=h.sru3xzbt2i1k >>>> [2] https://github.com/ververica/flink-sql-gateway >>>> >>>> Best, >>>> Godfrey >>>> >>>> Flavio Pompermaier <pomperma...@okkam.it> 于2020年4月16日周四 下午4:42写道： >>>> >>>>> Hi Jeff, >>>>> FLIP-24 [1] proposed to develop a SQL gateway to query Flink via SQL >>>>> but since then no progress has been made on that point. Do you think that >>>>> Zeppelin could be used somehow as a SQL Gateway towards Flink for the >>>>> moment? >>>>> Any chance that a Flink SQL Gateway could ever be developed? Is there >>>>> anybody interested in this? >>>>> >>>>> Best, >>>>> Flavio >>>>> >>>>> [1] >>>>> https://cwiki.apache.org/confluence/display/FLINK/FLIP-24+-+SQL+Client >>>>> >>>> -- Best Regards Jeff Zhang
