[GitHub] [flink] flinkbot edited a comment on pull request #12275: [FLINK-16021][table-common] DescriptorProperties.putTableSchema does …

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

[GitHub] [flink-statefun] tzulitai closed pull request #115: [FLINK-17518] [e2e] Add remote module E2E

2020-05-21 Thread GitBox
tzulitai closed pull request #115: URL: https://github.com/apache/flink-statefun/pull/115 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [flink] klion26 commented on a change in pull request #12189: [FLINK-17376][API/DataStream]Deprecated methods and related code updated

2020-05-21 Thread GitBox
klion26 commented on a change in pull request #12189: URL: https://github.com/apache/flink/pull/12189#discussion_r428476861 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java ## @@ -219,31 +219,6 @@ public void dispose() {

[jira] [Closed] (FLINK-17518) Add HTTP-based request reply protocol E2E test for Stateful Functions

2020-05-21 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-17518. --- Resolution: Fixed master - 2abbff1b0036fa3099cccdb13330e97078bd4d97 release-2.0 - cc

[GitHub] [flink] zhengcanbin commented on pull request #12215: [FLINK-17565][k8s] Bump fabric8 version from 4.5.2 to 4.9.2

2020-05-21 Thread GitBox
zhengcanbin commented on pull request #12215: URL: https://github.com/apache/flink/pull/12215#issuecomment-631927890 > @zhengcanbin Thanks a lot for creating this PR. I am afraid this PR could not work because the new `kubernetes-client` version introduce some additional dependencies(e.g.

[GitHub] [flink] flinkbot edited a comment on pull request #12215: [FLINK-17565][k8s] Bump fabric8 version from 4.5.2 to 4.9.2

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

[jira] [Commented] (FLINK-16402) Alter table fails on Hive catalog

2020-05-21 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112891#comment-17112891 ] Matyas Orhidi commented on FLINK-16402: --- hi [~lirui] [~gyfora] the error message i

[jira] [Commented] (FLINK-17657) jdbc not support read BIGINT UNSIGNED field

2020-05-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112897#comment-17112897 ] Leonard Xu commented on FLINK-17657: [~zhanglun] Thanks for the report, it's a bug f

[GitHub] [flink] flinkbot edited a comment on pull request #12215: [FLINK-17565][k8s] Bump fabric8 version from 4.5.2 to 4.9.2

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

[GitHub] [flink] flinkbot edited a comment on pull request #12275: [FLINK-16021][table-common] DescriptorProperties.putTableSchema does …

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

[GitHub] [flink] GJL opened a new pull request #12276: [FLINK-13553][tests][qs] Improve Logging to debug Test Instability

2020-05-21 Thread GitBox
GJL opened a new pull request #12276: URL: https://github.com/apache/flink/pull/12276 ## What is the purpose of the change *This improves logging in AbstractServerHandler to debug a test instability (timeouts in `KvStateServerHandlerTest`; see FLINK-13553)* ## Brief change

[GitHub] [flink] flinkbot commented on pull request #12276: [FLINK-13553][tests][qs] Improve Logging to debug Test Instability

2020-05-21 Thread GitBox
flinkbot commented on pull request #12276: URL: https://github.com/apache/flink/pull/12276#issuecomment-631947196 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] [Created] (FLINK-17860) Recursively remove channel state directories

2020-05-21 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-17860: - Summary: Recursively remove channel state directories Key: FLINK-17860 URL: https://issues.apache.org/jira/browse/FLINK-17860 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #12273: [FLINK-17850][jdbc] Fix PostgresCatalogITCase.testGroupByInsert() fails on CI

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

[GitHub] [flink] flinkbot edited a comment on pull request #12215: [FLINK-17565][k8s] Bump fabric8 version from 4.5.2 to 4.9.2

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

[GitHub] [flink] flinkbot commented on pull request #12276: [FLINK-13553][tests][qs] Improve Logging to debug Test Instability

2020-05-21 Thread GitBox
flinkbot commented on pull request #12276: URL: https://github.com/apache/flink/pull/12276#issuecomment-631952514 ## CI report: * 627cef7e0f6cc46ad9c329f013fd1b4a3f956b70 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Created] (FLINK-17861) Channel state handles, when inlined, duplicate underlying data

