[jira] [Comment Edited] (FLINK-15000) Metrics is very slow when parallelism is over 1000

2019-12-09 Thread fa zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16988573#comment-16988573 ] fa zheng edited comment on FLINK-15000 at 12/10/19 7:58 AM: it mainly caused

[GitHub] [flink] zhijiangW commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
zhijiangW commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#discussion_r355886957 ## File path:

[jira] [Updated] (FLINK-7151) Support function DDL

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-7151: - Fix Version/s: (was: 1.10.0) 1.11.0 Change the fix version to 1.11.0 since we already

[jira] [Comment Edited] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

2019-12-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992220#comment-16992220 ] Xintong Song edited comment on FLINK-15103 at 12/10/19 7:50 AM: Ok, I

[GitHub] [flink] flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests URL: https://github.com/apache/flink/pull/10348#issuecomment-559509076 ## CI report: * 54ecee627e7036f4d150aad330b9772406a19494 Travis:

[jira] [Comment Edited] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

2019-12-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992220#comment-16992220 ] Xintong Song edited comment on FLINK-15103 at 12/10/19 7:49 AM: Ok, I

[GitHub] [flink] flinkbot edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum URL: https://github.com/apache/flink/pull/9768#issuecomment-534899022 ## CI report: * 51ae12da735fd7fd1bdadd282839c9bfe7b80146 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10507: [FLINK-15146][CORE]Fix the value of that should be strictly greater than zero

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10507: [FLINK-15146][CORE]Fix the value of that should be strictly greater than zero URL: https://github.com/apache/flink/pull/10507#issuecomment-563900578 ## CI report: * 5e6a4e1ba03194e13928342ab5d77fa516e16b00 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10506: [FLINK-15166][runtime] Fix that buffer is wrongly recycled when data compression is enabled for blocking shuffle.

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10506: [FLINK-15166][runtime] Fix that buffer is wrongly recycled when data compression is enabled for blocking shuffle. URL: https://github.com/apache/flink/pull/10506#issuecomment-563900511 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10505: [FLINK-14958][table]ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10505: [FLINK-14958][table]ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String URL: https://github.com/apache/flink/pull/10505#issuecomment-563892373 ## CI report: * f742b7defe3d40ae00fb3e0adb66e4dc3ec20087 Travis:

[jira] [Updated] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-12352: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change the fix version to 1.11.0 since we already

[jira] [Commented] (FLINK-14392) Introduce JobClient API(FLIP-74)

2019-12-09 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992272#comment-16992272 ] Zili Chen commented on FLINK-14392: --- >From my side the {{JobClient}} is full-featured and ready for

[jira] [Comment Edited] (FLINK-13437) Add Hive SQL E2E test

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992269#comment-16992269 ] Yu Li edited comment on FLINK-13437 at 12/10/19 7:40 AM: - Thanks for the

[jira] [Commented] (FLINK-13437) Add Hive SQL E2E test

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992269#comment-16992269 ] Yu Li commented on FLINK-13437: --- Thanks for the confirmation and efforts [~ykt836] [~lzljs3620320] ! >

[jira] [Updated] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14359: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change fix version to 1.11.0 since we already

[jira] [Commented] (FLINK-13998) Fix ORC test failure with Hive 2.0.x

2019-12-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992266#comment-16992266 ] Jingsong Lee commented on FLINK-13998: -- I will modify it to 1.11 > Fix ORC test failure with Hive

[jira] [Updated] (FLINK-13998) Fix ORC test failure with Hive 2.0.x

2019-12-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13998: - Fix Version/s: (was: 1.10.0) 1.11.0 > Fix ORC test failure with Hive

[jira] [Commented] (FLINK-13998) Fix ORC test failure with Hive 2.0.x

2019-12-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992265#comment-16992265 ] Jingsong Lee commented on FLINK-13998: -- Since useOrcVectorizedRead has been introduced, this bug

