[GitHub] [incubator-seatunnel] yuzhenhai0808 opened a new issue, #4552: [Bug] [PostgresTypeMapper] switch case

[via GitHub]

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

   ### 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
   
   no return in code
   
   ### SeaTunnel Version
   
   2.3.1
   
   ### SeaTunnel Config
   
   ```conf
   Jdbc {
       url = "jdbc:postgresql://*/*"
       driver = "org.postgresql.Driver"
       connection_check_timeout_sec = 100
       user = "*"
       password = "*"
       query = "select * from A"
   }
   ```
   
   
   ### Running Command
   
   ```shell
   ./bin/start-seatunnel-spark-3-connector-v2.sh \
   --master yarn \
   --deploy-mode cluster  \
   --config ./config/streaming.conf
   ```
   
   
   ### Error Exception
   
   ```log
   
org.apache.seatunnel.connectors.seatunnel.jdbc.exception.JdbcConnectorException:
 ErrorCode:[COMMON-05], ErrorDescription:[Unsupported operation] - Doesn't 
support Postgres type 'timestamptz' yet
        at 
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.psql.PostgresTypeMapper.mapping(PostgresTypeMapper.java:160)
        at 
org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource.initTableField(JdbcSource.java:156)
        at 
org.apache.seatunnel.connectors.seatunnel.jdbc.source.JdbcSource.prepare(JdbcSource.java:91)
        at 
org.apache.seatunnel.core.starter.spark.execution.SourceExecuteProcessor.initializePlugins(SourceExecuteProcessor.java:104)
        at 
org.apache.seatunnel.core.starter.spark.execution.SparkAbstractPluginExecuteProcessor.<init>(SparkAbstractPluginExecuteProcessor.java:49)
        at 
org.apache.seatunnel.core.starter.spark.execution.SourceExecuteProcessor.<init>(SourceExecuteProcessor.java:51)
        at 
org.apache.seatunnel.core.starter.spark.execution.SparkExecution.<init>(SparkExecution.java:57)
        at 
org.apache.seatunnel.core.starter.spark.command.SparkTaskExecuteCommand.execute(SparkTaskExecuteCommand.java:59)
        at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40)
        at 
org.apache.seatunnel.core.starter.spark.SeaTunnelSpark.main(SeaTunnelSpark.java:35)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at 
org.apache.spark.deploy.yarn.ApplicationMaster$$anon$2.run(ApplicationMaster.scala:737)
   ```
   
   
   ### Flink or Spark Version
   
   spark 3.2.1
   
   ### Java or Scala Version
   
   _No response_
   
   ### Screenshots
   
               case PG_TIMESTAMP_ARRAY:
               case PG_NUMERIC_ARRAY:
               case PG_TIMESTAMPTZ:
               case PG_TIMESTAMPTZ_ARRAY:
               case PG_TIME_ARRAY:
               case PG_DATE_ARRAY:
               default:
                   throw new JdbcConnectorException(
                           CommonErrorCode.UNSUPPORTED_OPERATION,
                           String.format("Doesn't support Postgres type '%s' 
yet", pgType));
   
   ### 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: commits-unsubscr...@seatunnel.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org