[jira] [Created] (FLINK-37081) The debezium version of sqlserver cdc needs to be upgraded to 2.6 or higher

2025-01-08 Thread zhang (Jira)
zhang created FLINK-37081: - Summary: The debezium version of sqlserver cdc needs to be upgraded to 2.6 or higher Key: FLINK-37081 URL: https://issues.apache.org/jira/browse/FLINK-37081 Project: Flink

[jira] [Created] (FLINK-36635) PhysicalSlotRequestBulkImpl is not used and can be removed

2024-10-30 Thread Yi Zhang (Jira)
Yi Zhang created FLINK-36635: Summary: PhysicalSlotRequestBulkImpl is not used and can be removed Key: FLINK-36635 URL: https://issues.apache.org/jira/browse/FLINK-36635 Project: Flink Issue Type

[jira] [Created] (FLINK-36599) Correct the name of the config which enables response codes group

2024-10-24 Thread Alan Zhang (Jira)
Alan Zhang created FLINK-36599: -- Summary: Correct the name of the config which enables response codes group Key: FLINK-36599 URL: https://issues.apache.org/jira/browse/FLINK-36599 Project: Flink

[jira] [Created] (FLINK-35332) Manually setting rest.bind-address does not work for Flink running on Hadoop Yarn dual network environment

2024-05-13 Thread Yao Zhang (Jira)
Yao Zhang created FLINK-35332: - Summary: Manually setting rest.bind-address does not work for Flink running on Hadoop Yarn dual network environment Key: FLINK-35332 URL: https://issues.apache.org/jira/browse/FLINK-353

[jira] [Created] (FLINK-35279) Support "last-state" upgrade mode for FlinkSessionJob

2024-04-30 Thread Alan Zhang (Jira)
Alan Zhang created FLINK-35279: -- Summary: Support "last-state" upgrade mode for FlinkSessionJob Key: FLINK-35279 URL: https://issues.apache.org/jira/browse/FLINK-35279 Project: Flink Issue Type

[jira] [Created] (FLINK-35219) [Flink SQL]Support deserialize json string into Map

2024-04-23 Thread zhihao zhang (Jira)
zhihao zhang created FLINK-35219: Summary: [Flink SQL]Support deserialize json string into Map Key: FLINK-35219 URL: https://issues.apache.org/jira/browse/FLINK-35219 Project: Flink Issue Typ

[jira] [Created] (FLINK-34618) Migrate SplitPythonConditionFromJoinRule

2024-03-07 Thread Yongming Zhang (Jira)
Yongming Zhang created FLINK-34618: -- Summary: Migrate SplitPythonConditionFromJoinRule Key: FLINK-34618 URL: https://issues.apache.org/jira/browse/FLINK-34618 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-27 Thread Lyn Zhang (Jira)
Lyn Zhang created FLINK-33670: - Summary: Public operators cannot be reused in multi sinks Key: FLINK-33670 URL: https://issues.apache.org/jira/browse/FLINK-33670 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

2023-10-24 Thread zhang (Jira)
zhang created FLINK-33355: - Summary: can't reduce the parallelism from 'n' to '1' when recovering through a savepoint. Key: FLINK-33355 URL: https://issues.apache.org/jira/browse/FLINK-33355 Project: Flink

[jira] [Created] (FLINK-33127) HeapKeyedStateBackend: use buffered I/O to speed up local recovery

2023-09-20 Thread Yangyang ZHANG (Jira)
Yangyang ZHANG created FLINK-33127: -- Summary: HeapKeyedStateBackend: use buffered I/O to speed up local recovery Key: FLINK-33127 URL: https://issues.apache.org/jira/browse/FLINK-33127 Project: Flink

[jira] [Created] (FLINK-33112) Support placement constraint

2023-09-18 Thread Junfan Zhang (Jira)
Junfan Zhang created FLINK-33112: Summary: Support placement constraint Key: FLINK-33112 URL: https://issues.apache.org/jira/browse/FLINK-33112 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-33090) CheckpointsCleaner clean individual checkpoint states in parallel

