[
https://issues.apache.org/jira/browse/FLINK-33777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-33777.
------------------------------------
Fix Version/s: 1.19.0
Resolution: Fixed
Fixed in 0e515dce78832dbbbf5fce9c8cdd113bbb62cdf0
> ParquetTimestampITCase>FsStreamingSinkITCaseBase failing in CI
> --------------------------------------------------------------
>
> Key: FLINK-33777
> URL: https://issues.apache.org/jira/browse/FLINK-33777
> Project: Flink
> Issue Type: Bug
> Affects Versions: 1.19.0
> Reporter: Jim Hughes
> Assignee: Sergey Nuyanzin
> Priority: Major
> Labels: pull-request-available, test-stability
> Fix For: 1.19.0
>
>
> 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)
