Leopold-Xu opened a new issue, #1446:
URL: https://github.com/apache/sedona/issues/1446
## Expected behavior
i hope this proble solved,print result like this,Thanks!:
+----+--------------------------------+--------------------------------+
| op | geom_polygon | name_polygon |
+----+--------------------------------+--------------------------------+
| +I | POLYGON ((-0.5 -0.5, -0.5 0... | polygon0 |
| +I | POLYGON ((0.5 0.5, 0.5 1.5,... | polygon1 |
| +I | POLYGON ((1.5 1.5, 1.5 2.5,... | polygon2 |
| +I | POLYGON ((2.5 2.5, 2.5 3.5,... | polygon3 |
| +I | POLYGON ((3.5 3.5, 3.5 4.5,... | polygon4 |
| +I | POLYGON ((4.5 4.5, 4.5 5.5,... | polygon5 |
| +I | POLYGON ((5.5 5.5, 5.5 6.5,... | polygon6 |
| +I | POLYGON ((6.5 6.5, 6.5 7.5,... | polygon7 |
| +I | POLYGON ((7.5 7.5, 7.5 8.5,... | polygon8 |
| +I | POLYGON ((8.5 8.5, 8.5 9.5,... | polygon9 |
+----+--------------------------------+--------------------------------+
10 rows in set
## Actual behavior
**this is java code:**
```
public void test() {
StreamExecutionEnvironment env =
StreamExecutionEnvironment.createRemoteEnvironment("192.168.0.102",8081,
"C:/Users/15218/Desktop/quickstart/jars/flink-connector-jdbc-3.1.2-1.18.jar",
"C:/Users/15218/Desktop/quickstart/jars/postgresql-42.7.3.jar"
);
EnvironmentSettings settings =
EnvironmentSettings.newInstance().inStreamingMode().build();
StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env,
settings);
StreamTableEnvironment send = SedonaContext.create(env, tableEnv);
String sourceSql = "SELECT id,age,wkt FROM test";
String postgresSinkDDL = "CREATE TABLE source_table (\n" +
" id INT,\n" +
" age INT,\n" +
" wkt STRING,\n" +
" PRIMARY KEY (id) NOT ENFORCED\n" +
") WITH (\n" +
" 'connector' = 'jdbc',\n" +
" 'url' = 'jdbc:postgresql://192.168.0.102:5432/jjlbsdb',\n"+
" 'table-name' = 'test',\n" +
" 'driver' = 'org.postgresql.Driver',\n" +
" 'username' = 'postgres',\n" +
" 'password' ='postgres'\n" +
")";
tableEnv.executeSql(postgresSinkDDL);
Table result = tableEnv.sqlQuery("select id,age,wkt from
source_table");
result.execute().print();
send.createTemporaryView("myTable", result);
Table geomTbl = send.sqlQuery("SELECT id,age,ST_GeomFromWKT(wkt) as
point FROM myTable");
geomTbl.execute().print();
}
```
## Steps to reproduce the problem
**when program execute last line "geomTbl.execute().print() ' happened
ereor:`**
`Caused by: org.apache.flink.util.FlinkRuntimeException: java.io.EOFException
at
org.apache.flink.table.data.binary.BinaryRawValueData.toObject(BinaryRawValueData.java:66)
~[flink-table-common-1.19.0.jar:1.19.0]
at GeneratedCastExecutor$0.cast(Unknown Source) ~[na:na]
at
org.apache.flink.table.planner.functions.casting.RowDataToStringConverterImpl.lambda$init$0(RowDataToStringConverterImpl.java:81)
~[flink-table-planner_2.12-1.19.0.jar:1.19.0]
at
org.apache.flink.table.planner.functions.casting.RowDataToStringConverterImpl.convert(RowDataToStringConverterImpl.java:94)
~[flink-table-planner_2.12-1.19.0.jar:1.19.0]
at
org.apache.flink.table.utils.print.TableauStyle.rowFieldsToString(TableauStyle.java:174)
~[flink-table-common-1.19.0.jar:1.19.0]
at
org.apache.flink.table.utils.print.TableauStyle.print(TableauStyle.java:148)
~[flink-table-common-1.19.0.jar:1.19.0]
at
org.apache.flink.table.api.internal.TableResultImpl.print(TableResultImpl.java:163)
~[flink-table-api-java-1.19.0.jar:1.19.0]
at
com.jjgis.sedonaquickstart.demos.web.BasicController.test(BasicController.java:68)
~[classes/:na]
at
com.jjgis.sedonaquickstart.demos.web.BasicController.run(BasicController.java:75)
~[classes/:na]
at
org.springframework.boot.SpringApplication.callRunner(SpringApplication.java:773)
[spring-boot-2.6.13.jar:2.6.13]
... 5 common frames omitted`
## Settings
Sedona version = 1.6.0
Apache Spark version = ?
Apache Flink version = 1.19
API type = Java
Scala version = 2.12,
JRE version = 1.8
Python version = ?
Environment = Standalone, AWS EC2, EMR, Azure, Databricks?
--
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: dev-unsubscr...@sedona.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
