[GitHub] [inlong] ZuoFengZhang opened a new issue, #6734: [Bug] [Manager] The data format of the ddl statement of the Pulsar table does not match the front-end configuration

Sun, 04 Dec 2022 20:41:26 -0800 


ZuoFengZhang opened a new issue, #6734:
URL: https://github.com/apache/inlong/issues/6734

   ### What happened
   
   
   
   <img width="965" alt="Pasted image 20221205123015" 
src="https://user-images.githubusercontent.com/5709212/205550701-3390afa2-c17b-4436-8bb4-d06f05c1ae04.png";>
   
   ```sql
   CREATE TABLE `table_first_stream_v5`(
   `f1` INT,
   `user_name` STRING)
   WITH (
   'inlong.metric.labels' = 
'groupId=first_stream_group_v5&streamId=first_stream_v5&nodeId=first_stream_v5',
   'connector' = 'pulsar-inlong',
   'inlong-msg.csv.array-element-delimiter' = ';',
   'inlong-msg.csv.disable-quote-character' = 'true',
   'inlong-msg.inner.format' = 'csv',
   'inlong-msg.csv.allow-comments' = 'false',
   'format' = 'inlong-msg',
   'inlong-msg.csv.field-delimiter' = ',',
   'inlong-msg.csv.ignore-parse-errors' = 'true',
   'inlong-msg.ignore-parse-errors' = 'false',
   'admin-url' = 'http://127.0.0.1:8080',
   'generic' = 'true',
   'service-url' = 'pulsar://127.0.0.1:6650',
   'topic' = 'public/first_stream_group_v5/first_stream_v5',
   'scan.startup.mode' = 'earliest'
   )
   ```
   
   <img width="968" alt="Pasted image 20221205123316" 
src="https://user-images.githubusercontent.com/5709212/205550804-6ece2505-66b2-4f8f-9c78-5baf8005cb04.png";>
   
   
   ```sql
   CREATE TABLE `table_first_stream_v5`(
       `f1` INT,
       `user_name` STRING)
       WITH (
       'inlong.metric.labels' = 
'groupId=first_stream_group_v5&streamId=first_stream_v5&nodeId=first_stream_v5',
       'connector' = 'pulsar-inlong',
       'inlong-msg.csv.array-element-delimiter' = ';',
       'inlong-msg.csv.disable-quote-character' = 'true',
       'inlong-msg.inner.format' = 'csv',
       'inlong-msg.csv.allow-comments' = 'false',
       'format' = 'inlong-msg',
       'inlong-msg.csv.field-delimiter' = ',',
       'inlong-msg.csv.ignore-parse-errors' = 'true',
       'inlong-msg.ignore-parse-errors' = 'false',
       'admin-url' = 'http://127.0.0.1:8080',
       'generic' = 'true',
       'service-url' = 'pulsar://127.0.0.1:6650',
       'topic' = 'public/first_stream_group_v5/first_stream_v5',
       'scan.startup.mode' = 'earliest'
   ) 
   ```
   
   ### What you expected to happen
   
   Data format that matches the front-end configuration
   
   ### How to reproduce
   
   Register a stream, select the pulsar table as the data source, and choose 
any data format
   
   ### Environment
   
   _No response_
   
   ### InLong version
   
   master
   
   ### InLong Component
   
   InLong Manager
   
   ### Are you willing to submit PR?
   
   - [X] Yes, I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://www.apache.org/foundation/policies/conduct)
   


-- 
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]

Reply via email to