[
https://issues.apache.org/jira/browse/FLINK-33777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-33777:
----------------------------------
Description:
>From this CI run:
>[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=55334&view=logs&j=2e8cb2f7-b2d3-5c62-9c05-cd756d33a819&t=2dd510a3-5041-5201-6dc3-54d310f68906]
{code:java}
Dec 07 19:57:30 19:57:30.026 [ERROR] Errors:
Dec 07 19:57:30 19:57:30.026 [ERROR]
ParquetTimestampITCase>FsStreamingSinkITCaseBase.testNonPart:84->FsStreamingSinkITCaseBase.testPartitionCustomFormatDate:151->FsStreamingSinkITCaseBase.test:186
» Validation
Dec 07 19:57:30 19:57:30.026 [ERROR]
ParquetTimestampITCase>FsStreamingSinkITCaseBase.testPart:89->FsStreamingSinkITCaseBase.testPartitionCustomFormatDate:151->FsStreamingSinkITCaseBase.test:186
» Validation
Dec 07 19:57:30 19:57:30.026 [ERROR]
ParquetTimestampITCase>FsStreamingSinkITCaseBase.testPartitionWithBasicDate:126->FsStreamingSinkITCaseBase.test:186
» Validation {code}
The errors each appear somewhat similar:
{code:java}
Dec 07 19:54:43 19:54:43.934 [ERROR]
org.apache.flink.formats.parquet.ParquetTimestampITCase.testPartitionWithBasicDate
Time elapsed: 1.822 s <<< ERROR!
Dec 07 19:54:43 org.apache.flink.table.api.ValidationException: Unable to find
a field named 'f0' in the physical data type derived from the given type
information for schema declaration. Make sure that the type information is not
a generic raw type. Currently available fields are: [a, b, c, d, e]
Dec 07 19:54:43 at
org.apache.flink.table.catalog.SchemaTranslator.patchDataTypeFromColumn(SchemaTranslator.java:350)
Dec 07 19:54:43 at
org.apache.flink.table.catalog.SchemaTranslator.patchDataTypeFromDeclaredSchema(SchemaTranslator.java:337)
Dec 07 19:54:43 at
org.apache.flink.table.catalog.SchemaTranslator.createConsumingResult(SchemaTranslator.java:235)
Dec 07 19:54:43 at
org.apache.flink.table.catalog.SchemaTranslator.createConsumingResult(SchemaTranslator.java:180)
Dec 07 19:54:43 at
org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.fromStreamInternal(AbstractStreamTableEnvironmentImpl.java:141)
Dec 07 19:54:43 at
org.apache.flink.table.api.bridge.scala.internal.StreamTableEnvironmentImpl.createTemporaryView(StreamTableEnvironmentImpl.scala:121)
Dec 07 19:54:43 at
org.apache.flink.table.planner.runtime.stream.FsStreamingSinkITCaseBase.test(FsStreamingSinkITCaseBase.scala:186)
Dec 07 19:54:43 at
org.apache.flink.table.planner.runtime.stream.FsStreamingSinkITCaseBase.testPartitionWithBasicDate(FsStreamingSinkITCaseBase.scala:126)
{code}
was:
>From this CI run:
>[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=55334&view=logs&j=2e8cb2f7-b2d3-5c62-9c05-cd756d33a819&t=2dd510a3-5041-5201-6dc3-54d310f68906]
```
Dec 07 19:57:30 19:57:30.026 [ERROR] Errors:
Dec 07 19:57:30 19:57:30.026 [ERROR]
ParquetTimestampITCase>FsStreamingSinkITCaseBase.testNonPart:84->FsStreamingSinkITCaseBase.testPartitionCustomFormatDate:151->FsStreamingSinkITCaseBase.test:186
» Validation
Dec 07 19:57:30 19:57:30.026 [ERROR]
ParquetTimestampITCase>FsStreamingSinkITCaseBase.testPart:89->FsStreamingSinkITCaseBase.testPartitionCustomFormatDate:151->FsStreamingSinkITCaseBase.test:186
» Validation
Dec 07 19:57:30 19:57:30.026 [ERROR]
ParquetTimestampITCase>FsStreamingSinkITCaseBase.testPartitionWithBasicDate:126->FsStreamingSinkITCaseBase.test:186
» Validation
```
The errors each appear somewhat similar:
```
Dec 07 19:54:43 19:54:43.934 [ERROR]
org.apache.flink.formats.parquet.ParquetTimestampITCase.testPartitionWithBasicDate
Time elapsed: 1.822 s <<< ERROR!
Dec 07 19:54:43 org.apache.flink.table.api.ValidationException: Unable to find
a field named 'f0' in the physical data type derived from the given type
information for schema declaration. Make sure that the type information is not
a generic raw type. Currently available fields are: [a, b, c, d, e]
Dec 07 19:54:43 at
org.apache.flink.table.catalog.SchemaTranslator.patchDataTypeFromColumn(SchemaTranslator.java:350)
Dec 07 19:54:43 at
org.apache.flink.table.catalog.SchemaTranslator.patchDataTypeFromDeclaredSchema(SchemaTranslator.java:337)
Dec 07 19:54:43 at
org.apache.flink.table.catalog.SchemaTranslator.createConsumingResult(SchemaTranslator.java:235)
Dec 07 19:54:43 at
org.apache.flink.table.catalog.SchemaTranslator.createConsumingResult(SchemaTranslator.java:180)
Dec 07 19:54:43 at
org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.fromStreamInternal(AbstractStreamTableEnvironmentImpl.java:141)
Dec 07 19:54:43 at
org.apache.flink.table.api.bridge.scala.internal.StreamTableEnvironmentImpl.createTemporaryView(StreamTableEnvironmentImpl.scala:121)
Dec 07 19:54:43 at
org.apache.flink.table.planner.runtime.stream.FsStreamingSinkITCaseBase.test(FsStreamingSinkITCaseBase.scala:186)
Dec 07 19:54:43 at
org.apache.flink.table.planner.runtime.stream.FsStreamingSinkITCaseBase.testPartitionWithBasicDate(FsStreamingSinkITCaseBase.scala:126)
```
> ParquetTimestampITCase>FsStreamingSinkITCaseBase failing in CI
> --------------------------------------------------------------
>
> Key: FLINK-33777
> URL: https://issues.apache.org/jira/browse/FLINK-33777
> Project: Flink
> Issue Type: Bug
> Reporter: Jim Hughes
> Assignee: Sergey Nuyanzin
> Priority: Major
> Labels: pull-request-available
>
> From this CI run:
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=55334&view=logs&j=2e8cb2f7-b2d3-5c62-9c05-cd756d33a819&t=2dd510a3-5041-5201-6dc3-54d310f68906]
> {code:java}
> Dec 07 19:57:30 19:57:30.026 [ERROR] Errors:
> Dec 07 19:57:30 19:57:30.026 [ERROR]
> ParquetTimestampITCase>FsStreamingSinkITCaseBase.testNonPart:84->FsStreamingSinkITCaseBase.testPartitionCustomFormatDate:151->FsStreamingSinkITCaseBase.test:186
> » Validation
> Dec 07 19:57:30 19:57:30.026 [ERROR]
> ParquetTimestampITCase>FsStreamingSinkITCaseBase.testPart:89->FsStreamingSinkITCaseBase.testPartitionCustomFormatDate:151->FsStreamingSinkITCaseBase.test:186
> » Validation
> Dec 07 19:57:30 19:57:30.026 [ERROR]
> ParquetTimestampITCase>FsStreamingSinkITCaseBase.testPartitionWithBasicDate:126->FsStreamingSinkITCaseBase.test:186
> » Validation {code}
> The errors each appear somewhat similar:
> {code:java}
> Dec 07 19:54:43 19:54:43.934 [ERROR]
> org.apache.flink.formats.parquet.ParquetTimestampITCase.testPartitionWithBasicDate
> Time elapsed: 1.822 s <<< ERROR!
> Dec 07 19:54:43 org.apache.flink.table.api.ValidationException: Unable to
> find a field named 'f0' in the physical data type derived from the given type
> information for schema declaration. Make sure that the type information is
> not a generic raw type. Currently available fields are: [a, b, c, d, e]
> Dec 07 19:54:43 at
> org.apache.flink.table.catalog.SchemaTranslator.patchDataTypeFromColumn(SchemaTranslator.java:350)
>
> Dec 07 19:54:43 at
> org.apache.flink.table.catalog.SchemaTranslator.patchDataTypeFromDeclaredSchema(SchemaTranslator.java:337)
>
> Dec 07 19:54:43 at
> org.apache.flink.table.catalog.SchemaTranslator.createConsumingResult(SchemaTranslator.java:235)
>
> Dec 07 19:54:43 at
> org.apache.flink.table.catalog.SchemaTranslator.createConsumingResult(SchemaTranslator.java:180)
>
> Dec 07 19:54:43 at
> org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.fromStreamInternal(AbstractStreamTableEnvironmentImpl.java:141)
>
> Dec 07 19:54:43 at
> org.apache.flink.table.api.bridge.scala.internal.StreamTableEnvironmentImpl.createTemporaryView(StreamTableEnvironmentImpl.scala:121)
>
> Dec 07 19:54:43 at
> org.apache.flink.table.planner.runtime.stream.FsStreamingSinkITCaseBase.test(FsStreamingSinkITCaseBase.scala:186)
>
> Dec 07 19:54:43 at
> org.apache.flink.table.planner.runtime.stream.FsStreamingSinkITCaseBase.testPartitionWithBasicDate(FsStreamingSinkITCaseBase.scala:126)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
