[
https://issues.apache.org/jira/browse/FLINK-17850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112546#comment-17112546
]
Robert Metzger commented on FLINK-17850:
----------------------------------------
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=1962&view=logs&j=d44f43ce-542c-597d-bf94-b0718c71e5e8&t=34f486e1-e1e4-5dd2-9c06-bfdd9b9c74a8
> PostgresCatalogITCase . testGroupByInsert() fails on CI
> -------------------------------------------------------
>
> Key: FLINK-17850
> URL: https://issues.apache.org/jira/browse/FLINK-17850
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Ecosystem
> Affects Versions: 1.11.0
> Reporter: Stephan Ewen
> Priority: Blocker
> Labels: test-stability
> Fix For: 1.11.0, 1.12.0
>
>
> {{org.apache.flink.connector.jdbc.catalog.PostgresCatalogITCase .
> testGroupByInsert}}
> Error:
> {code}
> 2020-05-20T16:36:33.9647037Z org.apache.flink.table.api.ValidationException:
> 2020-05-20T16:36:33.9647354Z Field types of query result and registered
> TableSink mypg.postgres.primitive_table2 do not match.
> 2020-05-20T16:36:33.9648233Z Query schema: [int: INT NOT NULL, EXPR$1:
> VARBINARY(2147483647) NOT NULL, short: SMALLINT NOT NULL, EXPR$3: BIGINT,
> EXPR$4: FLOAT, EXPR$5: DOUBLE, EXPR$6: DECIMAL(10, 5), EXPR$7: BOOLEAN,
> EXPR$8: VARCHAR(2147483647), EXPR$9: CHAR(1) NOT NULL, EXPR$10: CHAR(1) NOT
> NULL, EXPR$11: VARCHAR(20), EXPR$12: TIMESTAMP(5), EXPR$13: DATE, EXPR$14:
> TIME(0), EXPR$15: DECIMAL(38, 18)]
> 2020-05-20T16:36:33.9650272Z Sink schema: [int: INT, bytea:
> VARBINARY(2147483647), short: SMALLINT, long: BIGINT, real: FLOAT,
> double_precision: DOUBLE, numeric: DECIMAL(10, 5), decimal: DECIMAL(10, 1),
> boolean: BOOLEAN, text: VARCHAR(2147483647), char: CHAR(1), character:
> CHAR(3), character_varying: VARCHAR(20), timestamp: TIMESTAMP(5), date: DATE,
> time: TIME(0), default_numeric: DECIMAL(38, 18)]
> 2020-05-20T16:36:33.9651218Z at
> org.apache.flink.table.planner.sinks.TableSinkUtils$.validateSchemaAndApplyImplicitCast(TableSinkUtils.scala:100)
> 2020-05-20T16:36:33.9651689Z at
> org.apache.flink.table.planner.delegation.PlannerBase$$anonfun$2.apply(PlannerBase.scala:218)
> 2020-05-20T16:36:33.9652136Z at
> org.apache.flink.table.planner.delegation.PlannerBase$$anonfun$2.apply(PlannerBase.scala:193)
> 2020-05-20T16:36:33.9652936Z at scala.Option.map(Option.scala:146)
> 2020-05-20T16:36:33.9653593Z at
> org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:193)
> 2020-05-20T16:36:33.9653993Z at
> org.apache.flink.table.planner.delegation.PlannerBase$$anonfun$1.apply(PlannerBase.scala:152)
> 2020-05-20T16:36:33.9654428Z at
> org.apache.flink.table.planner.delegation.PlannerBase$$anonfun$1.apply(PlannerBase.scala:152)
> 2020-05-20T16:36:33.9654841Z at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
> 2020-05-20T16:36:33.9655221Z at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
> 2020-05-20T16:36:33.9655759Z at
> scala.collection.Iterator$class.foreach(Iterator.scala:891)
> 2020-05-20T16:36:33.9656072Z at
> scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
> 2020-05-20T16:36:33.9656413Z at
> scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
> 2020-05-20T16:36:33.9656890Z at
> scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> 2020-05-20T16:36:33.9657211Z at
> scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
> 2020-05-20T16:36:33.9657525Z at
> scala.collection.AbstractTraversable.map(Traversable.scala:104)
> 2020-05-20T16:36:33.9657878Z at
> org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:152)
> 2020-05-20T16:36:33.9658350Z at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1217)
> 2020-05-20T16:36:33.9658784Z at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:663)
> 2020-05-20T16:36:33.9659391Z at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeOperation(TableEnvironmentImpl.java:750)
> 2020-05-20T16:36:33.9659856Z at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:653)
> 2020-05-20T16:36:33.9660507Z at
> org.apache.flink.table.planner.runtime.utils.TableEnvUtil$.execInsertSqlAndWaitResult(TableEnvUtil.scala:27)
> 2020-05-20T16:36:33.9661115Z at
> org.apache.flink.table.planner.runtime.utils.TableEnvUtil.execInsertSqlAndWaitResult(TableEnvUtil.scala)
> 2020-05-20T16:36:33.9661583Z at
> org.apache.flink.connector.jdbc.catalog.PostgresCatalogITCase.testGroupByInsert(PostgresCatalogITCase.java:88)
> {code}
> Full log:
> https://dev.azure.com/sewen0794/19b23adf-d190-4fb4-ae6e-2e92b08923a3/_apis/build/builds/25/logs/93
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
