Closed dafanshu closed 1 year ago
Dinky User Console: [FlinkExecute] 2023-01-18T09:35:24.224 INFO: Start initialize FlinkSQLEnv: [FlinkExecute] 2023-01-18T09:35:24.229 CONFIG: Variable opened. [FlinkExecute] 2023-01-18T09:35:24.229 INFO: Initializing global variables... [FlinkExecute] 2023-01-18T09:35:24.233 ERROR: org.springframework.jdbc.BadSqlGrammarException:
; bad SQL grammar []; nested exception is java.sql.SQLSyntaxErrorException: Unknown column 'tenant_id' in 'field list'
execute success
EXECUTE CDCSOURCE jobname WITH ( 'connector' = 'iot-mysql-106', 'hostname' = 'mysql-cpxnhn.ddc', 'port' = '3306', 'username' = 'dev', 'password' = 'dev', 'checkpoint' = '3000', 'scan.startup.mode' = 'initial', 'parallelism' = '1', 'table-name' = 'dlink.dlink_flinkdocument', 'sink.connector' = 'doris-on-k8s', 'sink.fenodes' = 'doris-fe.doris-on-k8s:9030', 'sink.username' = 'root', 'sink.password' = '', 'sink.sink.batch.size' = '1', 'sink.sink.max-retries' = '1', 'sink.sink.batch.interval' = '60000', 'sink.sink.db' = 'demo', 'sink.table.prefix' = 'ODS', 'sink.table.upper' = 'true', 'sink.table.identifier' = '${schemaName}.${tableName}', 'sink.sink.enable-delete' = 'true' )
No response
0.7.0
This bug has been fixed.
aiwenmo
commented
1 year ago aiwenmo
commented
1 year ago
Search before asking
What happened
Dinky User Console: [FlinkExecute] 2023-01-18T09:35:24.224 INFO: Start initialize FlinkSQLEnv: [FlinkExecute] 2023-01-18T09:35:24.229 CONFIG: Variable opened. [FlinkExecute] 2023-01-18T09:35:24.229 INFO: Initializing global variables... [FlinkExecute] 2023-01-18T09:35:24.233 ERROR: org.springframework.jdbc.BadSqlGrammarException:
Error querying database. Cause: java.sql.SQLSyntaxErrorException: Unknown column 'tenant_id' in 'field list'
The error may exist in com/dlink/mapper/FragmentVariableMapper.java (best guess)
The error may involve defaultParameterMap
The error occurred while setting parameters
SQL: SELECT id, alias, tenant_id, fragment_value, note, name, enabled, create_time, update_time FROM dlink_fragment WHERE (enabled = ?) AND dlink_fragment.tenant_id = 1
Cause: java.sql.SQLSyntaxErrorException: Unknown column 'tenant_id' in 'field list'
; bad SQL grammar []; nested exception is java.sql.SQLSyntaxErrorException: Unknown column 'tenant_id' in 'field list'
What you expected to happen
execute success
How to reproduce
EXECUTE CDCSOURCE jobname WITH ( 'connector' = 'iot-mysql-106', 'hostname' = 'mysql-cpxnhn.ddc', 'port' = '3306', 'username' = 'dev', 'password' = 'dev', 'checkpoint' = '3000', 'scan.startup.mode' = 'initial', 'parallelism' = '1', 'table-name' = 'dlink.dlink_flinkdocument', 'sink.connector' = 'doris-on-k8s', 'sink.fenodes' = 'doris-fe.doris-on-k8s:9030', 'sink.username' = 'root', 'sink.password' = '', 'sink.sink.batch.size' = '1', 'sink.sink.max-retries' = '1', 'sink.sink.batch.interval' = '60000', 'sink.sink.db' = 'demo', 'sink.table.prefix' = 'ODS', 'sink.table.upper' = 'true', 'sink.table.identifier' = '${schemaName}.${tableName}', 'sink.sink.enable-delete' = 'true' )
Anything else
No response
Version
0.7.0
Are you willing to submit PR?
Code of Conduct