Meta42

能够找一个复杂的例子具体说明一下么？比如带有子查询的SQL，对应的加工方式应该如何表达。

``` INSERT INTO t2(a, b) SELECT tt1.a AS a, tt1.b AS b FROM ( SELECT a AS a, MAX(t2.b, t1.c) as b FROM (select sum(a) + sum(c) as b from...

> cc @pan3793 @iodone What is the reason for the removal? Is it possible to have the lineage plugin applied to the custom spark engine that is not Kyubi Engine?

@wForget #3444, In order to implement the `PlanOnly` mode of lineage, imported `SQLParserHelper` with spark-lineage-plugin. This will cause the kyuubi spark engine to strongly depend on spark-lineage-plugin. Are you in...

> seems unrelated failure: > > ``` > AdminResourceSuite: > - delete engine - user share level *** FAILED *** > List("serviceUri=localhost:32971;version=1.7.0-SNAPSHOT;refId=8bd0f165-37a6-49cf-af67-d82f7a0b3cbb;sequence=0000000000") had size 1 instead of expected size 0...

> > > seems unrelated failure: > > > ``` > > > AdminResourceSuite: > > > - delete engine - user share level *** FAILED *** > > >...

@zhaomin1423 The `EventBus` implementation of asynchronous processing triggers a thread for each event and does not implement a consumer-production model with the event message queue, too many `OperationEvent` may lead...

> I'm so curious about the result with SQL's lineage~ You can refer to this pr https://github.com/apache/incubator-kyuubi/pull/3185

> Yes, I'm following up on this.

I tried to reproduce the problem with the following example： With Beeline: ``` SET kyuubi.operation.language=scala; spark.sql("add jar file:/Users/work/tmp/jar-test/target/spark_to_cassandra_jars-1.0-SNAPSHOT.jar"); import org.apache.spark.sql.{SaveMode, SparkSession}; import com.datastax.spark.connector.cql.CassandraConnectorConf; import org.apache.spark.sql.cassandra._; spark.setCassandraConf(CassandraConnectorConf.KeepAliveMillisParam.option(10000)); val writeDf = spark.read.parquet("/Users/work/tmp/test.parquet");...