Jim Hughes created FLINK-33777:
----------------------------------
Summary: 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
>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)
```
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