2023-09-14 Thread Yi Zhang (Jira)
Yi Zhang created FLINK-33090: Summary: CheckpointsCleaner clean individual checkpoint states in parallel Key: FLINK-33090 URL: https://issues.apache.org/jira/browse/FLINK-33090 Project: Flink Is

[jira] [Created] (FLINK-32969) IfCallGen Bug

2023-08-27 Thread Lyn Zhang (Jira)
Lyn Zhang created FLINK-32969: - Summary: IfCallGen Bug Key: FLINK-32969 URL: https://issues.apache.org/jira/browse/FLINK-32969 Project: Flink Issue Type: Bug Reporter: Lyn Zhang

[jira] [Created] (FLINK-32819) flink can not parse the param `#` correctly in k8s application mode

2023-08-09 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-32819: - Summary: flink can not parse the param `#` correctly in k8s application mode Key: FLINK-32819 URL: https://issues.apache.org/jira/browse/FLINK-32819 Project: Flink

[jira] [Created] (FLINK-32740) Introduce literal null value for flink-conf.yaml

2023-08-03 Thread Yao Zhang (Jira)
Yao Zhang created FLINK-32740: - Summary: Introduce literal null value for flink-conf.yaml Key: FLINK-32740 URL: https://issues.apache.org/jira/browse/FLINK-32740 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-32598) Spill data from feedback edge to disk to avoid possible OOM

2023-07-17 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-32598: - Summary: Spill data from feedback edge to disk to avoid possible OOM Key: FLINK-32598 URL: https://issues.apache.org/jira/browse/FLINK-32598 Project: Flink

[jira] [Created] (FLINK-32293) Support vector with long index

2023-06-08 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-32293: - Summary: Support vector with long index Key: FLINK-32293 URL: https://issues.apache.org/jira/browse/FLINK-32293 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-32292) TableUtils.getRowTypeInfo fails to get type information of Tuple

2023-06-08 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-32292: - Summary: TableUtils.getRowTypeInfo fails to get type information of Tuple Key: FLINK-32292 URL: https://issues.apache.org/jira/browse/FLINK-32292 Project: Flink

[jira] [Created] (FLINK-31910) Using BroadcastUtils#withBroadcast in iteration perround mode got stuck

2023-04-24 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31910: - Summary: Using BroadcastUtils#withBroadcast in iteration perround mode got stuck Key: FLINK-31910 URL: https://issues.apache.org/jira/browse/FLINK-31910 Project: Fl

[jira] [Created] (FLINK-31909) Using BroadcastUtils#withBroadcast in iteration perround mode got stuck

2023-04-24 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31909: - Summary: Using BroadcastUtils#withBroadcast in iteration perround mode got stuck Key: FLINK-31909 URL: https://issues.apache.org/jira/browse/FLINK-31909 Project: Fl

[jira] [Created] (FLINK-31903) Caching records fails in BroadcastUtils#withBroadcastStream

2023-04-24 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31903: - Summary: Caching records fails in BroadcastUtils#withBroadcastStream Key: FLINK-31903 URL: https://issues.apache.org/jira/browse/FLINK-31903 Project: Flink

[jira] [Created] (FLINK-31901) AbstractBroadcastWrapperOperator should not block checkpoint barriers when processing cached records

2023-04-23 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31901: - Summary: AbstractBroadcastWrapperOperator should not block checkpoint barriers when processing cached records Key: FLINK-31901 URL: https://issues.apache.org/jira/browse/FLINK-3

[jira] [Created] (FLINK-31732) flink-ml-uber module should include statefun as a dependency

2023-04-04 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31732: - Summary: flink-ml-uber module should include statefun as a dependency Key: FLINK-31732 URL: https://issues.apache.org/jira/browse/FLINK-31732 Project: Flink

[jira] [Created] (FLINK-31667) Should not enforce attached mode in RemoteEnvironment & RemoteStreamEnvironment

