[GitHub] [flink] wangyang0918 commented on pull request #12071: [FLINK-17416][e2e][k8s] Use fixed v1.16.9 because fabric8 kubernetes-client could not work with higher version under jdk 8u252

2020-05-10 Thread GitBox
wangyang0918 commented on pull request #12071: URL: https://github.com/apache/flink/pull/12071#issuecomment-626509660 cc @rmetzger This is an automated message from the Apache Git Service. To respond to the message, please l

[jira] [Commented] (FLINK-17571) A better way to show the files used in currently checkpoints

2020-05-10 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104131#comment-17104131 ] Congxian Qiu(klion26) commented on FLINK-17571: --- sorry for the late replay

[GitHub] [flink] wangyang0918 opened a new pull request #12071: [FLINK-17416][e2e][k8s] Use fixed v1.16.9 because fabric8 kubernetes-client could not work with higher version under jdk 8u252

2020-05-10 Thread GitBox
wangyang0918 opened a new pull request #12071: URL: https://github.com/apache/flink/pull/12071 ## What is the purpose of the change Use fixed v1.16.9 because fabric8 kubernetes-client could not work with higher version under jdk 8u252. ## Brief change log *

[jira] [Updated] (FLINK-17523) Add call expression with a class of UDF

2020-05-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17523: --- Labels: pull-request-available (was: ) > Add call expression with a class of UDF > ---

[GitHub] [flink] dawidwys opened a new pull request #12070: [FLINK-17523] Add call expression with a class of UDF as a parameter

2020-05-10 Thread GitBox
dawidwys opened a new pull request #12070: URL: https://github.com/apache/flink/pull/12070 ## What is the purpose of the change Add a `call` method that accept a class of UDF. Similar to `org.apache.flink.table.api.TableEnvironment#createTemporarySystemFunction(java.lang.String, jav

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

2020-05-10 Thread GitBox
zhijiangW commented on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-626507028 @pnowojski I already addressed the last nit comments. Besides that I also adjusted another two places. 1. In `StreamTask#beforeInvoke`, I take the following way instead

[GitHub] [flink] flinkbot commented on pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

2020-05-10 Thread GitBox
flinkbot commented on pull request #12069: URL: https://github.com/apache/flink/pull/12069#issuecomment-626507230 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 commented on pull request #12068: [hotfix][typo]Fix typo in task_lifecycle docs

2020-05-10 Thread GitBox
flinkbot commented on pull request #12068: URL: https://github.com/apache/flink/pull/12068#issuecomment-626506454 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 #12062: [FLINK-17587][filesystem] Filesystem streaming sink support commit success file

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12062: URL: https://github.com/apache/flink/pull/12062#issuecomment-626437386 ## CI report: * 38d4e669261a6fde7595223bf804b45e838476b2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12067: [FLINK-17536] Change the config option of slot max limitation to slot…

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12067: URL: https://github.com/apache/flink/pull/12067#issuecomment-626497495 ## CI report: * dae804ce40b787a4b5a6d9f3aef730cef218db9e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12033: [FLINK-17015]Fix NPE from NullAwareMapIterator

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12033: URL: https://github.com/apache/flink/pull/12033#issuecomment-625870561 ## CI report: * 188f7416604519b214ef83b11bb443956f059736 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #11981: [FLINK-17002] Support CREATE TABLE ... LIKE clause

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #11981: URL: https://github.com/apache/flink/pull/11981#issuecomment-623312081 ## CI report: * 4454b77214cd904ce395d4ae073c83cab1f03628 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] TsReaper opened a new pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

2020-05-10 Thread GitBox
TsReaper opened a new pull request #12069: URL: https://github.com/apache/flink/pull/12069 ## Pre-review note This PR is waiting for #12037 to merge. The 1st commit is exactly the same with the blocking PR. Please start reviewing from the 2nd commit. This PR will be rebased once the

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

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #11899: URL: https://github.com/apache/flink/pull/11899#issuecomment-618868456 ## CI report: * 4ffaa5da88576abdbfb2e221faa8823313559c99 UNKNOWN * bf0fd0c41bd7d444f21b21d790f7286a6de3f132 Travis: [SUCCESS](https://travis-ci.com/github/f

