ParyshevSergey commented on PR #8839: URL: https://github.com/apache/incubator-gluten/pull/8839#issuecomment-2705617976
> @ParyshevSergey , your query runs well in my side, could you give more logs? [log.txt](https://github.com/user-attachments/files/19121180/log.txt) I attache the log. Also add some information, in OpenSource Flink 1.20 i create module flink-examples-gluten with all needed dependencies, in this module i run the job. ```java package org.apache.flink.examples.gluten; import io.github.zhztheplayer.velox4j.Velox4j; import org.apache.flink.configuration.Configuration; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.table.api.bridge.java.StreamTableEnvironment; import java.util.concurrent.ExecutionException; public class TestJob { public static void main(String[] args) throws ExecutionException, InterruptedException { Velox4j.initialize(); Configuration conf = new Configuration(); StreamExecutionEnvironment see = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(conf); see.setParallelism(1); StreamTableEnvironment ste = StreamTableEnvironment.create(see); ste.executeSql( "create table srcTbl (id int, price int, name string) WITH ('connector'='datagen')"); ste.executeSql("create table snkTbl (id int, price int) WITH ('connector'='blackhole')"); ste.executeSql("insert into snkTbl select id, price from srcTbl where price > 10").await(); } } ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