2023-03-29 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-31667: -- Summary: Should not enforce attached mode in RemoteEnvironment & RemoteStreamEnvironment Key: FLINK-31667 URL: https://issues.apache.org/jira/browse/FLINK-31667 Project:

[jira] [Created] (FLINK-31603) Line break should be removed in create table with-clauses, load module with-clauses and table hints for both keys and values

2023-03-23 Thread Yao Zhang (Jira)
Yao Zhang created FLINK-31603: - Summary: Line break should be removed in create table with-clauses, load module with-clauses and table hints for both keys and values Key: FLINK-31603 URL: https://issues.apache.org/jir

[jira] [Created] (FLINK-31459) add UPDATE COLUMN POSITION for flink table store

2023-03-14 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-31459: - Summary: add UPDATE COLUMN POSITION for flink table store Key: FLINK-31459 URL: https://issues.apache.org/jira/browse/FLINK-31459 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-31410) ListStateWithCache Should support incremental snapshot

2023-03-12 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31410: - Summary: ListStateWithCache Should support incremental snapshot Key: FLINK-31410 URL: https://issues.apache.org/jira/browse/FLINK-31410 Project: Flink Issu

[jira] [Created] (FLINK-31374) ProxyStreamPartitioner should implement ConfigurableStreamPartitioner

2023-03-08 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31374: - Summary: ProxyStreamPartitioner should implement ConfigurableStreamPartitioner Key: FLINK-31374 URL: https://issues.apache.org/jira/browse/FLINK-31374 Project: Flin

[jira] [Created] (FLINK-31373) PerRoundWrapperOperator should carry epoch information in watermark

2023-03-08 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31373: - Summary: PerRoundWrapperOperator should carry epoch information in watermark Key: FLINK-31373 URL: https://issues.apache.org/jira/browse/FLINK-31373 Project: Flink

[jira] [Created] (FLINK-31338) support infer parallelism for flink table store

2023-03-06 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-31338: - Summary: support infer parallelism for flink table store Key: FLINK-31338 URL: https://issues.apache.org/jira/browse/FLINK-31338 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-31276) VectorIndexerTest#testFitAndPredictWithHandleInvalid fails

2023-03-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31276: - Summary: VectorIndexerTest#testFitAndPredictWithHandleInvalid fails Key: FLINK-31276 URL: https://issues.apache.org/jira/browse/FLINK-31276 Project: Flink

[jira] [Created] (FLINK-31258) can not get kerberos keytab in flink operator

2023-02-28 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-31258: - Summary: can not get kerberos keytab in flink operator Key: FLINK-31258 URL: https://issues.apache.org/jira/browse/FLINK-31258 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31255) OperatorUtils#createWrappedOperatorConfig fails to wrap operator config

2023-02-28 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31255: - Summary: OperatorUtils#createWrappedOperatorConfig fails to wrap operator config Key: FLINK-31255 URL: https://issues.apache.org/jira/browse/FLINK-31255 Project: Fl

[jira] [Created] (FLINK-31224) Add metrics for flink table store

2023-02-25 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-31224: - Summary: Add metrics for flink table store Key: FLINK-31224 URL: https://issues.apache.org/jira/browse/FLINK-31224 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31212) Data lost if window group after interval left join

2023-02-24 Thread Lyn Zhang (Jira)
Lyn Zhang created FLINK-31212: - Summary: Data lost if window group after interval left join Key: FLINK-31212 URL: https://issues.apache.org/jira/browse/FLINK-31212 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31191) VectorIndexer should check whether doublesByColumn is null before snapshot

2023-02-22 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31191: - Summary: VectorIndexer should check whether doublesByColumn is null before snapshot Key: FLINK-31191 URL: https://issues.apache.org/jira/browse/FLINK-31191 Project:

[jira] [Created] (FLINK-31173) TailOperator should only have one input