[GitHub] [flink] gk0916 opened a new pull request #12068: [hotfix][typo]Fix typo in task_lifecycle docs

2020-05-10 Thread GitBox
gk0916 opened a new pull request #12068: URL: https://github.com/apache/flink/pull/12068 ## What is the purpose of the change *This pull request fix typo in task_lifecycle docs. And it just missing a "." ## Brief change log ## Verifying this change

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

2020-05-10 Thread GitBox
zhijiangW removed a comment on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-626483029 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] flinkbot edited a comment on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #8693: URL: https://github.com/apache/flink/pull/8693#issuecomment-542518065 ## CI report: * b470751fa4c472828269e9b94c3bdb82e587908f Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/132086267) * 05958418a283158f5b571b03b

[jira] [Updated] (FLINK-17601) TableEnvironmentITCase.testStatementSet fails on travis

2020-05-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17601: --- Labels: test-stability (was: ) > TableEnvironmentITCase.testStatementSet fails on travis >

[jira] [Updated] (FLINK-17601) TableEnvironmentITCase.testStatementSet fails on travis

2020-05-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17601: --- Affects Version/s: (was: 1.11.0) > TableEnvironmentITCase.testStatementSet fails on trav

[jira] [Comment Edited] (FLINK-17556) FATAL: Thread 'flink-metrics-akka.remote.default-remote-dispatcher-3' produced an uncaught exception. Stopping the process... java.lang.OutOfMemoryError: Direct b

2020-05-10 Thread Tammy zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104126#comment-17104126 ] Tammy zhang edited comment on FLINK-17556 at 5/11/20, 6:37 AM: ---

[jira] [Commented] (FLINK-17607) TableEnvironmentITCase.testStatementSet fails on azure

2020-05-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104127#comment-17104127 ] Piotr Nowojski commented on FLINK-17607: Yes, sorry I've just noticed it. > Tab

[jira] [Comment Edited] (FLINK-17556) FATAL: Thread 'flink-metrics-akka.remote.default-remote-dispatcher-3' produced an uncaught exception. Stopping the process... java.lang.OutOfMemoryError: Direct b

2020-05-10 Thread Tammy zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104126#comment-17104126 ] Tammy zhang edited comment on FLINK-17556 at 5/11/20, 6:36 AM: ---

[jira] [Commented] (FLINK-17556) FATAL: Thread 'flink-metrics-akka.remote.default-remote-dispatcher-3' produced an uncaught exception. Stopping the process... java.lang.OutOfMemoryError: Direct buffer

2020-05-10 Thread Tammy zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104126#comment-17104126 ] Tammy zhang commented on FLINK-17556: - Thank you for your reply. The version i used

[jira] [Closed] (FLINK-17607) TableEnvironmentITCase.testStatementSet fails on azure

2020-05-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17607. -- Resolution: Duplicate > TableEnvironmentITCase.testStatementSet fails on azure > -

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

2020-05-10 Thread GitBox
JingsongLi commented on a change in pull request #11496: URL: https://github.com/apache/flink/pull/11496#discussion_r422812402 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/RandomGenerator.java ## @@ -0,0 +1,119 @@ +/*

[jira] [Commented] (FLINK-17607) TableEnvironmentITCase.testStatementSet fails on azure

2020-05-10 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104124#comment-17104124 ] godfrey he commented on FLINK-17607: hi [~pnowojski] it has been fixed in https://i

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

2020-05-10 Thread GitBox
JingsongLi commented on a change in pull request #11496: URL: https://github.com/apache/flink/pull/11496#discussion_r422808641 ## 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-17607) TableEnvironmentITCase.testStatementSet fails on azure

2020-05-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104123#comment-17104123 ] Piotr Nowojski commented on FLINK-17607: Another instance: https://dev.azure.co

