[jira] [Created] (FLINK-7179) Projectable ProjectableTableSource interface doesn't compatible with BoundedOutOfOrdernessTimestampExtractor

2017-07-13 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-7179: Summary: Projectable ProjectableTableSource interface doesn't compatible with BoundedOutOfOrdernessTimestampExtractor Key: FLINK-7179 URL:

[jira] [Updated] (FLINK-7179) ProjectableTableSource interface doesn't compatible with BoundedOutOfOrdernessTimestampExtractor

2017-07-13 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-7179: - Summary: ProjectableTableSource interface doesn't compatible with

[jira] [Assigned] (FLINK-7179) ProjectableTableSource interface doesn't compatible with BoundedOutOfOrdernessTimestampExtractor

2017-07-25 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang reassigned FLINK-7179: Assignee: Zhenqiu Huang > ProjectableTableSource interface doesn't compatible with >

[jira] [Created] (FLINK-7493) Create Pinot Connector

2017-08-22 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-7493: Summary: Create Pinot Connector Key: FLINK-7493 URL: https://issues.apache.org/jira/browse/FLINK-7493 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-7492) Memsql Connector

2017-08-22 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-7492: Summary: Memsql Connector Key: FLINK-7492 URL: https://issues.apache.org/jira/browse/FLINK-7492 Project: Flink Issue Type: New Feature Reporter:

[jira] [Commented] (FLINK-6693) Support DATE_FORMAT function in the SQL API

2017-05-23 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022107#comment-16022107 ] Zhenqiu Huang commented on FLINK-6693: -- I am interested with this task. If you haven't started work

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-08-02 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567546#comment-16567546 ] Zhenqiu Huang commented on FLINK-7243: -- [~najman] [~nssalian] I created a diff for the task. After

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-08-02 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567824#comment-16567824 ] Zhenqiu Huang commented on FLINK-7243: -- [~najman] [~nssalian] Created a pull request

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-07-31 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564753#comment-16564753 ] Zhenqiu Huang commented on FLINK-7243: -- [~najman] I am adding some ITTest tonight. Will create the

[jira] [Comment Edited] (FLINK-7243) Add ParquetInputFormat

2018-08-07 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16567824#comment-16567824 ] Zhenqiu Huang edited comment on FLINK-7243 at 8/7/18 7:45 PM: -- [~najman]

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-07-08 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16536525#comment-16536525 ] Zhenqiu Huang commented on FLINK-7243: -- [~nssalian]  We already have a working version on

[jira] [Assigned] (FLINK-7243) Add ParquetInputFormat

2018-04-18 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang reassigned FLINK-7243: Assignee: Zhenqiu Huang (was: godfrey he) > Add ParquetInputFormat >

[jira] [Assigned] (FLINK-7244) Add ParquetTableSource Implementation based on ParquetInputFormat

2018-04-18 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang reassigned FLINK-7244: Assignee: Zhenqiu Huang > Add ParquetTableSource Implementation based on

[jira] [Commented] (FLINK-10729) Create a Hive a connector to access Hive data

2018-10-30 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16669528#comment-16669528 ] Zhenqiu Huang commented on FLINK-10729: --- Hi Xuefu, I am interested with this Task, Would you

[jira] [Assigned] (FLINK-10729) Create a Hive a connector to access Hive data

2018-10-30 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang reassigned FLINK-10729: - Assignee: Zhenqiu Huang > Create a Hive a connector to access Hive data >

[jira] [Commented] (FLINK-10729) Create a Hive connector for Hive data access in Flink

2018-11-01 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16672530#comment-16672530 ] Zhenqiu Huang commented on FLINK-10729: --- [~xuefuz] Agree. If you want to use native formats in

[jira] [Created] (FLINK-10868) Flink's Yarn ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

2018-11-13 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-10868: - Summary: Flink's Yarn ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement Key: FLINK-10868 URL:

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

