[jira] [Created] (FLINK-34460) Jdbc driver get rid of flink-core

Fang Yong created FLINK-34460: - Summary: Jdbc driver get rid of flink-core Key: FLINK-34460 URL: https://issues.apache.org/jira/browse/FLINK-34460 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-34090) Introduce SerializerConfig for serialization

Fang Yong created FLINK-34090: - Summary: Introduce SerializerConfig for serialization Key: FLINK-34090 URL: https://issues.apache.org/jira/browse/FLINK-34090 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34037) FLIP-398: Improve Serialization Configuration And Usage In Flink

Fang Yong created FLINK-34037: - Summary: FLIP-398: Improve Serialization Configuration And Usage In Flink Key: FLINK-34037 URL: https://issues.apache.org/jira/browse/FLINK-34037 Project: Flink

[jira] [Created] (FLINK-33626) Wrong style in flink ui

Fang Yong created FLINK-33626: - Summary: Wrong style in flink ui Key: FLINK-33626 URL: https://issues.apache.org/jira/browse/FLINK-33626 Project: Flink Issue Type: Bug Components:

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

Fang Yong created FLINK-33212: - Summary: Introduce job status changed listener for lineage Key: FLINK-33212 URL: https://issues.apache.org/jira/browse/FLINK-33212 Project: Flink Issue Type:

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

Fang Yong created FLINK-33211: - Summary: Implement table lineage graph Key: FLINK-33211 URL: https://issues.apache.org/jira/browse/FLINK-33211 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33210) Introduce lineage graph relevant interfaces

Fang Yong created FLINK-33210: - Summary: Introduce lineage graph relevant interfaces Key: FLINK-33210 URL: https://issues.apache.org/jira/browse/FLINK-33210 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33033) Add haservice micro benchmark for olap

Fang Yong created FLINK-33033: - Summary: Add haservice micro benchmark for olap Key: FLINK-33033 URL: https://issues.apache.org/jira/browse/FLINK-33033 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32968) Update doc for customized catalog listener

Fang Yong created FLINK-32968: - Summary: Update doc for customized catalog listener Key: FLINK-32968 URL: https://issues.apache.org/jira/browse/FLINK-32968 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-32749) Sql gateway supports default catalog loaded by CatalogStore

Fang Yong created FLINK-32749: - Summary: Sql gateway supports default catalog loaded by CatalogStore Key: FLINK-32749 URL: https://issues.apache.org/jira/browse/FLINK-32749 Project: Flink Issue

[jira] [Created] (FLINK-32747) Support ddl for catalog from CatalogStore

Fang Yong created FLINK-32747: - Summary: Support ddl for catalog from CatalogStore Key: FLINK-32747 URL: https://issues.apache.org/jira/browse/FLINK-32747 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32676) Add doc for catalog modification listener

Fang Yong created FLINK-32676: - Summary: Add doc for catalog modification listener Key: FLINK-32676 URL: https://issues.apache.org/jira/browse/FLINK-32676 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

Fang Yong created FLINK-32667: - Summary: Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster Key: FLINK-32667 URL: https://issues.apache.org/jira/browse/FLINK-32667

[jira] [Created] (FLINK-32665) Support read null value for csv format

Fang Yong created FLINK-32665: - Summary: Support read null value for csv format Key: FLINK-32665 URL: https://issues.apache.org/jira/browse/FLINK-32665 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-32643) Introduce off-heap shared state cache across stateful operators in TM

Fang Yong created FLINK-32643: - Summary: Introduce off-heap shared state cache across stateful operators in TM Key: FLINK-32643 URL: https://issues.apache.org/jira/browse/FLINK-32643 Project: Flink

[jira] [Created] (FLINK-32633) Kubernetes e2e test is not stable

Fang Yong created FLINK-32633: - Summary: Kubernetes e2e test is not stable Key: FLINK-32633 URL: https://issues.apache.org/jira/browse/FLINK-32633 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-32622) Do not add mini-batch assigner operator if it is useless

Fang Yong created FLINK-32622: - Summary: Do not add mini-batch assigner operator if it is useless Key: FLINK-32622 URL: https://issues.apache.org/jira/browse/FLINK-32622 Project: Flink Issue

[jira] [Created] (FLINK-32512) SHOW JARS should not show the jars for temporary function

Fang Yong created FLINK-32512: - Summary: SHOW JARS should not show the jars for temporary function Key: FLINK-32512 URL: https://issues.apache.org/jira/browse/FLINK-32512 Project: Flink Issue

