Re: sql multisink explain result is more expensive than expected

should I post in Dev user list ? On Mon, 7 Jun 2021 at 18:56 Luan Cooper wrote: > Hi > > We're using multi sink in sql with view, the TestCase is > > """java > @Test > def testJoinTemporalTableWithViewWithFilterPushDown(): Unit = { >

sql multisink explain result is more expensive than expected

Hi We're using multi sink in sql with view, the TestCase is """java @Test def testJoinTemporalTableWithViewWithFilterPushDown(): Unit = { createLookupTable("LookupTableAsync1", new AsyncTableFunction1) util.addTable( """ |CREATE TEMPORARY VIEW v_vvv AS |SELECT *

sql/table configuration naming guide/style/spec

Hi I've read Sql Configuration guide https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/config.html#execution-options *which is very helpful to write sql like hive* *example on our flink sql ide: * set table.exec.async-lookup.timeout = 3s; insert into xxx select * from xxx *w

Re: How to disconnect taskmanager via rest api?

possibility to achieve > this already? > > Regards, > Timo > > On 21.09.20 06:37, Luan Cooper wrote: > > Hi > > > > We're running flink standalone cluster on k8s > > when deleting a taskmanager pod manually, jobmanager *should disconnect > > it i

How to disconnect taskmanager via rest api?

Hi We're running flink standalone cluster on k8s when deleting a taskmanager pod manually, jobmanager *should disconnect it immediately* however no such rest api available right now we have to wait `akka.tcp.timeout` which means 30s later or more What if I want to disconnect tm via rest api Whic