2023-02-21 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31173: - Summary: TailOperator should only have one input Key: FLINK-31173 URL: https://issues.apache.org/jira/browse/FLINK-31173 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31170) The spelling error of the document word causes sql to fail to execute

2023-02-21 Thread BoYi Zhang (Jira)
BoYi Zhang created FLINK-31170: -- Summary: The spelling error of the document word causes sql to fail to execute Key: FLINK-31170 URL: https://issues.apache.org/jira/browse/FLINK-31170 Project: Flink

[jira] [Created] (FLINK-31160) Support join/cogroup in BroadcastUtils.withBroadcastStream

2023-02-20 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-31160: - Summary: Support join/cogroup in BroadcastUtils.withBroadcastStream Key: FLINK-31160 URL: https://issues.apache.org/jira/browse/FLINK-31160 Project: Flink

[jira] [Created] (FLINK-31128) Add Create Table As for flink table store

2023-02-19 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-31128: - Summary: Add Create Table As for flink table store Key: FLINK-31128 URL: https://issues.apache.org/jira/browse/FLINK-31128 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31028) Provide different compression methods for per level

2023-02-12 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-31028: - Summary: Provide different compression methods for per level Key: FLINK-31028 URL: https://issues.apache.org/jira/browse/FLINK-31028 Project: Flink Issue Type: New

[jira] [Created] (FLINK-31011) upgrade hiverunner version

2023-02-10 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-31011: - Summary: upgrade hiverunner version Key: FLINK-31011 URL: https://issues.apache.org/jira/browse/FLINK-31011 Project: Flink Issue Type: Improvement Compon

[jira] [Created] (FLINK-30933) Result of join inside iterationBody loses max watermark

2023-02-06 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-30933: - Summary: Result of join inside iterationBody loses max watermark Key: FLINK-30933 URL: https://issues.apache.org/jira/browse/FLINK-30933 Project: Flink Iss

[jira] [Created] (FLINK-30871) add bloom filter for orc

2023-02-01 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-30871: - Summary: add bloom filter for orc Key: FLINK-30871 URL: https://issues.apache.org/jira/browse/FLINK-30871 Project: Flink Issue Type: Improvement Compone

[jira] [Created] (FLINK-30671) Add AlgoOperator for ClusteringEvaluator

2023-01-12 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-30671: - Summary: Add AlgoOperator for ClusteringEvaluator Key: FLINK-30671 URL: https://issues.apache.org/jira/browse/FLINK-30671 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-30608) support rename table

2023-01-09 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-30608: - Summary: support rename table Key: FLINK-30608 URL: https://issues.apache.org/jira/browse/FLINK-30608 Project: Flink Issue Type: Improvement Reporter:

[jira] [Created] (FLINK-30595) support create table like

2023-01-06 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-30595: - Summary: support create table like Key: FLINK-30595 URL: https://issues.apache.org/jira/browse/FLINK-30595 Project: Flink Issue Type: Improvement Repor

[jira] [Created] (FLINK-30566) Add benchmark configurations for agglomerativeclustering, hashingtf, idf, kbinsdiscretizer, linearregression, linearsvc, logisticregression, ngram, regextokenizer, toke

2023-01-04 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-30566: - Summary: Add benchmark configurations for agglomerativeclustering, hashingtf, idf, kbinsdiscretizer, linearregression, linearsvc, logisticregression, ngram, regextokenizer, tokenizer and vectorindexer

[jira] [Created] (FLINK-30541) Add Transformer and Estimator for OnlineStandardScaler

2023-01-02 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-30541: - Summary: Add Transformer and Estimator for OnlineStandardScaler Key: FLINK-30541 URL: https://issues.apache.org/jira/browse/FLINK-30541 Project: Flink Issu

[jira] [Created] (FLINK-30524) Unify the style of the logs page

2022-12-28 Thread Yongming Zhang (Jira)
Yongming Zhang created FLINK-30524: -- Summary: Unify the style of the logs page Key: FLINK-30524 URL: https://issues.apache.org/jira/browse/FLINK-30524 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30505) Close the connection between TM and JM when task executor failed