[jira] [Updated] (FLINK-17607) TableEnvironmentITCase.testStatementSet fails on azure

2020-05-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17607: --- Priority: Critical (was: Major) > TableEnvironmentITCase.testStatementSet fails on azure >

[jira] [Updated] (FLINK-17591) TableEnvironmentITCase.testExecuteSqlAndToDataStream failed

2020-05-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17591: --- Priority: Critical (was: Major) > TableEnvironmentITCase.testExecuteSqlAndToDataStream fail

[jira] [Updated] (FLINK-17591) TableEnvironmentITCase.testExecuteSqlAndToDataStream failed

2020-05-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17591: --- Priority: Major (was: Critical) > TableEnvironmentITCase.testExecuteSqlAndToDataStream fail

[jira] [Commented] (FLINK-17607) TableEnvironmentITCase.testStatementSet fails on azure

2020-05-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104122#comment-17104122 ] Piotr Nowojski commented on FLINK-17607: Could be related to FLINK-16636 or FLIN

[jira] [Created] (FLINK-17607) TableEnvironmentITCase.testStatementSet fails on azure

2020-05-10 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-17607: -- Summary: TableEnvironmentITCase.testStatementSet fails on azure Key: FLINK-17607 URL: https://issues.apache.org/jira/browse/FLINK-17607 Project: Flink Is

[jira] [Commented] (FLINK-17556) FATAL: Thread 'flink-metrics-akka.remote.default-remote-dispatcher-3' produced an uncaught exception. Stopping the process... java.lang.OutOfMemoryError: Direct buffer

2020-05-10 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104118#comment-17104118 ] Yingjie Cao commented on FLINK-17556: - Which version do you use? Is there any user c

[GitHub] [flink] KurtYoung commented on a change in pull request #12049: [FLINK-17252] [table] supports SELECT statement in TableEnvironment#executeSql and introduce Table#execute api

2020-05-10 Thread GitBox
KurtYoung commented on a change in pull request #12049: URL: https://github.com/apache/flink/pull/12049#discussion_r422809027 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/delegation/Planner.java ## @@ -74,14 +76,22 @@ */

[jira] [Updated] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

2020-05-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16636: --- Affects Version/s: (was: 1.11.0) > TableEnvironmentITCase is crashing on Travis > --

[jira] [Updated] (FLINK-17591) TableEnvironmentITCase.testExecuteSqlAndToDataStream failed

2020-05-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17591: --- Labels: test-stability (was: ) > TableEnvironmentITCase.testExecuteSqlAndToDataStream faile

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

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

[jira] [Updated] (FLINK-17591) TableEnvironmentITCase.testExecuteSqlAndToDataStream failed

2020-05-10 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17591: --- Fix Version/s: 1.11.0 > TableEnvironmentITCase.testExecuteSqlAndToDataStream failed > --

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #12062: [FLINK-17587][filesystem] Filesystem streaming sink support commit success file

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12062: URL: https://github.com/apache/flink/pull/12062#issuecomment-626437386 ## CI report: * 38d4e669261a6fde7595223bf804b45e838476b2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12067: [FLINK-17536] Change the config option of slot max limitation to slot…

2020-05-10 Thread GitBox
flinkbot commented on pull request #12067: URL: https://github.com/apache/flink/pull/12067#issuecomment-626497495 ## CI report: * dae804ce40b787a4b5a6d9f3aef730cef218db9e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12004: URL: https://github.com/apache/flink/pull/12004#issuecomment-624445192 ## CI report: * 3ac79a41395792dfecefc87a19c58468e91ede8d UNKNOWN * b3802f894dcdd7226316583e66b37a662c3e5bdb Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #8693: URL: https://github.com/apache/flink/pull/8693#issuecomment-542518065 ## CI report: * b470751fa4c472828269e9b94c3bdb82e587908f Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/builds/132086267) * 05958418a283158f5b571b03b

