[Bug] connector-influxdb module InfluxDBSource class's initColumnsIndex method, sql invalide when sql contains tz function cause by direct append QUERY_LIMIT

[zhengyuan-cn]

Search before asking

• I had searched in the issues and found no similar issues.

What happened

connector-influxdb module InfluxDBSource class's initColumnsIndex method, sql invalide when sql contains tz function cause by direct append QUERY_LIMIT

fix code:
String sql = sourceConfig.getSql(); String query = sql + QUERY_LIMIT; // if sql contains tz(), can't be append QUERY_LIMIT at last . see bug #4231 if (sql.toLowerCase().contains("tz")) { int start = sql.toLowerCase().indexOf("tz"); StringBuilder tmpSql = new StringBuilder(sql); tmpSql.insert(start-1, QUERY_LIMIT+" "); query = tmpSql.toString(); }

SeaTunnel Version

2.3.0-release

SeaTunnel Config

ingore

Running Command

ingore

Error Exception

SQL syntax error

Flink or Spark Version

2.4.8

Java or Scala Version

1.8

Screenshots

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[Hisoka-X]

Hi, still waiting your fix PR.😁

[zhengyuan-cn]

I fixed commited code's bug , position by java regex

[github-actions]

This issue has been automatically marked as stale because it has not had recent activity for 30 days. It will be closed in next 7 days if no further activity occurs.