2022-12-26 Thread Yongming Zhang (Jira)
Yongming Zhang created FLINK-30505: -- Summary: Close the connection between TM and JM when task executor failed Key: FLINK-30505 URL: https://issues.apache.org/jira/browse/FLINK-30505 Project: Flink

[jira] [Created] (FLINK-30451) Add Estimator and Transformer for Swing

2022-12-18 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-30451: - Summary: Add Estimator and Transformer for Swing Key: FLINK-30451 URL: https://issues.apache.org/jira/browse/FLINK-30451 Project: Flink Issue Type: New Fea

[jira] [Created] (FLINK-30434) The non-null check for transactionalIdPrefix is unnecessary in the KafkaWriter constructor

2022-12-16 Thread Zhengqi Zhang (Jira)
Zhengqi Zhang created FLINK-30434: - Summary: The non-null check for transactionalIdPrefix is unnecessary in the KafkaWriter constructor Key: FLINK-30434 URL: https://issues.apache.org/jira/browse/FLINK-30434

[jira] [Created] (FLINK-30347) Connecting SqlGateway via beeline gets java.lang.UnsupportedOperationException:: Unrecognized TGetInfoType value: CLI_ODBC_KEYWORDS

2022-12-08 Thread Yao Zhang (Jira)
Yao Zhang created FLINK-30347: - Summary: Connecting SqlGateway via beeline gets java.lang.UnsupportedOperationException:: Unrecognized TGetInfoType value: CLI_ODBC_KEYWORDS Key: FLINK-30347 URL: https://issues.apache

[jira] [Created] (FLINK-30287) Configmaps get cleaned up when upgrading standalone Flink cluster

2022-12-02 Thread Steven Zhang (Jira)
Steven Zhang created FLINK-30287: Summary: Configmaps get cleaned up when upgrading standalone Flink cluster Key: FLINK-30287 URL: https://issues.apache.org/jira/browse/FLINK-30287 Project: Flink

[jira] [Created] (FLINK-30249) TableUtils.getRowTypeInfo() creating wrong TypeInformation

2022-11-30 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-30249: - Summary: TableUtils.getRowTypeInfo() creating wrong TypeInformation Key: FLINK-30249 URL: https://issues.apache.org/jira/browse/FLINK-30249 Project: Flink

[jira] [Created] (FLINK-29911) Improve performance of AgglomerativeClustering

2022-11-06 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29911: - Summary: Improve performance of AgglomerativeClustering Key: FLINK-29911 URL: https://issues.apache.org/jira/browse/FLINK-29911 Project: Flink Issue Type:

[jira] [Created] (FLINK-29824) AgglomerativeClustering fails when the distanceThreshold is very large

2022-10-31 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29824: - Summary: AgglomerativeClustering fails when the distanceThreshold is very large Key: FLINK-29824 URL: https://issues.apache.org/jira/browse/FLINK-29824 Project: Fli

[jira] [Created] (FLINK-29696) [Doc] Operator helm install command points to wrong repo

2022-10-19 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-29696: --- Summary: [Doc] Operator helm install command points to wrong repo Key: FLINK-29696 URL: https://issues.apache.org/jira/browse/FLINK-29696 Project: Flink Issue

[jira] [Created] (FLINK-29390) Pulsar SQL Connector: SQLClient E2E testing

2022-09-22 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-29390: --- Summary: Pulsar SQL Connector: SQLClient E2E testing Key: FLINK-29390 URL: https://issues.apache.org/jira/browse/FLINK-29390 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-29358) Pulsar Table Connector testing

2022-09-20 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-29358: --- Summary: Pulsar Table Connector testing Key: FLINK-29358 URL: https://issues.apache.org/jira/browse/FLINK-29358 Project: Flink Issue Type: Sub-task C

[jira] [Created] (FLINK-29359) Pulsar Table Connector pom config and packaging