2019-01-14 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16742763#comment-16742763 ] Zhenqiu Huang commented on FLINK-10868: --- [~till.rohrmann] When I test the PR in production, i

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

2018-12-22 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16727294#comment-16727294 ] Zhenqiu Huang commented on FLINK-10868: --- I like this idea. It is pretty clean. After failSlot in

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

2018-12-24 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16728594#comment-16728594 ] Zhenqiu Huang commented on FLINK-10868: --- [~till.rohrmann] [~gjy] Would you please have a look my

[jira] [Assigned] (FLINK-11054) Ingest Long value as TIMESTAMP attribute

2018-12-03 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang reassigned FLINK-11054: - Assignee: Zhenqiu Huang > Ingest Long value as TIMESTAMP attribute >

[jira] [Commented] (FLINK-11054) Ingest Long value as TIMESTAMP attribute

2018-12-03 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16707525#comment-16707525 ] Zhenqiu Huang commented on FLINK-11054: --- [~twalthr] [~fhueske] Agree to Fabian. We met this issue

[jira] [Commented] (FLINK-10868) Flink's Yarn ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

2018-11-23 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16697677#comment-16697677 ] Zhenqiu Huang commented on FLINK-10868: --- [~suez1224] [~till.rohrmann] Agree with Shuyi's

[jira] [Comment Edited] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

2018-11-24 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16697677#comment-16697677 ] Zhenqiu Huang edited comment on FLINK-10868 at 11/24/18 5:48 PM: -

[jira] [Updated] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

2018-11-24 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-10868: -- Summary: Flink's JobCluster ResourceManager doesn't use yarn.maximum-failed-containers as

[jira] [Updated] (FLINK-10868) Flink's Yarn ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

2018-11-19 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-10868: -- Description: Currently, YarnResourceManager does use  yarn.maximum-failed-containers as limit

[jira] [Commented] (FLINK-10868) Flink's Yarn ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement

2018-11-19 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692708#comment-16692708 ] Zhenqiu Huang commented on FLINK-10868: --- [~till.rohrmann] I am working on a fix in

[jira] [Updated] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use maximum-failed-containers as limit of resource acquirement

2019-01-25 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-10868: -- Component/s: Mesos Summary: Flink's JobCluster ResourceManager doesn't use

[jira] [Commented] (FLINK-7244) Add ParquetTableSource Implementation based on ParquetInputFormat

2019-03-27 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802982#comment-16802982 ] Zhenqiu Huang commented on FLINK-7244: -- [~yanghua] Just created PR. Feel free to add comments to

[jira] [Commented] (FLINK-9607) Support ParquetTableSink

2019-03-27 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803361#comment-16803361 ] Zhenqiu Huang commented on FLINK-9607: -- [~yanghua][~guibopan] Are you working on this? If so, I

[jira] [Commented] (FLINK-9607) Support ParquetTableSink

2019-03-27 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803590#comment-16803590 ] Zhenqiu Huang commented on FLINK-9607: -- [~yanghua] [~guibopan] OK, I am recently working on this

[jira] [Commented] (FLINK-11910) Make Yarn Application Type Customizable with Flink Version

2019-03-14 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792787#comment-16792787 ] Zhenqiu Huang commented on FLINK-11910: --- !Screen Shot 2019-03-14 at 8.17.18 AM.png! Verified end

[jira] [Updated] (FLINK-11910) Make Yarn Application Type Customizable with Flink Version

2019-03-14 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-11910: -- Attachment: Screen Shot 2019-03-14 at 8.17.18 AM.png > Make Yarn Application Type

[jira] [Created] (FLINK-11910) Make Yarn Application Type Customizable with Flink Version

2019-03-13 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-11910: - Summary: Make Yarn Application Type Customizable with Flink Version Key: FLINK-11910 URL: https://issues.apache.org/jira/browse/FLINK-11910 Project: Flink

