[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * 65b0ffa4eafedf431e7fd4e6e6b1b6d2d32386bd Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161834928) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvir

flinkbot edited a comment on pull request #11905: URL: https://github.com/apache/flink/pull/11905#issuecomment-619089324 ## CI report: * a718d0e67e1890a9cc8a280a7621f89cae8212dc Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161949777) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

flinkbot edited a comment on pull request #11567: URL: https://github.com/apache/flink/pull/11567#issuecomment-606017854 ## CI report: * 260dec1b8646e0c8a44b784cdb32290832b48951 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161317745) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvir

flinkbot edited a comment on pull request #11905: URL: https://github.com/apache/flink/pull/11905#issuecomment-619089324 ## CI report: * af67911ce3d587b4cd17d7757b98222f26264439 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161860341) Azure:

[jira] [Updated] (FLINK-16661) Introduce the YarnApplicationClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-16661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16661: - Component/s: Client / Job Submission > Introduce the YarnApplicationClusterEntrypoint >

[jira] [Updated] (FLINK-16656) Introduce DispatcherBootstrap to initialise Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-16656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16656: - Component/s: Client / Job Submission > Introduce DispatcherBootstrap to initialise

[jira] [Updated] (FLINK-16655) Introduce the EmbeddedExecutor for executing the main() on the Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-16655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16655: - Component/s: Client / Job Submission > Introduce the EmbeddedExecutor for executing the

[jira] [Updated] (FLINK-16660) Introduce the ApplicationDispatcherBootstrap

