[GitHub] [flink] KarmaGYZ commented on a change in pull request #11854: [WIP] Introduce external resource framework

KarmaGYZ commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r414340925 ## File path: flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java ## @@ -175,6 +177,11 @@ public Distribu

[GitHub] [flink] lirui-apache commented on a change in pull request #11791: [FLINK-17210][sql-parser][hive] Implement database DDLs for Hive dialect

lirui-apache commented on a change in pull request #11791: URL: https://github.com/apache/flink/pull/11791#discussion_r414333859 ## File path: flink-table/flink-sql-parser/pom.xml ## @@ -298,6 +348,23 @@ under the License.

[GitHub] [flink] Ruan-Xin commented on pull request #11876: [FLINK-17334] HIVE UDF BUGFIX

Ruan-Xin commented on pull request #11876: URL: https://github.com/apache/flink/pull/11876#issuecomment-618837763 Hi @lirui-apache I have pushed the new fix and add test cases~ This is an automated message from the Apache Gi

[GitHub] [flink] zentol commented on a change in pull request #11879: [FLINK-17308] Add regular cleanup task for ExecutionGraphCache

zentol commented on a change in pull request #11879: URL: https://github.com/apache/flink/pull/11879#discussion_r414334764 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/metrics/JobVertexWatermarksHandlerTest.java ## @@ -87,7 +87,7 @@ publi

[jira] [Updated] (FLINK-17338) LocalExecutorITCase.testBatchQueryCancel test timeout

