[GitHub] [incubator-seatunnel] MonsterChenzhuo opened a new issue, #4635: [Bug] [Assert Sink]Fix the problem that the data type

Thu, 20 Apr 2023 01:44:17 -0700 


MonsterChenzhuo opened a new issue, #4635:
URL: https://github.com/apache/incubator-seatunnel/issues/4635

   ### Search before asking
   
   - [X] I had searched in the 
[issues](https://github.com/apache/incubator-seatunnel/issues?q=is%3Aissue+label%3A%22bug%22)
 and found no similar issues.
   
   
   ### What happened
   
   
   I defined an Assertsink, using the field_rules method to validate data. I 
found that bigint, bytes, etc. are not supported. I checked the documentation, 
and the types do not correspond with some parts of the ST Row type. Please 
translate this into English.
   
   I have defined an Assertsink and used the field_rules method for data 
validation. I discovered that bigint, bytes, and so on are not supported. I've 
reviewed the documentation, and the types don't fully match up with some parts 
of the ST Row type.
   
   <img width="1238" alt="图片" 
src="https://user-images.githubusercontent.com/60029759/233310047-edb675d1-1668-4388-b502-db75651e29a0.png";>
   
   
   ### SeaTunnel Version
   
   v2.3.1
   
   ### SeaTunnel Config
   
   ```conf
   sink {
     Assert {
       source_table_name = "fake1"
       rules =
         {
           row_rules = [
             {
               rule_type = MAX_ROW
               rule_value = 100
             },
             {
               rule_type = MIN_ROW
               rule_value = 5
             }
           ],
           field_rules = [{
             field_name = name
             field_type = string
             field_value = [
               {
                 rule_type = NOT_NULL
               },
               {
                 rule_type = MIN_LENGTH
                 rule_value = 5
               },
               {
                 rule_type = MAX_LENGTH
                 rule_value = 65535
               }
             ]
           }, {
             field_name = age
             field_type = bigint
             field_value = [
               {
                 rule_type = NOT_NULL
               },
               {
                 rule_type = MIN
                 rule_value = 32767
               },
               {
                 rule_type = MAX
                 rule_value = 2147483647
               }
             ]
           }
           ]
         }
   
     }
   ```
   
   
   ### Running Command
   
   ```shell
   null
   ```
   
   
   ### Error Exception
   
   ```log
   <img width="1188" alt="图片" 
src="https://user-images.githubusercontent.com/60029759/233310035-7a760d1a-fd79-49e9-9a1e-73e09c964e6c.png";>
   ```
   
   
   ### Flink or Spark Version
   
   _No response_
   
   ### Java or Scala Version
   
   _No response_
   
   ### Screenshots
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [ ] 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