[jira] [Commented] (FLINK-7244) Add ParquetTableSource Implementation based on ParquetInputFormat

2019-03-22 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16799083#comment-16799083 ] Zhenqiu Huang commented on FLINK-7244: -- [~yanghua] I am adding more test cases. Will have an

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use maximum-failed-containers as limit of resource acquirement

2019-02-16 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16770134#comment-16770134 ] Zhenqiu Huang commented on FLINK-10868: --- @tillrohrmann I tested the PR end to end in production.

[jira] [Commented] (FLINK-11521) Make RetryingRegistration timeouts configurable

2019-02-02 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16759102#comment-16759102 ] Zhenqiu Huang commented on FLINK-11521: --- [~till.rohrmann] Can I take this? > Make

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use maximum-failed-containers as limit of resource acquirement

2019-02-02 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16759111#comment-16759111 ] Zhenqiu Huang commented on FLINK-10868: --- [~till.rohrmann] Thanks for reviewing the PR. According

[jira] [Assigned] (FLINK-12124) Security is not support dynamicProperties

2019-04-08 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang reassigned FLINK-12124: - Assignee: Zhenqiu Huang > Security is not support dynamicProperties >

[jira] [Commented] (FLINK-12124) Security is not support dynamicProperties

2019-04-08 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16812739#comment-16812739 ] Zhenqiu Huang commented on FLINK-12124: --- [~zhouqi] I have simliar requirement in our org. Will

[jira] [Comment Edited] (FLINK-10912) Configurable RocksDBStateBackend options factory

2019-03-15 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793600#comment-16793600 ] Zhenqiu Huang edited comment on FLINK-10912 at 3/15/19 12:59 PM: - Can

[jira] [Commented] (FLINK-10912) Configurable RocksDBStateBackend options factory

2019-03-15 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793600#comment-16793600 ] Zhenqiu Huang commented on FLINK-10912: --- Can this feature be used in Flink 1.6 release? >

[jira] [Updated] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-04-29 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-12342: -- Attachment: container.log > Yarn Resource Manager Acquires Too Many Containers >

[jira] [Commented] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-04-29 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829009#comment-16829009 ] Zhenqiu Huang commented on FLINK-12342: --- [^container.log] [~till.rohrmann] As the full log is

[jira] [Commented] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-04-30 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830875#comment-16830875 ] Zhenqiu Huang commented on FLINK-12342: --- [~till.rohrmann] After reading the AMRMAsynclient, I just

[jira] [Commented] (FLINK-12343) Allow set file.replication in Yarn Configuration

2019-04-30 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830362#comment-16830362 ] Zhenqiu Huang commented on FLINK-12343: --- [~till.rohrmann] I agree that we shouldn't define a

[jira] [Commented] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-05-02 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16831427#comment-16831427 ] Zhenqiu Huang commented on FLINK-12342: --- As using the config and set it to 3000 milliseconds, the

[jira] [Updated] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-04-29 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-12342: -- Attachment: Screen Shot 2019-04-29 at 12.06.23 AM.png > Yarn Resource Manager Acquires Too

[jira] [Commented] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-04-29 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829614#comment-16829614 ] Zhenqiu Huang commented on FLINK-12342: --- !flink-1.4.png! !flink-1.6.png! [~till.rohrmann] This

[jira] [Updated] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-04-29 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-12342: -- Attachment: flink-1.6.png flink-1.4.png > Yarn Resource Manager Acquires Too

[jira] [Commented] (FLINK-12343) Allow set file.replication in Yarn Configuration

2019-04-30 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830330#comment-16830330 ] Zhenqiu Huang commented on FLINK-12343: --- [~till.rohrmann][~rmetzger] I think we can set the

[jira] [Assigned] (FLINK-12440) Add all connector support align Java Table API

2019-05-07 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang reassigned FLINK-12440: - Assignee: Zhenqiu Huang > Add all connector support align Java Table API >