2020-05-21 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-17861: - Summary: Channel state handles, when inlined, duplicate underlying data Key: FLINK-17861 URL: https://issues.apache.org/jira/browse/FLINK-17861 Project: Fli

[GitHub] [flink] JingsongLi merged pull request #12274: [FLINK-17474][parquet][hive] Parquet reader should be case insensitive for hive

2020-05-21 Thread GitBox
JingsongLi merged pull request #12274: URL: https://github.com/apache/flink/pull/12274 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] JingsongLi merged pull request #12241: [FLINK-17474][parquet][hive] Parquet reader should be case insensitive for hive

2020-05-21 Thread GitBox
JingsongLi merged pull request #12241: URL: https://github.com/apache/flink/pull/12241 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Closed] (FLINK-17474) Test and correct case insensitive for parquet and orc in hive

2020-05-21 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17474. Resolution: Implemented master: 4d1a2f5da980f79b62dacf836e32ad1487a78eb0 release-1.11: d00fa4c67a

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

2020-05-21 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112925#comment-17112925 ] Jingsong Lee commented on FLINK-17086: -- Hi [~leiwangouc], related issues have been

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

2020-05-21 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17086. Resolution: Fixed > Flink sql client not able to read parquet hive table because > `HiveMapredSp

[jira] [Updated] (FLINK-17860) Recursively remove channel state directories

2020-05-21 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-17860: -- Description: With a high degree of parallelism, we end up with n*n files in each check

[jira] [Updated] (FLINK-17860) Recursively remove channel state directories

2020-05-21 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-17860: -- Description: With a high degree of parallelism, we end up with n*n number of files in

[GitHub] [flink] flinkbot edited a comment on pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

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

[jira] [Assigned] (FLINK-17657) jdbc not support read BIGINT UNSIGNED field

2020-05-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17657: --- Assignee: Leonard Xu > jdbc not support read BIGINT UNSIGNED field > --

[GitHub] [flink] flinkbot edited a comment on pull request #12276: [FLINK-13553][tests][qs] Improve Logging to debug Test Instability

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

[GitHub] [flink] flinkbot edited a comment on pull request #12273: [FLINK-17850][jdbc] Fix PostgresCatalogITCase.testGroupByInsert() fails on CI

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

[jira] [Updated] (FLINK-17657) jdbc not support read BIGINT UNSIGNED field

2020-05-21 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17657: Fix Version/s: 1.11.0 > jdbc not support read BIGINT UNSIGNED field >

[jira] [Resolved] (FLINK-14369) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

2020-05-21 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-14369. -- Resolution: Fixed I believe this issue is related to FLINK-14370 & FLINK-14235. The problem is

[jira] [Updated] (FLINK-16605) Add max limitation to the total number of slots

2020-05-21 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16605: --- Issue Type: New Feature (was: Improvement) > Add max limitation to the total number of slots >

[jira] [Commented] (FLINK-16605) Add max limitation to the total number of slots

2020-05-21 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112968#comment-17112968 ] Yangze Guo commented on FLINK-16605: [~gjy] We may add release note for it? > Add m

[GitHub] [flink] danny0405 commented on a change in pull request #12260: [FLINK-17189][table-planner] Table with proctime attribute cannot be read from Hive catalog

2020-05-21 Thread GitBox
danny0405 commented on a change in pull request #12260: URL: https://github.com/apache/flink/pull/12260#discussion_r428524670 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/sources/TableSourceUtil.scala ## @@ -238,6 +250,14 @@

[jira] [Created] (FLINK-17862) The internal class StreamingRuntimeContext is leaked in AbstractUdfStreamOperator

2020-05-21 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17862: -- Summary: The internal class StreamingRuntimeContext is leaked in AbstractUdfStreamOperator Key: FLINK-17862 URL: https://issues.apache.org/jira/browse/FLINK-17862 Project

[jira] [Updated] (FLINK-17862) The internal class StreamingRuntimeContext is leaked in AbstractUdfStreamOperator

2020-05-21 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17862: --- Component/s: API / DataStream > The internal class StreamingRuntimeContext is leaked in > AbstractU

[GitHub] [flink] flinkbot edited a comment on pull request #12215: [FLINK-17565][k8s] Bump fabric8 version from 4.5.2 to 4.9.2

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12215: URL: https://github.com/apache/flink/pull/12215#issuecomment-630047332 ## CI report: * 65c86e560750386063796783054ed5ea7ea42881 UNKNOWN * 96ecf9da6d438f616bc9b39b69b0f1c7319b1c34 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] JingsongLi commented on a change in pull request #12260: [FLINK-17189][table-planner] Table with proctime attribute cannot be read from Hive catalog

2020-05-21 Thread GitBox
JingsongLi commented on a change in pull request #12260: URL: https://github.com/apache/flink/pull/12260#discussion_r428534265 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/sources/TableSourceUtil.scala ## @@ -238,6 +250,14 @

[GitHub] [flink] wangyang0918 commented on pull request #12215: [FLINK-17565][k8s] Bump fabric8 version from 4.5.2 to 4.9.2

2020-05-21 Thread GitBox
wangyang0918 commented on pull request #12215: URL: https://github.com/apache/flink/pull/12215#issuecomment-631977115 @zhengcanbin Thanks for the updating. LGTM now. One more thing, we need to revert this commit 5846e5458e20308db4f0dd1c87d511a60817472c to verify FLINK-17416 is fixed(

[GitHub] [flink] hequn8128 commented on a change in pull request #12246: [FLINK-17303][python] Return TableResult for Python TableEnvironment

2020-05-21 Thread GitBox
hequn8128 commented on a change in pull request #12246: URL: https://github.com/apache/flink/pull/12246#discussion_r428525745 ## File path: flink-python/pyflink/table/tests/test_sql.py ## @@ -58,6 +56,67 @@ def test_sql_query(self): expected = ['2,Hi,Hello', '3,Hello,H

[GitHub] [flink] zhengcanbin opened a new pull request #12277: [FLINK-17230] Fix incorrect returned address of Endpoint for external Service of ClusterIP type

2020-05-21 Thread GitBox
zhengcanbin opened a new pull request #12277: URL: https://github.com/apache/flink/pull/12277 ## What is the purpose of the change At the moment, when external Service is set to ClusterIP, we return `${internal-service-name} + "." + nameSpace` as the address of the Endpoint, which c

[jira] [Updated] (FLINK-17230) Fix incorrect returned address of Endpoint for the ClusterIP Service

2020-05-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17230: --- Labels: pull-request-available (was: ) > Fix incorrect returned address of Endpoint for the

[jira] [Resolved] (FLINK-17447) Flink CEPOperator StateException

2020-05-21 Thread chun111111 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chun11 resolved FLINK-17447. Resolution: Not A Bug > Flink CEPOperator StateException > > >

[GitHub] [flink] flinkbot commented on pull request #12277: [FLINK-17230] Fix incorrect returned address of Endpoint for external Service of ClusterIP type

2020-05-21 Thread GitBox
flinkbot commented on pull request #12277: URL: https://github.com/apache/flink/pull/12277#issuecomment-631978940 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] wangyang0918 edited a comment on pull request #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

2020-05-21 Thread GitBox
wangyang0918 edited a comment on pull request #12240: URL: https://github.com/apache/flink/pull/12240#issuecomment-630701881 cc @tillrohrmann follow what we have discussed in FLINK-15792, this PR will make logs accessible via `kubectl logs` by default. Please have a look at your convenienc

[GitHub] [flink] zhengcanbin commented on pull request #12215: [FLINK-17565][k8s] Bump fabric8 version from 4.5.2 to 4.9.2

2020-05-21 Thread GitBox
zhengcanbin commented on pull request #12215: URL: https://github.com/apache/flink/pull/12215#issuecomment-631983535 > @zhengcanbin Thanks for the updating. LGTM now. > > One more thing, we need to revert this commit [5846e54](https://github.com/apache/flink/commit/5846e5458e20308db4

[jira] [Created] (FLINK-17863) flink streaming sql read hive with lots small files need to control parallelism

2020-05-21 Thread richt richt (Jira)
richt richt created FLINK-17863: --- Summary: flink streaming sql read hive with lots small files need to control parallelism Key: FLINK-17863 URL: https://issues.apache.org/jira/browse/FLINK-17863 Proj

[jira] [Created] (FLINK-17864) Update document about removing #registerTableSource

2020-05-21 Thread Danny Chen (Jira)
Danny Chen created FLINK-17864: -- Summary: Update document about removing #registerTableSource Key: FLINK-17864 URL: https://issues.apache.org/jira/browse/FLINK-17864 Project: Flink Issue Type: S

[jira] [Commented] (FLINK-17863) flink streaming sql read hive with lots small files need to control parallelism

2020-05-21 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113012#comment-17113012 ] Jingsong Lee commented on FLINK-17863: -- Hi [~yantianyu], there is a "table.exec.hiv

[GitHub] [flink] carp84 closed pull request #12096: [FLINK-16074][docs-zh] Translate the Overview page for State & Fault Tolerance into Chinese

2020-05-21 Thread GitBox
carp84 closed pull request #12096: URL: https://github.com/apache/flink/pull/12096 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[jira] [Closed] (FLINK-16074) Translate the "Overview" page for "State & Fault Tolerance" into Chinese

2020-05-21 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-16074. - Fix Version/s: (was: 1.12.0) 1.11.0 Resolution: Done Merged into: master via 25c15

[GitHub] [flink] flinkbot edited a comment on pull request #12215: [FLINK-17565][k8s] Bump fabric8 version from 4.5.2 to 4.9.2

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12215: URL: https://github.com/apache/flink/pull/12215#issuecomment-630047332 ## CI report: * 65c86e560750386063796783054ed5ea7ea42881 UNKNOWN * 96ecf9da6d438f616bc9b39b69b0f1c7319b1c34 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

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

[GitHub] [flink] flinkbot commented on pull request #12277: [FLINK-17230] Fix incorrect returned address of Endpoint for external Service of ClusterIP type

2020-05-21 Thread GitBox
flinkbot commented on pull request #12277: URL: https://github.com/apache/flink/pull/12277#issuecomment-631994506 ## CI report: * 689aafe09dd533f85d746915b404d126e051dd6b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #12260: [FLINK-17189][table-planner] Table with proctime attribute cannot be read from Hive catalog

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

[GitHub] [flink] flinkbot edited a comment on pull request #12246: [FLINK-17303][python] Return TableResult for Python TableEnvironment

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

[GitHub] [flink] carp84 commented on pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

2020-05-21 Thread GitBox
carp84 commented on pull request #8693: URL: https://github.com/apache/flink/pull/8693#issuecomment-631995913 Already merged into master via: * f0ed29c06d331892a06ee9bddea4173d6300835d * fae6a6cad3f4fe30d80cc9dd664b2efc72c0be36 * 1f6b1e6b8ffb38f196c2a1c6348cb96935e9a9cc relea

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

2020-05-21 Thread GitBox
carp84 edited a comment on pull request #8693: URL: https://github.com/apache/flink/pull/8693#issuecomment-631995913 Already merged into master via: * f0ed29c06d331892a06ee9bddea4173d6300835d * fae6a6cad3f4fe30d80cc9dd664b2efc72c0be36 * 1f6b1e6b8ffb38f196c2a1c6348cb96935e9a9cc

[GitHub] [flink] carp84 closed pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

2020-05-21 Thread GitBox
carp84 closed pull request #8693: URL: https://github.com/apache/flink/pull/8693 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Updated] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

2020-05-21 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-8871: - Issue Type: Improvement (was: Bug) Merged into master via: * f0ed29c06d331892a06ee9bddea4173d6300835d * fae6a6ca

[jira] [Updated] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

2020-05-21 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-8871: Release Note: This improvement help to abort checkpoint more eagerly, and also introduce interface #notifyC

[jira] [Updated] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

2020-05-21 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-8871: - Issue Type: Improvement (was: Bug) > Checkpoint cancellation is not propagated to stop checkpointing threads on

[jira] [Closed] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

2020-05-21 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-8871. Release Note: FLINK-8871 helps to abort checkpoint more eagerly, and added a new interface #notifyCheckpointAborted

[GitHub] [flink] flinkbot edited a comment on pull request #12215: [FLINK-17565][k8s] Bump fabric8 version from 4.5.2 to 4.9.2

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12215: URL: https://github.com/apache/flink/pull/12215#issuecomment-630047332 ## CI report: * 65c86e560750386063796783054ed5ea7ea42881 UNKNOWN * 96ecf9da6d438f616bc9b39b69b0f1c7319b1c34 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12260: [FLINK-17189][table-planner] Table with proctime attribute cannot be read from Hive catalog

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

[GitHub] [flink] flinkbot edited a comment on pull request #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

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

[GitHub] [flink] flinkbot edited a comment on pull request #12246: [FLINK-17303][python] Return TableResult for Python TableEnvironment

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

[GitHub] [flink] flinkbot edited a comment on pull request #12277: [FLINK-17230] Fix incorrect returned address of Endpoint for external Service of ClusterIP type

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

[jira] [Closed] (FLINK-17864) Update document about removing #registerTableSource

2020-05-21 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17864. -- Resolution: Duplicate > Update document about removing #registerTableSource >

[jira] [Closed] (FLINK-14492) Modify state backend to report reserved memory to MemoryManager

2020-05-21 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-14492. - Resolution: Duplicate This work is already done through FLINK-15084 > Modify state backend to report reserved m

[jira] [Closed] (FLINK-14489) Check and make sure state backend fits into TaskExecutor memory configuration

2020-05-21 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-14489. - Resolution: Later We had some discussion (in this [google doc|https://docs.google.com/document/d/12HL7qd3fF3nLO

[GitHub] [flink] flinkbot edited a comment on pull request #12260: [FLINK-17189][table-planner] Table with proctime attribute cannot be read from Hive catalog

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

[jira] [Closed] (FLINK-14883) Resource management on state backends

2020-05-21 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li closed FLINK-14883. - Resolution: Later Now RocksDBStateBackend is already included into resource management ([documents here|https:

[GitHub] [flink] flinkbot edited a comment on pull request #12246: [FLINK-17303][python] Return TableResult for Python TableEnvironment

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

[GitHub] [flink] fpompermaier commented on pull request #12273: [FLINK-17850][jdbc] Fix PostgresCatalogITCase.testGroupByInsert() fails on CI

2020-05-21 Thread GitBox
fpompermaier commented on pull request #12273: URL: https://github.com/apache/flink/pull/12273#issuecomment-632022838 LGTM on my side. Then what should I do with the other PR that was reverted? This is an automated message fr

[jira] [Commented] (FLINK-17849) YARNHighAvailabilityITCase hangs in Azure Pipelines CI

2020-05-21 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113079#comment-17113079 ] Yang Wang commented on FLINK-17849: --- When i check the jobmanager.log of the failed tes

[jira] [Updated] (FLINK-17849) YARNHighAvailabilityITCase hangs in Azure Pipelines CI

2020-05-21 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-17849: -- Attachment: jobmanager.log > YARNHighAvailabilityITCase hangs in Azure Pipelines CI >

[GitHub] [flink] klion26 commented on pull request #12096: [FLINK-16074][docs-zh] Translate the Overview page for State & Fault Tolerance into Chinese

2020-05-21 Thread GitBox
klion26 commented on pull request #12096: URL: https://github.com/apache/flink/pull/12096#issuecomment-632025908 @carp84 thanks for the review and merging. This is an automated message from the Apache Git Service. To respond

[jira] [Assigned] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

2020-05-21 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-17322: --- Assignee: Arvid Heise > Enable latency tracker would corrupt the broadcast state >

[jira] [Updated] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

2020-05-21 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-17322: Affects Version/s: (was: 1.9.2) (was: 1.10.0)

[GitHub] [flink] klion26 closed pull request #7955: [FLINK-11797][checkpoint][test]Implement empty test functions in CheckpointCoordinatorMasterHooksTest

2020-05-21 Thread GitBox
klion26 closed pull request #7955: URL: https://github.com/apache/flink/pull/7955 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to th

[jira] [Commented] (FLINK-17322) Enable latency tracker would corrupt the broadcast state

2020-05-21 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113083#comment-17113083 ] Arvid Heise commented on FLINK-17322: - There is a fundamental issue with latency mar

[jira] [Commented] (FLINK-17849) YARNHighAvailabilityITCase hangs in Azure Pipelines CI

2020-05-21 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113092#comment-17113092 ] Yang Wang commented on FLINK-17849: --- The reason why the {{YARNHighAvailabilityITCase}}

[jira] [Commented] (FLINK-16402) Alter table fails on Hive catalog

2020-05-21 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113093#comment-17113093 ] Rui Li commented on FLINK-16402: Hi [~morhidi], thanks for the clarifications. I'm still

[jira] [Commented] (FLINK-17351) CheckpointCoordinator and CheckpointFailureManager ignores checkpoint timeouts

2020-05-21 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113095#comment-17113095 ] Congxian Qiu(klion26) commented on FLINK-17351: --- Attach another issue whic

[GitHub] [flink] flinkbot edited a comment on pull request #12260: [FLINK-17189][table-planner] Table with proctime attribute cannot be read from Hive catalog

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

[jira] [Commented] (FLINK-17750) YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint failed on azure

2020-05-21 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113100#comment-17113100 ] Yang Wang commented on FLINK-17750: --- I am afraid the "AssertionError: There is at leas

[jira] [Created] (FLINK-17865) Increase default size of `state.backend.fs.memory-threshold`

2020-05-21 Thread Yu Li (Jira)
Yu Li created FLINK-17865: - Summary: Increase default size of `state.backend.fs.memory-threshold` Key: FLINK-17865 URL: https://issues.apache.org/jira/browse/FLINK-17865 Project: Flink Issue Type: I

[GitHub] [flink] wuchong commented on a change in pull request #12260: [FLINK-17189][table-planner] Table with proctime attribute cannot be read from Hive catalog

2020-05-21 Thread GitBox
wuchong commented on a change in pull request #12260: URL: https://github.com/apache/flink/pull/12260#discussion_r428601204 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/sources/TableSourceUtil.scala ## @@ -238,6 +250,14 @@ o

[jira] [Created] (FLINK-17866) InvalidPathException was thrown when running the test cases of PyFlink on Windows

2020-05-21 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-17866: - Summary: InvalidPathException was thrown when running the test cases of PyFlink on Windows Key: FLINK-17866 URL: https://issues.apache.org/jira/browse/FLINK-17866 Project:

[jira] [Assigned] (FLINK-17866) InvalidPathException was thrown when running the test cases of PyFlink on Windows

2020-05-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17866: --- Assignee: Wei Zhong > InvalidPathException was thrown when running the test cases of PyFlink on >

[jira] [Updated] (FLINK-17866) InvalidPathException was thrown when running the test cases of PyFlink on Windows

2020-05-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17866: Affects Version/s: 1.11.0 > InvalidPathException was thrown when running the test cases of PyFlink on > W

[jira] [Updated] (FLINK-17866) InvalidPathException was thrown when running the test cases of PyFlink on Windows

2020-05-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17866: Fix Version/s: 1.11.0 > InvalidPathException was thrown when running the test cases of PyFlink on > Windo

[jira] [Updated] (FLINK-17771) "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11

2020-05-21 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-17771: -- Attachment: image-2020-05-21-20-11-07-626.png > "PyFlink end-to-end test" fails with "The output resul

[jira] [Updated] (FLINK-17771) "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11

2020-05-21 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-17771: -- Attachment: image-2020-05-21-20-11-29-389.png > "PyFlink end-to-end test" fails with "The output resul

[jira] [Updated] (FLINK-17771) "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11

2020-05-21 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-17771: -- Attachment: image-2020-05-21-20-11-48-220.png > "PyFlink end-to-end test" fails with "The output resul

[jira] [Updated] (FLINK-17771) "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11

2020-05-21 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-17771: -- Attachment: image-2020-05-21-20-12-16-889.png > "PyFlink end-to-end test" fails with "The output resul

[GitHub] [flink] wuchong commented on pull request #12273: [FLINK-17850][jdbc] Fix PostgresCatalogITCase.testGroupByInsert() fails on CI

2020-05-21 Thread GitBox
wuchong commented on pull request #12273: URL: https://github.com/apache/flink/pull/12273#issuecomment-632052087 Thanks for the reviewing @fpompermaier . This is the only commit been reverted. I will merge this when the build is passed. -

[GitHub] [flink] leonardBang commented on pull request #12273: [FLINK-17850][jdbc] Fix PostgresCatalogITCase.testGroupByInsert() fails on CI

2020-05-21 Thread GitBox
leonardBang commented on pull request #12273: URL: https://github.com/apache/flink/pull/12273#issuecomment-632052580 Thanks for the update @wuchong , LGTM This is an automated message from the Apache Git Service. To respond t

[GitHub] [flink] flinkbot edited a comment on pull request #12260: [FLINK-17189][table-planner] Table with proctime attribute cannot be read from Hive catalog

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

[GitHub] [flink] flinkbot edited a comment on pull request #12273: [FLINK-17850][jdbc] Fix PostgresCatalogITCase.testGroupByInsert() fails on CI

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

  1   2   3   4   >