[ https://issues.apache.org/jira/browse/FLINK-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-17338: -- Fix Version/s: 1.10.1 Affects Version/s: 1.10.0 Also see this failure in release-1.10 crone job: http

[GitHub] [flink] flinkbot edited a comment on pull request #11857: [FLINK-17180][runtime] Implement SchedulingPipelinedRegion interface

flinkbot edited a comment on pull request #11857: URL: https://github.com/apache/flink/pull/11857#issuecomment-617622388 ## CI report: * 153983502e03705fa2496728c1ef76167a6fe68c Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161681085) Azure: [SUCCESS](http

[GitHub] [flink] flinkbot edited a comment on pull request #11791: [FLINK-17210][sql-parser][hive] Implement database DDLs for Hive dialect

flinkbot edited a comment on pull request #11791: URL: https://github.com/apache/flink/pull/11791#issuecomment-615162346 ## CI report: * 6359340c0b5b01923d7ac2824b9eb1071e0f2f37 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161755234) Azure: [SUCCESS](http

[GitHub] [flink] flinkbot edited a comment on pull request #11857: [FLINK-17180][runtime] Implement SchedulingPipelinedRegion interface

flinkbot edited a comment on pull request #11857: URL: https://github.com/apache/flink/pull/11857#issuecomment-617622388 ## CI report: * 153983502e03705fa2496728c1ef76167a6fe68c Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161681085) Azure: [SUCCESS](http

[GitHub] [flink] flinkbot edited a comment on pull request #11791: [FLINK-17210][sql-parser][hive] Implement database DDLs for Hive dialect

flinkbot edited a comment on pull request #11791: URL: https://github.com/apache/flink/pull/11791#issuecomment-615162346 ## CI report: * 6359340c0b5b01923d7ac2824b9eb1071e0f2f37 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161755234) Azure: [PENDING](http

[jira] [Closed] (FLINK-17215) Clean the build document for Pyflink

[ https://issues.apache.org/jira/browse/FLINK-17215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17215. --- Resolution: Resolved Merged to release-1.9 via 8c8fa36f118ac841990fbaced14e71aeb946edf1 > Clean the build d

[jira] [Updated] (FLINK-17215) Clean the build document for Pyflink

[ https://issues.apache.org/jira/browse/FLINK-17215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17215: Component/s: Documentation > Clean the build document for Pyflink > >

[GitHub] [flink] flinkbot edited a comment on pull request #11897: [FLINK-16104] Translate "Streaming Aggregation" page of "Table API & SQL" into Chinese

flinkbot edited a comment on pull request #11897: URL: https://github.com/apache/flink/pull/11897#issuecomment-618812841 ## CI report: * 7969f07cca4581f4ae7cbef7bd06787b3e90d248 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161766709) Azure: [PENDING](http

[GitHub] [flink] flinkbot edited a comment on pull request #11893: [FLINK-17344] Fix unstability of RecordWriterTest. testIdleTime and TaskMailboxProcessorTest.testIdleTime

flinkbot edited a comment on pull request #11893: URL: https://github.com/apache/flink/pull/11893#issuecomment-618771008 ## CI report: * b6a842dcaf10cca2b72a0155c1be580c5d9a3448 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161751204) Azure: [SUCCESS](http

[GitHub] [flink] flinkbot edited a comment on pull request #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

flinkbot edited a comment on pull request #11837: URL: https://github.com/apache/flink/pull/11837#issuecomment-616956896 ## CI report: * 9a4391b7c7248cdca1d2536f402891a6b64335b7 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161760513) Azure: [FAILURE](http

[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL

flinkbot edited a comment on pull request #11892: URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534 ## CI report: * 84b468105ad7674897ed1df0f126d5f078944225 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161749793) Azure: [SUCCESS](http

[GitHub] [flink] danny0405 commented on a change in pull request #11791: [FLINK-17210][sql-parser][hive] Implement database DDLs for Hive dialect

danny0405 commented on a change in pull request #11791: URL: https://github.com/apache/flink/pull/11791#discussion_r414314520 ## File path: flink-table/flink-sql-parser/pom.xml ## @@ -298,6 +348,23 @@ under the License. $

[GitHub] [flink] danny0405 commented on a change in pull request #11791: [FLINK-17210][sql-parser][hive] Implement database DDLs for Hive dialect

danny0405 commented on a change in pull request #11791: URL: https://github.com/apache/flink/pull/11791#discussion_r414313942 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/hive/HiveDDLUtils.java ## @@ -0,0 +1,94 @@ +/* + * Licensed to

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11854: [WIP] Introduce external resource framework

KarmaGYZ commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r414313708 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/externalresource/ExternalResourceUtilsTest.java ## @@ -85,4 +88,20 @@ public void tes

[GitHub] [flink] GJL commented on a change in pull request #11857: [FLINK-17180][runtime] Implement SchedulingPipelinedRegion interface

GJL commented on a change in pull request #11857: URL: https://github.com/apache/flink/pull/11857#discussion_r414313732 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/RestartPipelinedRegionFailoverStrategy.java ## @@ -84,34 +77

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11854: [WIP] Introduce external resource framework

KarmaGYZ commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r414312301 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/SavepointEnvironment.java ## @@ -198,6 +199,11

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11854: [WIP] Introduce external resource framework

KarmaGYZ commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r414312301 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/SavepointEnvironment.java ## @@ -198,6 +199,11

[GitHub] [flink] flinkbot commented on pull request #11897: [FLINK-16104] Translate "Streaming Aggregation" page of "Table API & SQL" into Chinese

flinkbot commented on pull request #11897: URL: https://github.com/apache/flink/pull/11897#issuecomment-618812841 ## CI report: * 7969f07cca4581f4ae7cbef7bd06787b3e90d248 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #11893: [FLINK-17344] Fix unstability of RecordWriterTest. testIdleTime and TaskMailboxProcessorTest.testIdleTime

flinkbot edited a comment on pull request #11893: URL: https://github.com/apache/flink/pull/11893#issuecomment-618771008 ## CI report: * b6a842dcaf10cca2b72a0155c1be580c5d9a3448 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161751204) Azure: [PENDING](http

[GitHub] [flink] flinkbot edited a comment on pull request #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

flinkbot edited a comment on pull request #11837: URL: https://github.com/apache/flink/pull/11837#issuecomment-616956896 ## CI report: * 9a4391b7c7248cdca1d2536f402891a6b64335b7 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161760513) Azure: [PENDING](http

[GitHub] [flink] danny0405 commented on a change in pull request #11791: [FLINK-17210][sql-parser][hive] Implement database DDLs for Hive dialect

danny0405 commented on a change in pull request #11791: URL: https://github.com/apache/flink/pull/11791#discussion_r414308065 ## File path: flink-table/flink-sql-parser/src/main/codegen-hive/data/Parser.tdd ## @@ -0,0 +1,547 @@ +# Licensed to the Apache Software Foundation (ASF

[GitHub] [flink] flinkbot edited a comment on pull request #11896: [FLINK-14356] [single-value] Introduce "single-value" format to (de)serialize message to a single field

flinkbot edited a comment on pull request #11896: URL: https://github.com/apache/flink/pull/11896#issuecomment-618808279 ## CI report: * 6c5110c57efcb28693fa1bb15f59dbfc9850e58f Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161765118) Azure: [PENDING](http

[GitHub] [flink] flinkbot edited a comment on pull request #11838: [FLINK-16965] Convert Graphite reporter to plugin

flinkbot edited a comment on pull request #11838: URL: https://github.com/apache/flink/pull/11838#issuecomment-616983944 ## CI report: * cd4f2390481d8edcea676f07a6db2eafe0a4025c UNKNOWN * b961c6a03d184e9a091b1513cb82f7aaa3956cf3 Travis: [SUCCESS](https://travis-ci.com/github/f

[GitHub] [flink] flinkbot edited a comment on pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN * cba096ae3d8eba4a0d39c64659f76ad10a62

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11854: [WIP] Introduce external resource framework

KarmaGYZ commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r414305550 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/DistributedRuntimeUDFContext.java ## @@ -41,10 +44,14 @@ public class

[GitHub] [flink] danny0405 commented on a change in pull request #11791: [FLINK-17210][sql-parser][hive] Implement database DDLs for Hive dialect

danny0405 commented on a change in pull request #11791: URL: https://github.com/apache/flink/pull/11791#discussion_r414305379 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java ## @@ -1403,4 +1446,29 @@ public

[GitHub] [flink] danny0405 commented on a change in pull request #11791: [FLINK-17210][sql-parser][hive] Implement database DDLs for Hive dialect

danny0405 commented on a change in pull request #11791: URL: https://github.com/apache/flink/pull/11791#discussion_r414269563 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java ## @@ -247,7 +253,10 @@ public C

[GitHub] [flink] flinkbot commented on pull request #11897: [FLINK-16104] Translate "Streaming Aggregation" page of "Table API & SQL" into Chinese

flinkbot commented on pull request #11897: URL: https://github.com/apache/flink/pull/11897#issuecomment-618810155 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 pro

[jira] [Assigned] (FLINK-17344) RecordWriterTest.testIdleTime possibly deadlocks on Travis

[ https://issues.apache.org/jira/browse/FLINK-17344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17344: Assignee: Wenlong Lyu (was: Wenlong Li) > RecordWriterTest.testIdleTime possibly deadlocks on Tr

[jira] [Updated] (FLINK-16104) Translate "Streaming Aggregation" page of "Table API & SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16104: --- Labels: pull-request-available (was: ) > Translate "Streaming Aggregation" page of "Table A

[jira] [Assigned] (FLINK-17344) RecordWriterTest.testIdleTime possibly deadlocks on Travis

[ https://issues.apache.org/jira/browse/FLINK-17344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17344: Assignee: Wenlong Li > RecordWriterTest.testIdleTime possibly deadlocks on Travis > -

[GitHub] [flink] chaojianok opened a new pull request #11897: [FLINK-16104] Translate "Streaming Aggregation" page of "Table API & SQL" into Chinese

chaojianok opened a new pull request #11897: URL: https://github.com/apache/flink/pull/11897 [FLINK-16104] Translate "Streaming Aggregation" page of "Table API & SQL" into Chinese. This is an automated message from the Apach

[GitHub] [flink] KurtYoung commented on a change in pull request #11874: [FLINK-16935][table-planner-blink] Enable or delete most of the ignored test cases in blink planner.

KurtYoung commented on a change in pull request #11874: URL: https://github.com/apache/flink/pull/11874#discussion_r414302741 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/expressions/NonDeterministicTests.scala ## @@ -23,71

[GitHub] [flink] flinkbot edited a comment on pull request #11895: [FLINK-10911] Flink's flink-scala-shell is not working with Scala 2.12

flinkbot edited a comment on pull request #11895: URL: https://github.com/apache/flink/pull/11895#issuecomment-618799215 ## CI report: * 191da9e8a608bde3657193779bc9f0a48350f36d Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161760585) Azure: [PENDING](http

[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL

flinkbot edited a comment on pull request #11892: URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534 ## CI report: * 84b468105ad7674897ed1df0f126d5f078944225 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161749793) Azure: [PENDING](http

[GitHub] [flink] flinkbot commented on pull request #11896: [FLINK-14356] [single-value] Introduce "single-value" format to (de)serialize message to a single field

flinkbot commented on pull request #11896: URL: https://github.com/apache/flink/pull/11896#issuecomment-618808279 ## CI report: * 6c5110c57efcb28693fa1bb15f59dbfc9850e58f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN * cba096ae3d8eba4a0d39c64659f76ad10a62

[GitHub] [flink] flinkbot edited a comment on pull request #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot edited a comment on pull request #11797: URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN * b8122fd40266de44eea61cd65e0b61cecea8 Travis: [SUCCESS](https://travis-ci.com/github/f

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11854: [WIP] Introduce external resource framework

KarmaGYZ commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r414300630 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/externalresource/ExternalResourceUtils.java ## @@ -117,4 +138,17 @@

[GitHub] [flink] zjffdu commented on pull request #11895: [FLINK-10911] Flink's flink-scala-shell is not working with Scala 2.12

zjffdu commented on pull request #11895: URL: https://github.com/apache/flink/pull/11895#issuecomment-618806981 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please l

[GitHub] [flink] flinkbot commented on pull request #11896: [FLINK-14356] [single-value] Introduce "single-value" format to (de)serialize message to a single field

flinkbot commented on pull request #11896: URL: https://github.com/apache/flink/pull/11896#issuecomment-618801326 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 pro

[jira] [Updated] (FLINK-14356) Introduce "single-field" format to (de)serialize message to a single field

[ https://issues.apache.org/jira/browse/FLINK-14356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14356: --- Labels: pull-request-available (was: ) > Introduce "single-field" format to (de)serialize m

[GitHub] [flink] hackergin opened a new pull request #11896: [FLINK-14356] [single-value] Introduce "single-value" format to (de)serialize message to a single field

hackergin opened a new pull request #11896: URL: https://github.com/apache/flink/pull/11896 ## What is the purpose of the change This pull request introduct single-value format to (de)serialize message to a single field ## Brief change log - add single-val

[GitHub] [flink] flinkbot edited a comment on pull request #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

flinkbot edited a comment on pull request #11837: URL: https://github.com/apache/flink/pull/11837#issuecomment-616956896 ## CI report: * 38df357bc5c54d93159c2d460833cf80c42b5e0c Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161413766) Azure: [SUCCESS](http

[GitHub] [flink] flinkbot commented on pull request #11895: [FLINK-10911] Flink's flink-scala-shell is not working with Scala 2.12 [WIP]

flinkbot commented on pull request #11895: URL: https://github.com/apache/flink/pull/11895#issuecomment-618799215 ## CI report: * 191da9e8a608bde3657193779bc9f0a48350f36d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #11838: [FLINK-16965] Convert Graphite reporter to plugin

flinkbot edited a comment on pull request #11838: URL: https://github.com/apache/flink/pull/11838#issuecomment-616983944 ## CI report: * cd4f2390481d8edcea676f07a6db2eafe0a4025c UNKNOWN * b961c6a03d184e9a091b1513cb82f7aaa3956cf3 Travis: [SUCCESS](https://travis-ci.com/github/f

[GitHub] [flink] flinkbot edited a comment on pull request #11853: [FLINK-15006][table-planner] Add option to shuffle-by-partition when dynamic inserting

flinkbot edited a comment on pull request #11853: URL: https://github.com/apache/flink/pull/11853#issuecomment-617586421 ## CI report: * 99b58fba1e22bdbba0896f0aba181eafc6a28e7f Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161461206) Azure: [SUCCESS](http

[GitHub] [flink] flinkbot edited a comment on pull request #11796: [FLINK-14258][table][filesystem] Integrate file system connector to streaming sink

flinkbot edited a comment on pull request #11796: URL: https://github.com/apache/flink/pull/11796#issuecomment-615254717 ## CI report: * 90fa0d286fbdae57d834d527a8843a8a493d5a0d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160733394) Azure: [FAILURE](http

[jira] [Created] (FLINK-17364) Support StreamingFileSink in PrestoS3FileSystem

Lu Niu created FLINK-17364: -- Summary: Support StreamingFileSink in PrestoS3FileSystem Key: FLINK-17364 URL: https://issues.apache.org/jira/browse/FLINK-17364 Project: Flink Issue Type: Improvement

[GitHub] [flink] Ruan-Xin commented on pull request #11876: [FLINK-17334] HIVE UDF BUGFIX

Ruan-Xin commented on pull request #11876: URL: https://github.com/apache/flink/pull/11876#issuecomment-618795529 > ObjectInspectorFactory.ObjectInspectorOptions.JAVA) I got it, You're right, I can get the correct result with this method. ---

[GitHub] [flink] flinkbot edited a comment on pull request #11853: [FLINK-15006][table-planner] Add option to shuffle-by-partition when dynamic inserting

flinkbot edited a comment on pull request #11853: URL: https://github.com/apache/flink/pull/11853#issuecomment-617586421 ## CI report: * 99b58fba1e22bdbba0896f0aba181eafc6a28e7f Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161461206) Azure: [SUCCESS](http

[GitHub] [flink] flinkbot edited a comment on pull request #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

flinkbot edited a comment on pull request #11837: URL: https://github.com/apache/flink/pull/11837#issuecomment-616956896 ## CI report: * 38df357bc5c54d93159c2d460833cf80c42b5e0c Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161413766) Azure: [SUCCESS](http

[GitHub] [flink] flinkbot edited a comment on pull request #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

flinkbot edited a comment on pull request #11797: URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN * b8122fd40266de44eea61cd65e0b61cecea8 Travis: [SUCCESS](https://travis-ci.com/github/f

[GitHub] [flink] flinkbot edited a comment on pull request #11796: [FLINK-14258][table][filesystem] Integrate file system connector to streaming sink

flinkbot edited a comment on pull request #11796: URL: https://github.com/apache/flink/pull/11796#issuecomment-615254717 ## CI report: * 90fa0d286fbdae57d834d527a8843a8a493d5a0d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160733394) Azure: [FAILURE](http

[GitHub] [flink] flinkbot edited a comment on pull request #11774: [FLINK-17020][runtime] Introduce GlobalDataExchangeMode for JobGraph generation

flinkbot edited a comment on pull request #11774: URL: https://github.com/apache/flink/pull/11774#issuecomment-614576955 ## CI report: * 1f72fb850f69449f4ef886ec0cad8a0644bab93d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161169787) Azure: [SUCCESS](http

[jira] [Commented] (FLINK-17273) Fix not calling ResourceManager#closeTaskManagerConnection in KubernetesResourceManager in case of registered TaskExecutor failure

[ https://issues.apache.org/jira/browse/FLINK-17273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091156#comment-17091156 ] Canbin Zheng commented on FLINK-17273: -- Thanks a lot for the input [~trohrmann] [~x

[jira] [Commented] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091155#comment-17091155 ] chenxyz commented on FLINK-16662: - [~jark] thx, you're right, end-to-end test is a bette

[GitHub] [flink] xintongsong commented on a change in pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

xintongsong commented on a change in pull request #11323: URL: https://github.com/apache/flink/pull/11323#discussion_r414277526 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java ## @@ -320,5 +333,16 @@ private void internal

[GitHub] [flink] flinkbot commented on pull request #11895: [FLINK-10911] Flink's flink-scala-shell is not working with Scala 2.12 [WIP]

flinkbot commented on pull request #11895: URL: https://github.com/apache/flink/pull/11895#issuecomment-618789667 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #11774: [FLINK-17020][runtime] Introduce GlobalDataExchangeMode for JobGraph generation

flinkbot edited a comment on pull request #11774: URL: https://github.com/apache/flink/pull/11774#issuecomment-614576955 ## CI report: * 1f72fb850f69449f4ef886ec0cad8a0644bab93d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161169787) Azure: [SUCCESS](http

[GitHub] [flink] zjffdu opened a new pull request #11895: [FLINK-10911] Flink's flink-scala-shell is not working with Scala 2.12 [WIP]

zjffdu opened a new pull request #11895: URL: https://github.com/apache/flink/pull/11895 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[GitHub] [flink] lirui-apache commented on pull request #11876: [FLINK-17334] HIVE UDF BUGFIX

lirui-apache commented on pull request #11876: URL: https://github.com/apache/flink/pull/11876#issuecomment-618788643 @Ruan-Xin I meant you can change `HiveSimpleUDF::getHiveResultType` to something like this: ``` @Override public DataType getHiveResultType(Object[] const

[jira] [Created] (FLINK-17363) Asynchronous association dimension table timeout

robert created FLINK-17363: -- Summary: Asynchronous association dimension table timeout Key: FLINK-17363 URL: https://issues.apache.org/jira/browse/FLINK-17363 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-17308) ExecutionGraphCache cachedExecutionGraphs not cleanup cause OOM Bug

[ https://issues.apache.org/jira/browse/FLINK-17308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091144#comment-17091144 ] sunjincheng commented on FLINK-17308: - Reset the fix version as 1.9.3 was released.

[GitHub] [flink] zhuzhurk commented on a change in pull request #11857: [FLINK-17180][runtime] Implement SchedulingPipelinedRegion interface

zhuzhurk commented on a change in pull request #11857: URL: https://github.com/apache/flink/pull/11857#discussion_r414264754 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/RestartPipelinedRegionFailoverStrategy.java ## @@ -84,3

[jira] [Updated] (FLINK-17308) ExecutionGraphCache cachedExecutionGraphs not cleanup cause OOM Bug

[ https://issues.apache.org/jira/browse/FLINK-17308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-17308: Fix Version/s: (was: 1.9.3) 1.9.4 > ExecutionGraphCache cachedExecutionGrap

[GitHub] [flink] flinkbot commented on pull request #11894: [WIP][FLINK-10911] Flink's flink-scala-shell is not working with Scala 2.12

flinkbot commented on pull request #11894: URL: https://github.com/apache/flink/pull/11894#issuecomment-618785514 ## CI report: * 191da9e8a608bde3657193779bc9f0a48350f36d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] zhuzhurk commented on a change in pull request #11857: [FLINK-17180][runtime] Implement SchedulingPipelinedRegion interface

zhuzhurk commented on a change in pull request #11857: URL: https://github.com/apache/flink/pull/11857#discussion_r414264754 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/RestartPipelinedRegionFailoverStrategy.java ## @@ -84,3

[GitHub] [flink] flinkbot edited a comment on pull request #11791: [FLINK-17210][sql-parser][hive] Implement database DDLs for Hive dialect

flinkbot edited a comment on pull request #11791: URL: https://github.com/apache/flink/pull/11791#issuecomment-615162346 ## CI report: * a6642cdfead306f1192f73c861e7201af9d38c56 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160705250) Azure: [FAILURE](http

[GitHub] [flink] zhuzhurk commented on a change in pull request #11774: [FLINK-17020][runtime] Introduce GlobalDataExchangeMode for JobGraph generation

zhuzhurk commented on a change in pull request #11774: URL: https://github.com/apache/flink/pull/11774#discussion_r414269826 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java ## @@ -898,6 +825,116 @@ publi

[GitHub] [flink] zhuzhurk commented on a change in pull request #11774: [FLINK-17020][runtime] Introduce GlobalDataExchangeMode for JobGraph generation

zhuzhurk commented on a change in pull request #11774: URL: https://github.com/apache/flink/pull/11774#discussion_r414270078 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java ## @@ -898,6 +825,116 @@ publi

[jira] [Commented] (FLINK-17334) Flink does not support HIVE UDFs with primitive return types

[ https://issues.apache.org/jira/browse/FLINK-17334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091141#comment-17091141 ] xin.ruan commented on FLINK-17334: -- Hi all, I want to support array and map types, but

[jira] [Commented] (FLINK-17086) Flink sql client not able to read parquet hive table because `HiveMapredSplitReader` not supports name mapping reading for parquet format.

[ https://issues.apache.org/jira/browse/FLINK-17086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091140#comment-17091140 ] Rui Li commented on FLINK-17086: Hi [~leiwangouc], FLINK-16802 has been fixed and you ca

[jira] [Updated] (FLINK-17334) Flink does not support HIVE UDFs with primitive return types

[ https://issues.apache.org/jira/browse/FLINK-17334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xin.ruan updated FLINK-17334: - Attachment: screenshot-1.png > Flink does not support HIVE UDFs with primitive return types > -

[jira] [Updated] (FLINK-17334) Flink does not support HIVE UDFs with primitive return types

[ https://issues.apache.org/jira/browse/FLINK-17334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xin.ruan updated FLINK-17334: - Description: We are currently migrating Hive UDF to Flink. While testing compatibility, we found that F

[jira] [Updated] (FLINK-14543) Support partition for temporary table

[ https://issues.apache.org/jira/browse/FLINK-14543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-14543: - Fix Version/s: 1.11.0 > Support partition for temporary table >

[jira] [Closed] (FLINK-14543) Support partition for temporary table

[ https://issues.apache.org/jira/browse/FLINK-14543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-14543. Resolution: Fixed master: 6976e50e68f64d133fbf223a56db4a8b09e079cb > Support partition for tempor

[jira] [Closed] (FLINK-15901) Support partitioned generic table in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-15901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-15901. Resolution: Fixed master: 3a30886e300835e158177944f734a47453a4beab > Support partitioned generic

[jira] [Updated] (FLINK-14356) Introduce "single-field" format to (de)serialize message to a single field

[ https://issues.apache.org/jira/browse/FLINK-14356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14356: Fix Version/s: 1.11.0 > Introduce "single-field" format to (de)serialize message to a single field > -

[GitHub] [flink] flinkbot commented on pull request #11894: [WIP][FLINK-10911] Flink's flink-scala-shell is not working with Scala 2.12

flinkbot commented on pull request #11894: URL: https://github.com/apache/flink/pull/11894#issuecomment-618783169 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 pro

[jira] [Updated] (FLINK-17334) Flink does not support HIVE UDFs with primitive return types

[ https://issues.apache.org/jira/browse/FLINK-17334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xin.ruan updated FLINK-17334: - Description: We are currently migrating Hive UDF to Flink. While testing compatibility, we found that F

[jira] [Updated] (FLINK-10911) Flink's flink-scala-shell is not working with Scala 2.12

[ https://issues.apache.org/jira/browse/FLINK-10911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10911: --- Labels: pull-request-available (was: ) > Flink's flink-scala-shell is not working with Scal

[GitHub] [flink] zjffdu opened a new pull request #11894: [WIP][FLINK-10911] Flink's flink-scala-shell is not working with Scala 2.12

zjffdu opened a new pull request #11894: URL: https://github.com/apache/flink/pull/11894 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[jira] [Closed] (FLINK-16803) Need to make sure partition inherit table spec when writing to Hive tables

[ https://issues.apache.org/jira/browse/FLINK-16803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-16803. > Need to make sure partition inherit table spec when writing to Hive tables > ---

[jira] [Updated] (FLINK-16803) Need to make sure partition inherit table spec when writing to Hive tables

[ https://issues.apache.org/jira/browse/FLINK-16803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-16803: - Affects Version/s: 1.10.0 > Need to make sure partition inherit table spec when writing to Hive

[jira] [Updated] (FLINK-16802) Set schema info in JobConf for Hive readers

[ https://issues.apache.org/jira/browse/FLINK-16802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-16802: - Affects Version/s: 1.10.0 > Set schema info in JobConf for Hive readers > --

[jira] [Closed] (FLINK-16802) Set schema info in JobConf for Hive readers

[ https://issues.apache.org/jira/browse/FLINK-16802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-16802. Fix Version/s: 1.11.0 Assignee: Rui Li Resolution: Fixed master: 43cf121e77f8d001d

[jira] [Assigned] (FLINK-16803) Need to make sure partition inherit table spec when writing to Hive tables

[ https://issues.apache.org/jira/browse/FLINK-16803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16803: Assignee: Rui Li > Need to make sure partition inherit table spec when writing to Hive ta

[GitHub] [flink] JingsongLi commented on pull request #11791: [FLINK-17210][sql-parser][hive] Implement database DDLs for Hive dialect

JingsongLi commented on pull request #11791: URL: https://github.com/apache/flink/pull/11791#issuecomment-618782334 CC: @danny0405 This is an automated message from the Apache Git Service. To respond to the message, please l

[GitHub] [flink] flinkbot edited a comment on pull request #11884: [FLINK-17345][python][table] Support register and get Python UDF in Catalog.

flinkbot edited a comment on pull request #11884: URL: https://github.com/apache/flink/pull/11884#issuecomment-618376627 ## CI report: * 570f7e22326fc2f2d9f7dff4066192b604e7c479 Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/161749776) Azure: [FAILURE](htt

[GitHub] [flink] zhuzhurk commented on a change in pull request #11857: [FLINK-17180][runtime] Implement SchedulingPipelinedRegion interface

zhuzhurk commented on a change in pull request #11857: URL: https://github.com/apache/flink/pull/11857#discussion_r414264754 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/RestartPipelinedRegionFailoverStrategy.java ## @@ -84,3

[GitHub] [flink] flinkbot edited a comment on pull request #11791: [FLINK-17210][sql-parser][hive] Implement database DDLs for Hive dialect

flinkbot edited a comment on pull request #11791: URL: https://github.com/apache/flink/pull/11791#issuecomment-615162346 ## CI report: * a6642cdfead306f1192f73c861e7201af9d38c56 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160705250) Azure: [FAILURE](http

[GitHub] [flink] flinkbot edited a comment on pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN * cba096ae3d8eba4a0d39c64659f76ad10a62

[GitHub] [flink] zhuzhurk commented on a change in pull request #11857: [FLINK-17180][runtime] Implement SchedulingPipelinedRegion interface

zhuzhurk commented on a change in pull request #11857: URL: https://github.com/apache/flink/pull/11857#discussion_r414264754 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/RestartPipelinedRegionFailoverStrategy.java ## @@ -84,3

[jira] [Commented] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091129#comment-17091129 ] Jark Wu commented on FLINK-16662: - Btw, your approach is very similar to an end-to-end t

[jira] [Commented] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091128#comment-17091128 ] Jark Wu commented on FLINK-16662: - Hi [~chenxyz], I think a better test is to add a real

  1   2   3   4   5   6   >