[jira] [Assigned] (FLINK-12440) Add all connector support align Java Table API

2019-05-07 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang reassigned FLINK-12440: - Assignee: sunjincheng (was: Zhenqiu Huang) > Add all connector support align Java

[jira] [Commented] (FLINK-12343) Allow set hdfs.replication in FlinkYarnSessionCli

2019-04-27 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827782#comment-16827782 ] Zhenqiu Huang commented on FLINK-12343: --- [~rmetzger] I think configuration option should be

[jira] [Updated] (FLINK-12343) Allow set hdfs.replication in Yarn Configuration

2019-04-27 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-12343: -- Summary: Allow set hdfs.replication in Yarn Configuration (was: Allow set hdfs.replication

[jira] [Commented] (FLINK-12343) Allow set hdfs.replication in Yarn Configuration

2019-04-28 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827997#comment-16827997 ] Zhenqiu Huang commented on FLINK-12343: --- It can be set by in both way. Here is to set the bigger

[jira] [Updated] (FLINK-12343) Allow set file.replication in Yarn Configuration

2019-04-28 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-12343: -- Summary: Allow set file.replication in Yarn Configuration (was: Allow set hdfs.replication

[jira] [Commented] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-04-28 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16827993#comment-16827993 ] Zhenqiu Huang commented on FLINK-12342: --- [~till.rohrmann] The job that has the issue tries to

[jira] [Updated] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-04-26 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-12342: -- Environment: We runs job in Flink release 1.6.3. Description: In currently

[jira] [Created] (FLINK-12342) Yarn Resource Manager Acquire Too Many Containers

2019-04-26 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-12342: - Summary: Yarn Resource Manager Acquire Too Many Containers Key: FLINK-12342 URL: https://issues.apache.org/jira/browse/FLINK-12342 Project: Flink Issue

[jira] [Updated] (FLINK-12342) Yarn Resource Manager Acquires Too Many Containers

2019-04-26 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-12342: -- Summary: Yarn Resource Manager Acquires Too Many Containers (was: Yarn Resource Manager

[jira] [Created] (FLINK-12343) Allow set hdfs.replication in FlinkYarnSessionCli

2019-04-26 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-12343: - Summary: Allow set hdfs.replication in FlinkYarnSessionCli Key: FLINK-12343 URL: https://issues.apache.org/jira/browse/FLINK-12343 Project: Flink Issue

[jira] [Closed] (FLINK-7244) Add ParquetTableSource Implementation based on ParquetInputFormat

2019-07-10 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang closed FLINK-7244. Resolution: Implemented Fix Version/s: 1.9.0 Release Note:

[jira] [Commented] (FLINK-13132) Allow ClusterEntrypoints use user main method to generate job graph

2019-07-08 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880502#comment-16880502 ] Zhenqiu Huang commented on FLINK-13132: --- [~maguowei] [~till.rohrmann] The reason I want to

[jira] [Commented] (FLINK-13132) Allow ClusterEntrypoints use user main method to generate job graph

2019-07-07 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16879947#comment-16879947 ] Zhenqiu Huang commented on FLINK-13132: --- [~yunta] Yes, you are right. I updated the description

[jira] [Updated] (FLINK-13132) Allow ClusterEntrypoints use user main method to generate job graph

2019-07-07 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-13132: -- Description: We are building a service that can transparently deploy a job to different

[jira] [Commented] (FLINK-13132) Allow ClusterEntrypoints use user main method to generate job graph

2019-07-14 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884819#comment-16884819 ] Zhenqiu Huang commented on FLINK-13132: --- [~fly_in_gis] Our concern of the cost is mainly on the

[jira] [Commented] (FLINK-13132) Allow ClusterEntrypoints use user main method to generate job graph

2019-07-14 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884822#comment-16884822 ] Zhenqiu Huang commented on FLINK-13132: --- [~maguowei] For your questions, I think you are mainly

[jira] [Commented] (FLINK-7244) Add ParquetTableSource Implementation based on ParquetInputFormat

2019-04-23 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824178#comment-16824178 ] Zhenqiu Huang commented on FLINK-7244: -- [~fhueske] I just finished the first around of revision by

[jira] [Commented] (FLINK-7493) Create Pinot Connector

2019-04-23 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824194#comment-16824194 ] Zhenqiu Huang commented on FLINK-7493: -- [~rmetzger] I am going to close the ticket. Most of the

[jira] [Closed] (FLINK-7493) Create Pinot Connector

2019-04-23 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang closed FLINK-7493. Resolution: Invalid > Create Pinot Connector > -- > > Key:

[jira] [Commented] (FLINK-7151) Add a function SQL DDL

2019-08-22 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913959#comment-16913959 ] Zhenqiu Huang commented on FLINK-7151: -- [~phoenixjiangnan] As it is already in AthenaX. We would

[jira] [Commented] (FLINK-7151) Add a function SQL DDL

2019-08-24 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16914838#comment-16914838 ] Zhenqiu Huang commented on FLINK-7151: -- [~phoenixjiangnan]Sure. Thanks for the suggestion. I will

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use maximum-failed-containers as limit of resource acquirement

2019-09-05 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923557#comment-16923557 ] Zhenqiu Huang commented on FLINK-10868: --- [~Anyang1024] I think the request is reasonable from my

[jira] [Commented] (FLINK-7151) Add a basic function SQL DDL

2019-09-11 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16927928#comment-16927928 ] Zhenqiu Huang commented on FLINK-7151: -- [~fhueske][~phoenixjiangnan] Agree with your suggestions. I

[jira] [Updated] (FLINK-7151) Add a basic function SQL DDL

2019-09-15 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-7151: - Description: Based on create function and table.we can register a udf,udaf,udtf use sql: {code}

[jira] [Created] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode

2019-09-09 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-14033: - Summary: Distributed caches are not registered in Yarn Per Job Cluster Mode Key: FLINK-14033 URL: https://issues.apache.org/jira/browse/FLINK-14033 Project: Flink

[jira] [Commented] (FLINK-7151) Add a function SQL DDL

2019-09-07 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16925023#comment-16925023 ] Zhenqiu Huang commented on FLINK-7151: -- [~phoenixjiangnan][~danny0405] I created a small doc for the

[jira] [Commented] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode

2019-09-17 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931732#comment-16931732 ] Zhenqiu Huang commented on FLINK-14033: --- Agree. It is not for a jar. The issue happens on another

[jira] [Commented] (FLINK-7151) Add a basic function SQL DDL

2019-09-16 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16930455#comment-16930455 ] Zhenqiu Huang commented on FLINK-7151: -- [~fhueske][~phoenixjiangnan] I just created an initial

[jira] [Commented] (FLINK-7151) Add a function SQL DDL

2019-09-08 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16925215#comment-16925215 ] Zhenqiu Huang commented on FLINK-7151: -- [~phoenixjiangnan] Please try to access it now. > Add a

[jira] [Commented] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode

2019-09-18 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933057#comment-16933057 ] Zhenqiu Huang commented on FLINK-14033: --- [~trohrmann][~fly_in_gis] Would you please take a look at

[jira] [Updated] (FLINK-13132) Allow JobClusterEntrypoints use user main method to generate job graph

2019-07-17 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-13132: -- Summary: Allow JobClusterEntrypoints use user main method to generate job graph (was: Allow

[jira] [Commented] (FLINK-13132) Allow ClusterEntrypoints use user main method to generate job graph

2019-07-15 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885834#comment-16885834 ] Zhenqiu Huang commented on FLINK-13132: --- [~till.rohrmann] Would you please take a look the

[jira] [Commented] (FLINK-7151) Add a basic function SQL DDL

2019-10-02 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16942925#comment-16942925 ] Zhenqiu Huang commented on FLINK-7151: -- [~phoenixjiangnan][~danny0405][~suez1224] Resolved comments

[jira] [Created] (FLINK-13132) Allow ClusterEntrypoints use user main method to generate job graph

2019-07-06 Thread Zhenqiu Huang (JIRA)
Zhenqiu Huang created FLINK-13132: - Summary: Allow ClusterEntrypoints use user main method to generate job graph Key: FLINK-13132 URL: https://issues.apache.org/jira/browse/FLINK-13132 Project: Flink

[jira] [Commented] (FLINK-14711) Create Alter Function and Show Functions DDL

2019-11-16 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16975932#comment-16975932 ] Zhenqiu Huang commented on FLINK-14711: --- [~Terry1897] [~phoenixjiangnan] [~xuefuz] Please this PR.

[jira] [Commented] (FLINK-7151) Add a basic function SQL DDL

2019-11-16 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16975904#comment-16975904 ] Zhenqiu Huang commented on FLINK-7151: -- [~Terry1897] [~phoenixjiangnan] [~xuefuz] Would you please

[jira] [Created] (FLINK-14837) Support Function DDL in TableEnvironment

2019-11-18 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-14837: - Summary: Support Function DDL in TableEnvironment Key: FLINK-14837 URL: https://issues.apache.org/jira/browse/FLINK-14837 Project: Flink Issue Type:

[jira] [Updated] (FLINK-7151) Add create and drop function DDL in SQL Parser

2019-11-18 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-7151: - Summary: Add create and drop function DDL in SQL Parser (was: Add a basic function SQL DDL) >

[jira] [Updated] (FLINK-14711) Add Alter Function and Show Functions in SQL Parser

2019-11-18 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-14711: -- Summary: Add Alter Function and Show Functions in SQL Parser (was: Create Alter Function and

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

2019-11-18 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-7151: - Summary: Support function DDL (was: Add create and drop function DDL in SQL Parser) > Support

[jira] [Created] (FLINK-14841) Add create and drop function DDL in parser

2019-11-18 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-14841: - Summary: Add create and drop function DDL in parser Key: FLINK-14841 URL: https://issues.apache.org/jira/browse/FLINK-14841 Project: Flink Issue Type:

[jira] [Commented] (FLINK-14841) Add create and drop function DDL in parser

2019-11-18 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976689#comment-16976689 ] Zhenqiu Huang commented on FLINK-14841: --- [~dwysakowicz] [~rmetzger] It is a sub ticket of support

[jira] [Updated] (FLINK-14841) Add create and drop function DDL in parser

2019-11-18 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-14841: -- Labels: table-api (was: ) > Add create and drop function DDL in parser >

[jira] [Commented] (FLINK-14841) Add create and drop function DDL in parser

2019-11-18 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976692#comment-16976692 ] Zhenqiu Huang commented on FLINK-14841: --- The PR for this ticket

[jira] [Comment Edited] (FLINK-14841) Add create and drop function DDL in parser

2019-11-18 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976692#comment-16976692 ] Zhenqiu Huang edited comment on FLINK-14841 at 11/18/19 5:06 PM: - The PR

[jira] [Updated] (FLINK-14906) Add function related method in CatalogManager

2019-11-21 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-14906: -- Description: 1) Add a temporary function hashmap to store temporary functions 2) Add create,

[jira] [Created] (FLINK-14906) Add function related method in CatalogManager

2019-11-21 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-14906: - Summary: Add function related method in CatalogManager Key: FLINK-14906 URL: https://issues.apache.org/jira/browse/FLINK-14906 Project: Flink Issue Type:

[jira] [Updated] (FLINK-14906) Add function related method in CatalogManager

2019-11-21 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-14906: -- Description: 1) Add a temporary function hashmap to store temporary functions 2) Add create,

  1   2   3   >