2022-09-20 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-29359: --- Summary: Pulsar Table Connector pom config and packaging Key: FLINK-29359 URL: https://issues.apache.org/jira/browse/FLINK-29359 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-29360) Pulsar Table Connector Documentation

2022-09-20 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-29360: --- Summary: Pulsar Table Connector Documentation Key: FLINK-29360 URL: https://issues.apache.org/jira/browse/FLINK-29360 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29356) Pulsar Table Source code :implementation

2022-09-20 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-29356: --- Summary: Pulsar Table Source code :implementation Key: FLINK-29356 URL: https://issues.apache.org/jira/browse/FLINK-29356 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29357) Pulsar Table Sink code: implementation

2022-09-20 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-29357: --- Summary: Pulsar Table Sink code: implementation Key: FLINK-29357 URL: https://issues.apache.org/jira/browse/FLINK-29357 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29176) Add python source/test for ChiSqTest

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29176: - Summary: Add python source/test for ChiSqTest Key: FLINK-29176 URL: https://issues.apache.org/jira/browse/FLINK-29176 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-29175) Add documents for AgglomerativeClustering, KbinsCretizer, ChisquaredTest, VectorIndexer, Tokenizer, RegexTokenizer, IDF

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29175: - Summary: Add documents for AgglomerativeClustering, KbinsCretizer, ChisquaredTest, VectorIndexer, Tokenizer, RegexTokenizer, IDF Key: FLINK-29175 URL: https://issues.apache.org/

[jira] [Created] (FLINK-29174) Add document for ML algorithms

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29174: - Summary: Add document for ML algorithms Key: FLINK-29174 URL: https://issues.apache.org/jira/browse/FLINK-29174 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29172) Add built-in string_split function.

2022-09-01 Thread Yongming Zhang (Jira)
Yongming Zhang created FLINK-29172: -- Summary: Add built-in string_split function. Key: FLINK-29172 URL: https://issues.apache.org/jira/browse/FLINK-29172 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-29170) Add Transformer and Estimator for VarianceThresholdSelector

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29170: - Summary: Add Transformer and Estimator for VarianceThresholdSelector Key: FLINK-29170 URL: https://issues.apache.org/jira/browse/FLINK-29170 Project: Flink

[jira] [Created] (FLINK-29169) Add Transformer and Estimator for UnivariateFeatureSelector

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29169: - Summary: Add Transformer and Estimator for UnivariateFeatureSelector Key: FLINK-29169 URL: https://issues.apache.org/jira/browse/FLINK-29169 Project: Flink

[jira] [Created] (FLINK-29168) Add Transformer for NGram

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29168: - Summary: Add Transformer for NGram Key: FLINK-29168 URL: https://issues.apache.org/jira/browse/FLINK-29168 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-29128) Uncatch IllegalStateException found when log split changes handling result in KafkaPartitionSplitReader

2022-08-29 Thread Leo zhang (Jira)
Leo zhang created FLINK-29128: - Summary: Uncatch IllegalStateException found when log split changes handling result in KafkaPartitionSplitReader Key: FLINK-29128 URL: https://issues.apache.org/jira/browse/FLINK-29128

[jira] [Created] (FLINK-28906) Add AlgoOperator for AgglomerativeClustering

2022-08-10 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28906: - Summary: Add AlgoOperator for AgglomerativeClustering Key: FLINK-28906 URL: https://issues.apache.org/jira/browse/FLINK-28906 Project: Flink Issue Type: Ne

[jira] [Created] (FLINK-28806) Add Estimator and Transformer for IDF

2022-08-04 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28806: - Summary: Add Estimator and Transformer for IDF Key: FLINK-28806 URL: https://issues.apache.org/jira/browse/FLINK-28806 Project: Flink Issue Type: New Featu

[jira] [Created] (FLINK-28805) Add Transformer for HashingTF

2022-08-04 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28805: - Summary: Add Transformer for HashingTF Key: FLINK-28805 URL: https://issues.apache.org/jira/browse/FLINK-28805 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28803) Add Transformer and Estimator for KBinsDiscretizer