[GitHub] [flink] godfreyhe commented on pull request #12049: [FLINK-17252] [table] supports SELECT statement in TableEnvironment#executeSql and introduce Table#execute api

2020-05-10 Thread GitBox
godfreyhe commented on pull request #12049: URL: https://github.com/apache/flink/pull/12049#issuecomment-626496388 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] SteNicholas commented on pull request #12033: [FLINK-17015]Fix NPE from NullAwareMapIterator

2020-05-10 Thread GitBox
SteNicholas commented on pull request #12033: URL: https://github.com/apache/flink/pull/12033#issuecomment-626495937 @Myasuka According to the discussion, I have already align the behavior of `HeapMapState` #entries(), #keys(), #values(), and #iterator() and `RocksDBMapState` #entries() t

[jira] [Created] (FLINK-17606) Introduce DataGen connector in table

2020-05-10 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17606: Summary: Introduce DataGen connector in table Key: FLINK-17606 URL: https://issues.apache.org/jira/browse/FLINK-17606 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-17523) Add call expression with a class of UDF

2020-05-10 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-17523: Assignee: Dawid Wysakowicz > Add call expression with a class of UDF > -

[jira] [Commented] (FLINK-17559) Backpressure seems to be broken when not going through network

2020-05-10 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104115#comment-17104115 ] Yingjie Cao commented on FLINK-17559: - I wonder if you cache any data in your UDFs,

[GitHub] [flink] jinglining commented on pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

2020-05-10 Thread GitBox
jinglining commented on pull request #11752: URL: https://github.com/apache/flink/pull/11752#issuecomment-626493911 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] jinglining removed a comment on pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

2020-05-10 Thread GitBox
jinglining removed a comment on pull request #11752: URL: https://github.com/apache/flink/pull/11752#issuecomment-625765695 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

2020-05-10 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104109#comment-17104109 ] Yang Wang commented on FLINK-17598: --- So do you mean to use StatefulSet to replace the

[GitHub] [flink] flinkbot edited a comment on pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12004: URL: https://github.com/apache/flink/pull/12004#issuecomment-624445192 ## CI report: * 3ac79a41395792dfecefc87a19c58468e91ede8d UNKNOWN * b3802f894dcdd7226316583e66b37a662c3e5bdb Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #12067: [FLINK-17536] Change the config option of slot max limitation to slot…

2020-05-10 Thread GitBox
flinkbot commented on pull request #12067: URL: https://github.com/apache/flink/pull/12067#issuecomment-626490048 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] KarmaGYZ opened a new pull request #12067: [FLINK-17536] Change the config option of slot max limitation to slot…

2020-05-10 Thread GitBox
KarmaGYZ opened a new pull request #12067: URL: https://github.com/apache/flink/pull/12067 …manager.number-of-slots.max ## What is the purpose of the change Change the config option of slot max limitation to slotmanager.number-of-slots.max ## Brief change log

[GitHub] [flink] KarmaGYZ commented on pull request #12067: [FLINK-17536] Change the config option of slot max limitation to slot…

2020-05-10 Thread GitBox
KarmaGYZ commented on pull request #12067: URL: https://github.com/apache/flink/pull/12067#issuecomment-626488822 cc @GJL This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-17536) Change the config option of slot max limitation to "slotmanager.number-of-slots.max"

2020-05-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17536: --- Labels: pull-request-available (was: ) > Change the config option of slot max limitation to

[GitHub] [flink] wangyang0918 commented on pull request #12040: [FLINK-13938][yarn] Use provided lib dirs to accelerate flink submission

2020-05-10 Thread GitBox
wangyang0918 commented on pull request #12040: URL: https://github.com/apache/flink/pull/12040#issuecomment-626488446 cc @kl0u could you help with the reviewing? This is an automated message from the Apache Git Service. To re

[jira] [Comment Edited] (FLINK-17560) No Slots available exception in Apache Flink Job Manager while Scheduling

