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

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

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

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692708#comment-16692708 ] Zhenqiu Huang commented on FLINK-10868: --- [~till.rohrmann] I am working on a fix i

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

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16697677#comment-16697677 ] Zhenqiu Huang commented on FLINK-10868: --- [~suez1224] [~till.rohrmann] Agree with

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

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

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

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

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-11054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16707525#comment-16707525 ] Zhenqiu Huang commented on FLINK-11054: --- [~twalthr] [~fhueske] Agree to Fabian. W

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

[ https://issues.apache.org/jira/browse/FLINK-6693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16022107#comment-16022107 ] Zhenqiu Huang commented on FLINK-6693: -- I am interested with this task. If you haven'

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

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] [Created] (FLINK-7493) Create Pinot Connector

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 Repo

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

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923557#comment-16923557 ] Zhenqiu Huang commented on FLINK-10868: --- [~Anyang1024] I think the request is reas

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

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925023#comment-16925023 ] Zhenqiu Huang commented on FLINK-7151: -- [~phoenixjiangnan][~danny0405] I created a s

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

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925215#comment-16925215 ] Zhenqiu Huang commented on FLINK-7151: -- [~phoenixjiangnan] Please try to access it n

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

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 basic function SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16927928#comment-16927928 ] Zhenqiu Huang commented on FLINK-7151: -- [~fhueske][~phoenixjiangnan] Agree with your

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

[ 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] [Commented] (FLINK-7151) Add a basic function SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930455#comment-16930455 ] Zhenqiu Huang commented on FLINK-7151: -- [~fhueske][~phoenixjiangnan] I just created

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

