Re: HTTP or REST SQL Client

[Austin Cawley-Edwards]

Hi Declan,

I think the Flink-sql-gateway[1] is what you’re after, though I’m not sure
of its current state. I’m cc’ing Ingo, who may be able to help direct us.

Best,
Austin

[1]: https://github.com/ververica/flink-sql-gateway

On Sat, Oct 2, 2021 at 10:56 AM Declan Harrison 
wrote:

> Hi All
>
> I know Flink has support for a command line SQL client however I was
> wondering if there is any support for providing a RESTful SQL client over
> HTTP for example?  If not is this something the team would consider
> supporting in the near future?
>
> Thanks
> Declan
>

Error: Timeout of 60000ms expired before the position for partition

[Dipanjan Mazumder]

Hi,
  I am getting below error while starting the flink as a standalone single jvm 
process through jar. The kafka is deployed as a seperate cluster and the 
process is not able to start and fails with below error after 60sec:
org.apache.kafka.common.errors.TimeoutException: Timeout of 6ms expired 
before the position for partition topic_input_si_risk_engine-0 could be 
determined

Not sure of the reason , but don't get this issue when kafka and zookeeper is 
on the same machine as the flink process that is consuming data from kafka.
Any pointers would be helpful.
RegardsDipanjan

HTTP or REST SQL Client

[Declan Harrison]

Hi All

I know Flink has support for a command line SQL client however I was
wondering if there is any support for providing a RESTful SQL client over
HTTP for example?  If not is this something the team would consider
supporting in the near future?

Thanks
Declan

Re: FlinkSQL Source和Sink的Operator name为什么格式不同

[Benchao Li]

Hi Ada,

这应该就是一个实现上的失误：

1.
source的名字是calcite的`TableScan#explainTerms`里面实现的，用的是`explainTerms(pw).item("table",
this.table.getQualifiedName())`
2.
sink里的名字是flink里的`Sink#explainTerms`实现的，用的是`.explainTerms(pw).item("table",
tableIdentifier.asSummaryString())`

yidan zhao  于2021年9月30日周四 上午11:43写道：

> 我猜哈，是因为source支持多张表。比如多个表union支持select的情况。
>
> Ada Luna  于2021年9月29日周三 下午6:02写道：
>
> > Source: TableSourceScan(table=[[default_catalog, default_database,
> > ods_k]], fields=[id, name])
> > Sink: Sink(table=[default_catalog.default_database.ads_k], fields=[id,
> > name])
> > Sink: Sink(table=[default_catalog.default_database.ads_k2], fields=[id,
> > name]))
> >
> >
> > TableSourceScan 和 Sink相比多了个 中括号，并且采用 ',' 分割名字功空间，这是为什么
> >
>


-- 

Best,
Benchao Li