[
https://issues.apache.org/jira/browse/FLINK-33777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794577#comment-17794577
]
Sergey Nuyanzin commented on FLINK-33777:
-----------------------------------------
Thanks for investigating this
the reason is that the PR for FLINK-33718 was based before changes for
FLINK-25565 and as a result didn't take them into account...
I should have rebased before merging
Sorry for the inconvenience
> 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]
> ```
> 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)