2020-05-10 Thread josson paul kalapparambath (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104103#comment-17104103 ] josson paul kalapparambath edited comment on FLINK-17560 at 5/11/20, 6:00 AM:

[jira] [Commented] (FLINK-17560) No Slots available exception in Apache Flink Job Manager while Scheduling

2020-05-10 Thread josson paul kalapparambath (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104103#comment-17104103 ] josson paul kalapparambath commented on FLINK-17560: [~xintongsong]

[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

2020-05-10 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104102#comment-17104102 ] Tzu-Li (Gordon) Tai commented on FLINK-16850: - [~yunta] sure, I'll commit an

[jira] [Updated] (FLINK-17536) Change the config option of slot max limitation to "slotmanager.number-of-slots.max"

2020-05-10 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17536: --- Summary: Change the config option of slot max limitation to "slotmanager.number-of-slots.max" (was:

[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

2020-05-10 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104099#comment-17104099 ] Yun Tang commented on FLINK-16850: -- [~tzulitai], would you please kindly help to create

[GitHub] [flink-web] klion26 commented on pull request #267: [FLINK-13682][docs-zh] Translate "Code Style - Scala Guide" page into Chinese

2020-05-10 Thread GitBox
klion26 commented on pull request #267: URL: https://github.com/apache/flink-web/pull/267#issuecomment-626486117 @yangjf2019 thanks for addressing my comments, LGTM ping @wuchong This is an automated message from the Apac

[GitHub] [flink-statefun] tzulitai opened a new pull request #107: [FLINK-17605] Consolidate flink.version property in parent POM

2020-05-10 Thread GitBox
tzulitai opened a new pull request #107: URL: https://github.com/apache/flink-statefun/pull/107 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[jira] [Updated] (FLINK-17605) Consolidate flink.version in Stateful Functions POM files

2020-05-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17605: --- Labels: pull-request-available (was: ) > Consolidate flink.version in Stateful Functions PO

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

2020-05-10 Thread GitBox
zhijiangW commented on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-626483029 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[jira] [Created] (FLINK-17605) Consolidate flink.version in Stateful Functions POM files

2020-05-10 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-17605: --- Summary: Consolidate flink.version in Stateful Functions POM files Key: FLINK-17605 URL: https://issues.apache.org/jira/browse/FLINK-17605 Project: Flink

[GitHub] [flink] zjffdu commented on pull request #11895: [FLINK-10911][scala-shell] Enable flink-scala-shell with Scala 2.12

2020-05-10 Thread GitBox
zjffdu commented on pull request #11895: URL: https://github.com/apache/flink/pull/11895#issuecomment-626482480 @aljoscha I found that the case class issue is caused by `FLINK-10493` which introduce `ScalaCaseClassSerializer`. In our internal flink branch which is based on 1.5 that has no

[GitHub] [flink] flinkbot edited a comment on pull request #11297: [FLINK-16364] [table] Deprecate the methods in TableEnvironment proposed by FLIP-84

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #11297: URL: https://github.com/apache/flink/pull/11297#issuecomment-593931358 ## CI report: * bd7ca0b4407e126739f17292b8a6a0561508351e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12066: [hotfix][runtime] Remove useless local variable in CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12066: URL: https://github.com/apache/flink/pull/12066#issuecomment-626471650 ## CI report: * fa88acd466c5c1d22389d73610009b0c25c69fbb Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12063: [FLINK-17603][table][core] Prepare Hive partitioned streaming source

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12063: URL: https://github.com/apache/flink/pull/12063#issuecomment-626441217 ## CI report: * 11d3939cde0deeac80e4642bb946622e7ee4d850 UNKNOWN * 64ffbab011482e857ba986b2116d9dfb94138259 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12061: [FLINK-17454][python]python gateway callback server port should not b…

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12061: URL: https://github.com/apache/flink/pull/12061#issuecomment-626432764 ## CI report: * da1bf1e181793e94b1c9147546e15101e87e066f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12066: [hotfix][runtime] Remove useless local variable in CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained

2020-05-10 Thread GitBox
flinkbot commented on pull request #12066: URL: https://github.com/apache/flink/pull/12066#issuecomment-626471650 ## CI report: * fa88acd466c5c1d22389d73610009b0c25c69fbb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12064: [hotfix][javadocs]java doc error fix

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12064: URL: https://github.com/apache/flink/pull/12064#issuecomment-626450834 ## CI report: * a799713860db44d58407123f19236b68e231094b Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/165085794) Azure: [FAILURE](http

[GitHub] [flink] flinkbot edited a comment on pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12004: URL: https://github.com/apache/flink/pull/12004#issuecomment-624445192 ## CI report: * 44df52a0ff62e1b4ec65efd6a14a8b07d7712e75 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #12066: [hotfix][runtime] Remove useless local variable in CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained

2020-05-10 Thread GitBox
flinkbot commented on pull request #12066: URL: https://github.com/apache/flink/pull/12066#issuecomment-626467290 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] zhengcanbin opened a new pull request #12066: [hotfix][runtime] Remove useless local variable in CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained

2020-05-10 Thread GitBox
zhengcanbin opened a new pull request #12066: URL: https://github.com/apache/flink/pull/12066 Remove useless local variable `taskStates` in `CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained` This is an autom

[GitHub] [flink] flinkbot edited a comment on pull request #12061: [FLINK-17454][python]python gateway callback server port should not b…

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12061: URL: https://github.com/apache/flink/pull/12061#issuecomment-626432764 ## CI report: * d07c04b5ac978764112af3bf1d35285195e3440d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #11297: [FLINK-16364] [table] Deprecate the methods in TableEnvironment proposed by FLIP-84

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #11297: URL: https://github.com/apache/flink/pull/11297#issuecomment-593931358 ## CI report: * bbf0bc3e167ac3aa30f1044a352f4bdac4a416a2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] KurtYoung commented on a change in pull request #11297: [FLINK-16364] [table] Deprecate the methods in TableEnvironment proposed by FLIP-84

2020-05-10 Thread GitBox
KurtYoung commented on a change in pull request #11297: URL: https://github.com/apache/flink/pull/11297#discussion_r422772319 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/utils/TableEnvUtil.scala ## @@ -0,0 +1,41 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12065: [FLINK-17604] Implement format factory for CSV serialization and

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12065: URL: https://github.com/apache/flink/pull/12065#issuecomment-626450869 ## CI report: * a2a08d561137d48bdff518491863b331765df2a9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12061: [FLINK-17454][python]python gateway callback server port should not b…

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12061: URL: https://github.com/apache/flink/pull/12061#issuecomment-626432764 ## CI report: * d07c04b5ac978764112af3bf1d35285195e3440d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12049: [FLINK-17252] [table] supports SELECT statement in TableEnvironment#executeSql and introduce Table#execute api

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12049: URL: https://github.com/apache/flink/pull/12049#issuecomment-626106371 ## CI report: * 3640d760380b6b527a115e09363f596fd0134c82 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #12063: [FLINK-17603][table][core] Prepare Hive partitioned streaming source

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12063: URL: https://github.com/apache/flink/pull/12063#issuecomment-626441217 ## CI report: * 11d3939cde0deeac80e4642bb946622e7ee4d850 UNKNOWN * 64ffbab011482e857ba986b2116d9dfb94138259 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12037: [FLINK-14807][runtime][client] Introduce communication through REST API between the clients and the operator coordinators

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12037: URL: https://github.com/apache/flink/pull/12037#issuecomment-625870801 ## CI report: * c06e5db9e64a2b39d857babff53d401697b87262 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12004: URL: https://github.com/apache/flink/pull/12004#issuecomment-624445192 ## CI report: * 44df52a0ff62e1b4ec65efd6a14a8b07d7712e75 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #11297: [FLINK-16364] [table] Deprecate the methods in TableEnvironment proposed by FLIP-84

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #11297: URL: https://github.com/apache/flink/pull/11297#issuecomment-593931358 ## CI report: * bbf0bc3e167ac3aa30f1044a352f4bdac4a416a2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] xintongsong commented on pull request #11191: [FLINK-16094][docs] Translate /dev/table/functions/udfs.zh.md

2020-05-10 Thread GitBox
xintongsong commented on pull request #11191: URL: https://github.com/apache/flink/pull/11191#issuecomment-626457779 Thanks @libenchao, I'm reviewing this right now. This is an automated message from the Apache Git Service. T

[GitHub] [flink] JingsongLi commented on a change in pull request #11755: [FLINK-14257][Connectors / FileSystem]Integrate csv to FileSystemTableFactory

2020-05-10 Thread GitBox
JingsongLi commented on a change in pull request #11755: URL: https://github.com/apache/flink/pull/11755#discussion_r422441201 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataFileSystemFormatFactory.java ## @@ -0,0 +1,354 @@ +package

[jira] [Closed] (FLINK-17601) TableEnvironmentITCase.testStatementSet fails on travis

2020-05-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17601. -- Resolution: Fixed master: 51c7d61f3e7661f6aad331245ca94ecb82be3994 > TableEnvironmentITCase.testState

[GitHub] [flink] shuiqiangchen commented on a change in pull request #12061: [FLINK-17454][python]python gateway callback server port should not b…

2020-05-10 Thread GitBox
shuiqiangchen commented on a change in pull request #12061: URL: https://github.com/apache/flink/pull/12061#discussion_r422764493 ## File path: flink-python/pyflink/java_gateway.py ## @@ -49,15 +49,19 @@ def get_gateway(): # if Java Gateway is already running

[GitHub] [flink] shuiqiangchen commented on a change in pull request #12061: [FLINK-17454][python]python gateway callback server port should not b…

2020-05-10 Thread GitBox
shuiqiangchen commented on a change in pull request #12061: URL: https://github.com/apache/flink/pull/12061#discussion_r422764356 ## File path: flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.java ## @@ -300,6 +294,48 @@ static GatewayServer startGatew

[jira] [Comment Edited] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

2020-05-10 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104040#comment-17104040 ] Canbin Zheng edited comment on FLINK-17598 at 5/11/20, 3:48 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #12063: [FLINK-17603][table][core] Prepare Hive partitioned streaming source

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12063: URL: https://github.com/apache/flink/pull/12063#issuecomment-626441217 ## CI report: * 11d3939cde0deeac80e4642bb946622e7ee4d850 UNKNOWN * 64ffbab011482e857ba986b2116d9dfb94138259 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12010: [FLINK-17286][connectors / filesystem]Integrate json to file system connector

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12010: URL: https://github.com/apache/flink/pull/12010#issuecomment-624746999 ## CI report: * d7445e68ed77a6b1b88fdf0dac8638ff62ac8967 UNKNOWN * edacdf8f0062fdae68a1581936a7410c1b35baa2 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

2020-05-10 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17104040#comment-17104040 ] Canbin Zheng commented on FLINK-17598: -- [~fly_in_gis] Not exactly. The *StatefulSet

[GitHub] [flink] flinkbot edited a comment on pull request #12065: [FLINK-17604] Implement format factory for CSV serialization and

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12065: URL: https://github.com/apache/flink/pull/12065#issuecomment-626450869 ## CI report: * a2a08d561137d48bdff518491863b331765df2a9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12004: [FLINK-17434][core][hive] Hive partitioned source support streaming read

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12004: URL: https://github.com/apache/flink/pull/12004#issuecomment-624445192 ## CI report: * 44df52a0ff62e1b4ec65efd6a14a8b07d7712e75 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12064: [hotfix][javadocs]java doc error fix

2020-05-10 Thread GitBox
flinkbot edited a comment on pull request #12064: URL: https://github.com/apache/flink/pull/12064#issuecomment-626450834 ## CI report: * a799713860db44d58407123f19236b68e231094b Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/165085794) Azure: [PENDING](http

  1   2   3   >