[ https://issues.apache.org/jira/browse/FLINK-16660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16660: - Component/s: Client / Job Submission > Introduce the ApplicationDispatcherBootstrap >

[jira] [Updated] (FLINK-16657) Wire the EmbeddedExecutor to the Web Submission logic.

[ https://issues.apache.org/jira/browse/FLINK-16657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16657: - Component/s: Client / Job Submission > Wire the EmbeddedExecutor to the Web Submission

[jira] [Updated] (FLINK-16654) Implement Application Mode according to FLIP-85

[ https://issues.apache.org/jira/browse/FLINK-16654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16654: - Component/s: Client / Job Submission > Implement Application Mode according to FLIP-85

[jira] [Updated] (FLINK-16658) Wire the EmbeddedExecutor to the StandaloneJobClusterEntryPoint.

[ https://issues.apache.org/jira/browse/FLINK-16658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16658: - Component/s: Client / Job Submission > Wire the EmbeddedExecutor to the

[GitHub] [flink] flinkbot edited a comment on pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvir

flinkbot edited a comment on pull request #11905: URL: https://github.com/apache/flink/pull/11905#issuecomment-619089324 ## CI report: * af67911ce3d587b4cd17d7757b98222f26264439 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161860341) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11908: [hotfix] Remove useless FlinkYarnSessionCli#logAndSysout method

flinkbot edited a comment on pull request #11908: URL: https://github.com/apache/flink/pull/11908#issuecomment-619312653 ## CI report: * 9c21872fb88b20f94c323231adda9f718a544a81 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161945228) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11908: [hotfix] Remove useless FlinkYarnSessionCli#logAndSysout method

flinkbot edited a comment on pull request #11908: URL: https://github.com/apache/flink/pull/11908#issuecomment-619312653 ## CI report: * 9c21872fb88b20f94c323231adda9f718a544a81 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161945228) Azure:

[GitHub] [flink] flinkbot commented on pull request #11908: [hotfix] Remove useless FlinkYarnSessionCli#logAndSysout method

flinkbot commented on pull request #11908: URL: https://github.com/apache/flink/pull/11908#issuecomment-619312653 ## CI report: * 9c21872fb88b20f94c323231adda9f718a544a81 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #11908: [hotfix] Remove useless FlinkYarnSessionCli#logAndSysout method

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

[GitHub] [flink] zzchun opened a new pull request #11908: [hotfix] Remove useless FlinkYarnSessionCli#logAndSysout method

zzchun opened a new pull request #11908: URL: https://github.com/apache/flink/pull/11908 ## What is the purpose of the change Remove useless FlinkYarnSessionCli#logAndSysout method ## Does this pull request potentially affect one of the following parts: -

[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_r414957216 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/hive/HiveDDLUtils.java ## @@ -0,0 +1,94 @@ +/* + * Licensed

[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_r414956968 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java ## @@ -1403,4 +1446,29 @@

[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_r414956660 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java ## @@ -247,7 +253,10 @@ 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_r414956231 ## File path: flink-table/flink-sql-parser-hive/src/main/java/org/apache/flink/sql/parser/hive/package-info.java ## @@ -0,0 +1,45 @@ +/* + * Licensed

[jira] [Commented] (FLINK-17312) Support sql client start with restore savepoint

[ https://issues.apache.org/jira/browse/FLINK-17312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17092018#comment-17092018 ] lun zhang commented on FLINK-17312: --- [~ykt836]Thank you for your reply.I also think adding this to DML

[jira] [Updated] (FLINK-17312) Support sql client start with restore savepoint

[ https://issues.apache.org/jira/browse/FLINK-17312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lun zhang updated FLINK-17312: -- Description: Now flink support stop or cancel a flink job by *flink cancel -s savepointpath*  . And

[GitHub] [flink] flinkbot commented on pull request #11907: [hotfix] Remove useless FlinkYarnSessionCli#logAndSysout method

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

[GitHub] [flink] zzchun opened a new pull request #11907: [hotfix] Remove useless FlinkYarnSessionCli#logAndSysout method

zzchun opened a new pull request #11907: URL: https://github.com/apache/flink/pull/11907 ## What is the purpose of the change Remove useless FlinkYarnSessionCli#logAndSysout method ## Does this pull request potentially affect one of the following parts: -

[jira] [Commented] (FLINK-17312) Support sql client start with restore savepoint

[ https://issues.apache.org/jira/browse/FLINK-17312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091995#comment-17091995 ] Kurt Young commented on FLINK-17312: [~zhanglun] Yes, I was aware of your proposal and design. The

[GitHub] [flink] flinkbot edited a comment on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

flinkbot edited a comment on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-618914824 ## CI report: * 56a3c01587e6e87d3a9d82fbe14c3c72724bb547 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161906304) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

flinkbot edited a comment on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-618914824 ## CI report: * 56a3c01587e6e87d3a9d82fbe14c3c72724bb547 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161906304) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11891: [FLINK-17359] [flink-core] Fixing EntropyInjector to resolve entropy for ClassLoaderFixingFileSystem

flinkbot edited a comment on pull request #11891: URL: https://github.com/apache/flink/pull/11891#issuecomment-618694277 ## CI report: * c2f022bebf3f5933b06b6b1d941b4e75499d13d2 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161881354) Azure:

[jira] [Assigned] (FLINK-17375) Clean up CI system related scripts

[ https://issues.apache.org/jira/browse/FLINK-17375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-17375: Assignee: Robert Metzger (was: Bowen Li) > Clean up CI system related scripts >

[jira] [Commented] (FLINK-17375) Clean up CI system related scripts

[ https://issues.apache.org/jira/browse/FLINK-17375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091979#comment-17091979 ] Bowen Li commented on FLINK-17375: -- yep, not sure how it happened. Back to you now :) > Clean up CI

[jira] [Commented] (FLINK-17333) add doc for 'create catalog' ddl

[ https://issues.apache.org/jira/browse/FLINK-17333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091977#comment-17091977 ] Bowen Li commented on FLINK-17333: -- master: f6f2fb56c3ee1d801f0db62fed357f918d40d4d0 > add doc for

[GitHub] [flink] bowenli86 commented on a change in pull request #11871: [FLINK-17333][doc] add doc for 'create catalog' ddl

bowenli86 commented on a change in pull request #11871: URL: https://github.com/apache/flink/pull/11871#discussion_r414923148 ## File path: docs/dev/table/sql/create.md ## @@ -210,6 +210,22 @@ The key and value of expression `key1=val1` should both be string literal. See d

[jira] [Closed] (FLINK-17175) StringUtils.arrayToString() should consider Object[] lastly

[ https://issues.apache.org/jira/browse/FLINK-17175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-17175. Resolution: Fixed master: 6128bd1060e299d798dc486385991d6142bc7d0d > StringUtils.arrayToString() should

[jira] [Closed] (FLINK-16812) support array types in PostgresRowConverter

[ https://issues.apache.org/jira/browse/FLINK-16812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-16812. Resolution: Fixed master: 4121292fbb63dacef29245a2234da68fa499efa6 > support array types in

[GitHub] [flink] flinkbot edited a comment on pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvir

flinkbot edited a comment on pull request #11905: URL: https://github.com/apache/flink/pull/11905#issuecomment-619089324 ## CI report: * af67911ce3d587b4cd17d7757b98222f26264439 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161860341) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11891: [FLINK-17359] [flink-core] Fixing EntropyInjector to resolve entropy for ClassLoaderFixingFileSystem

flinkbot edited a comment on pull request #11891: URL: https://github.com/apache/flink/pull/11891#issuecomment-618694277 ## CI report: * c2f022bebf3f5933b06b6b1d941b4e75499d13d2 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161881354) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

flinkbot edited a comment on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-619214462 ## CI report: * 8369308a540ab4e435812ce842e202192cc5a623 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161902486) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11904: [FLINK-17373][table] Support the NULL type for function calls

flinkbot edited a comment on pull request #11904: URL: https://github.com/apache/flink/pull/11904#issuecomment-619033904 ## CI report: * 3dc410fd16c3cd8c6bce69d24d34935f8bd17c90 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161842553) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on pull request #11353: URL: https://github.com/apache/flink/pull/11353#issuecomment-596455079 ## CI report: * d3311198b6bdb3067daaede3847e73c9d2b2496e Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161846091) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * 65b0ffa4eafedf431e7fd4e6e6b1b6d2d32386bd Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161834928) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on pull request #11323: URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: * edd2f98c2a607655aef8823024753fccebe29a7d UNKNOWN * c3d0dec360e6bff3be682c88412a2e20c6f2992e Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on pull request #11353: URL: https://github.com/apache/flink/pull/11353#issuecomment-596455079 ## CI report: * d3311198b6bdb3067daaede3847e73c9d2b2496e Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161846091) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

flinkbot edited a comment on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-618914824 ## CI report: * ab928ebf00806aef7200103c6160e5b027b14b0e Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/161799850) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11887: [FLINK-14816] Add thread dump feature for taskmanager

flinkbot edited a comment on pull request #11887: URL: https://github.com/apache/flink/pull/11887#issuecomment-618505450 ## CI report: * bc5fd415d52f54be1aec59ff86b0d1571fb88489 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161834854) Azure:

[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: * 3a861a4778cf6b4347788fd7a6cfc6e6c5bd970a Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161834683) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

flinkbot edited a comment on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-618914824 ## CI report: * ab928ebf00806aef7200103c6160e5b027b14b0e Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161799850) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

flinkbot edited a comment on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-619214462 ## CI report: * 8369308a540ab4e435812ce842e202192cc5a623 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161902486) Azure:

[GitHub] [flink] flinkbot commented on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

flinkbot commented on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-619214462 ## CI report: * 8369308a540ab4e435812ce842e202192cc5a623 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] fpompermaier commented on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

fpompermaier commented on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-619212627 @flinkbot run travis @flinkbot run azure This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot commented on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

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

[jira] [Updated] (FLINK-17356) Properly set constraints (PK and UNIQUE)

[ https://issues.apache.org/jira/browse/FLINK-17356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17356: --- Labels: pull-request-available (was: ) > Properly set constraints (PK and UNIQUE) >

[GitHub] [flink] fpompermaier opened a new pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

fpompermaier opened a new pull request #11906: URL: https://github.com/apache/flink/pull/11906 ## What is the purpose of the change Support the reading of PK and Unique constraints when reading JDBC tables. ## Brief change log - *Modified PostgresCatalog in

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * 65b0ffa4eafedf431e7fd4e6e6b1b6d2d32386bd Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161834928) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11902: [FLINK-17370][table-common] Ensure deterministic type inference extraction

flinkbot edited a comment on pull request #11902: URL: https://github.com/apache/flink/pull/11902#issuecomment-618997535 ## CI report: * 48994c96a848e9921ec08c60d1cea3e2cde835c1 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161830955) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11901: [FLINK-16971][python][sql-client] Support Python UDF in SQL Client.

flinkbot edited a comment on pull request #11901: URL: https://github.com/apache/flink/pull/11901#issuecomment-618997437 ## CI report: * d87aa0d87d7120cb4b193c99fa853eaa5e5bc3f6 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161830922) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11891: [FLINK-17359] [flink-core] Fixing EntropyInjector to resolve entropy for ClassLoaderFixingFileSystem

flinkbot edited a comment on pull request #11891: URL: https://github.com/apache/flink/pull/11891#issuecomment-618694277 ## CI report: * e3f3baf6df11d8d90e49fcef8ce9ad487d7da6ab Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161730635) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11886: [FLINK-17074] Deprecate key based methods that do not use KeySelector in Datastreams API

flinkbot edited a comment on pull request #11886: URL: https://github.com/apache/flink/pull/11886#issuecomment-618445341 ## CI report: * 41c07bdb9baa8798c8d61e267822d25b6c45714b Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161827268) Azure:

[jira] [Comment Edited] (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=17091759#comment-17091759 ] Yu Li edited comment on FLINK-17308 at 4/24/20, 5:55 PM: - Changing the fix

[GitHub] [flink] flinkbot edited a comment on pull request #11891: [FLINK-17359] [flink-core] Fixing EntropyInjector to resolve entropy for ClassLoaderFixingFileSystem

flinkbot edited a comment on pull request #11891: URL: https://github.com/apache/flink/pull/11891#issuecomment-618694277 ## CI report: * e3f3baf6df11d8d90e49fcef8ce9ad487d7da6ab Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161730635) Azure:

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

flinkbot edited a comment on pull request #11874: URL: https://github.com/apache/flink/pull/11874#issuecomment-618262774 ## CI report: * 1bdd69335126fb32b5c98ea0dfcfe32d588610f5 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161808517) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11854: [WIP] Introduce external resource framework

flinkbot edited a comment on pull request #11854: URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491 ## CI report: * bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN * 9061364804a28bfaaf6f7d30e4f18343f060d204 Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11848: [FLINK-17313]fix type validation error when sink table ddl exists column with precision of decimal/varchar

flinkbot edited a comment on pull request #11848: URL: https://github.com/apache/flink/pull/11848#issuecomment-617531785 ## CI report: * 7357ae7ca4a8a752458b1ed3b6391c846ff6bd09 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161808435) Azure:

[GitHub] [flink] bowenli86 commented on a change in pull request #11496: [FLINK-16743][table] Introduce datagen, print, blackhole connectors

bowenli86 commented on a change in pull request #11496: URL: https://github.com/apache/flink/pull/11496#discussion_r414739195 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGeneratorSource.java ## @@ -0,0 +1,102 @@

[jira] [Commented] (FLINK-17375) Clean up CI system related scripts

[ https://issues.apache.org/jira/browse/FLINK-17375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091763#comment-17091763 ] Robert Metzger commented on FLINK-17375: [~phoenixjiangnan] did you intentionally unassign me

[GitHub] [flink] bowenli86 removed a comment on pull request #11496: [FLINK-16743][table] Introduce datagen, print, blackhole connectors

bowenli86 removed a comment on pull request #11496: URL: https://github.com/apache/flink/pull/11496#issuecomment-619141665 revive the thread. These will be very useful for users This is an automated message from the Apache

[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 ] Yu Li updated FLINK-17308: -- Fix Version/s: (was: 1.10.1) 1.10.2 Changing the fix version to 1.10.2 since the first

[jira] [Commented] (FLINK-16743) Introduce datagen, print, blackhole connectors

[ https://issues.apache.org/jira/browse/FLINK-16743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091758#comment-17091758 ] Bowen Li commented on FLINK-16743: -- revive the thread. These will be very useful for users. Hopefully

[GitHub] [flink] bowenli86 commented on pull request #11496: [FLINK-16743][table] Introduce datagen, print, blackhole connectors

bowenli86 commented on pull request #11496: URL: https://github.com/apache/flink/pull/11496#issuecomment-619141665 revive the thread. These will be very useful for users This is an automated message from the Apache Git

[jira] [Assigned] (FLINK-17375) Clean up CI system related scripts

[ https://issues.apache.org/jira/browse/FLINK-17375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-17375: Assignee: Bowen Li (was: Robert Metzger) > Clean up CI system related scripts >

[jira] [Created] (FLINK-17376) Remove deprecated state access methods

Stephan Ewen created FLINK-17376: Summary: Remove deprecated state access methods Key: FLINK-17376 URL: https://issues.apache.org/jira/browse/FLINK-17376 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-17364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091726#comment-17091726 ] Lu Niu commented on FLINK-17364: Hi, [~kkl0u] . Thanks for replying!  PrestoS3FileSystem expose a

[GitHub] [flink] flinkbot edited a comment on pull request #11899: [FLINK-17342] enqueue savepoint requests in UC mode

flinkbot edited a comment on pull request #11899: URL: https://github.com/apache/flink/pull/11899#issuecomment-618868456 ## CI report: * 3b40f3410a32673b70803a05bdb5f643f8931683 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161799813) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvir

flinkbot edited a comment on pull request #11905: URL: https://github.com/apache/flink/pull/11905#issuecomment-619089324 ## CI report: * af67911ce3d587b4cd17d7757b98222f26264439 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161860341) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11848: [FLINK-17313]fix type validation error when sink table ddl exists column with precision of decimal/varchar

flinkbot edited a comment on pull request #11848: URL: https://github.com/apache/flink/pull/11848#issuecomment-617531785 ## CI report: * 7357ae7ca4a8a752458b1ed3b6391c846ff6bd09 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161808435) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11869: [FLINK-17111][table] Support SHOW VIEWS in Flink SQL

flinkbot edited a comment on pull request #11869: URL: https://github.com/apache/flink/pull/11869#issuecomment-618183108 ## CI report: * a602abb4a2d51262c393a373aa13cb4875b4a7f5 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161799681) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on pull request #11323: URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: * edd2f98c2a607655aef8823024753fccebe29a7d UNKNOWN * c3d0dec360e6bff3be682c88412a2e20c6f2992e Travis:

[GitHub] [flink] pnowojski commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

pnowojski commented on a change in pull request #11687: URL: https://github.com/apache/flink/pull/11687#discussion_r414697432 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputGate.java ## @@ -131,7 +133,18 @@ /**

[GitHub] [flink] flinkbot edited a comment on pull request #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

flinkbot edited a comment on pull request #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 1cad51e77ee67e492ddc439431b233f05b723067 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161799648) Azure:

[jira] [Comment Edited] (FLINK-17312) Support sql client start with restore savepoint

[ https://issues.apache.org/jira/browse/FLINK-17312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091693#comment-17091693 ] lun zhang edited comment on FLINK-17312 at 4/24/20, 4:11 PM: - [~ykt836] 

[jira] [Commented] (FLINK-17312) Support sql client start with restore savepoint

[ https://issues.apache.org/jira/browse/FLINK-17312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091693#comment-17091693 ] lun zhang commented on FLINK-17312: --- [~ykt836] Thank you for your reply.You may misunderstand my 

[GitHub] [flink] flinkbot edited a comment on pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvir

flinkbot edited a comment on pull request #11905: URL: https://github.com/apache/flink/pull/11905#issuecomment-619089324 ## CI report: * af67911ce3d587b4cd17d7757b98222f26264439 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161860341) Azure:

[jira] [Updated] (FLINK-17312) Support sql client start with restore savepoint

[ https://issues.apache.org/jira/browse/FLINK-17312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lun zhang updated FLINK-17312: -- Description: Sql client  not support  *insert sql job* restart with *restore* *savepoint*

[jira] [Updated] (FLINK-17312) Support sql client start with restore savepoint

[ https://issues.apache.org/jira/browse/FLINK-17312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lun zhang updated FLINK-17312: -- Summary: Support sql client start with restore savepoint (was: Support sql client start with

[GitHub] [flink] flinkbot commented on pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvironment#

flinkbot commented on pull request #11905: URL: https://github.com/apache/flink/pull/11905#issuecomment-619089324 ## CI report: * af67911ce3d587b4cd17d7757b98222f26264439 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #11869: [FLINK-17111][table] Support SHOW VIEWS in Flink SQL

flinkbot edited a comment on pull request #11869: URL: https://github.com/apache/flink/pull/11869#issuecomment-618183108 ## CI report: * a602abb4a2d51262c393a373aa13cb4875b4a7f5 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161799681) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11860: [FLINK-17311][python] Add executable permissions to the script in the wheel package

flinkbot edited a comment on pull request #11860: URL: https://github.com/apache/flink/pull/11860#issuecomment-617666482 ## CI report: * 714c695075126b455af4b8cf4d04875d597342a2 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161799608) Azure:

[jira] [Closed] (FLINK-13639) Consider refactoring of IntermediateResultPartitionID to consist of IntermediateDataSetID and partitionIndex

[ https://issues.apache.org/jira/browse/FLINK-13639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-13639. --- Fix Version/s: 1.11.0 Resolution: Fixed Implemented via c4b44e9d4a7af9e841f785fcf0e4831f4cd5afe9 >

[jira] [Updated] (FLINK-13639) Consider refactoring of IntermediateResultPartitionID to consist of IntermediateDataSetID and partitionIndex

[ https://issues.apache.org/jira/browse/FLINK-13639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-13639: Affects Version/s: 1.11.0 > Consider refactoring of IntermediateResultPartitionID to consist of >

[GitHub] [flink] zhuzhurk commented on pull request #11855: [FLINK-13639] Refactor the IntermediateResultPartitionID to consist o…

zhuzhurk commented on pull request #11855: URL: https://github.com/apache/flink/pull/11855#issuecomment-619081026 Merging. This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-17021) Blink Planner set GlobalDataExchangeMode

[ https://issues.apache.org/jira/browse/FLINK-17021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17021: Description: Blink planner config option "table.exec.shuffle-mode" should be extended to set

[jira] [Closed] (FLINK-17021) Blink Planner set GlobalDataExchangeMode

[ https://issues.apache.org/jira/browse/FLINK-17021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-17021. --- Resolution: Fixed implemented via deb1268d26124b9b1eb1a2699f1a8d8afd1cac48 > Blink Planner set

[GitHub] [flink] flinkbot edited a comment on pull request #11904: [FLINK-17373][table] Support the NULL type for function calls

flinkbot edited a comment on pull request #11904: URL: https://github.com/apache/flink/pull/11904#issuecomment-619033904 ## CI report: * 3dc410fd16c3cd8c6bce69d24d34935f8bd17c90 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161842553) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11323: [FLINK-16439][k8s] Make KubernetesResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on pull request #11323: URL: https://github.com/apache/flink/pull/11323#issuecomment-595267888 ## CI report: * edd2f98c2a607655aef8823024753fccebe29a7d UNKNOWN * c3d0dec360e6bff3be682c88412a2e20c6f2992e Travis:

[GitHub] [flink] flinkbot commented on pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvironment#

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

[jira] [Commented] (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:comment-tabpanel=17091654#comment-17091654 ] Till Rohrmann commented on FLINK-10911: --- Maybe it is no longer true and we can close this issue as

[jira] [Updated] (FLINK-17267) supports EXPLAIN statement in TableEnvironment#executeSql and Table#explain api

[ https://issues.apache.org/jira/browse/FLINK-17267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17267: --- Labels: pull-request-available (was: ) > supports EXPLAIN statement in

[GitHub] [flink] godfreyhe opened a new pull request #11905: [FLINK-17267] [table] legacy planner supports explain insert operation and introduce TableEnvironment#explainSql/Introduce TableEnvironment

godfreyhe opened a new pull request #11905: URL: https://github.com/apache/flink/pull/11905 ## What is the purpose of the change *For TableEnvironment#explain() method, legacy batch planner throws exception directly and legacy stream planner does not handle sink node. This

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: URL: https://github.com/apache/flink/pull/11109#discussion_r414648626 ## File path: flink-core/src/main/java/org/apache/flink/util/JavaGcCleanerWrapper.java ## @@ -43,326 +47,338 @@ private static final Logger

[GitHub] [flink] tillrohrmann commented on a change in pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

tillrohrmann commented on a change in pull request #11109: URL: https://github.com/apache/flink/pull/11109#discussion_r414648626 ## File path: flink-core/src/main/java/org/apache/flink/util/JavaGcCleanerWrapper.java ## @@ -43,326 +47,338 @@ private static final Logger

  1   2   3   4   5   >