[jira] [Closed] (FLINK-30465) Remove flink-connector-jdbc from master branch

[ https://issues.apache.org/jira/browse/FLINK-30465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30465. -- Fix Version/s: 1.17.0 Resolution: Fixed Fixed in master:

[jira] [Closed] (FLINK-28742) Table.to_pandas fails with lit("xxx")

[ https://issues.apache.org/jira/browse/FLINK-28742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-28742. --- Fix Version/s: 1.17.0 1.16.1 1.15.4 Resolution: Fixed Fixed

[GitHub] [flink] swuferhong commented on a diff in pull request #21530: [FLINK-30376][table-planner] Introduce a new flink bushy join reorder rule which based on greedy algorithm

swuferhong commented on code in PR #21530: URL: https://github.com/apache/flink/pull/21530#discussion_r1065280135 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java: ## @@ -0,0 +1,620 @@ +/* + *

[jira] [Created] (FLINK-30611) Expire snapshot should be reentrant

Jingsong Lee created FLINK-30611: Summary: Expire snapshot should be reentrant Key: FLINK-30611 URL: https://issues.apache.org/jira/browse/FLINK-30611 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-27716) Add Python API docs in ML

[ https://issues.apache.org/jira/browse/FLINK-27716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-27716: - Fix Version/s: ml-2.2.0 > Add Python API docs in ML > - > >

[GitHub] [flink] Myasuka merged pull request #19599: [FLINK-27327][docs] Add description about changing max parallelism ex…

Myasuka merged PR #19599: URL: https://github.com/apache/flink/pull/19599 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-30481) create base aws-glue catalog implementation in flink-connector-aws

[ https://issues.apache.org/jira/browse/FLINK-30481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30481: --- Labels: pull-request-available (was: ) > create base aws-glue catalog implementation in

[GitHub] [flink-connector-aws] boring-cyborg[bot] commented on pull request #43: [FLINK-30481][DRAFT]Glue Catalog Implementation

boring-cyborg[bot] commented on PR #43: URL: https://github.com/apache/flink-connector-aws/pull/43#issuecomment-1376709501 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is an

[GitHub] [flink] ramkrish86 commented on pull request #21508: [FLINK-30128] Introduce Azure Data Lake Gen2 APIs in the Hadoop Recoverable path

ramkrish86 commented on PR #21508: URL: https://github.com/apache/flink/pull/21508#issuecomment-137671 > That is to say, with what we currently have, there's no need to update the FTS documentation. And if we want to support FTS + ABFS + Spark/Hive/Trino, we would need to open another

[jira] [Updated] (FLINK-30615) Refactor ReadWriteTableITCase to get rid of Managed Table

[ https://issues.apache.org/jira/browse/FLINK-30615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuzelin updated FLINK-30615: Description: # Get rid of Managed Table # Split kafka log test into a new test class. > Refactor

[jira] [Commented] (FLINK-29595) Add Estimator and Transformer for ChiSqSelector

[ https://issues.apache.org/jira/browse/FLINK-29595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656423#comment-17656423 ] Dong Lin commented on FLINK-29595: -- ChiSqSelector has been be implemented as part of the

[jira] [Comment Edited] (FLINK-29595) Add Estimator and Transformer for ChiSqSelector

[ https://issues.apache.org/jira/browse/FLINK-29595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656423#comment-17656423 ] Dong Lin edited comment on FLINK-29595 at 1/10/23 5:23 AM: --- ChiSqSelector has

[jira] [Closed] (FLINK-29595) Add Estimator and Transformer for ChiSqSelector

[ https://issues.apache.org/jira/browse/FLINK-29595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-29595. Release Note: This is duplicate of FLINK-29601 Resolution: Duplicate > Add Estimator and

[jira] [Assigned] (FLINK-29595) Add Estimator and Transformer for ChiSqSelector

[ https://issues.apache.org/jira/browse/FLINK-29595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-29595: Assignee: Jiang Xin > Add Estimator and Transformer for ChiSqSelector >

[jira] [Closed] (FLINK-30586) Fix calcCodeGen failed if calc with like condition contains double quotation mark

[ https://issues.apache.org/jira/browse/FLINK-30586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30586. -- Resolution: Fixed Fixed in 1.17.0: 68b37fb867374df5a201f0b170e35c21266e5d7b > Fix calcCodeGen failed

[GitHub] [flink] swuferhong commented on a diff in pull request #21530: [FLINK-30376][table-planner] Introduce a new flink bushy join reorder rule which based on greedy algorithm

swuferhong commented on code in PR #21530: URL: https://github.com/apache/flink/pull/21530#discussion_r1065379525 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java: ## @@ -0,0 +1,620 @@ +/* + *

[jira] [Commented] (FLINK-30257) SqlClientITCase#testMatchRecognize failed

[ https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656476#comment-17656476 ] Matthias Pohl commented on FLINK-30257: ---

[jira] [Updated] (FLINK-30616) Don't support batchMessageId when restore from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-30616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] songv updated FLINK-30616: -- Description: I have a non-partition topic:  * the producer for the topic sends batch messages to the

[GitHub] [flink] swuferhong commented on a diff in pull request #21530: [FLINK-30376][table-planner] Introduce a new flink bushy join reorder rule which based on greedy algorithm

swuferhong commented on code in PR #21530: URL: https://github.com/apache/flink/pull/21530#discussion_r1065265984 ## docs/layouts/shortcodes/generated/optimizer_config_configuration.html: ## @@ -41,6 +41,12 @@ Boolean Enables join reorder in optimizer.

[GitHub] [flink] swuferhong commented on a diff in pull request #21530: [FLINK-30376][table-planner] Introduce a new flink bushy join reorder rule which based on greedy algorithm

swuferhong commented on code in PR #21530: URL: https://github.com/apache/flink/pull/21530#discussion_r1065269586 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/RewriteMultiJoinConditionRule.scala: ## @@ -45,7 +48,12 @@ class

[GitHub] [flink] xintongsong commented on pull request #21508: [FLINK-30128] Introduce Azure Data Lake Gen2 APIs in the Hadoop Recoverable path

xintongsong commented on PR #21508: URL: https://github.com/apache/flink/pull/21508#issuecomment-1376671834 > @xintongsong - Also want to know about this https://nightlies.apache.org/flink/flink-table-store-docs-master/docs/filesystems/overview/. Now since ABFS support is available in

[jira] [Created] (FLINK-30612) ObjectArrayConverter is not thread-safe，raised by reuseArray、reuseWriter

guoxin created FLINK-30612: -- Summary: ObjectArrayConverter is not thread-safe，raised by reuseArray、reuseWriter Key: FLINK-30612 URL: https://issues.apache.org/jira/browse/FLINK-30612 Project: Flink

[GitHub] [flink-web] lincoln-lil merged pull request #600: Add Lincoln Lee to the committer list

lincoln-lil merged PR #600: URL: https://github.com/apache/flink-web/pull/600 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-30099) Add tests to cover model data APIs for all existing algorithms

[ https://issues.apache.org/jira/browse/FLINK-30099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-30099. Resolution: Fixed > Add tests to cover model data APIs for all existing algorithms >

[GitHub] [flink] Myasuka commented on pull request #18523: [FLINK-25068][Runtime/Web] Show the maximum parallelism(number of key groups) of a job in Web UI

Myasuka commented on PR #18523: URL: https://github.com/apache/flink/pull/18523#issuecomment-1376708958 @zlzhang0122 could you please update this PR to rebase with latest code? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Closed] (FLINK-28761) BinaryClassificationEvaluator cannot work with unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-28761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-28761. Release Note: We decided that Flink ML stages do not need to support unaligned checkpoint and rescaling

[jira] [Updated] (FLINK-29597) Add Estimator and Transformer for QuantileDiscretizer

[ https://issues.apache.org/jira/browse/FLINK-29597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-29597: - Fix Version/s: (was: ml-2.2.0) > Add Estimator and Transformer for QuantileDiscretizer >

[jira] [Updated] (FLINK-30144) Guarantee Flink ML operators function correctly with object-reuse enabled

[ https://issues.apache.org/jira/browse/FLINK-30144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-30144: - Affects Version/s: (was: ml-2.1.0) > Guarantee Flink ML operators function correctly with

[jira] [Updated] (FLINK-30144) Guarantee Flink ML operators function correctly with object-reuse enabled

[ https://issues.apache.org/jira/browse/FLINK-30144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-30144: - Fix Version/s: ml-2.2.0 > Guarantee Flink ML operators function correctly with object-reuse enabled >

[jira] [Updated] (FLINK-29843) Euclidean Distance Measure generates NAN distance values

[ https://issues.apache.org/jira/browse/FLINK-29843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-29843: - Fix Version/s: ml-2.2.0 > Euclidean Distance Measure generates NAN distance values >

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

[ https://issues.apache.org/jira/browse/FLINK-29824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-29824: - Affects Version/s: (was: ml-2.2.0) > AgglomerativeClustering fails when the distanceThreshold is

[jira] [Assigned] (FLINK-30006) Cannot remove columns that are incorrectly considered constants from an Aggregate In Streaming

[ https://issues.apache.org/jira/browse/FLINK-30006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-30006: --- Assignee: lincoln lee > Cannot remove columns that are incorrectly considered constants

[jira] [Commented] (FLINK-30598) Wrong code generated for WatermarkGenerator because of inconsistent source type info when deserialized from exec plan

[ https://issues.apache.org/jira/browse/FLINK-30598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656363#comment-17656363 ] lincoln lee commented on FLINK-30598: - This issue has several dependencies to be resolved, pending

[GitHub] [flink] swuferhong commented on a diff in pull request #21530: [FLINK-30376][table-planner] Introduce a new flink bushy join reorder rule which based on greedy algorithm

swuferhong commented on code in PR #21530: URL: https://github.com/apache/flink/pull/21530#discussion_r1065269586 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/RewriteMultiJoinConditionRule.scala: ## @@ -45,7 +48,12 @@ class

[jira] [Closed] (FLINK-30128) Introduce Azure Data Lake Gen2 APIs in the Hadoop Recoverable path

[ https://issues.apache.org/jira/browse/FLINK-30128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-30128. Fix Version/s: 1.17.0 Release Note: FileSink now supports Azure Data Lake Storage Gen2 APIs

[GitHub] [flink] SinBex commented on pull request #21634: [FLINK-30480][runtime] Add benchmarks for adaptive batch scheduler.

SinBex commented on PR #21634: URL: https://github.com/apache/flink/pull/21634#issuecomment-1376685536 @zhuzhurk @reswqa Could you please help me to review this pr? and I'm not sure if it is appropriate for the case with hybrid type edges. Looking forward to your suggestions, thanks

[GitHub] [flink-web] lincoln-lil commented on pull request #600: Add Lincoln Lee to the committer list

lincoln-lil commented on PR #600: URL: https://github.com/apache/flink-web/pull/600#issuecomment-1376692262 @fsk119 thanks for reviewing this! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] swuferhong commented on a diff in pull request #21530: [FLINK-30376][table-planner] Introduce a new flink bushy join reorder rule which based on greedy algorithm

swuferhong commented on code in PR #21530: URL: https://github.com/apache/flink/pull/21530#discussion_r1065314128 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java: ## @@ -0,0 +1,620 @@ +/* + *

[jira] [Assigned] (FLINK-30014) Fix the NPE from aggregate util

[ https://issues.apache.org/jira/browse/FLINK-30014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-30014: Assignee: Jiang Xin > Fix the NPE from aggregate util > --- > >

[GitHub] [flink] swuferhong commented on a diff in pull request #21530: [FLINK-30376][table-planner] Introduce a new flink bushy join reorder rule which based on greedy algorithm

swuferhong commented on code in PR #21530: URL: https://github.com/apache/flink/pull/21530#discussion_r1065313823 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java: ## @@ -0,0 +1,620 @@ +/* + *

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

[ https://issues.apache.org/jira/browse/FLINK-29174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-29174: Assignee: Zhipeng Zhang > Add document for ML algorithms > -- > >

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

[ https://issues.apache.org/jira/browse/FLINK-29174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-29174. Fix Version/s: (was: ml-2.2.0) Resolution: Fixed > Add document for ML algorithms >

[jira] [Created] (FLINK-30614) Improve resolving schema compatibility -- Milestone two

Hangxiang Yu created FLINK-30614: Summary: Improve resolving schema compatibility -- Milestone two Key: FLINK-30614 URL: https://issues.apache.org/jira/browse/FLINK-30614 Project: Flink

[jira] [Created] (FLINK-30615) Refactor ReadWriteTableITCase to get rid of Managed Table

yuzelin created FLINK-30615: --- Summary: Refactor ReadWriteTableITCase to get rid of Managed Table Key: FLINK-30615 URL: https://issues.apache.org/jira/browse/FLINK-30615 Project: Flink Issue Type:

[jira] [Closed] (FLINK-25148) PipelinedSubpartition.resumeConsumption throws IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-25148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-25148. Resolution: Cannot Reproduce > PipelinedSubpartition.resumeConsumption throws IllegalStateException >

[GitHub] [flink-table-store] tsreaper opened a new pull request, #473: [FLINK-30603] Fix unstable test CompactActionITCase#testStreamingCompact

tsreaper opened a new pull request, #473: URL: https://github.com/apache/flink-table-store/pull/473 In `CompactActionITCase#testStreamingCompact`, parallelism of compact job may be larger than 1, so there is a small possibility that different writers will perform full compaction in

[GitHub] [flink] swuferhong commented on a diff in pull request #21530: [FLINK-30376][table-planner] Introduce a new flink bushy join reorder rule which based on greedy algorithm

swuferhong commented on code in PR #21530: URL: https://github.com/apache/flink/pull/21530#discussion_r1065350761 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java: ## @@ -0,0 +1,620 @@ +/* + *

[GitHub] [flink] masteryhx opened a new pull request, #21635: Improve resolving schema compatibility -- Milestone one

masteryhx opened a new pull request, #21635: URL: https://github.com/apache/flink/pull/21635 ## What is the purpose of the change This pr reverses the direction of resolving schema compatibility could improve the usability of schema evolution. See FLIP-263 for more details.

[jira] [Updated] (FLINK-29769) Further limit the explosion range of failover in hybrid shuffle mode

[ https://issues.apache.org/jira/browse/FLINK-29769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-29769: --- Affects Version/s: (was: 1.17.0) > Further limit the explosion range of failover in hybrid

[jira] [Updated] (FLINK-30612) ObjectArrayConverter is not thread-safe，raised by reuseArray、reuseWriter

[ https://issues.apache.org/jira/browse/FLINK-30612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] guoxin updated FLINK-30612: --- Priority: Blocker (was: Major) > ObjectArrayConverter is not thread-safe，raised by reuseArray、reuseWriter

[jira] [Commented] (FLINK-30191) Update py4j from 0.10.9.3 to 0.10.9.7

[ https://issues.apache.org/jira/browse/FLINK-30191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656477#comment-17656477 ] Yunfeng Zhou commented on FLINK-30191: -- Hi [~martijnvisser], would you mind my asking about the

[jira] [Updated] (FLINK-30616) Don't support batchMessageId when restore from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-30616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] songv updated FLINK-30616: -- Description: I have a non-partition topic:  * the producer for the topic sends batch messages to the

[GitHub] [flink-connector-pulsar] syhily opened a new pull request, #15: [FLINK-28870][Connector/Pulsar] Improve the Pulsar source performance when meeting small data rates.

syhily opened a new pull request, #15: URL: https://github.com/apache/flink-connector-pulsar/pull/15 ## What is the purpose of the change When using Pulsar Source to consume data, if the data rate is small, e.g. 2 msg/s, there will be long periods of time when no messages are

[GitHub] [flink-connector-pulsar] tisonkun commented on a diff in pull request #13: [FLINK-28082][Connector/Pulsar] Add end-to-end encryption support.

tisonkun commented on code in PR #13: URL: https://github.com/apache/flink-connector-pulsar/pull/13#discussion_r1065269809 ## docs/content.zh/docs/connectors/datastream/pulsar.md: ## @@ -804,113 +798,25 @@ Pulsar Sink 使用生产者 API 来发送消息。Pulsar 的 `ProducerConfigurat {{<

[GitHub] [flink] xintongsong commented on pull request #21508: [FLINK-30128] Introduce Azure Data Lake Gen2 APIs in the Hadoop Recoverable path

xintongsong commented on PR #21508: URL: https://github.com/apache/flink/pull/21508#issuecomment-1376622507 > https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/datastream/streamfile_sink/#important-considerations Here we say that we support S3, HDFS and local.

[GitHub] [flink] swuferhong commented on a diff in pull request #21530: [FLINK-30376][table-planner] Introduce a new flink bushy join reorder rule which based on greedy algorithm

swuferhong commented on code in PR #21530: URL: https://github.com/apache/flink/pull/21530#discussion_r1065269586 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/RewriteMultiJoinConditionRule.scala: ## @@ -45,7 +48,12 @@ class

[jira] [Assigned] (FLINK-30603) CompactActionITCase in table store is unstable

[ https://issues.apache.org/jira/browse/FLINK-30603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng reassigned FLINK-30603: --- Assignee: Caizhi Weng > CompactActionITCase in table store is unstable >

[GitHub] [flink-connector-pulsar] syhily commented on a diff in pull request #13: [FLINK-28082][Connector/Pulsar] Add end-to-end encryption support.

syhily commented on code in PR #13: URL: https://github.com/apache/flink-connector-pulsar/pull/13#discussion_r1065298845 ## flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/crypto/PulsarCrypto.java: ## @@ -0,0 +1,86 @@ +/* + * Licensed to the

[GitHub] [flink] swuferhong commented on a diff in pull request #21530: [FLINK-30376][table-planner] Introduce a new flink bushy join reorder rule which based on greedy algorithm

swuferhong commented on code in PR #21530: URL: https://github.com/apache/flink/pull/21530#discussion_r1065316262 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java: ## @@ -0,0 +1,620 @@ +/* + *

[jira] [Updated] (FLINK-30401) Add Estimator and Transformer for MinHashLSH

[ https://issues.apache.org/jira/browse/FLINK-30401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-30401: - Fix Version/s: ml-2.2.0 > Add Estimator and Transformer for MinHashLSH >

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

[ https://issues.apache.org/jira/browse/FLINK-29170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-29170. Release Note: This is duplicate of https://issues.apache.org/jira/browse/FLINK-29409 Resolution:

[jira] [Resolved] (FLINK-27327) Add description about changing max parallelism explicitly leads to state incompatibility

[ https://issues.apache.org/jira/browse/FLINK-27327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-27327. -- Fix Version/s: 1.16.1 1.15.4 Resolution: Fixed Merged master:

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

[ https://issues.apache.org/jira/browse/FLINK-29170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-29170: Assignee: Jiang Xin (was: Zhipeng Zhang) > Add Transformer and Estimator for

[jira] [Created] (FLINK-30613) Improve resolving schema compatibility -- Milestone one

Hangxiang Yu created FLINK-30613: Summary: Improve resolving schema compatibility -- Milestone one Key: FLINK-30613 URL: https://issues.apache.org/jira/browse/FLINK-30613 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-29169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-29169. Release Note: This is duplicate of FLINK-29601 Resolution: Fixed > Add Transformer and Estimator

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

[ https://issues.apache.org/jira/browse/FLINK-29169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reopened FLINK-29169: -- > Add Transformer and Estimator for UnivariateFeatureSelector >

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

[ https://issues.apache.org/jira/browse/FLINK-29169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-29169: Assignee: Jiang Xin (was: Zhipeng Zhang) > Add Transformer and Estimator for

[jira] [Closed] (FLINK-26265) Support Java algorithm in Python ML API

[ https://issues.apache.org/jira/browse/FLINK-26265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-26265. Resolution: Fixed > Support Java algorithm in Python ML API > --- > >

[jira] [Updated] (FLINK-27716) Add Python API docs in ML

[ https://issues.apache.org/jira/browse/FLINK-27716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-27716: - Parent: (was: FLINK-26265) Issue Type: Improvement (was: Sub-task) > Add Python API docs

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

[ https://issues.apache.org/jira/browse/FLINK-29824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-29824: - Fix Version/s: ml-2.2.0 > AgglomerativeClustering fails when the distanceThreshold is very large >

[jira] [Updated] (FLINK-27715) Add more Python ML examples

[ https://issues.apache.org/jira/browse/FLINK-27715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-27715: - Fix Version/s: ml-2.2.0 > Add more Python ML examples > --- > >

[jira] [Assigned] (FLINK-30586) Fix calcCodeGen failed if calc with like condition contains double quotation mark

[ https://issues.apache.org/jira/browse/FLINK-30586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-30586: -- Assignee: Yunhong Zheng > Fix calcCodeGen failed if calc with like condition contains double

[GitHub] [flink] godfreyhe closed pull request #21609: [FLINK-30586][table-runtime] Fix calcCodeGen failed if calc with 'like' condition contains double quotation mark

godfreyhe closed pull request #21609: [FLINK-30586][table-runtime] Fix calcCodeGen failed if calc with 'like' condition contains double quotation mark URL: https://github.com/apache/flink/pull/21609 -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-30257) SqlClientITCase#testMatchRecognize failed

[ https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656473#comment-17656473 ] Matthias Pohl commented on FLINK-30257: ---

[jira] [Commented] (FLINK-30257) SqlClientITCase#testMatchRecognize failed

[ https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656474#comment-17656474 ] Matthias Pohl commented on FLINK-30257: ---

[GitHub] [flink] swuferhong commented on a diff in pull request #21530: [FLINK-30376][table-planner] Introduce a new flink bushy join reorder rule which based on greedy algorithm

swuferhong commented on code in PR #21530: URL: https://github.com/apache/flink/pull/21530#discussion_r1065276259 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkJoinReorderRule.java: ## @@ -0,0 +1,102 @@ +/* + * Licensed

[GitHub] [flink] godfreyhe closed pull request #21556: [FLINK-30491][hive] Hive table partition supports deserializing later during runtime

godfreyhe closed pull request #21556: [FLINK-30491][hive] Hive table partition supports deserializing later during runtime URL: https://github.com/apache/flink/pull/21556 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Closed] (FLINK-28082) Support end to end encryption on Pulsar connector.

[ https://issues.apache.org/jira/browse/FLINK-28082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-28082. - Fix Version/s: pulsar-4.0.0 (was: 1.17.0) Resolution: Fixed master via

[jira] [Closed] (FLINK-30536) Remove CountingOutput from per-record code path for most operators

[ https://issues.apache.org/jira/browse/FLINK-30536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-30536. Resolution: Fixed > Remove CountingOutput from per-record code path for most operators >

[jira] [Updated] (FLINK-29600) Add Estimator and Transformer for BucketedRandomProjectionLSH

[ https://issues.apache.org/jira/browse/FLINK-29600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-29600: - Fix Version/s: (was: ml-2.2.0) > Add Estimator and Transformer for BucketedRandomProjectionLSH >

[jira] [Commented] (FLINK-26974) Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17656417#comment-17656417 ] Huang Xingbo commented on FLINK-26974: -- I'm very sorry, due to several other unexpected things in

[GitHub] [flink] swuferhong commented on a diff in pull request #21530: [FLINK-30376][table-planner] Introduce a new flink bushy join reorder rule which based on greedy algorithm

swuferhong commented on code in PR #21530: URL: https://github.com/apache/flink/pull/21530#discussion_r1065381018 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkBushyJoinReorderRule.java: ## @@ -0,0 +1,620 @@ +/* + *

[GitHub] [flink] maosuhan commented on pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

maosuhan commented on PR #21613: URL: https://github.com/apache/flink/pull/21613#issuecomment-1376836273 @laughingman7743 It looks all right now. @libenchao Do you have time to take another look at this? -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink-web] gaborgsomogyi commented on pull request #599: Flink Kubernetes Operator 1.3.1

gaborgsomogyi commented on PR #599: URL: https://github.com/apache/flink-web/pull/599#issuecomment-1376848906 Looks good, except the jira list which is somehow collapsed. 

[GitHub] [flink] xintongsong closed pull request #21508: [FLINK-30128] Introduce Azure Data Lake Gen2 APIs in the Hadoop Recoverable path

xintongsong closed pull request #21508: [FLINK-30128] Introduce Azure Data Lake Gen2 APIs in the Hadoop Recoverable path URL: https://github.com/apache/flink/pull/21508 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Closed] (FLINK-29640) Enhance the function configured by execution.shutdown-on-attached-exit by heartbeat between client and dispatcher

[ https://issues.apache.org/jira/browse/FLINK-29640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29640. Fix Version/s: 1.17.0 Resolution: Done master (1.17):

[jira] [Created] (FLINK-30610) Flink-table-runtime free for disk io in flink-core

Jingsong Lee created FLINK-30610: Summary: Flink-table-runtime free for disk io in flink-core Key: FLINK-30610 URL: https://issues.apache.org/jira/browse/FLINK-30610 Project: Flink Issue

[jira] [Updated] (FLINK-30612) ObjectArrayConverter is not thread-safe，raised by reuseArray、reuseWriter

[ https://issues.apache.org/jira/browse/FLINK-30612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] guoxin updated FLINK-30612: --- Description: data clutter in multi-threaded environment. by design? or , how do i use it in multi-thread

[jira] [Updated] (FLINK-30612) ObjectArrayConverter is not thread-safe，raised by reuseArray、reuseWriter

[ https://issues.apache.org/jira/browse/FLINK-30612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] guoxin updated FLINK-30612: --- Description: data clutter in multi-threaded environment. by design? or , how do i use it in multi-thread

[GitHub] [flink-connector-pulsar] syhily commented on pull request #15: [FLINK-28870][Connector/Pulsar] Improve the Pulsar source performance when meeting small data rates.

syhily commented on PR #15: URL: https://github.com/apache/flink-connector-pulsar/pull/15#issuecomment-1376694084 > To keep the user experience consistent, is it possible to make singleFetchTime optional and only into use if configured? Yep. -- This is an automated message from

[GitHub] [flink] lsyldliu commented on pull request #21629: [FLINK-30579][hive] Introducing cofigurable option to enable hive native function

lsyldliu commented on PR #21629: URL: https://github.com/apache/flink/pull/21629#issuecomment-1376707230 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Closed] (FLINK-29599) Add Estimator and Transformer for MinHashLSH

[ https://issues.apache.org/jira/browse/FLINK-29599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-29599. Release Note: Duplicate of FLINK-30401 Resolution: Duplicate > Add Estimator and Transformer for

[jira] [Closed] (FLINK-30122) Flink ML KMeans getting model data throws TypeError

[ https://issues.apache.org/jira/browse/FLINK-30122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-30122. Resolution: Fixed > Flink ML KMeans getting model data throws TypeError >

[jira] [Updated] (FLINK-30122) Flink ML KMeans getting model data throws TypeError

[ https://issues.apache.org/jira/browse/FLINK-30122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-30122: - Fix Version/s: ml-2.2.0 > Flink ML KMeans getting model data throws TypeError >

[jira] [Assigned] (FLINK-30401) Add Estimator and Transformer for MinHashLSH

[ https://issues.apache.org/jira/browse/FLINK-30401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-30401: Assignee: Fan Hong > Add Estimator and Transformer for MinHashLSH >

[jira] [Updated] (FLINK-29596) Add Estimator and Transformer for RFormula

[ https://issues.apache.org/jira/browse/FLINK-29596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-29596: - Fix Version/s: (was: ml-2.2.0) > Add Estimator and Transformer for RFormula >

[jira] [Closed] (FLINK-30241) Flink ML Iteration ConcurrentModificationException

[ https://issues.apache.org/jira/browse/FLINK-30241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-30241. Resolution: Cannot Reproduce > Flink ML Iteration ConcurrentModificationException >

[jira] [Closed] (FLINK-29763) TaskManager heatbeat timeout exception in Github CI for python tests

[ https://issues.apache.org/jira/browse/FLINK-29763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-29763. Resolution: Cannot Reproduce > TaskManager heatbeat timeout exception in Github CI for python tests >

[jira] [Updated] (FLINK-30603) CompactActionITCase in table store is unstable

[ https://issues.apache.org/jira/browse/FLINK-30603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30603: --- Labels: pull-request-available (was: ) > CompactActionITCase in table store is unstable >

[GitHub] [flink-table-store] tsreaper merged pull request #473: [FLINK-30603] Fix unstable test CompactActionITCase#testStreamingCompact

tsreaper merged PR #473: URL: https://github.com/apache/flink-table-store/pull/473 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

  1   2   3   >