[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

[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

[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] [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=17845177#comment-17845177 ] Zhenqiu Huang commented on FLINK-34651: --- Have you tried to put lib into your Flink App uber jar?

[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

[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=17834045#comment-17834045 ] Zhenqiu Huang commented on FLINK-35015: --- After taking deeper look on the code, AvroSchemaConverter

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

[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

[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

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

[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] [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=17818458#comment-17818458 ] Zhenqiu Huang commented on FLINK-33244: --- [~amar1509] Is it still an issue for the latest operator

[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] [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=17808334#comment-17808334 ] Zhenqiu Huang commented on FLINK-34007: --- [~mapohl] Ack. There are no new observations from last 2

[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=17807486#comment-17807486 ] Zhenqiu Huang edited comment on FLINK-31275 at 1/16/24 10:59 PM: - Hi

[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=17807486#comment-17807486 ] Zhenqiu Huang commented on FLINK-31275: --- Hi Everyone, I also want to bump the thread due to the

[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=17807017#comment-17807017 ] Zhenqiu Huang edited comment on FLINK-34007 at 1/16/24 3:40 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=17807017#comment-17807017 ] Zhenqiu Huang edited comment on FLINK-34007 at 1/16/24 3:34 AM:

[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=17807017#comment-17807017 ] Zhenqiu Huang commented on FLINK-34007: --- [~mapohl] I am intensively testing flink 1.18. Within two

[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

[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=17806410#comment-17806410 ] Zhenqiu Huang commented on FLINK-34007: --- [~mapohl] Yes, from the observation on the failure case,

[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=17805294#comment-17805294 ] Zhenqiu Huang commented on FLINK-34007: --- [~mapohl] Yes, I mistakenly looked into the flink 1.17

[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=17805203#comment-17805203 ] Zhenqiu Huang commented on FLINK-34007: --- I have been investigating the

[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

[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] [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=17804840#comment-17804840 ] Zhenqiu Huang commented on FLINK-34007: --- >From initial investigation, the job manager is initially

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

[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=17781841#comment-17781841 ] Zhenqiu Huang edited comment on FLINK-31275 at 11/1/23 6:23 PM: I 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=17781841#comment-17781841 ] Zhenqiu Huang commented on FLINK-31275: --- I am recently working Flink with open lineage

[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=17775527#comment-17775527 ] Zhenqiu Huang commented on FLINK-31275: --- [~zjureel] We have similar requirements. To accelerate

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

[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=17773373#comment-17773373 ] Zhenqiu Huang commented on FLINK-33200: --- We tried both 1.17.1 and 1.18-SNAPSHOT > ItemAt

[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=17772723#comment-17772723 ] Zhenqiu Huang commented on FLINK-33200: --- [~lzljs3620320] As StringDataTypeInfo is the default key

[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] [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] [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=17772399#comment-17772399 ] Zhenqiu Huang commented on FLINK-31275: --- [~jark] This JIRA is mentioned in FLIP-314. Is there

[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=17762137#comment-17762137 ] Zhenqiu Huang edited comment on FLINK-32777 at 9/7/23 3:52 AM: --- [~heywxl]

[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=17762137#comment-17762137 ] Zhenqiu Huang commented on FLINK-32777: --- [~heywxl] Thanks for the confirmation. Given there is

[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=17751882#comment-17751882 ] Zhenqiu Huang commented on FLINK-32777: --- Flink operator is already using the latest stable version

[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=17751880#comment-17751880 ] Zhenqiu Huang commented on FLINK-32777: --- >From the discussion in OKHttp community. The issue is

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

[ https://issues.apache.org/jira/browse/FLINK-32777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-32777: -- Priority: Minor (was: Major) > Upgrade Okhttp version to support IPV6 >

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

Zhenqiu Huang created FLINK-32777: - Summary: Upgrade Okhttp version to support IPV6 Key: FLINK-32777 URL: https://issues.apache.org/jira/browse/FLINK-32777 Project: Flink Issue Type:

[jira] [Updated] (FLINK-32729) allow create an initial deployment with suspend state

[ https://issues.apache.org/jira/browse/FLINK-32729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-32729: -- Description: With this feature, Users could create an application in suspend status as a

[jira] [Created] (FLINK-32729) allow create an initial deployment with suspend state

Zhenqiu Huang created FLINK-32729: - Summary: allow create an initial deployment with suspend state Key: FLINK-32729 URL: https://issues.apache.org/jira/browse/FLINK-32729 Project: Flink

[jira] [Created] (FLINK-32597) Drop Yarn specific get rest endpoints

Zhenqiu Huang created FLINK-32597: - Summary: Drop Yarn specific get rest endpoints Key: FLINK-32597 URL: https://issues.apache.org/jira/browse/FLINK-32597 Project: Flink Issue Type:

[jira] [Commented] (FLINK-31849) Enforce some some simple validation directly through the CRD

[ https://issues.apache.org/jira/browse/FLINK-31849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722435#comment-17722435 ] Zhenqiu Huang commented on FLINK-31849: --- [~gyfora] May I take this? > Enforce some some simple

[jira] [Commented] (FLINK-31998) Flink Operator Deadlock on run job Failure

[ https://issues.apache.org/jira/browse/FLINK-31998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722434#comment-17722434 ] Zhenqiu Huang commented on FLINK-31998: --- [~gyfora] Technically, if a session job is created, it is

[jira] [Created] (FLINK-31947) Enable stdout redirect in flink-console.sh

Zhenqiu Huang created FLINK-31947: - Summary: Enable stdout redirect in flink-console.sh Key: FLINK-31947 URL: https://issues.apache.org/jira/browse/FLINK-31947 Project: Flink Issue Type:

[jira] [Created] (FLINK-31730) Support Ephemeral Storage in KubernetesConfigOptions

Zhenqiu Huang created FLINK-31730: - Summary: Support Ephemeral Storage in KubernetesConfigOptions Key: FLINK-31730 URL: https://issues.apache.org/jira/browse/FLINK-31730 Project: Flink Issue

[jira] [Commented] (FLINK-30609) Add ephemeral storage to CRD

[ https://issues.apache.org/jira/browse/FLINK-30609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708165#comment-17708165 ] Zhenqiu Huang commented on FLINK-30609: --- [~nfraison.datadog] Please review the PR according to the

[jira] [Commented] (FLINK-30609) Add ephemeral storage to CRD

[ https://issues.apache.org/jira/browse/FLINK-30609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708033#comment-17708033 ] Zhenqiu Huang commented on FLINK-30609: --- [~nfraison.datadog] We are glad that you also have the

[jira] [Commented] (FLINK-30363) Disable HadoppConf and Kerboros Decorator by default

[ https://issues.apache.org/jira/browse/FLINK-30363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645924#comment-17645924 ] Zhenqiu Huang commented on FLINK-30363: --- Discussed with [~gyfora] offline, the change will wait

[jira] [Comment Edited] (FLINK-30363) Disable HadoppConf and Kerboros Decorator by default

[ https://issues.apache.org/jira/browse/FLINK-30363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645844#comment-17645844 ] Zhenqiu Huang edited comment on FLINK-30363 at 12/11/22 7:34 PM: -

[jira] [Commented] (FLINK-30363) Disable HadoppConf and Kerboros Decorator by default

[ https://issues.apache.org/jira/browse/FLINK-30363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645844#comment-17645844 ] Zhenqiu Huang commented on FLINK-30363: --- [~gyfora] Would you please assign this jira to me, if

[jira] [Created] (FLINK-30363) Disable HadoppConf and Kerboros Decorator by default

Zhenqiu Huang created FLINK-30363: - Summary: Disable HadoppConf and Kerboros Decorator by default Key: FLINK-30363 URL: https://issues.apache.org/jira/browse/FLINK-30363 Project: Flink Issue

[jira] [Commented] (FLINK-27831) Provide example of Beam on the k8s operator

[ https://issues.apache.org/jira/browse/FLINK-27831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644076#comment-17644076 ] Zhenqiu Huang commented on FLINK-27831: --- [~mbalassi] I am interested with task. Would you please

[jira] [Comment Edited] (FLINK-29655) Split Flink CRD from flink-kubernates-operator module

[ https://issues.apache.org/jira/browse/FLINK-29655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618947#comment-17618947 ] Zhenqiu Huang edited comment on FLINK-29655 at 10/17/22 2:58 PM: -

[jira] [Commented] (FLINK-29655) Split Flink CRD from flink-kubernates-operator module

[ https://issues.apache.org/jira/browse/FLINK-29655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618947#comment-17618947 ] Zhenqiu Huang commented on FLINK-29655: --- [~gyfora] I feel flink-kubernetes-operator-api is more

[jira] [Created] (FLINK-29655) Split Flink CRD from flink-kubernates-operator module

Zhenqiu Huang created FLINK-29655: - Summary: Split Flink CRD from flink-kubernates-operator module Key: FLINK-29655 URL: https://issues.apache.org/jira/browse/FLINK-29655 Project: Flink

[jira] [Commented] (FLINK-29363) Allow web ui to fully redirect to other page

[ https://issues.apache.org/jira/browse/FLINK-29363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17607823#comment-17607823 ] Zhenqiu Huang commented on FLINK-29363: --- Yes, our scenarios is exactly the same as what

[jira] [Created] (FLINK-29363) Allow web ui to fully redirect to other page

Zhenqiu Huang created FLINK-29363: - Summary: Allow web ui to fully redirect to other page Key: FLINK-29363 URL: https://issues.apache.org/jira/browse/FLINK-29363 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-29327) Operator configs are showing up among standard Flink configs

[ https://issues.apache.org/jira/browse/FLINK-29327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17605955#comment-17605955 ] Zhenqiu Huang edited comment on FLINK-29327 at 9/16/22 8:56 PM: It is

[jira] [Commented] (FLINK-29327) Operator configs are showing up among standard Flink configs

[ https://issues.apache.org/jira/browse/FLINK-29327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17605955#comment-17605955 ] Zhenqiu Huang commented on FLINK-29327: --- It is true that it doesn't impact the functionality. But

[jira] [Commented] (FLINK-29327) Operator configs are showing up among standard Flink configs

[ https://issues.apache.org/jira/browse/FLINK-29327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17605919#comment-17605919 ] Zhenqiu Huang commented on FLINK-29327: --- [~matyas] [~bamrabi] I am glad to take this task. >

[jira] [Commented] (FLINK-27660) Table API support create function using customed jar

[ https://issues.apache.org/jira/browse/FLINK-27660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553683#comment-17553683 ] Zhenqiu Huang commented on FLINK-27660: --- [~lsy] Make sense. I have started working on the

[jira] [Commented] (FLINK-27660) Table API support create function using customed jar

[ https://issues.apache.org/jira/browse/FLINK-27660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553282#comment-17553282 ] Zhenqiu Huang commented on FLINK-27660: --- [~lsy] [~jark] Looks like implementation of this jira

[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=17519221#comment-17519221 ] Zhenqiu Huang commented on FLINK-20833: --- [~xtsong] I am rebasing master for my diff. Would you

[jira] [Comment Edited] (FLINK-26539) Support dynamic partial features update in Cassandra connector

[ https://issues.apache.org/jira/browse/FLINK-26539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512063#comment-17512063 ] Zhenqiu Huang edited comment on FLINK-26539 at 3/24/22, 8:31 PM: -

[jira] [Commented] (FLINK-26539) Support dynamic partial features update in Cassandra connector

[ https://issues.apache.org/jira/browse/FLINK-26539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512063#comment-17512063 ] Zhenqiu Huang commented on FLINK-26539: --- [~martijnvisser] [~ym] What jean want to achieve is to

[jira] [Created] (FLINK-26539) Support dynamic partial features update in Cassandra connector

Zhenqiu Huang created FLINK-26539: - Summary: Support dynamic partial features update in Cassandra connector Key: FLINK-26539 URL: https://issues.apache.org/jira/browse/FLINK-26539 Project: Flink

[jira] [Commented] (FLINK-26308) Remove need for flink-operator clusterrole

[ https://issues.apache.org/jira/browse/FLINK-26308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496369#comment-17496369 ] Zhenqiu Huang commented on FLINK-26308: --- [~mbalassi] Are you committing the code to flink repo or

[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=17379272#comment-17379272 ] Zhenqiu Huang commented on FLINK-14055: --- [~gelimusong] In my current test scenario, I am using the

[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=17377488#comment-17377488 ] Zhenqiu Huang commented on FLINK-14055: --- [~frank wang] >From my testing experience for yarn, there

[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=17377072#comment-17377072 ] Zhenqiu Huang commented on FLINK-14055: --- [~gelimusong] Please see the doc I shared. Yes, the

[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=17376830#comment-17376830 ] Zhenqiu Huang commented on FLINK-14055: --- In our internal PoC, we are using the URLClassLoader, so

[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=17376238#comment-17376238 ] Zhenqiu Huang commented on FLINK-14055: --- [~frank wang] Sure. The feature covers many components

[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=17374938#comment-17374938 ] Zhenqiu Huang commented on FLINK-14055: --- [~zhouqi] [~jark] Yes, using the independent classloader

[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=17335080#comment-17335080 ] Zhenqiu Huang commented on FLINK-20833: --- [~rmetzger] [~xintongsong] Would you please help to

[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=17292321#comment-17292321 ] Zhenqiu Huang commented on FLINK-20833: --- [~rmetzger][~trohrmann] I saw you are adding the new

[jira] [Commented] (FLINK-21473) Migrate ParquetInputFormat to BulkFormat interface

[ https://issues.apache.org/jira/browse/FLINK-21473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17290733#comment-17290733 ] Zhenqiu Huang commented on FLINK-21473: --- [~lzljs3620320] According to existing implementation, I

[jira] [Updated] (FLINK-21474) Migrate ParquetTableSource to use DynamicTableSource Interface

[ https://issues.apache.org/jira/browse/FLINK-21474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-21474: -- Summary: Migrate ParquetTableSource to use DynamicTableSource Interface (was: Migrate

[jira] [Updated] (FLINK-21474) Migrate ParquetTableSource to DynamicTable Source Interface

[ https://issues.apache.org/jira/browse/FLINK-21474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-21474: -- Summary: Migrate ParquetTableSource to DynamicTable Source Interface (was: Migrate

[jira] [Updated] (FLINK-21474) Migrate ParquetTableSource to DynamicTableSource Interface

[ https://issues.apache.org/jira/browse/FLINK-21474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-21474: -- Summary: Migrate ParquetTableSource to DynamicTableSource Interface (was: Migrate

[jira] [Created] (FLINK-21474) Migrate FileSystemTableSource to DynamicTable Source Interface

Zhenqiu Huang created FLINK-21474: - Summary: Migrate FileSystemTableSource to DynamicTable Source Interface Key: FLINK-21474 URL: https://issues.apache.org/jira/browse/FLINK-21474 Project: Flink

[jira] [Created] (FLINK-21473) Migrate ParquetInputFormat to BulkFormat interface

Zhenqiu Huang created FLINK-21473: - Summary: Migrate ParquetInputFormat to BulkFormat interface Key: FLINK-21473 URL: https://issues.apache.org/jira/browse/FLINK-21473 Project: Flink Issue

[jira] [Commented] (FLINK-21468) ParquetTableSource: where clause on integer does not work

[ https://issues.apache.org/jira/browse/FLINK-21468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17289185#comment-17289185 ] Zhenqiu Huang commented on FLINK-21468: --- Hi Etienne, It is probably related with predicate push

[jira] [Commented] (FLINK-21389) ParquetInputFormat should not need parquet schema as user input

[ https://issues.apache.org/jira/browse/FLINK-21389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286103#comment-17286103 ] Zhenqiu Huang commented on FLINK-21389: --- [~echauchot] Thanks for reporting this. The context of

[jira] [Commented] (FLINK-21388) Parquet DECIMAL logical type is not properly supported in ParquetSchemaConverter

[ https://issues.apache.org/jira/browse/FLINK-21388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286105#comment-17286105 ] Zhenqiu Huang commented on FLINK-21388: --- [~echauchot] Thanks for reporting this bug. > Parquet

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

[ https://issues.apache.org/jira/browse/FLINK-20461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285035#comment-17285035 ] Zhenqiu Huang commented on FLINK-20461: --- [~trohrmann][~dwysakowicz] I am not able to reproduce

[jira] [Commented] (FLINK-21139) ThresholdMeterTest.testMarkMultipleEvents unstable

[ https://issues.apache.org/jira/browse/FLINK-21139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275963#comment-17275963 ] Zhenqiu Huang commented on FLINK-21139: --- [~xintongsong] Make sense. Just created the PR. Please

[jira] [Commented] (FLINK-21139) ThresholdMeterTest.testMarkMultipleEvents unstable

[ https://issues.apache.org/jira/browse/FLINK-21139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17275780#comment-17275780 ] Zhenqiu Huang commented on FLINK-21139: --- [~trohrmann] [~xintongsong] The ManualClock is defined in

[jira] [Commented] (FLINK-21139) ThresholdMeterTest.testMarkMultipleEvents unstable

[ https://issues.apache.org/jira/browse/FLINK-21139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272297#comment-17272297 ] Zhenqiu Huang commented on FLINK-21139: --- [~trohrmann] Sure. Please assign it to me to fix it

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

[ https://issues.apache.org/jira/browse/FLINK-21107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang closed FLINK-21107. - Resolution: Won't Fix > Move test base classes from flink-tests to flink-test-utils >

[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

[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=17267662#comment-17267662 ] Zhenqiu Huang commented on FLINK-20811: --- [~xintongsong] I think we are on the same page. If

[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=17267586#comment-17267586 ] Zhenqiu Huang commented on FLINK-20833: --- [~rmetzger] Thanks for the comments. 1) I added comments

[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=17267584#comment-17267584 ] Zhenqiu Huang edited comment on FLINK-20811 at 1/19/21, 1:02 AM: -

[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=17267584#comment-17267584 ] Zhenqiu Huang commented on FLINK-20811: --- [~xintongsong] Thanks for the suggestion. One of my team

  1   2   3   >