[jira] [Created] (FLINK-32407) Notify catalog listener for table events

Fang Yong created FLINK-32407: - Summary: Notify catalog listener for table events Key: FLINK-32407 URL: https://issues.apache.org/jira/browse/FLINK-32407 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32406) Notify catalog listener for database events

Fang Yong created FLINK-32406: - Summary: Notify catalog listener for database events Key: FLINK-32406 URL: https://issues.apache.org/jira/browse/FLINK-32406 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32405) Initialize catalog listener for CatalogManager

Fang Yong created FLINK-32405: - Summary: Initialize catalog listener for CatalogManager Key: FLINK-32405 URL: https://issues.apache.org/jira/browse/FLINK-32405 Project: Flink Issue Type:

[jira] [Created] (FLINK-32404) Introduce catalog modification listener and factory interfaces

Fang Yong created FLINK-32404: - Summary: Introduce catalog modification listener and factory interfaces Key: FLINK-32404 URL: https://issues.apache.org/jira/browse/FLINK-32404 Project: Flink

[jira] [Created] (FLINK-32403) Add database related operations in catalog manager

Fang Yong created FLINK-32403: - Summary: Add database related operations in catalog manager Key: FLINK-32403 URL: https://issues.apache.org/jira/browse/FLINK-32403 Project: Flink Issue Type:

[jira] [Created] (FLINK-32402) FLIP-294: Support Customized Catalog Modification Listener

Fang Yong created FLINK-32402: - Summary: FLIP-294: Support Customized Catalog Modification Listener Key: FLINK-32402 URL: https://issues.apache.org/jira/browse/FLINK-32402 Project: Flink Issue

[jira] [Created] (FLINK-32396) Support timestamp for jdbc driver and gateway

Fang Yong created FLINK-32396: - Summary: Support timestamp for jdbc driver and gateway Key: FLINK-32396 URL: https://issues.apache.org/jira/browse/FLINK-32396 Project: Flink Issue Type:

[jira] [Created] (FLINK-32343) Fix exception for jdbc tools

Fang Yong created FLINK-32343: - Summary: Fix exception for jdbc tools Key: FLINK-32343 URL: https://issues.apache.org/jira/browse/FLINK-32343 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-32332) Jar files for catalog function are not listed correctly

Fang Yong created FLINK-32332: - Summary: Jar files for catalog function are not listed correctly Key: FLINK-32332 URL: https://issues.apache.org/jira/browse/FLINK-32332 Project: Flink Issue

[jira] [Created] (FLINK-32309) Shared classpaths and jars manager for jobs in sql gateway cause confliction

Fang Yong created FLINK-32309: - Summary: Shared classpaths and jars manager for jobs in sql gateway cause confliction Key: FLINK-32309 URL: https://issues.apache.org/jira/browse/FLINK-32309 Project:

[jira] [Created] (FLINK-32300) Support get object for result set

Fang Yong created FLINK-32300: - Summary: Support get object for result set Key: FLINK-32300 URL: https://issues.apache.org/jira/browse/FLINK-32300 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-32265) Use default classloader in jobmanager when there are no user jars for job

Fang Yong created FLINK-32265: - Summary: Use default classloader in jobmanager when there are no user jars for job Key: FLINK-32265 URL: https://issues.apache.org/jira/browse/FLINK-32265 Project: Flink

[jira] [Created] (FLINK-32213) Add get off heap buffer in memory segment

Fang Yong created FLINK-32213: - Summary: Add get off heap buffer in memory segment Key: FLINK-32213 URL: https://issues.apache.org/jira/browse/FLINK-32213 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-32211) Supports row format in ExecutorImpl for jdbc driver

Fang Yong created FLINK-32211: - Summary: Supports row format in ExecutorImpl for jdbc driver Key: FLINK-32211 URL: https://issues.apache.org/jira/browse/FLINK-32211 Project: Flink Issue Type:

[jira] [Created] (FLINK-32129) Filesystem connector is not compatible with option 'pipeline.generic-types'

Fang Yong created FLINK-32129: - Summary: Filesystem connector is not compatible with option 'pipeline.generic-types' Key: FLINK-32129 URL: https://issues.apache.org/jira/browse/FLINK-32129 Project: Flink

[jira] [Created] (FLINK-32118) Support customized listener during task manager startup

Fang Yong created FLINK-32118: - Summary: Support customized listener during task manager startup Key: FLINK-32118 URL: https://issues.apache.org/jira/browse/FLINK-32118 Project: Flink Issue