[jira] [Closed] (FLINK-13947) Check Hive shim serialization in Hive UDF wrapper classes and test coverage

2019-12-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-13947. Resolution: Fixed > Check Hive shim serialization in Hive UDF wrapper classes and test coverage >

[jira] [Commented] (FLINK-13947) Check Hive shim serialization in Hive UDF wrapper classes and test coverage

2019-12-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992264#comment-16992264 ] Jingsong Lee commented on FLINK-13947: -- Now HiveShim is serializable now and there are some tests

[GitHub] [flink] flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo URL: https://github.com/apache/flink/pull/10458#issuecomment-562482569 ## CI report: * 303f921f58ff61aa3e332c36ffdc07d5f9ceb352 Travis:

[jira] [Assigned] (FLINK-13437) Add Hive SQL E2E test

2019-12-09 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-13437: -- Assignee: Terry Wang (was: Jingsong Lee) > Add Hive SQL E2E test > - >

[jira] [Updated] (FLINK-15169) Errors happen in the scheduling of DefaultScheduler is not shown in WebUI

2019-12-09 Thread Gary Yao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15169: - Priority: Blocker (was: Major) > Errors happen in the scheduling of DefaultScheduler is not shown in

[jira] [Updated] (FLINK-15169) Errors happen in the scheduling of DefaultScheduler is not shown in WebUI

