barunkumaracharya opened a new issue, #37524:
URL: https://github.com/apache/beam/issues/37524

   ### What happened?
   
   I had a Iceberg Row which had a column called "eventTime". The eventTime 
column datatype was 
[org.apache.beam.sdk.schemas.logicaltypes.DateTime](https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/DateTime.java).
   
   I wanted to convert the Row DataType to my java class and for this purpose, 
i was trying to use the 
[Convert.FromRow](https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Convert.java)
 transform
   There is no test case that converts a logical beam type to java type in 
ConvertTest.java
   
   I have tried many data types and options but I was not able to convert it to 
a Java DataType. I have tried Java Instant, Java LocalDateTime, Joda Instant / 
LocalDateTime but was still not able to convert it. One of the main reasons 
that i observed was that the Static Schema Inference class that JavaFieldSchema 
schemaProvider class uses to determine the Beam Type from a Java Type does not 
have support for Beam Logical Type. Checkout function **fieldFromType** in this 
[file](https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/StaticSchemaInference.java)
   
   
   This was the error that i was continuously facing when i was trying to 
convert it -
   `"Cannot convert between types that don't have equivalent schemas."`
   which is present in the ConvertHelpers.java class.
   
   ### Issue Priority
   
   Priority: 2 (default / most bugs should be filed as P2)
   
   ### Issue Components
   
   - [ ] Component: Python SDK
   - [x] Component: Java SDK
   - [ ] Component: Go SDK
   - [ ] Component: Typescript SDK
   - [ ] Component: IO connector
   - [ ] Component: Beam YAML
   - [ ] Component: Beam examples
   - [ ] Component: Beam playground
   - [ ] Component: Beam katas
   - [ ] Component: Website
   - [ ] Component: Infrastructure
   - [ ] Component: Spark Runner
   - [ ] Component: Flink Runner
   - [ ] Component: Samza Runner
   - [ ] Component: Twister2 Runner
   - [ ] Component: Hazelcast Jet Runner
   - [ ] Component: Google Cloud Dataflow Runner


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