[jira] [Created] (FLINK-32042) Support customized exec node graph processor for planner

Fang Yong created FLINK-32042: - Summary: Support customized exec node graph processor for planner Key: FLINK-32042 URL: https://issues.apache.org/jira/browse/FLINK-32042 Project: Flink Issue

[jira] [Created] (FLINK-31801) Missing elasticsearch connector on maven central repository

Fang Yong created FLINK-31801: - Summary: Missing elasticsearch connector on maven central repository Key: FLINK-31801 URL: https://issues.apache.org/jira/browse/FLINK-31801 Project: Flink

[jira] [Created] (FLINK-31741) Supports data conversion according to type for executor

Fang Yong created FLINK-31741: - Summary: Supports data conversion according to type for executor Key: FLINK-31741 URL: https://issues.apache.org/jira/browse/FLINK-31741 Project: Flink Issue

[jira] [Created] (FLINK-31687) Flink jdbc driver get rid of flink core

Fang Yong created FLINK-31687: - Summary: Flink jdbc driver get rid of flink core Key: FLINK-31687 URL: https://issues.apache.org/jira/browse/FLINK-31687 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31668) Gateway should close select query when session is timeout

Fang Yong created FLINK-31668: - Summary: Gateway should close select query when session is timeout Key: FLINK-31668 URL: https://issues.apache.org/jira/browse/FLINK-31668 Project: Flink Issue

[jira] [Created] (FLINK-31606) Translate "sqlClient.md" page of "table" into Chinese

Fang Yong created FLINK-31606: - Summary: Translate "sqlClient.md" page of "table" into Chinese Key: FLINK-31606 URL: https://issues.apache.org/jira/browse/FLINK-31606 Project: Flink Issue Type:

[jira] [Created] (FLINK-31556) Translate "rest" page of "sql-gateway" into Chinese

Fang Yong created FLINK-31556: - Summary: Translate "rest" page of "sql-gateway" into Chinese Key: FLINK-31556 URL: https://issues.apache.org/jira/browse/FLINK-31556 Project: Flink Issue Type:

[jira] [Created] (FLINK-31555) Translate "hiveserver2" page of "sql-gateway" into Chinese

Fang Yong created FLINK-31555: - Summary: Translate "hiveserver2" page of "sql-gateway" into Chinese Key: FLINK-31555 URL: https://issues.apache.org/jira/browse/FLINK-31555 Project: Flink Issue

[jira] [Created] (FLINK-31554) Translate "Overview" page of "sql-gateway" into Chinese

Fang Yong created FLINK-31554: - Summary: Translate "Overview" page of "sql-gateway" into Chinese Key: FLINK-31554 URL: https://issues.apache.org/jira/browse/FLINK-31554 Project: Flink Issue

[jira] [Created] (FLINK-31549) Add doc for jdbc driver

Fang Yong created FLINK-31549: - Summary: Add doc for jdbc driver Key: FLINK-31549 URL: https://issues.apache.org/jira/browse/FLINK-31549 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-31548) Introduce FlinkDataSource for jdbc driver

Fang Yong created FLINK-31548: - Summary: Introduce FlinkDataSource for jdbc driver Key: FLINK-31548 URL: https://issues.apache.org/jira/browse/FLINK-31548 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31547) Introduce FlinkResultSetMetaData for jdbc driver

Fang Yong created FLINK-31547: - Summary: Introduce FlinkResultSetMetaData for jdbc driver Key: FLINK-31547 URL: https://issues.apache.org/jira/browse/FLINK-31547 Project: Flink Issue Type:

[jira] [Created] (FLINK-31546) Add column info and management for sql jdbc

Fang Yong created FLINK-31546: - Summary: Add column info and management for sql jdbc Key: FLINK-31546 URL: https://issues.apache.org/jira/browse/FLINK-31546 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31545) FlinkConnection creates and manages statements

Fang Yong created FLINK-31545: - Summary: FlinkConnection creates and manages statements Key: FLINK-31545 URL: https://issues.apache.org/jira/browse/FLINK-31545 Project: Flink Issue Type:

[jira] [Created] (FLINK-31544) Introduce FlinkDatabaseMetaData for jdbc driver

Fang Yong created FLINK-31544: - Summary: Introduce FlinkDatabaseMetaData for jdbc driver Key: FLINK-31544 URL: https://issues.apache.org/jira/browse/FLINK-31544 Project: Flink Issue Type:

[jira] [Created] (FLINK-31543) Introduce FlinkStatement for jdbc driver

Fang Yong created FLINK-31543: - Summary: Introduce FlinkStatement for jdbc driver Key: FLINK-31543 URL: https://issues.apache.org/jira/browse/FLINK-31543 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-31538) Supports parse catalog/database and properties for uri

Fang Yong created FLINK-31538: - Summary: Supports parse catalog/database and properties for uri Key: FLINK-31538 URL: https://issues.apache.org/jira/browse/FLINK-31538 Project: Flink Issue Type:

[jira] [Created] (FLINK-31523) Merge query files and processing in sql client and gateway

Fang Yong created FLINK-31523: - Summary: Merge query files and processing in sql client and gateway Key: FLINK-31523 URL: https://issues.apache.org/jira/browse/FLINK-31523 Project: Flink Issue

[jira] [Created] (FLINK-31522) Introduce FlinkResultSet and related classes for jdbc driver

Fang Yong created FLINK-31522: - Summary: Introduce FlinkResultSet and related classes for jdbc driver Key: FLINK-31522 URL: https://issues.apache.org/jira/browse/FLINK-31522 Project: Flink

[jira] [Created] (FLINK-31521) Initialize flink jdbc driver module in flink-table

Fang Yong created FLINK-31521: - Summary: Initialize flink jdbc driver module in flink-table Key: FLINK-31521 URL: https://issues.apache.org/jira/browse/FLINK-31521 Project: Flink Issue Type:

[jira] [Created] (FLINK-31496) FLIP-293: Introduce Flink Jdbc Driver For Sql Gateway

Fang Yong created FLINK-31496: - Summary: FLIP-293: Introduce Flink Jdbc Driver For Sql Gateway Key: FLINK-31496 URL: https://issues.apache.org/jira/browse/FLINK-31496 Project: Flink Issue Type:

[jira] [Created] (FLINK-7941) Port SubtasksTimesHandler to new REST endpoint

Fang Yong created FLINK-7941: Summary: Port SubtasksTimesHandler to new REST endpoint Key: FLINK-7941 URL: https://issues.apache.org/jira/browse/FLINK-7941 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7857) Port JobVertexDetails to REST endpoint

Fang Yong created FLINK-7857: Summary: Port JobVertexDetails to REST endpoint Key: FLINK-7857 URL: https://issues.apache.org/jira/browse/FLINK-7857 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7858) Port JobVertexTaskManagersHandler to REST endpoint

Fang Yong created FLINK-7858: Summary: Port JobVertexTaskManagersHandler to REST endpoint Key: FLINK-7858 URL: https://issues.apache.org/jira/browse/FLINK-7858 Project: Flink Issue Type:

[jira] [Created] (FLINK-7856) Port JobVertexBackPressureHandler to REST endpoint

Fang Yong created FLINK-7856: Summary: Port JobVertexBackPressureHandler to REST endpoint Key: FLINK-7856 URL: https://issues.apache.org/jira/browse/FLINK-7856 Project: Flink Issue Type:

[jira] [Created] (FLINK-7855) Port JobVertexAccumulatorsHandler to REST endpoint

Fang Yong created FLINK-7855: Summary: Port JobVertexAccumulatorsHandler to REST endpoint Key: FLINK-7855 URL: https://issues.apache.org/jira/browse/FLINK-7855 Project: Flink Issue Type:

[jira] [Created] (FLINK-7222) Kafka010ITCase fails on windows

Fang Yong created FLINK-7222: Summary: Kafka010ITCase fails on windows Key: FLINK-7222 URL: https://issues.apache.org/jira/browse/FLINK-7222 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-7010) Lamdba expression in flatMap throws InvalidTypesException in DataSet

Fang Yong created FLINK-7010: Summary: Lamdba expression in flatMap throws InvalidTypesException in DataSet Key: FLINK-7010 URL: https://issues.apache.org/jira/browse/FLINK-7010 Project: Flink

[jira] [Created] (FLINK-6366) KafkaConsumer is not closed in FlinkKafkaConsumer09

Fang Yong created FLINK-6366: Summary: KafkaConsumer is not closed in FlinkKafkaConsumer09 Key: FLINK-6366 URL: https://issues.apache.org/jira/browse/FLINK-6366 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

Fang Yong created FLINK-6352: Summary: FlinkKafkaConsumer should support to use timestamp to set up start offset Key: FLINK-6352 URL: https://issues.apache.org/jira/browse/FLINK-6352 Project: Flink