prakash-42 commented on PR #596: URL: https://github.com/apache/flink-kubernetes-operator/pull/596#issuecomment-1939705128
Sorry to bug you again @mxm , but where is the place to submit bugs/ask questions for the flink operator? (The JIRA project doesn't have public signup, are the flink mailing lists active?) I tried to use the [flink-sql-runner-example](https://github.com/apache/flink-kubernetes-operator/tree/main/examples/flink-sql-runner-example) before writing documentation about it, and stumbled into two issues: 1. **The regex for SET statement is not flexible. (not a blocker)** [The regex for SET statement](https://github.com/apache/flink-kubernetes-operator/blob/release-1.7/examples/flink-sql-runner-example/src/main/java/org/apache/flink/examples/SqlRunner.java#L44) enforces that the user provides single quote (`'`) around the key and value. Also there must be space on both sides of the equals (`=`) 2. **Any text present between backticks(\`) is getting lost** (unable to debug the reason) When I try to submit a script that uses backticks around field names, the text between backticks isn't read by the code. ([FileUtils.readFileUtf8](https://github.com/apache/flink-kubernetes-operator/blob/release-1.7/examples/flink-sql-runner-example/src/main/java/org/apache/flink/examples/SqlRunner.java#L55) is responsible for this, I added a log). (I used `flink:1.17` as my base image). I'm not able to reproduce this behavior locally, only happens when I package the job and deploy it in our EKS cluster. Here's a portion of SQL script I used (I printed the full script to console, even the content b/w backticks from the comments was gone) ``` SET 'execution.checkpointing.interval' = '30s'; SET 'pipeline.name' = 'MyFlinkJob'; -- some comment text in `back ticks` -- some more text in ```back ticks x3``` CREATE TABLE Library_Book_Source ( database_name STRING METADATA VIRTUAL, table_name STRING METADATA VIRTUAL, `ID` INT NOT NULL, Title VARCHAR(255), `Price` VARCHAR(50), PRIMARY KEY (`ID`) NOT ENFORCED ) WITH ( 'connector' = 'mysql-cdc', 'hostname' = 'DB_HOST', 'port' = '3306', 'username' = 'username', 'password' = 'password', 'database-name' = 'Library', 'table-name' = 'Book', 'jdbc.properties.useSSL' = 'false' ); ``` Due to these problems, I'm not sure if this example is production ready and whether or not it should be added in our documentation. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