2022-08-04 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28803: - Summary: Add Transformer and Estimator for KBinsDiscretizer Key: FLINK-28803 URL: https://issues.apache.org/jira/browse/FLINK-28803 Project: Flink Issue Ty

[jira] [Created] (FLINK-28741) Unexpected result if insert 'false' to boolean column

2022-07-29 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-28741: -- Summary: Unexpected result if insert 'false' to boolean column Key: FLINK-28741 URL: https://issues.apache.org/jira/browse/FLINK-28741 Project: Flink Issue Type:

[jira] [Created] (FLINK-28739) Illegal State for checkpoint in LogisticRegressionTest.test_get_model_data

2022-07-29 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28739: - Summary: Illegal State for checkpoint in LogisticRegressionTest.test_get_model_data Key: FLINK-28739 URL: https://issues.apache.org/jira/browse/FLINK-28739 Project

[jira] [Created] (FLINK-28684) NullPointerException at OneHotEncoder.GenerateModelDataOperator.snapshot

2022-07-25 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28684: - Summary: NullPointerException at OneHotEncoder.GenerateModelDataOperator.snapshot Key: FLINK-28684 URL: https://issues.apache.org/jira/browse/FLINK-28684 Project: F

[jira] [Created] (FLINK-28635) HybridSourceReader availabilityFuture always completed

2022-07-21 Thread hongfei zhang (Jira)
hongfei zhang created FLINK-28635: - Summary: HybridSourceReader availabilityFuture always completed Key: FLINK-28635 URL: https://issues.apache.org/jira/browse/FLINK-28635 Project: Flink Issu

[jira] [Created] (FLINK-28502) Add Transformer for RegexTokenizer

2022-07-11 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28502: - Summary: Add Transformer for RegexTokenizer Key: FLINK-28502 URL: https://issues.apache.org/jira/browse/FLINK-28502 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28501) Add Transformer and Estimator for VectorIndexer

2022-07-11 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28501: - Summary: Add Transformer and Estimator for VectorIndexer Key: FLINK-28501 URL: https://issues.apache.org/jira/browse/FLINK-28501 Project: Flink Issue Type:

[jira] [Created] (FLINK-28500) Add Transformer for Tokenizer

2022-07-11 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-28500: - Summary: Add Transformer for Tokenizer Key: FLINK-28500 URL: https://issues.apache.org/jira/browse/FLINK-28500 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-28475) kafka connector won't stop when the stopping offset is zero

2022-07-09 Thread Leo zhang (Jira)
Leo zhang created FLINK-28475: - Summary: kafka connector won't stop when the stopping offset is zero Key: FLINK-28475 URL: https://issues.apache.org/jira/browse/FLINK-28475 Project: Flink Issue

[jira] [Created] (FLINK-28397) Source Supports Speculative Execution For Batch Job

2022-07-05 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-28397: -- Summary: Source Supports Speculative Execution For Batch Job Key: FLINK-28397 URL: https://issues.apache.org/jira/browse/FLINK-28397 Project: Flink Issue Type: S

[jira] [Created] (FLINK-28249) Flink can not delete older checkpoint folders from google storage bucket

2022-06-24 Thread Jie Zhang (Jira)
Jie Zhang created FLINK-28249: - Summary: Flink can not delete older checkpoint folders from google storage bucket Key: FLINK-28249 URL: https://issues.apache.org/jira/browse/FLINK-28249 Project: Flink

[jira] [Created] (FLINK-28003) 'pos ' field would be updated to 'POSITION' when use SqlClient

2022-06-10 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-28003: -- Summary: 'pos ' field would be updated to 'POSITION' when use SqlClient Key: FLINK-28003 URL: https://issues.apache.org/jira/browse/FLINK-28003 Project: Flink

[jira] [Created] (FLINK-27952) Table UDF fails when using Double.POSITIVE_INFINITY as parameters

