You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2020/04/24 02:01:46 UTC
[GitHub] [flink] docete opened a new pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
docete opened a new pull request #11892:
URL: https://github.com/apache/flink/pull/11892
## What is the purpose of the change
FLINK-14688 introduces DESCRIBE statement in sql parser, but doesn't implement it in planner side because the TableEnvironment.sqlUpdate returns nothing. Since FLINK-16366 introduces TableEnvironment.executeSql and returns TableResult, we can implement DESCRIBE statement in planner now.
## Brief change log
- 84b4681 supports DESCRIBE statement in both planners
## Verifying this change
This change added tests
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): (yes / **no**)
- The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (yes / **no**)
- The serializers: (yes / **no** / don't know)
- The runtime per-record code paths (performance sensitive): (yes / **no** / don't know)
- Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Yarn/Mesos, ZooKeeper: (yes / **no** / don't know)
- The S3 file system connector: (yes / **no** / don't know)
## Documentation
- Does this pull request introduce a new feature? (**yes** / no)
- If yes, how is the feature documented? (not applicable / docs / **JavaDocs** / not documented)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] KurtYoung commented on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
KurtYoung commented on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-626684695
Thanks for the update! I tried this command locally with your test, it seems the output will be truncated with `TableResult.print()`.
For DDL command, I think it doesn't make sense to truncate the output. The truncation was mostly introduced for select query. Could you relax the column width limit for all DDL queries?
One possible solution might be relax the limit by default and only set the limitation if needed, like select query. cc @godfreyhe
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "SUCCESS",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "SUCCESS",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "PENDING",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162192970",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 84b468105ad7674897ed1df0f126d5f078944225 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161749793) Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155)
* 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN
* d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162192970) Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309)
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "PENDING",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 84b468105ad7674897ed1df0f126d5f078944225 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161749793) Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155)
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] godfreyhe commented on a change in pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
godfreyhe commented on a change in pull request #11892:
URL: https://github.com/apache/flink/pull/11892#discussion_r415486982
##########
File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/TableEnvImpl.scala
##########
@@ -721,6 +721,15 @@ abstract class TableEnvImpl(
dropViewOperation.isIfExists)
}
TableResultImpl.TABLE_RESULT_OK
+ case descOperation: DescribeTableOperation =>
+ val result = catalogManager.getTable(descOperation.getSqlIdentifier)
+ if (result.isPresent) {
+ buildShowResult(Array(result.get().getTable.getSchema.toString))
Review comment:
I find SQL parser support column comments ([see](https://github.com/apache/flink/blob/master/flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java#L225)), but we do not store the comments into TableSchema. we ignore `comment` column.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] godfreyhe commented on a change in pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
godfreyhe commented on a change in pull request #11892:
URL: https://github.com/apache/flink/pull/11892#discussion_r415473253
##########
File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/TableEnvImpl.scala
##########
@@ -721,6 +721,15 @@ abstract class TableEnvImpl(
dropViewOperation.isIfExists)
}
TableResultImpl.TABLE_RESULT_OK
+ case descOperation: DescribeTableOperation =>
+ val result = catalogManager.getTable(descOperation.getSqlIdentifier)
+ if (result.isPresent) {
+ buildShowResult(Array(result.get().getTable.getSchema.toString))
Review comment:
I find the print (through `TableResult#print`) result of `describe xx` looks a little strange:
```
+--------------------------------+
| result |
+--------------------------------+
| root
|-- a: INT
|-- b: S... |
+--------------------------------+
1 row in set
```
Users have to parse the unstructured result if he/she want to use the result to do sth through TableResult#collect method.
How about we return a structured tableau result, e.g.
```
+-------------+---------+-------------+
| name | type | comment |
+-------------+---------+-------------+
| a | INT | |
| b | STRING | |
+-------------+---------+-------------+
2 rows in set
```
This is different from the describe result in SQL client.
Anther thing we should consider is how to print `watermarkSpecs` and compute column.
How about we add a column named `expr` to represent `watermarkSpecs` and compute column.
```
+-------------+-------------+-------------+-------------+
| name | type | comment | expr |
+-------------+-------------+-------------+-------------+
| a | INT | | (NULL) |
| b | INT | | a + 1 |
| c |TIMESTAMP(3) | | (NULL) |
| WATERMARK | (NULL) | | c AS now() |
+-------------+-------------+-------------+-------------+
```
##########
File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/TableEnvImpl.scala
##########
@@ -721,6 +721,15 @@ abstract class TableEnvImpl(
dropViewOperation.isIfExists)
}
TableResultImpl.TABLE_RESULT_OK
+ case descOperation: DescribeTableOperation =>
+ val result = catalogManager.getTable(descOperation.getSqlIdentifier)
+ if (result.isPresent) {
+ buildShowResult(Array(result.get().getTable.getSchema.toString))
Review comment:
cc @twalthr
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] godfreyhe commented on a change in pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
godfreyhe commented on a change in pull request #11892:
URL: https://github.com/apache/flink/pull/11892#discussion_r422050608
##########
File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/TableEnvImpl.scala
##########
@@ -766,7 +768,29 @@ abstract class TableEnvImpl(
case descOperation: DescribeTableOperation =>
val result = catalogManager.getTable(descOperation.getSqlIdentifier)
if (result.isPresent) {
- buildShowResult(Array(result.get().getTable.getSchema.toString))
+ val schema = result.get.getTable.getSchema
+ val fieldToWatermark =
+ schema
+ .getWatermarkSpecs
+ .map(w => (w.getRowtimeAttribute, w.getWatermarkExpr)).toMap
+ val fieldToPrimaryKey = new JHashMap[String, String]()
+ if (schema.getPrimaryKey.isPresent) {
+ val columns = schema.getPrimaryKey.get.getColumns.asScala
+ columns.foreach(c => fieldToPrimaryKey.put(c, s"PRI(${columns.mkString(",")})"))
+ }
+ val data = Array.ofDim[String](schema.getFieldCount, 6)
+ schema.getTableColumns.asScala.zipWithIndex.foreach {
+ case (c, i) => {
+ val logicalType = c.getType.getLogicalType
+ data(i)(0) = c.getName
+ data(i)(1) = StringUtils.removeEnd(logicalType.toString, " NOT NULL")
+ data(i)(2) = if (logicalType.isNullable) "true" else "false"
+ data(i)(3) = fieldToPrimaryKey.getOrDefault(c.getName, "(NULL)")
+ data(i)(4) = c.getExpr.orElse("(NULL)")
+ data(i)(5) = fieldToWatermark.getOrDefault(c.getName, "(NULL)")
+ }
+ }
+ buildShowResult(Array("name", "type", "null", "key", "compute column", "watermark"), data)
Review comment:
ditto
##########
File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java
##########
@@ -861,23 +865,32 @@ private TableResult executeOperation(Operation operation) {
catalogManager.getTable(describeTableOperation.getSqlIdentifier());
if (result.isPresent()) {
TableSchema schema = result.get().getTable().getSchema();
- String[][] rows = Stream.concat(
+ Map<String, String> fieldToWatermark =
+ schema.getWatermarkSpecs()
+ .stream()
+ .collect(Collectors.toMap(WatermarkSpec::getRowtimeAttribute, WatermarkSpec::getWatermarkExpr));
+
+ Map<String, String> fieldToPrimaryKey = new HashMap<>();
+ schema.getPrimaryKey().ifPresent((p) -> {
+ List<String> columns = p.getColumns();
+ columns.forEach((c) -> fieldToPrimaryKey.put(c, String.format("PRI(%s)", String.join(",", columns))));
+ });
+
+ String[][] rows =
schema.getTableColumns()
.stream()
- .map((c) -> new String[]{
+ .map((c) -> {
+ LogicalType logicalType = c.getType().getLogicalType();
+ return new String[]{
c.getName(),
- c.getType().getLogicalType().toString(),
- c.getExpr().orElse("(NULL)")}),
- schema.getWatermarkSpecs()
- .stream()
- .map((w) -> new String[]{
- "WATERMARK",
- "(NULL)",
- w.getWatermarkExpr()
- })
- ).toArray(String[][]::new);
-
- return buildShowResult(new String[]{"name", "type", "expr"}, rows);
+ StringUtils.removeEnd(logicalType.toString(), " NOT NULL"),
+ logicalType.isNullable() ? "true" : "false",
+ fieldToPrimaryKey.getOrDefault(c.getName(), "(NULL)"),
+ c.getExpr().orElse("(NULL)"),
+ fieldToWatermark.getOrDefault(c.getName(), "(NULL)")};
+ }).toArray(String[][]::new);
+
+ return buildShowResult(new String[]{"name", "type", "null", "key", "compute column", "watermark"}, rows);
Review comment:
move these code to a separated method ?
##########
File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java
##########
@@ -861,23 +865,32 @@ private TableResult executeOperation(Operation operation) {
catalogManager.getTable(describeTableOperation.getSqlIdentifier());
if (result.isPresent()) {
TableSchema schema = result.get().getTable().getSchema();
- String[][] rows = Stream.concat(
+ Map<String, String> fieldToWatermark =
+ schema.getWatermarkSpecs()
+ .stream()
+ .collect(Collectors.toMap(WatermarkSpec::getRowtimeAttribute, WatermarkSpec::getWatermarkExpr));
+
+ Map<String, String> fieldToPrimaryKey = new HashMap<>();
+ schema.getPrimaryKey().ifPresent((p) -> {
+ List<String> columns = p.getColumns();
+ columns.forEach((c) -> fieldToPrimaryKey.put(c, String.format("PRI(%s)", String.join(",", columns))));
+ });
+
+ String[][] rows =
schema.getTableColumns()
.stream()
- .map((c) -> new String[]{
+ .map((c) -> {
+ LogicalType logicalType = c.getType().getLogicalType();
+ return new String[]{
c.getName(),
- c.getType().getLogicalType().toString(),
- c.getExpr().orElse("(NULL)")}),
- schema.getWatermarkSpecs()
- .stream()
- .map((w) -> new String[]{
- "WATERMARK",
- "(NULL)",
- w.getWatermarkExpr()
- })
- ).toArray(String[][]::new);
-
- return buildShowResult(new String[]{"name", "type", "expr"}, rows);
+ StringUtils.removeEnd(logicalType.toString(), " NOT NULL"),
+ logicalType.isNullable() ? "true" : "false",
+ fieldToPrimaryKey.getOrDefault(c.getName(), "(NULL)"),
Review comment:
we should use `null` instead of `(NULL)`, `(NULL)` just a display form defined in `PrintUtils`.
##########
File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java
##########
@@ -861,23 +865,32 @@ private TableResult executeOperation(Operation operation) {
catalogManager.getTable(describeTableOperation.getSqlIdentifier());
if (result.isPresent()) {
TableSchema schema = result.get().getTable().getSchema();
- String[][] rows = Stream.concat(
+ Map<String, String> fieldToWatermark =
+ schema.getWatermarkSpecs()
+ .stream()
+ .collect(Collectors.toMap(WatermarkSpec::getRowtimeAttribute, WatermarkSpec::getWatermarkExpr));
+
+ Map<String, String> fieldToPrimaryKey = new HashMap<>();
+ schema.getPrimaryKey().ifPresent((p) -> {
+ List<String> columns = p.getColumns();
+ columns.forEach((c) -> fieldToPrimaryKey.put(c, String.format("PRI(%s)", String.join(",", columns))));
+ });
+
+ String[][] rows =
schema.getTableColumns()
.stream()
- .map((c) -> new String[]{
+ .map((c) -> {
+ LogicalType logicalType = c.getType().getLogicalType();
+ return new String[]{
c.getName(),
- c.getType().getLogicalType().toString(),
- c.getExpr().orElse("(NULL)")}),
- schema.getWatermarkSpecs()
- .stream()
- .map((w) -> new String[]{
- "WATERMARK",
- "(NULL)",
- w.getWatermarkExpr()
- })
- ).toArray(String[][]::new);
-
- return buildShowResult(new String[]{"name", "type", "expr"}, rows);
+ StringUtils.removeEnd(logicalType.toString(), " NOT NULL"),
+ logicalType.isNullable() ? "true" : "false",
Review comment:
should be boolean type instead of String
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] docete commented on a change in pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
docete commented on a change in pull request #11892:
URL: https://github.com/apache/flink/pull/11892#discussion_r415484898
##########
File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/TableEnvImpl.scala
##########
@@ -721,6 +721,15 @@ abstract class TableEnvImpl(
dropViewOperation.isIfExists)
}
TableResultImpl.TABLE_RESULT_OK
+ case descOperation: DescribeTableOperation =>
+ val result = catalogManager.getTable(descOperation.getSqlIdentifier)
+ if (result.isPresent) {
+ buildShowResult(Array(result.get().getTable.getSchema.toString))
Review comment:
IMO the `comment` column is not needed since our SQL parser doesn't support column comments(We only support table comment now).
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "SUCCESS",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "SUCCESS",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 84b468105ad7674897ed1df0f126d5f078944225 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161749793) Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155)
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "FAILURE",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162192970",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "SUCCESS",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=815",
"triggerID" : "8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e",
"triggerType" : "PUSH"
}, {
"hash" : "7d409ad4e0c06600dc3dc7d2a9715c11215f923a",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "7d409ad4e0c06600dc3dc7d2a9715c11215f923a",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN
* d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162192970) Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309)
* 8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=815)
* 7d409ad4e0c06600dc3dc7d2a9715c11215f923a UNKNOWN
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "SUCCESS",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "SUCCESS",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 84b468105ad7674897ed1df0f126d5f078944225 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161749793) Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155)
* 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN
* d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43 UNKNOWN
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot commented on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot commented on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618760644
Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community
to review your pull request. We will use this comment to track the progress of the review.
## Automated Checks
Last check on commit 84b468105ad7674897ed1df0f126d5f078944225 (Fri Apr 24 02:03:43 UTC 2020)
**Warnings:**
* No documentation files were touched! Remember to keep the Flink docs up to date!
* **This pull request references an unassigned [Jira ticket](https://issues.apache.org/jira/browse/FLINK-17112).** According to the [code contribution guide](https://flink.apache.org/contributing/contribute-code.html), tickets need to be assigned before starting with the implementation work.
<sub>Mention the bot in a comment to re-run the automated checks.</sub>
## Review Progress
* ❓ 1. The [description] looks good.
* ❓ 2. There is [consensus] that the contribution should go into to Flink.
* ❓ 3. Needs [attention] from.
* ❓ 4. The change fits into the overall [architecture].
* ❓ 5. Overall code [quality] is good.
Please see the [Pull Request Review Guide](https://flink.apache.org/contributing/reviewing-prs.html) for a full explanation of the review process.<details>
The Bot is tracking the review progress through labels. Labels are applied according to the order of the review items. For consensus, approval by a Flink committer of PMC member is required <summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot approve description` to approve one or more aspects (aspects: `description`, `consensus`, `architecture` and `quality`)
- `@flinkbot approve all` to approve all aspects
- `@flinkbot approve-until architecture` to approve everything until `architecture`
- `@flinkbot attention @username1 [@username2 ..]` to require somebody's attention
- `@flinkbot disapprove architecture` to remove an approval you gave earlier
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] docete commented on a change in pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
docete commented on a change in pull request #11892:
URL: https://github.com/apache/flink/pull/11892#discussion_r422475071
##########
File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java
##########
@@ -929,16 +935,69 @@ private TableResult executeOperation(Operation operation) {
.setPrintStyle(TableResultImpl.PrintStyle.RAW_CONTENT)
.build();
+ } else if (operation instanceof DescribeTableOperation) {
+ DescribeTableOperation describeTableOperation = (DescribeTableOperation) operation;
+ Optional<CatalogManager.TableLookupResult> result =
+ catalogManager.getTable(describeTableOperation.getSqlIdentifier());
+ if (result.isPresent()) {
+ return buildDescribeResult(result.get().getTable().getSchema());
+ } else {
+ throw new ValidationException(String.format(
+ "Tables or views with the identifier '%s' doesn't exist",
+ describeTableOperation.getSqlIdentifier().asSummaryString()));
+ }
} else {
throw new TableException(UNSUPPORTED_QUERY_IN_EXECUTE_SQL_MSG);
}
}
private TableResult buildShowResult(String[] objects) {
+ return buildResult(
+ new String[]{"result"},
+ new DataType[]{DataTypes.STRING()},
+ Arrays.stream(objects).map((c) -> new String[]{c}).toArray(String[][]::new));
+ }
+
+ private TableResult buildDescribeResult(TableSchema schema) {
+ Map<String, String> fieldToWatermark =
+ schema.getWatermarkSpecs()
+ .stream()
+ .collect(Collectors.toMap(WatermarkSpec::getRowtimeAttribute, WatermarkSpec::getWatermarkExpr));
+
+ Map<String, String> fieldToPrimaryKey = new HashMap<>();
+ schema.getPrimaryKey().ifPresent((p) -> {
+ List<String> columns = p.getColumns();
+ columns.forEach((c) -> fieldToPrimaryKey.put(c, String.format("PRI(%s)", String.join(",", columns))));
+ });
+
+ Object[][] rows =
Review comment:
Not all strings. the nullable of type is boolean.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "DELETED",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162192970",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=815",
"triggerID" : "8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e",
"triggerType" : "PUSH"
}, {
"hash" : "7d409ad4e0c06600dc3dc7d2a9715c11215f923a",
"status" : "SUCCESS",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=821",
"triggerID" : "7d409ad4e0c06600dc3dc7d2a9715c11215f923a",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN
* 8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=815)
* 7d409ad4e0c06600dc3dc7d2a9715c11215f923a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=821)
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] KurtYoung commented on a change in pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
KurtYoung commented on a change in pull request #11892:
URL: https://github.com/apache/flink/pull/11892#discussion_r422459277
##########
File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java
##########
@@ -929,16 +935,69 @@ private TableResult executeOperation(Operation operation) {
.setPrintStyle(TableResultImpl.PrintStyle.RAW_CONTENT)
.build();
+ } else if (operation instanceof DescribeTableOperation) {
+ DescribeTableOperation describeTableOperation = (DescribeTableOperation) operation;
+ Optional<CatalogManager.TableLookupResult> result =
+ catalogManager.getTable(describeTableOperation.getSqlIdentifier());
+ if (result.isPresent()) {
+ return buildDescribeResult(result.get().getTable().getSchema());
+ } else {
+ throw new ValidationException(String.format(
+ "Tables or views with the identifier '%s' doesn't exist",
+ describeTableOperation.getSqlIdentifier().asSummaryString()));
+ }
} else {
throw new TableException(UNSUPPORTED_QUERY_IN_EXECUTE_SQL_MSG);
}
}
private TableResult buildShowResult(String[] objects) {
+ return buildResult(
+ new String[]{"result"},
+ new DataType[]{DataTypes.STRING()},
+ Arrays.stream(objects).map((c) -> new String[]{c}).toArray(String[][]::new));
+ }
+
+ private TableResult buildDescribeResult(TableSchema schema) {
+ Map<String, String> fieldToWatermark =
+ schema.getWatermarkSpecs()
+ .stream()
+ .collect(Collectors.toMap(WatermarkSpec::getRowtimeAttribute, WatermarkSpec::getWatermarkExpr));
+
+ Map<String, String> fieldToPrimaryKey = new HashMap<>();
+ schema.getPrimaryKey().ifPresent((p) -> {
+ List<String> columns = p.getColumns();
+ columns.forEach((c) -> fieldToPrimaryKey.put(c, String.format("PRI(%s)", String.join(",", columns))));
+ });
+
+ Object[][] rows =
Review comment:
use String[][]? The fields are all strings
##########
File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala
##########
@@ -985,6 +987,67 @@ class TableEnvironmentTest {
}
}
+ @Test
+ def testDescribeTableOrView(): Unit = {
+ val sourceDDL =
+ """
+ |CREATE TABLE T1(
+ | a int not null,
Review comment:
please add all supported types here
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "FAILURE",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162192970",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "SUCCESS",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=815",
"triggerID" : "8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e",
"triggerType" : "PUSH"
}, {
"hash" : "7d409ad4e0c06600dc3dc7d2a9715c11215f923a",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=821",
"triggerID" : "7d409ad4e0c06600dc3dc7d2a9715c11215f923a",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN
* d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162192970) Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309)
* 8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=815)
* 7d409ad4e0c06600dc3dc7d2a9715c11215f923a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=821)
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "SUCCESS",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 84b468105ad7674897ed1df0f126d5f078944225 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161749793) Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155)
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "DELETED",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162192970",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=815",
"triggerID" : "8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e",
"triggerType" : "PUSH"
}, {
"hash" : "7d409ad4e0c06600dc3dc7d2a9715c11215f923a",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=821",
"triggerID" : "7d409ad4e0c06600dc3dc7d2a9715c11215f923a",
"triggerType" : "PUSH"
}, {
"hash" : "4fca4d498b4fe7cab7da0537c8010298b1e0aa22",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=853",
"triggerID" : "4fca4d498b4fe7cab7da0537c8010298b1e0aa22",
"triggerType" : "PUSH"
}, {
"hash" : "b932462436bbab0e9c220203b374a9290ed7e1a4",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "b932462436bbab0e9c220203b374a9290ed7e1a4",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN
* 8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=815)
* 4fca4d498b4fe7cab7da0537c8010298b1e0aa22 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=853)
* b932462436bbab0e9c220203b374a9290ed7e1a4 UNKNOWN
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "FAILURE",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162192970",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "SUCCESS",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN
* d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162192970) Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309)
* 8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e UNKNOWN
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "SUCCESS",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "SUCCESS",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 84b468105ad7674897ed1df0f126d5f078944225 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161749793) Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155)
* 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot commented on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot commented on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 84b468105ad7674897ed1df0f126d5f078944225 UNKNOWN
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "FAILURE",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162192970",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN
* d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162192970) Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309)
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] docete removed a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
docete removed a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-625736929
`
+------+--------------------------------+-------+--------+-------------------+----------------------------+
| name | type | null | key | compute column | watermark |
+------+--------------------------------+-------+--------+-------------------+----------------------------+
| a | INT | false | (NULL) | (NULL) | (NULL) |
| b | STRING | true | (NULL) | (NULL) | (NULL) |
| c | ROW<`f0` INT NOT NULL, `f1... | false | (NULL) | (NULL) | (NULL) |
| ts | TIMESTAMP(3) | true | (NULL) | TO_TIMESTAMP(`b`) | `ts` - INTERVAL '1' SECOND |
+------+--------------------------------+-------+--------+-------------------+----------------------------+
`
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] docete commented on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
docete commented on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-625736929
`
+------+--------------------------------+-------+--------+-------------------+----------------------------+
| name | type | null | key | compute column | watermark |
+------+--------------------------------+-------+--------+-------------------+----------------------------+
| a | INT | false | (NULL) | (NULL) | (NULL) |
| b | STRING | true | (NULL) | (NULL) | (NULL) |
| c | ROW<`f0` INT NOT NULL, `f1... | false | (NULL) | (NULL) | (NULL) |
| ts | TIMESTAMP(3) | true | (NULL) | TO_TIMESTAMP(`b`) | `ts` - INTERVAL '1' SECOND |
+------+--------------------------------+-------+--------+-------------------+----------------------------+
`
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "FAILURE",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162192970",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "SUCCESS",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN
* d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162192970) Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309)
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "DELETED",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162192970",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=815",
"triggerID" : "8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e",
"triggerType" : "PUSH"
}, {
"hash" : "7d409ad4e0c06600dc3dc7d2a9715c11215f923a",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=821",
"triggerID" : "7d409ad4e0c06600dc3dc7d2a9715c11215f923a",
"triggerType" : "PUSH"
}, {
"hash" : "4fca4d498b4fe7cab7da0537c8010298b1e0aa22",
"status" : "FAILURE",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=853",
"triggerID" : "4fca4d498b4fe7cab7da0537c8010298b1e0aa22",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN
* 8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=815)
* 4fca4d498b4fe7cab7da0537c8010298b1e0aa22 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=853)
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL
Posted by GitBox <gi...@apache.org>.
flinkbot edited a comment on pull request #11892:
URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/161749793",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "84b468105ad7674897ed1df0f126d5f078944225",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=155",
"triggerID" : "84b468105ad7674897ed1df0f126d5f078944225",
"triggerType" : "PUSH"
}, {
"hash" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "196b7566be701c6c0759d08f76d7bec7148a47b3",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "DELETED",
"url" : "https://travis-ci.com/github/flink-ci/flink/builds/162192970",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"status" : "DELETED",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=309",
"triggerID" : "d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43",
"triggerType" : "PUSH"
}, {
"hash" : "8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e",
"status" : "PENDING",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=815",
"triggerID" : "8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e",
"triggerType" : "PUSH"
}, {
"hash" : "7d409ad4e0c06600dc3dc7d2a9715c11215f923a",
"status" : "SUCCESS",
"url" : "https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=821",
"triggerID" : "7d409ad4e0c06600dc3dc7d2a9715c11215f923a",
"triggerType" : "PUSH"
}, {
"hash" : "4fca4d498b4fe7cab7da0537c8010298b1e0aa22",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "4fca4d498b4fe7cab7da0537c8010298b1e0aa22",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN
* 8f3e1a4dd3d369fe0afd904a825d50aa3ee2ab8e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=815)
* 7d409ad4e0c06600dc3dc7d2a9715c11215f923a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=821)
* 4fca4d498b4fe7cab7da0537c8010298b1e0aa22 UNKNOWN
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run travis` re-run the last Travis build
- `@flinkbot run azure` re-run the last Azure build
</details>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org