[ https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931732#comment-16931732 ] Zhenqiu Huang commented on FLINK-14033: --- Agree. It is not for a jar. The issue hap

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

[ https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933057#comment-16933057 ] Zhenqiu Huang commented on FLINK-14033: --- [~trohrmann][~fly_in_gis] Would you pleas

[jira] [Created] (FLINK-14215) Add Docs for TM and JM Environment Variable Setting

Zhenqiu Huang created FLINK-14215: - Summary: Add Docs for TM and JM Environment Variable Setting Key: FLINK-14215 URL: https://issues.apache.org/jira/browse/FLINK-14215 Project: Flink Issue T

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

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16942925#comment-16942925 ] Zhenqiu Huang commented on FLINK-7151: -- [~phoenixjiangnan][~danny0405][~suez1224] Re

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944598#comment-16944598 ] Zhenqiu Huang commented on FLINK-14055: --- [~twalthr] Sure. I can't agree more. I th

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

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944599#comment-16944599 ] Zhenqiu Huang commented on FLINK-7151: -- [~twalthr] Thanks for bringing this up. I jo

[jira] [Comment Edited] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944601#comment-16944601 ] Zhenqiu Huang edited comment on FLINK-14055 at 10/4/19 3:43 PM: --

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944601#comment-16944601 ] Zhenqiu Huang commented on FLINK-14055: --- [~50man] If you already finished the jar

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

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948706#comment-16948706 ] Zhenqiu Huang commented on FLINK-7151: -- [~twalthr][~phoenixjiangnan] I can't agree m

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

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950699#comment-16950699 ] Zhenqiu Huang commented on FLINK-7151: -- [~dian.fu] Thanks for the input. I think lan

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

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952041#comment-16952041 ] Zhenqiu Huang commented on FLINK-7151: -- [~twalthr][~phoenixjiangnan][~jark][~dian.fu

[jira] [Commented] (FLINK-33211) Implement table lineage graph

[ https://issues.apache.org/jira/browse/FLINK-33211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862638#comment-17862638 ] Zhenqiu Huang commented on FLINK-33211: --- PR is merged to upstream > Implement tab

[jira] [Closed] (FLINK-33212) Introduce job status changed listener for lineage

[ https://issues.apache.org/jira/browse/FLINK-33212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang closed FLINK-33212. - Resolution: Done The PR is merged to upstream. > Introduce job status changed listener for line

[jira] [Closed] (FLINK-33211) Implement table lineage graph

[ https://issues.apache.org/jira/browse/FLINK-33211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang closed FLINK-33211. - Resolution: Done The PR is merged to upstream > Implement table lineage graph > ---

[jira] [Created] (FLINK-35745) Add namespace convention doc for Flink lineage

Zhenqiu Huang created FLINK-35745: - Summary: Add namespace convention doc for Flink lineage Key: FLINK-35745 URL: https://issues.apache.org/jira/browse/FLINK-35745 Project: Flink Issue Type:

[jira] [Commented] (FLINK-33244) Not Able To Pass the Configuration On Flink Session

[ https://issues.apache.org/jira/browse/FLINK-33244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818458#comment-17818458 ] Zhenqiu Huang commented on FLINK-33244: --- [~amar1509] Is it still an issue for the

[jira] [Created] (FLINK-34466) Implement Lineage Interface in Kafka Connector

Zhenqiu Huang created FLINK-34466: - Summary: Implement Lineage Interface in Kafka Connector Key: FLINK-34466 URL: https://issues.apache.org/jira/browse/FLINK-34466 Project: Flink Issue Type:

[jira] [Created] (FLINK-34467) Implement Lineage Interface in Jdbc Connector

Zhenqiu Huang created FLINK-34467: - Summary: Implement Lineage Interface in Jdbc Connector Key: FLINK-34467 URL: https://issues.apache.org/jira/browse/FLINK-34467 Project: Flink Issue Type: S

[jira] [Created] (FLINK-34468) Implement Lineage Interface in Cassandra Connector

Zhenqiu Huang created FLINK-34468: - Summary: Implement Lineage Interface in Cassandra Connector Key: FLINK-34468 URL: https://issues.apache.org/jira/browse/FLINK-34468 Project: Flink Issue Ty

[jira] [Created] (FLINK-34657) Implement Lineage Graph for streaming API use cases

Zhenqiu Huang created FLINK-34657: - Summary: Implement Lineage Graph for streaming API use cases Key: FLINK-34657 URL: https://issues.apache.org/jira/browse/FLINK-34657 Project: Flink Issue T

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781841#comment-17781841 ] Zhenqiu Huang commented on FLINK-31275: --- I am recently working Flink with open lin

[jira] [Comment Edited] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781841#comment-17781841 ] Zhenqiu Huang edited comment on FLINK-31275 at 11/1/23 6:23 PM: --

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after recovery from failure in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804840#comment-17804840 ] Zhenqiu Huang commented on FLINK-34007: --- >From initial investigation, the job mana

[jira] [Updated] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-34007: -- Summary: Flink Job stuck in suspend state after losing leadership in HA Mode (was: Flink Job

[jira] [Updated] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-34007: -- Attachment: job-manager.log > Flink Job stuck in suspend state after losing leadership in HA M

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805203#comment-17805203 ] Zhenqiu Huang commented on FLINK-34007: --- I have been investigating the io.fabric8

[jira] [Updated] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-34007: -- Attachment: Debug.log > Flink Job stuck in suspend state after losing leadership in HA Mode >

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805294#comment-17805294 ] Zhenqiu Huang commented on FLINK-34007: --- [~mapohl] Yes, I mistakenly looked into t

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806410#comment-17806410 ] Zhenqiu Huang commented on FLINK-34007: --- [~mapohl] Yes, from the observation on th

[jira] [Updated] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-34007: -- Attachment: LeaderElector-Debug.json > Flink Job stuck in suspend state after losing leadershi

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807017#comment-17807017 ] Zhenqiu Huang commented on FLINK-34007: --- [~mapohl] I am intensively testing flink

[jira] [Comment Edited] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807017#comment-17807017 ] Zhenqiu Huang edited comment on FLINK-34007 at 1/16/24 3:34 AM: --

[jira] [Comment Edited] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807017#comment-17807017 ] Zhenqiu Huang edited comment on FLINK-34007 at 1/16/24 3:40 AM: --

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807486#comment-17807486 ] Zhenqiu Huang commented on FLINK-31275: --- Hi Everyone, I also want to bump the thre

[jira] [Comment Edited] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807486#comment-17807486 ] Zhenqiu Huang edited comment on FLINK-31275 at 1/16/24 10:59 PM: -

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808334#comment-17808334 ] Zhenqiu Huang commented on FLINK-34007: --- [~mapohl] Ack. There are no new observati

[jira] [Created] (FLINK-34250) Add formats options to docs

Zhenqiu Huang created FLINK-34250: - Summary: Add formats options to docs Key: FLINK-34250 URL: https://issues.apache.org/jira/browse/FLINK-34250 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-34007) Flink Job stuck in suspend state after recovery from failure in HA Mode

Zhenqiu Huang created FLINK-34007: - Summary: Flink Job stuck in suspend state after recovery from failure in HA Mode Key: FLINK-34007 URL: https://issues.apache.org/jira/browse/FLINK-34007 Project: Fl

[jira] [Created] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

Zhenqiu Huang created FLINK-35015: - Summary: Flink Parquet Reader doesn't honor parquet configuration Key: FLINK-35015 URL: https://issues.apache.org/jira/browse/FLINK-35015 Project: Flink Is

[jira] [Updated] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

[ https://issues.apache.org/jira/browse/FLINK-35015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-35015: -- Priority: Minor (was: Critical) > Flink Parquet Reader doesn't honor parquet configuration >

[jira] [Commented] (FLINK-35015) Flink Parquet Reader doesn't honor parquet configuration

[ https://issues.apache.org/jira/browse/FLINK-35015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834045#comment-17834045 ] Zhenqiu Huang commented on FLINK-35015: --- After taking deeper look on the code, Avr

[jira] [Created] (FLINK-35925) Remove hive connector from Flink main repo

Zhenqiu Huang created FLINK-35925: - Summary: Remove hive connector from Flink main repo Key: FLINK-35925 URL: https://issues.apache.org/jira/browse/FLINK-35925 Project: Flink Issue Type: Tech

[jira] [Updated] (FLINK-35925) Remove hive connector from Flink main repo

[ https://issues.apache.org/jira/browse/FLINK-35925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-35925: -- Description: Given we have moved hive connector to standalone repo, we should remove the it f

[jira] [Closed] (FLINK-35925) Remove hive connector from Flink main repo

[ https://issues.apache.org/jira/browse/FLINK-35925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang closed FLINK-35925. - Resolution: Duplicate > Remove hive connector from Flink main repo > ---

[jira] [Commented] (FLINK-35925) Remove hive connector from Flink main repo

[ https://issues.apache.org/jira/browse/FLINK-35925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869690#comment-17869690 ] Zhenqiu Huang commented on FLINK-35925: --- [~Weijie Guo] Yes, it is. I think we clo

[jira] [Comment Edited] (FLINK-35925) Remove hive connector from Flink main repo

[ https://issues.apache.org/jira/browse/FLINK-35925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869690#comment-17869690 ] Zhenqiu Huang edited comment on FLINK-35925 at 7/30/24 4:02 PM: --

[jira] [Closed] (FLINK-33211) Implement table lineage graph

[ https://issues.apache.org/jira/browse/FLINK-33211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang closed FLINK-33211. - Resolution: Fixed > Implement table lineage graph > - > >

[jira] [Created] (FLINK-36169) Support namespace level resource check before scaling up

Zhenqiu Huang created FLINK-36169: - Summary: Support namespace level resource check before scaling up Key: FLINK-36169 URL: https://issues.apache.org/jira/browse/FLINK-36169 Project: Flink Is

[jira] [Updated] (FLINK-33212) Introduce job status changed listener for lineage

[ https://issues.apache.org/jira/browse/FLINK-33212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-33212: -- Affects Version/s: 1.20.0 (was: 1.19.0) > Introduce job status chan

[jira] [Commented] (FLINK-34651) The HiveTableSink of Flink does not support writing to S3

[ https://issues.apache.org/jira/browse/FLINK-34651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845177#comment-17845177 ] Zhenqiu Huang commented on FLINK-34651: --- Have you tried to put lib into your Flink

[jira] [Created] (FLINK-35326) Implement lineage interface for hive connector

Zhenqiu Huang created FLINK-35326: - Summary: Implement lineage interface for hive connector Key: FLINK-35326 URL: https://issues.apache.org/jira/browse/FLINK-35326 Project: Flink Issue Type:

[jira] [Updated] (FLINK-33212) Introduce job status changed listener for lineage

[ https://issues.apache.org/jira/browse/FLINK-33212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-33212: -- Description: Introduce job status changed listener relevant interfaces and its implementation.

[jira] [Updated] (FLINK-33212) Introduce job status changed listener for lineage

[ https://issues.apache.org/jira/browse/FLINK-33212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-33212: -- Description: # Introduce job status changed listener relevant interfaces and its implementatio

[jira] [Commented] (FLINK-32777) Upgrade Okhttp version to support IPV6

[ https://issues.apache.org/jira/browse/FLINK-32777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762137#comment-17762137 ] Zhenqiu Huang commented on FLINK-32777: --- [~heywxl] Thanks for the confirmation.

[jira] [Comment Edited] (FLINK-32777) Upgrade Okhttp version to support IPV6

[ https://issues.apache.org/jira/browse/FLINK-32777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762137#comment-17762137 ] Zhenqiu Huang edited comment on FLINK-32777 at 9/7/23 3:52 AM: ---

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772399#comment-17772399 ] Zhenqiu Huang commented on FLINK-31275: --- [~jark] This JIRA is mentioned in FLIP-31

[jira] [Created] (FLINK-33198) Add timestamp with local time zone support in Avro converters

Zhenqiu Huang created FLINK-33198: - Summary: Add timestamp with local time zone support in Avro converters Key: FLINK-33198 URL: https://issues.apache.org/jira/browse/FLINK-33198 Project: Flink

[jira] [Created] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

Zhenqiu Huang created FLINK-33200: - Summary: ItemAt Expression validation fail in Table API due to type mismatch Key: FLINK-33200 URL: https://issues.apache.org/jira/browse/FLINK-33200 Project: Flink

[jira] [Commented] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772723#comment-17772723 ] Zhenqiu Huang commented on FLINK-33200: --- [~lzljs3620320] As StringDataTypeInfo is

[jira] [Commented] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773373#comment-17773373 ] Zhenqiu Huang commented on FLINK-33200: --- We tried both 1.17.1 and 1.18-SNAPSHOT >

[jira] [Updated] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-33200: -- Affects Version/s: 1.17.1 1.18.0 1.18.1 > ItemAt

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775527#comment-17775527 ] Zhenqiu Huang commented on FLINK-31275: --- [~zjureel] We have similar requirements.

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244942#comment-17244942 ] Zhenqiu Huang commented on FLINK-20505: --- It should not be a flink bug. It is just

[jira] [Commented] (FLINK-20461) YARNFileReplicationITCase.testPerJobModeWithDefaultFileReplication

[ https://issues.apache.org/jira/browse/FLINK-20461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244951#comment-17244951 ] Zhenqiu Huang commented on FLINK-20461: --- [~hxbks2ks] I checked in master. Both tes

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247626#comment-17247626 ] Zhenqiu Huang commented on FLINK-20505: --- [~xintongsong] Sorry for the late respons

[jira] [Comment Edited] (FLINK-20505) Yarn provided lib does not work with http paths.

[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247626#comment-17247626 ] Zhenqiu Huang edited comment on FLINK-20505 at 12/11/20, 4:41 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251539#comment-17251539 ] Zhenqiu Huang commented on FLINK-10868: --- Hi [~xintongsong] I just found you comme

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

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252334#comment-17252334 ] Zhenqiu Huang commented on FLINK-10868: --- [~xintongsong] "record the failure for a

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

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252354#comment-17252354 ] Zhenqiu Huang commented on FLINK-10868: --- [~xintongsong] I updated the PR according

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

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252628#comment-17252628 ] Zhenqiu Huang commented on FLINK-10868: --- After looking into the Kubernetes driver

[jira] [Created] (FLINK-20054) 3 Level List is not supported in ParquetInputFormat

Zhenqiu Huang created FLINK-20054: - Summary: 3 Level List is not supported in ParquetInputFormat Key: FLINK-20054 URL: https://issues.apache.org/jira/browse/FLINK-20054 Project: Flink Issue T

[jira] [Commented] (FLINK-20248) `ParquetSchemaConverter` can not convert Array type to parquet Type

[ https://issues.apache.org/jira/browse/FLINK-20248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235717#comment-17235717 ] Zhenqiu Huang commented on FLINK-20248: --- [~zouyunhe] Thanks for reporting the issu

[jira] [Commented] (FLINK-20248) `ParquetSchemaConverter` can not convert Array type to parquet Type

[ https://issues.apache.org/jira/browse/FLINK-20248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17236876#comment-17236876 ] Zhenqiu Huang commented on FLINK-20248: --- [~zouyunhe] I created a PR to fix it. Wou

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17236877#comment-17236877 ] Zhenqiu Huang commented on FLINK-14055: --- [~twalthr] I have some time to work on it

[jira] [Updated] (FLINK-16005) Support yarn and hadoop config override

[ https://issues.apache.org/jira/browse/FLINK-16005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-16005: -- Summary: Support yarn and hadoop config override (was: Propagate yarn.application.classpath

[jira] [Commented] (FLINK-15416) Add Retry Mechanism for PartitionRequestClientFactory.ConnectingChannel

[ https://issues.apache.org/jira/browse/FLINK-15416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068980#comment-17068980 ] Zhenqiu Huang commented on FLINK-15416: --- [~pnowojski] I created a PR would you pl

[jira] [Commented] (FLINK-15416) Add Retry Mechanism for PartitionRequestClientFactory.ConnectingChannel

[ https://issues.apache.org/jira/browse/FLINK-15416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071305#comment-17071305 ] Zhenqiu Huang commented on FLINK-15416: --- [~pnowojski] I updated the PR accordingly

[jira] [Commented] (FLINK-20833) Expose pluggable interface for exception analysis and metrics reporting in Execution Graph

[ https://issues.apache.org/jira/browse/FLINK-20833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266945#comment-17266945 ] Zhenqiu Huang commented on FLINK-20833: --- [~rmetzger] [[~trohrmann]] Thanks for the

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267584#comment-17267584 ] Zhenqiu Huang commented on FLINK-20811: --- [~xintongsong] Thanks for the suggestion.

[jira] [Comment Edited] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267584#comment-17267584 ] Zhenqiu Huang edited comment on FLINK-20811 at 1/19/21, 1:02 AM: -

[jira] [Commented] (FLINK-20833) Expose pluggable interface for exception analysis and metrics reporting in Execution Graph

[ https://issues.apache.org/jira/browse/FLINK-20833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267586#comment-17267586 ] Zhenqiu Huang commented on FLINK-20833: --- [~rmetzger] Thanks for the comments. 1)

[jira] [Commented] (FLINK-20811) Support HTTP paths for yarn ship files/archives

[ https://issues.apache.org/jira/browse/FLINK-20811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267662#comment-17267662 ] Zhenqiu Huang commented on FLINK-20811: --- [~xintongsong] I think we are on the same

[jira] [Created] (FLINK-21107) Move test base classes from flink-tests to flink-test-utils

Zhenqiu Huang created FLINK-21107: - Summary: Move test base classes from flink-tests to flink-test-utils Key: FLINK-21107 URL: https://issues.apache.org/jira/browse/FLINK-21107 Project: Flink

  1   2   3   4   >