2019-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15169: Description: WebUI relies on {{ExecutionGraph#failureInfo}} and {{Execution#failureCause}} to generate

[jira] [Comment Edited] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

2019-12-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992220#comment-16992220 ] Xintong Song edited comment on FLINK-15103 at 12/10/19 7:23 AM: Ok, I

[jira] [Created] (FLINK-15169) Errors happen in the scheduling of DefaultScheduler is not shown in WebUI

2019-12-09 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-15169: --- Summary: Errors happen in the scheduling of DefaultScheduler is not shown in WebUI Key: FLINK-15169 URL: https://issues.apache.org/jira/browse/FLINK-15169 Project: Flink

[jira] [Comment Edited] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

2019-12-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992220#comment-16992220 ] Xintong Song edited comment on FLINK-15103 at 12/10/19 7:19 AM: Ok, I

[GitHub] [flink] flinkbot edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum URL: https://github.com/apache/flink/pull/9768#issuecomment-534899022 ## CI report: * 51ae12da735fd7fd1bdadd282839c9bfe7b80146 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10505: [FLINK-14958][table]ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10505: [FLINK-14958][table]ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String URL: https://github.com/apache/flink/pull/10505#issuecomment-563892373 ## CI report: * f742b7defe3d40ae00fb3e0adb66e4dc3ec20087 Travis:

[GitHub] [flink] flinkbot commented on issue #10507: [FLINK-15146][CORE]Fix the value of that should be strictly greater than zero

2019-12-09 Thread GitBox
flinkbot commented on issue #10507: [FLINK-15146][CORE]Fix the value of that should be strictly greater than zero URL: https://github.com/apache/flink/pull/10507#issuecomment-563900578 ## CI report: * 5e6a4e1ba03194e13928342ab5d77fa516e16b00 UNKNOWN Bot commands

[GitHub] [flink] flinkbot commented on issue #10506: [FLINK-15166][runtime] Fix that buffer is wrongly recycled when data compression is enabled for blocking shuffle.

2019-12-09 Thread GitBox
flinkbot commented on issue #10506: [FLINK-15166][runtime] Fix that buffer is wrongly recycled when data compression is enabled for blocking shuffle. URL: https://github.com/apache/flink/pull/10506#issuecomment-563900511 ## CI report: * 4f2b4aa04f47518706f004f7702cf42d76b79f4e

[GitHub] [flink] flinkbot edited a comment on issue #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503#issuecomment-563692047 ## CI report: * 0a63ef8576f25cdec9fe106d7f69429fff6a4c7e Travis:

[jira] [Created] (FLINK-15168) Exception is thrown when using kafka source connector with flink planner

2019-12-09 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-15168: Summary: Exception is thrown when using kafka source connector with flink planner Key: FLINK-15168 URL: https://issues.apache.org/jira/browse/FLINK-15168 Project:

[GitHub] [flink] flinkbot edited a comment on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#issuecomment-563198013 ## CI report: * 793df2e323b4f84433f99f21515b30a21524658c Travis:

[jira] [Resolved] (FLINK-14378) Cleanup rocksDB lib folder if fail to load library

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li resolved FLINK-14378. --- Resolution: Fixed Merged via: 0d9058c56e4f420d1c501e5aef981433a96650dd (Thanks [~sewen] for help review and

[GitHub] [flink] wangyang0918 commented on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
wangyang0918 commented on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#issuecomment-563899206 @zhijiangW Thanks for you comments. 1. The reason why i change the description of

[jira] [Comment Edited] (FLINK-15133) support sql_alchemy in Flink for broader python sql integration

2019-12-09 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992252#comment-16992252 ] sunjincheng edited comment on FLINK-15133 at 12/10/19 7:09 AM: --- I think

[jira] [Updated] (FLINK-14351) Refactor MetricRegistry delimiter retrieval into separate interface

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14351: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change fix version to 1.11.0 since we already

[jira] [Updated] (FLINK-14820) Replace Time with Duration in FutureUtils

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14820: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change fix version to 1.11.0 since we already

[jira] [Commented] (FLINK-15133) support sql_alchemy in Flink for broader python sql integration

2019-12-09 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992252#comment-16992252 ] sunjincheng commented on FLINK-15133: - I think this is tool lib for python user who want query DB by

[jira] [Commented] (FLINK-13437) Add Hive SQL E2E test

2019-12-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992250#comment-16992250 ] Jingsong Lee commented on FLINK-13437: -- PR: [https://github.com/apache/flink/pull/9919]

[jira] [Updated] (FLINK-13390) Clarify the exact meaning of state size when executing incremental checkpoint

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-13390: -- Fix Version/s: (was: 1.10.0) 1.11.0 Thanks for following this up from user ML.

[GitHub] [flink] flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo URL: https://github.com/apache/flink/pull/10458#issuecomment-562482569 ## CI report: * 303f921f58ff61aa3e332c36ffdc07d5f9ceb352 Travis:

[GitHub] [flink] wangyang0918 commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
wangyang0918 commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#discussion_r355871124 ## File path:

[GitHub] [flink] flinkbot commented on issue #10507: [FLINK-15146][CORE]Fix the value of that should be strictly greater than zero

2019-12-09 Thread GitBox
flinkbot commented on issue #10507: [FLINK-15146][CORE]Fix the value of that should be strictly greater than zero URL: https://github.com/apache/flink/pull/10507#issuecomment-563895954 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] wangyang0918 commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
wangyang0918 commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#discussion_r355870735 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
wangyang0918 commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#discussion_r355870584 ## File path:

[GitHub] [flink] hehuiyuan opened a new pull request #10507: [FLINK-15146][CORE]Fix the value of that should be strictly greater than zero

2019-12-09 Thread GitBox
hehuiyuan opened a new pull request #10507: [FLINK-15146][CORE]Fix the value of that should be strictly greater than zero URL: https://github.com/apache/flink/pull/10507 ## What is the purpose of the change Hi , the value of cleanupSize is grater than or equal 0. Whether that the

[jira] [Updated] (FLINK-15146) The value of `cleanupSize` should be grater than 0 for `IncrementalCleanupStrategy`

2019-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15146: --- Labels: pull-request-available (was: ) > The value of `cleanupSize` should be grater than

[jira] [Updated] (FLINK-14537) Improve influxdb reporter performance for kafka source/sink

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14537: -- Fix Version/s: (was: 1.10.0) Remove 1.10.0 from the fix version(s) since we already reached feature

[GitHub] [flink] wangyang0918 commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
wangyang0918 commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#discussion_r355869450 ## File path:

[jira] [Updated] (FLINK-14863) remove default in-memory catalog from CatalogManager

2019-12-09 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14863: - Fix Version/s: (was: 1.11.0) > remove default in-memory catalog from CatalogManager >

[GitHub] [flink] wangyang0918 commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
wangyang0918 commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#discussion_r355869102 ## File path:

[jira] [Updated] (FLINK-14046) DDL property 'format.fields.#.type' should ignore case

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14046: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change the fix version to 1.11.0 to facilitate

[GitHub] [flink] zhijiangW commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
zhijiangW commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#discussion_r355869144 ## File path:

[jira] [Updated] (FLINK-12302) Fixed the wrong finalStatus of yarn application when application finished

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-12302: -- Fix Version/s: (was: 1.10.0) 1.11.0 It seems we haven't reached a consensus here yet,

[jira] [Updated] (FLINK-12273) The default value of CheckpointRetentionPolicy should be RETAIN_ON_FAILURE, otherwise it cannot be recovered according to checkpoint after failure.

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-12273: -- Fix Version/s: (was: 1.10.0) 1.11.0 >From the discussion in relative PR, we haven't

[GitHub] [flink] zhijiangW commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
zhijiangW commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#discussion_r355867648 ## File path:

[GitHub] [flink] flinkbot commented on issue #10505: [FLINK-14958][table]ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String

2019-12-09 Thread GitBox
flinkbot commented on issue #10505: [FLINK-14958][table]ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String URL: https://github.com/apache/flink/pull/10505#issuecomment-563892373 ## CI report: * f742b7defe3d40ae00fb3e0adb66e4dc3ec20087 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10503: [FLINK-15137][avro] Improve schema derivation for Avro format

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10503: [FLINK-15137][avro] Improve schema derivation for Avro format URL: https://github.com/apache/flink/pull/10503#issuecomment-563692047 ## CI report: * 0a63ef8576f25cdec9fe106d7f69429fff6a4c7e Travis:

[jira] [Updated] (FLINK-15167) SQL CLI library option doesn't work for Hive connector

2019-12-09 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15167: - Fix Version/s: 1.10.0 > SQL CLI library option doesn't work for Hive connector >

[GitHub] [flink] flinkbot commented on issue #10506: [FLINK-15166][runtime] Fix that buffer is wrongly recycled when data compression is enabled for blocking shuffle.

2019-12-09 Thread GitBox
flinkbot commented on issue #10506: [FLINK-15166][runtime] Fix that buffer is wrongly recycled when data compression is enabled for blocking shuffle. URL: https://github.com/apache/flink/pull/10506#issuecomment-563891883 Thanks a lot for your contribution to the Apache Flink project. I'm

[GitHub] [flink] flinkbot edited a comment on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#issuecomment-563198013 ## CI report: * 793df2e323b4f84433f99f21515b30a21524658c Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
zhijiangW commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#discussion_r355866830 ## File path:

[jira] [Updated] (FLINK-15166) Shuffle data compression wrongly decrease the buffer reference count.

2019-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15166: --- Labels: pull-request-available (was: ) > Shuffle data compression wrongly decrease the

[jira] [Updated] (FLINK-15066) Cannot run multiple `insert into csvTable values ()`

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-15066: -- Issue Type: Bug (was: Improvement) Correct me if I'm wrong, but this seems more like a bug to fix instead of

[jira] [Updated] (FLINK-15167) SQL CLI library option doesn't work for Hive connector

2019-12-09 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-15167: --- Description: Put all Hive connector dependency jars in a folder and start sql cli like: {{sql-client.sh

[jira] [Updated] (FLINK-15167) SQL CLI library option doesn't work for Hive connector

2019-12-09 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-15167: --- Description: Put all Hive connector dependency jars in a folder and start sql cli like {{sql-client.sh

[GitHub] [flink] zhijiangW commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
zhijiangW commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#discussion_r355866084 ## File path:

[GitHub] [flink] wsry opened a new pull request #10506: [FLINK-15166][runtime] Fix that buffer is wrongly recycled when data compression is enabled for blocking shuffle.

2019-12-09 Thread GitBox
wsry opened a new pull request #10506: [FLINK-15166][runtime] Fix that buffer is wrongly recycled when data compression is enabled for blocking shuffle. URL: https://github.com/apache/flink/pull/10506 ## What is the purpose of the change For blocking shuffle data compression, the

[jira] [Created] (FLINK-15167) SQL CLI library option doesn't work for Hive connector

2019-12-09 Thread Rui Li (Jira)
Rui Li created FLINK-15167: -- Summary: SQL CLI library option doesn't work for Hive connector Key: FLINK-15167 URL: https://issues.apache.org/jira/browse/FLINK-15167 Project: Flink Issue Type: Bug

[GitHub] [flink] zhijiangW commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label

2019-12-09 Thread GitBox
zhijiangW commented on a change in pull request #10496: [FLINK-15153]Service selector needs to contain jobmanager component label URL: https://github.com/apache/flink/pull/10496#discussion_r355865915 ## File path:

[jira] [Updated] (FLINK-14971) Move ACK and declined message handling in the same thread with triggering

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14971: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change fix version to 1.11.0 since we already

[jira] [Updated] (FLINK-14934) Remove error log statement in ES connector

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14934: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change fix version to 1.11.0 since we already

[jira] [Updated] (FLINK-14893) Using Child ClassLoader to load class when Parent ClassLoader couldn't load in ParentFirstPatterns

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14893: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change fix version to 1.11.0 since we already

[jira] [Updated] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14902: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change fix version to 1.11.0 since we already

[jira] [Comment Edited] (FLINK-14647) Improve the exception message when required property is not matched

2019-12-09 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992206#comment-16992206 ] Nicholas Jiang edited comment on FLINK-14647 at 12/10/19 6:44 AM: --

[jira] [Updated] (FLINK-14863) remove default in-memory catalog from CatalogManager

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14863: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change fix version to 1.11.0 since we already

[jira] [Updated] (FLINK-14652) Refactor checkpointing related parts into one place on task side

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14652: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change fix version to 1.11.0 since we already

[jira] [Updated] (FLINK-14551) Unaligned checkpoints

2019-12-09 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-14551: - Fix Version/s: (was: 1.10.0) 1.11.0 > Unaligned checkpoints >

[jira] [Updated] (FLINK-15031) Calculate required shuffle memory before allocating slots if resources are specified

2019-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-15031: Parent: (was: FLINK-14058) Issue Type: Task (was: Sub-task) > Calculate required shuffle

[jira] [Updated] (FLINK-14510) Remove the lazy vertex attaching mechanism from ExecutionGraph

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14510: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change fix version to 1.11.0 since we already

[GitHub] [flink] jinglining commented on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo

2019-12-09 Thread GitBox
jinglining commented on issue #10458: [FLINK-14815][rest]Expose network metric in IOMetricsInfo URL: https://github.com/apache/flink/pull/10458#issuecomment-563888090 @flinkbot run travis This is an automated message from

[jira] [Commented] (FLINK-15159) the string of json is mapped to VARCHAR or STRING?

2019-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992227#comment-16992227 ] Jark Wu commented on FLINK-15159: - Currently, VARCHAR is the same with STRING, they are both alias of

[GitHub] [flink] flinkbot commented on issue #10505: [FLINK-14958][table]ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String

2019-12-09 Thread GitBox
flinkbot commented on issue #10505: [FLINK-14958][table]ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String URL: https://github.com/apache/flink/pull/10505#issuecomment-563887264 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[jira] [Comment Edited] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

2019-12-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992220#comment-16992220 ] Xintong Song edited comment on FLINK-15103 at 12/10/19 6:32 AM: Ok, I

[jira] [Updated] (FLINK-14958) ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String

2019-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14958: --- Labels: pull-request-available (was: ) > ProgramTargetDescriptor#jobID possibly can be of

[GitHub] [flink] AT-Fieldless opened a new pull request #10505: [FLINK-14958][table]ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String

2019-12-09 Thread GitBox
AT-Fieldless opened a new pull request #10505: [FLINK-14958][table]ProgramTargetDescriptor#jobID possibly can be of type JobID instead of String URL: https://github.com/apache/flink/pull/10505 ## What is the purpose of the change ProgramTargetDescriptor#jobID possibly can be of

[GitHub] [flink] flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests URL: https://github.com/apache/flink/pull/10348#issuecomment-559509076 ## CI report: * 54ecee627e7036f4d150aad330b9772406a19494 Travis:

[jira] [Updated] (FLINK-14471) Hide error message when metric api failed

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-14471: -- Fix Version/s: (was: 1.10.0) 1.11.0 Change fix version to 1.11.0 since we already

[jira] [Updated] (FLINK-14953) Parquet table source should use schema type to build FilterPredicate

2019-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14953: --- Labels: pull-request-available (was: ) > Parquet table source should use schema type to

[GitHub] [flink] KurtYoung closed pull request #10371: [FLINK-14953][formats] use table type to build parquet FilterPredicate

2019-12-09 Thread GitBox
KurtYoung closed pull request #10371: [FLINK-14953][formats] use table type to build parquet FilterPredicate URL: https://github.com/apache/flink/pull/10371 This is an automated message from the Apache Git Service. To

[jira] [Assigned] (FLINK-14032) Make the cache size of RocksDBPriorityQueueSetFactory configurable

2019-12-09 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-14032: Assignee: Yun Tang > Make the cache size of RocksDBPriorityQueueSetFactory configurable >

[GitHub] [flink] flinkbot edited a comment on issue #10504: [FLINK-15069][benchmark] Supplement the pipelined shuffle compression case for benchmark

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10504: [FLINK-15069][benchmark] Supplement the pipelined shuffle compression case for benchmark URL: https://github.com/apache/flink/pull/10504#issuecomment-563761500 ## CI report: * 64f397f5a4fdb5cf37119c1251e7a553d5c4da0f Travis:

[jira] [Commented] (FLINK-14392) Introduce JobClient API(FLIP-74)

2019-12-09 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992221#comment-16992221 ] Yu Li commented on FLINK-14392: --- Since we already reached feature freeze, I'm afraid this work (FLIP-74)

[jira] [Commented] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

2019-12-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992220#comment-16992220 ] Xintong Song commented on FLINK-15103: -- Ok, I think I find the cause of the regression. I’ll

[jira] [Commented] (FLINK-15146) The value of `cleanupSize` should be grater than 0 for `IncrementalCleanupStrategy`

2019-12-09 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16992218#comment-16992218 ] hehuiyuan commented on FLINK-15146: --- Hi  [~azagrebin]  , I am pleasure to do this. > The value of

[GitHub] [flink] flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests URL: https://github.com/apache/flink/pull/10348#issuecomment-559509076 ## CI report: * 54ecee627e7036f4d150aad330b9772406a19494 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10504: [FLINK-15069][benchmark] Supplement the pipelined shuffle compression case for benchmark

2019-12-09 Thread GitBox
flinkbot edited a comment on issue #10504: [FLINK-15069][benchmark] Supplement the pipelined shuffle compression case for benchmark URL: https://github.com/apache/flink/pull/10504#issuecomment-563761500 ## CI report: * 64f397f5a4fdb5cf37119c1251e7a553d5c4da0f Travis:

[jira] [Updated] (FLINK-14236) Make LazyFromSourcesSchedulingStrategy do lazy scheduling based on partition state only

2019-12-09 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14236: Fix Version/s: (was: 1.10.0) 1.11.0 > Make LazyFromSourcesSchedulingStrategy do

  1   2   3   4   5   6   7   8   >