[ 
https://issues.apache.org/jira/browse/FLINK-38149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ramin Gharib updated FLINK-38149:
---------------------------------
    Description: 
 

Currently, in the method 
[toLogicalTypeNotNull|https://github.com/raminqaf/flink/blob/main/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/typeutils/LogicalRelDataTypeConverter.java#L474-L474]
 method, the COLUMN_LIST cannot be converte to its logical type (DescritorType)
{code:java}
case REAL:
case TIME_WITH_LOCAL_TIME_ZONE:
case ANY:
case CURSOR:
case COLUMN_LIST:
case DYNAMIC_STAR:
case GEOMETRY:
case SARG:
default:
    throw new TableException("Unsupported RelDataType: " + relDataType); {code}
We should move it and add:
{code:java}
case COLUMN_LIST:
    return new DescriptorType(false); {code}
 

  was:
 

Currently the COLUMN_LIST cannot be converte to its logical type (DescritorType)
{code:java}
case REAL:
case TIME_WITH_LOCAL_TIME_ZONE:
case ANY:
case CURSOR:
case COLUMN_LIST:
case DYNAMIC_STAR:
case GEOMETRY:
case SARG:
default:
    throw new TableException("Unsupported RelDataType: " + relDataType); {code}
 

 


> Convert COLUMN_LIST to DescriptorType
> -------------------------------------
>
>                 Key: FLINK-38149
>                 URL: https://issues.apache.org/jira/browse/FLINK-38149
>             Project: Flink
>          Issue Type: Bug
>            Reporter: Ramin Gharib
>            Priority: Major
>
>  
> Currently, in the method 
> [toLogicalTypeNotNull|https://github.com/raminqaf/flink/blob/main/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/typeutils/LogicalRelDataTypeConverter.java#L474-L474]
>  method, the COLUMN_LIST cannot be converte to its logical type 
> (DescritorType)
> {code:java}
> case REAL:
> case TIME_WITH_LOCAL_TIME_ZONE:
> case ANY:
> case CURSOR:
> case COLUMN_LIST:
> case DYNAMIC_STAR:
> case GEOMETRY:
> case SARG:
> default:
>     throw new TableException("Unsupported RelDataType: " + relDataType); 
> {code}
> We should move it and add:
> {code:java}
> case COLUMN_LIST:
>     return new DescriptorType(false); {code}
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to