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

2020-05-21 Thread GitBox
flinkbot commented on pull request #12274: URL: https://github.com/apache/flink/pull/12274#issuecomment-631903745 ## CI report: * 411e5f0b0fa72c2f5aa163767ba7b9bcb45ee50f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12241: [FLINK-17474][parquet][hive] Parquet reader should be case insensitive for hive

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12241: URL: https://github.com/apache/flink/pull/12241#issuecomment-630692649 ## CI report: * a16df2eb5401a92070e634c13fbc27d445069671 Azure:

[jira] [Commented] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

2020-05-21 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112838#comment-17112838 ] Zhijiang commented on FLINK-17315: -- I close this ticket and try to resolve all the issues in

[GitHub] [flink-statefun] tzulitai closed pull request #114: [FLINK-17611] Add unix domain sockets to remote functions

2020-05-21 Thread GitBox
tzulitai closed pull request #114: URL: https://github.com/apache/flink-statefun/pull/114 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] flinkbot edited a comment on pull request #12241: [FLINK-17474][parquet][hive] Parquet reader should be case insensitive for hive

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12241: URL: https://github.com/apache/flink/pull/12241#issuecomment-630692649 ## CI report: * a16df2eb5401a92070e634c13fbc27d445069671 Azure:

[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:

[GitHub] [flink] flinkbot edited a comment on pull request #12274: [FLINK-17474][parquet][hive] Parquet reader should be case insensitive for hive

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12274: URL: https://github.com/apache/flink/pull/12274#issuecomment-631903745 ## CI report: * 411e5f0b0fa72c2f5aa163767ba7b9bcb45ee50f Azure:

[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] [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=17112891#comment-17112891 ] Matyas Orhidi commented on FLINK-16402: --- hi [~lirui] [~gyfora] the error message is coming from:

[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

[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:

[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:

[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

[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

[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:

[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:

[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

[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',

[jira] [Commented] (FLINK-17812) Bundle reporters in plugins/ directory

2020-05-21 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112831#comment-17112831 ] Yangze Guo commented on FLINK-17812: Not sure about that. It seems most of metrics reporters are

[jira] [Commented] (FLINK-17852) FlinkSQL support WITH clause in query statement

2020-05-21 Thread sam lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112836#comment-17112836 ] sam lin commented on FLINK-17852: - [~jark]: thanks for the code pointer.  Yeah, it will be great if we

[jira] [Updated] (FLINK-17859) [flink-s3-fs-presto] Upgrade the dependent presto-hive jar to latest version

2020-05-21 Thread sam lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sam lin updated FLINK-17859: Component/s: Connectors / Hive > [flink-s3-fs-presto] Upgrade the dependent presto-hive jar to latest

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

2020-05-21 Thread GitBox
flinkbot commented on pull request #12275: URL: https://github.com/apache/flink/pull/12275#issuecomment-631912691 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] danny0405 commented on pull request #12275: [FLINK-16021][table-common] DescriptorProperties.putTableSchema does …

2020-05-21 Thread GitBox
danny0405 commented on pull request #12275: URL: https://github.com/apache/flink/pull/12275#issuecomment-631912098 Hi, @twalthr , can you take a look if you have time ? This is an automated message from the Apache Git

[jira] [Created] (FLINK-17859) [flink-s3-fs-presto] Upgrade the dependent presto-hive jar to latest version

2020-05-21 Thread sam lin (Jira)
sam lin created FLINK-17859: --- Summary: [flink-s3-fs-presto] Upgrade the dependent presto-hive jar to latest version Key: FLINK-17859 URL: https://issues.apache.org/jira/browse/FLINK-17859 Project: Flink

[jira] [Updated] (FLINK-17859) [flink-s3-fs-presto] Upgrade the dependent presto-hive jar to latest version

2020-05-21 Thread sam lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sam lin updated FLINK-17859: Component/s: Connectors / FileSystem > [flink-s3-fs-presto] Upgrade the dependent presto-hive jar to

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

2020-05-21 Thread GitBox
tzulitai commented on pull request #115: URL: https://github.com/apache/flink-statefun/pull/115#issuecomment-631916294 Thanks for the review @igalshilman! Changing the script header to `#!bin/bash` to run it with standard bash shell makes the build script work in the CI as well.

[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] 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.

[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

[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

[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=17112968#comment-17112968 ] Yangze Guo commented on FLINK-16605: [~gjy] We may add release note for it? > Add max limitation to

[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

[jira] [Updated] (FLINK-16021) DescriptorProperties.putTableSchema does not include constraints

2020-05-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16021: --- Labels: pull-request-available (was: ) > DescriptorProperties.putTableSchema does not

[GitHub] [flink] danny0405 opened a new pull request #12275: [FLINK-16021][table-common] DescriptorProperties.putTableSchema does …

2020-05-21 Thread GitBox
danny0405 opened a new pull request #12275: URL: https://github.com/apache/flink/pull/12275 …not include constraints ## What is the purpose of the change Fix the primary key constraint info loss for TableSchema SEDE with `DescriptorProperties`.

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #115: [FLINK-17518] [e2e] Add remote module E2E

2020-05-21 Thread GitBox
tzulitai commented on a change in pull request #115: URL: https://github.com/apache/flink-statefun/pull/115#discussion_r428476280 ## File path: statefun-e2e-tests/pom.xml ## @@ -63,11 +63,26 @@ under the License. 1.6.0

[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:

[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:

[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:

[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: 

[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=17112925#comment-17112925 ] Jingsong Lee commented on FLINK-17086: -- Hi [~leiwangouc], related issues have been fixed, you can

[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 >

[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] [Comment Edited] (FLINK-17847) ArrayIndexOutOfBoundsException happens when codegen StreamExec operator

2020-05-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17112759#comment-17112759 ] Leonard Xu edited comment on FLINK-17847 at 5/21/20, 5:59 AM: -- Thanks

[jira] [Assigned] (FLINK-17847) ArrayIndexOutOfBoundsException happens when codegen StreamExec operator

2020-05-21 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17847: Assignee: Leonard Xu > ArrayIndexOutOfBoundsException happens when codegen StreamExec

[jira] [Closed] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

2020-05-21 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-17611. --- Fix Version/s: statefun-2.1.0 Resolution: Fixed Thanks for the contribution

[jira] [Closed] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

2020-05-21 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17315. Resolution: Duplicate > UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel >

[GitHub] [flink-statefun] tzulitai closed pull request #110: [FLINK-17611] Unix domain socket connection between worker and function

2020-05-21 Thread GitBox
tzulitai closed pull request #110: URL: https://github.com/apache/flink-statefun/pull/110 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-statefun] tzulitai commented on pull request #110: [FLINK-17611] Unix domain socket connection between worker and function

2020-05-21 Thread GitBox
tzulitai commented on pull request #110: URL: https://github.com/apache/flink-statefun/pull/110#issuecomment-631909890 Closing. Resolved via #114 (1c018e19d96f44334fe1b24280337679dc2a7be8). This is an automated message from

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

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

[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 -

[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=17112897#comment-17112897 ] Leonard Xu commented on FLINK-17657: [~zhanglun] Thanks for the report, it's a bug from type mapping

[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] [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 >

[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] 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

[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

[GitHub] [flink] senegalo commented on pull request #12056: [FLINK-17502] [flink-connector-rabbitmq] RMQSource refactor

2020-05-21 Thread GitBox
senegalo commented on pull request #12056: URL: https://github.com/apache/flink/pull/12056#issuecomment-631906626 @aljoscha @austince just a ping in case you missed my last comment This is an automated message from the

[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:

[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

[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

[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:

[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:

[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:

[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 >

[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

[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

[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

[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

[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

[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

[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

[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

[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:

[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:

[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:

[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:

[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

[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

[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=17113079#comment-17113079 ] Yang Wang commented on FLINK-17849: --- When i check the jobmanager.log of the failed test

[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

[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=17113083#comment-17113083 ] Arvid Heise commented on FLINK-17322: - There is a fundamental issue with latency markers and legacy

[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=17113095#comment-17113095 ] Congxian Qiu(klion26) commented on FLINK-17351: --- Attach another issue which wants to

[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=17113093#comment-17113093 ] Rui Li commented on FLINK-16402: Hi [~morhidi], thanks for the clarifications. I'm still not sure why

[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=17113100#comment-17113100 ] Yang Wang commented on FLINK-17750: --- I am afraid the "AssertionError: There is at least one

[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] [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

[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

[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 *

[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:

[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:

[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

[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=17113092#comment-17113092 ] Yang Wang commented on FLINK-17849: --- The reason why the {{YARNHighAvailabilityITCase}} hangs is that

[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

[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 >

  1   2   3   4   >