2022-06-08 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-27952: - Summary: Table UDF fails when using Double.POSITIVE_INFINITY as parameters Key: FLINK-27952 URL: https://issues.apache.org/jira/browse/FLINK-27952 Project: Flink

[jira] [Created] (FLINK-27877) Improve performance of several feature engineering algorithms

2022-06-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-27877: - Summary: Improve performance of several feature engineering algorithms Key: FLINK-27877 URL: https://issues.apache.org/jira/browse/FLINK-27877 Project: Flink

[jira] [Created] (FLINK-27826) Support machine learning training for high dimesional models

2022-05-28 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-27826: - Summary: Support machine learning training for high dimesional models Key: FLINK-27826 URL: https://issues.apache.org/jira/browse/FLINK-27826 Project: Flink

[jira] [Created] (FLINK-27550) Remove checking yarn queues before submitting job to Yarn

2022-05-08 Thread Junfan Zhang (Jira)
Junfan Zhang created FLINK-27550: Summary: Remove checking yarn queues before submitting job to Yarn Key: FLINK-27550 URL: https://issues.apache.org/jira/browse/FLINK-27550 Project: Flink Iss

[jira] [Created] (FLINK-27437) Syntax error when running tpcds test

2022-04-28 Thread Yao Zhang (Jira)
Yao Zhang created FLINK-27437: - Summary: Syntax error when running tpcds test Key: FLINK-27437 URL: https://issues.apache.org/jira/browse/FLINK-27437 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27320) When using KafkaSink EXACTLY_ONCE semantics, frequent OutOfOrderSequenceException anomalies

2022-04-20 Thread Zhengqi Zhang (Jira)
Zhengqi Zhang created FLINK-27320: - Summary: When using KafkaSink EXACTLY_ONCE semantics, frequent OutOfOrderSequenceException anomalies Key: FLINK-27320 URL: https://issues.apache.org/jira/browse/FLINK-27320

[jira] [Created] (FLINK-27318) KafkaSink: when init transaction, it take too long to get a producerId with epoch=0

2022-04-20 Thread Zhengqi Zhang (Jira)
Zhengqi Zhang created FLINK-27318: - Summary: KafkaSink: when init transaction, it take too long to get a producerId with epoch=0 Key: FLINK-27318 URL: https://issues.apache.org/jira/browse/FLINK-27318

[jira] [Created] (FLINK-27174) Non-null check for bootstrapServers field is incorrect in KafkaSink

2022-04-11 Thread Zhengqi Zhang (Jira)
Zhengqi Zhang created FLINK-27174: - Summary: Non-null check for bootstrapServers field is incorrect in KafkaSink Key: FLINK-27174 URL: https://issues.apache.org/jira/browse/FLINK-27174 Project: Flink

[jira] [Created] (FLINK-27086) Add a QA about how to handle exception when use hive parser in hive dialect document

2022-04-06 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-27086: -- Summary: Add a QA about how to handle exception when use hive parser in hive dialect document Key: FLINK-27086 URL: https://issues.apache.org/jira/browse/FLINK-27086 Proj

[jira] [Created] (FLINK-27072) Add Bucketizer in FlinkML

2022-04-05 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-27072: - Summary: Add Bucketizer in FlinkML Key: FLINK-27072 URL: https://issues.apache.org/jira/browse/FLINK-27072 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-27020) use hive dialect in SqlClient would thrown an error based on 1.15 version

2022-04-02 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-27020: -- Summary: use hive dialect in SqlClient would thrown an error based on 1.15 version Key: FLINK-27020 URL: https://issues.apache.org/jira/browse/FLINK-27020 Project: Flink

[jira] [Created] (FLINK-27019) use hive dialect in SqlClient would thrown an error based on 1.15 version

2022-04-02 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-27019: -- Summary: use hive dialect in SqlClient would thrown an error based on 1.15 version Key: FLINK-27019 URL: https://issues.apache.org/jira/browse/FLINK-27019 Project: Flink

  1   2   3   4   5   >