[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #163: [FLINK-29591] Add built-in UDFs to convert between arrays and vectors

2022-10-16 Thread GitBox
yunfengzhou-hub commented on code in PR #163: URL: https://github.com/apache/flink-ml/pull/163#discussion_r996638399 ## flink-ml-python/pyflink/ml/core/linalg.py: ## @@ -776,3 +777,15 @@ def _double_to_long_bits(value: float) -> int: value = float("nan") # pack

[jira] [Commented] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618658#comment-17618658 ] Xintong Song commented on FLINK-29572: -- [~gzkevinl], I probably haven't understand this service

[jira] [Created] (FLINK-29654) Vulnerable libraries - Flink 1.15.2

2022-10-16 Thread nagasudhakar (Jira)
nagasudhakar created FLINK-29654: Summary: Vulnerable libraries - Flink 1.15.2 Key: FLINK-29654 URL: https://issues.apache.org/jira/browse/FLINK-29654 Project: Flink Issue Type: Bug

[GitHub] [flink] reswqa closed pull request #20902: [FLINK-29419] fix the problem that testHybridFullExchangesRestart hang.

2022-10-16 Thread GitBox
reswqa closed pull request #20902: [FLINK-29419] fix the problem that testHybridFullExchangesRestart hang. URL: https://github.com/apache/flink/pull/20902 -- 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

[GitHub] [flink] reswqa commented on pull request #20902: [FLINK-29419] fix the problem that testHybridFullExchangesRestart hang.

2022-10-16 Thread GitBox
reswqa commented on PR #20902: URL: https://github.com/apache/flink/pull/20902#issuecomment-1280307609 This pull request does not fix the problem. -- 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

[jira] [Commented] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618429#comment-17618429 ] Xintong Song commented on FLINK-29646: -- cc [~fsk119] > SQL Gateway should return a simpler error

[jira] [Commented] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618428#comment-17618428 ] Xintong Song commented on FLINK-29646: -- I agree that for this specific example, or maybe generalize

[jira] [Commented] (FLINK-29653) close DynamicResult but it was already closed

2022-10-16 Thread Jingqi Shi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618422#comment-17618422 ] Jingqi Shi commented on FLINK-29653: Anyone can assign this to me? > close DynamicResult but it was

[jira] [Commented] (FLINK-29652) get duplicate result from sql-client in BATCH mode

2022-10-16 Thread Jingqi Shi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618423#comment-17618423 ] Jingqi Shi commented on FLINK-29652: Anyone can assign this to me?  > get duplicate result from

[jira] [Created] (FLINK-29653) close DynamicResult but it was already closed

2022-10-16 Thread Jingqi Shi (Jira)
Jingqi Shi created FLINK-29653: -- Summary: close DynamicResult but it was already closed Key: FLINK-29653 URL: https://issues.apache.org/jira/browse/FLINK-29653 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29652) get duplicate result from sql-client in BATCH mode

2022-10-16 Thread Jingqi Shi (Jira)
Jingqi Shi created FLINK-29652: -- Summary: get duplicate result from sql-client in BATCH mode Key: FLINK-29652 URL: https://issues.apache.org/jira/browse/FLINK-29652 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #21079: [FLINK-29648][python] Fix "LocalTimeTypeInfo not supported" error

2022-10-16 Thread GitBox
flinkbot commented on PR #21079: URL: https://github.com/apache/flink/pull/21079#issuecomment-1280292955 ## CI report: * 13b7ec676805c982c7c426fe9c5cb19cde33e793 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29648) "LocalDateTime not supported" error when retrieving Java TypeInformation from PyFlink

2022-10-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29648: --- Labels: pull-request-available (was: ) > "LocalDateTime not supported" error when

[GitHub] [flink] Vancior opened a new pull request, #21079: [FLINK-29648][python] Fix "LocalTimeTypeInfo not supported" error

2022-10-16 Thread GitBox
Vancior opened a new pull request, #21079: URL: https://github.com/apache/flink/pull/21079 ## What is the purpose of the change This PR fixes "LocalTimeTypeInfo not supported" error when retrieving TypeInformation from PyFlink, e.g. calling `key_by` after `to_data_stream`.

[jira] [Comment Edited] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-16 Thread yuanfenghu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618413#comment-17618413 ] yuanfenghu edited comment on FLINK-29646 at 10/17/22 4:46 AM: -- Thank  

[jira] [Comment Edited] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-16 Thread yuanfenghu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618413#comment-17618413 ] yuanfenghu edited comment on FLINK-29646 at 10/17/22 4:46 AM: -- Thank  

[jira] [Commented] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-16 Thread yuanfenghu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618413#comment-17618413 ] yuanfenghu commented on FLINK-29646: Thank  [~xtsong] . It is really not the best way to use root

[GitHub] [flink] masteryhx commented on a diff in pull request #21053: [FLINK-29157][doc] Clarify the contract between CompletedCheckpointStore and SharedStateRegistry

2022-10-16 Thread GitBox
masteryhx commented on code in PR #21053: URL: https://github.com/apache/flink/pull/21053#discussion_r996601693 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStore.java: ## @@ -39,6 +41,15 @@ public interface CompletedCheckpointStore {

[GitHub] [flink] fredia commented on a diff in pull request #20965: [FLINK-29244][state/changelog] Add metric lastMaterializationDuration…

2022-10-16 Thread GitBox
fredia commented on code in PR #20965: URL: https://github.com/apache/flink/pull/20965#discussion_r996599726 ## flink-state-backends/flink-statebackend-common/src/main/java/org/apache/flink/state/common/PeriodicMaterializationManager.java: ## @@ -251,6 +254,8 @@ private void

[jira] [Commented] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618406#comment-17618406 ] Xintong Song commented on FLINK-29646: -- Let me ask in this way: How do you know the last `caused

[jira] [Commented] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-16 Thread Kevin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618407#comment-17618407 ] Kevin Li commented on FLINK-29572: -- 1. It is called service mesh, basically all ingress/egress traffic

[jira] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-10-16 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618404#comment-17618404 ] Xingbo Huang commented on FLINK-29419: -- [~Weijie Guo]  Is any update on this issue? >

[jira] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-10-16 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618403#comment-17618403 ] Xingbo Huang commented on FLINK-29419: --

[jira] [Commented] (FLINK-26238) PulsarSinkITCase.writeRecordsToPulsar failed on azure

2022-10-16 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618402#comment-17618402 ] Xingbo Huang commented on FLINK-26238: --

[jira] [Commented] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

2022-10-16 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618401#comment-17618401 ] Xingbo Huang commented on FLINK-29387: --

[jira] [Commented] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

2022-10-16 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618400#comment-17618400 ] Xingbo Huang commented on FLINK-29387: --

[jira] [Commented] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

2022-10-16 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618399#comment-17618399 ] Xingbo Huang commented on FLINK-29387: --

[jira] [Commented] (FLINK-29427) LookupJoinITCase failed with classloader problem

2022-10-16 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618396#comment-17618396 ] Xingbo Huang commented on FLINK-29427: --

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #163: [FLINK-29591] Add built-in UDFs to convert between arrays and vectors

2022-10-16 Thread GitBox
lindong28 commented on code in PR #163: URL: https://github.com/apache/flink-ml/pull/163#discussion_r996575556 ## flink-ml-python/pyflink/ml/core/linalg.py: ## @@ -776,3 +777,15 @@ def _double_to_long_bits(value: float) -> int: value = float("nan") # pack double

[jira] [Commented] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-16 Thread yuanfenghu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618395#comment-17618395 ] yuanfenghu commented on FLINK-29646: I would like to explain the scenario where we use the gateway.

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

2022-10-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-29640: Assignee: Liu > Enhance the function configured by execution.shutdown-on-attached-exit

[jira] [Commented] (FLINK-29639) Add ResourceId in TransportException for debugging

2022-10-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618393#comment-17618393 ] Xintong Song commented on FLINK-29639: -- Thanks, [~Jiangang]. You are assigned > Add ResourceId in

[jira] [Assigned] (FLINK-29641) SortMergeResultPartitionReadSchedulerTest.testCreateSubpartitionReader

2022-10-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-29641: Assignee: Weijie Guo >

[jira] [Assigned] (FLINK-29639) Add ResourceId in TransportException for debugging

2022-10-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-29639: Assignee: Liu > Add ResourceId in TransportException for debugging >

[jira] [Comment Edited] (FLINK-29629) FlameGraph is empty for Legacy Source Threads

2022-10-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618392#comment-17618392 ] Zhu Zhu edited comment on FLINK-29629 at 10/17/22 3:13 AM: --- Thanks for

[jira] [Commented] (FLINK-29629) FlameGraph is empty for Legacy Source Threads

2022-10-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618392#comment-17618392 ] Zhu Zhu commented on FLINK-29629: - Thanks for reporting this! I agree it is not ideal but I think it is

[jira] [Comment Edited] (FLINK-29629) FlameGraph is empty for Legacy Source Threads

2022-10-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618392#comment-17618392 ] Zhu Zhu edited comment on FLINK-29629 at 10/17/22 3:12 AM: --- Thanks for

[jira] [Commented] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618387#comment-17618387 ] Xintong Song commented on FLINK-29646: -- That's probably worth-considering direction. It's quite

[GitHub] [flink] sap1ens commented on a diff in pull request #20475: [FLINK-28842][Connector/Kafka] Add client.id.prefix for the KafkaSink

2022-10-16 Thread GitBox
sap1ens commented on code in PR #20475: URL: https://github.com/apache/flink/pull/20475#discussion_r996570322 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSinkOptions.java: ## @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache

[GitHub] [flink] sap1ens commented on a diff in pull request #20475: [FLINK-28842][Connector/Kafka] Add client.id.prefix for the KafkaSink

2022-10-16 Thread GitBox
sap1ens commented on code in PR #20475: URL: https://github.com/apache/flink/pull/20475#discussion_r996570099 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java: ## @@ -398,6 +407,11 @@ private void

[GitHub] [flink] flinkbot commented on pull request #21078: [FLINK-28985][planner]sql like statement supports views

2022-10-16 Thread GitBox
flinkbot commented on PR #21078: URL: https://github.com/apache/flink/pull/21078#issuecomment-1280194634 ## CI report: * a3b63d0182634bf3cb7bf6c3e1a5de19f309dacd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-16 Thread yuanfenghu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618382#comment-17618382 ] yuanfenghu commented on FLINK-29646: Maybe you can add a parameter to the client, whether you need

[GitHub] [flink] waywtdcc closed pull request #20412: [FLINK-28985][planner]sql like statement supports views

2022-10-16 Thread GitBox
waywtdcc closed pull request #20412: [FLINK-28985][planner]sql like statement supports views URL: https://github.com/apache/flink/pull/20412 -- 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] fredia commented on a diff in pull request #21050: [FLINK-29095][state] Improve logging in SharedStateRegistry

2022-10-16 Thread GitBox
fredia commented on code in PR #21050: URL: https://github.com/apache/flink/pull/21050#discussion_r996564183 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java: ## @@ -95,60 +95,78 @@ public StreamStateHandle registerReference(

[jira] [Updated] (FLINK-28985) support create table like view

2022-10-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28985: --- Labels: pull-request-available (was: ) > support create table like view >

[GitHub] [flink] waywtdcc opened a new pull request, #21078: [FLINK-28985][planner]sql like statement supports views

2022-10-16 Thread GitBox
waywtdcc opened a new pull request, #21078: URL: https://github.com/apache/flink/pull/21078 ## What is the purpose of the change ``` At present, to create a table based on table like, you can only use the table type table, not the view type. create table

[jira] [Commented] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

2022-10-16 Thread Eric Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618378#comment-17618378 ] Eric Xiao commented on FLINK-29498: --- As discussed in the [slack

[jira] [Commented] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618377#comment-17618377 ] Xintong Song commented on FLINK-29646: -- First of all, the provided PR changes the default behavior

[GitHub] [flink] fredia commented on a diff in pull request #21050: [FLINK-29095][state] Improve logging in SharedStateRegistry

2022-10-16 Thread GitBox
fredia commented on code in PR #21050: URL: https://github.com/apache/flink/pull/21050#discussion_r996560465 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java: ## @@ -95,60 +95,78 @@ public StreamStateHandle registerReference(

[GitHub] [flink] fredia commented on a diff in pull request #21050: [FLINK-29095][state] Improve logging in SharedStateRegistry

2022-10-16 Thread GitBox
fredia commented on code in PR #21050: URL: https://github.com/apache/flink/pull/21050#discussion_r996560465 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java: ## @@ -95,60 +95,78 @@ public StreamStateHandle registerReference(

[jira] [Commented] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618373#comment-17618373 ] Xintong Song commented on FLINK-29572: -- [~gzkevinl], I'm still not entirely sure whether this is a

[jira] [Updated] (FLINK-29479) Support whether using system PythonPath for PyFlink jobs

2022-10-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-29479: Summary: Support whether using system PythonPath for PyFlink jobs (was: support whether using system env

[jira] [Closed] (FLINK-25497) Add more ML Python examples

2022-10-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-25497. --- Resolution: Duplicate Seems duplicate with FLINK-27715. Just close it~ > Add more ML Python examples >

[jira] [Commented] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-16 Thread yuanfenghu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618367#comment-17618367 ] yuanfenghu commented on FLINK-29646: There is no problem in reporting a complete exception. The

[jira] [Closed] (FLINK-26084) Python tests exit with code 137

2022-10-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-26084. --- Resolution: Cannot Reproduce > Python tests exit with code 137 > --- > >

[jira] [Closed] (FLINK-26264) Python Test failed on its docs building phase

2022-10-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-26264. --- Resolution: Cannot Reproduce > Python Test failed on its docs building phase >

[jira] [Closed] (FLINK-26385) Use new Kafka source and sink in Python API

2022-10-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-26385. --- Resolution: Duplicate > Use new Kafka source and sink in Python API >

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #162: [FLINK-29593] Add QuantileSummary to help calculate approximate quant…

2022-10-16 Thread GitBox
jiangxin369 commented on code in PR #162: URL: https://github.com/apache/flink-ml/pull/162#discussion_r996440219 ## flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java: ## @@ -0,0 +1,359 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[jira] [Closed] (FLINK-28667) "evictor" operations of "window_all" are supported in Python datastream API

2022-10-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-28667. --- Fix Version/s: (was: 1.17.0) Resolution: Duplicate > "evictor" operations of "window_all" are

[jira] [Commented] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618365#comment-17618365 ] Xintong Song commented on FLINK-29646: -- I'm -1 for this change. Reporting the root-cause exception

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #162: [FLINK-29593] Add QuantileSummary to help calculate approximate quant…

2022-10-16 Thread GitBox
jiangxin369 commented on code in PR #162: URL: https://github.com/apache/flink-ml/pull/162#discussion_r996445729 ## flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java: ## @@ -0,0 +1,359 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[jira] [Updated] (FLINK-29094) Cannot stop Python job with savepoint when using Kafka Consumer

2022-10-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-29094: Component/s: Connectors / Kafka (was: API / Python) > Cannot stop Python job with

[jira] [Updated] (FLINK-29479) support whether using system env for pythonpath

2022-10-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-29479: Affects Version/s: (was: 1.17.0) > support whether using system env for pythonpath >

[jira] [Commented] (FLINK-29651) Code gen will fail when the literal specified in user's sql hasn't be escaped

2022-10-16 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618362#comment-17618362 ] luoyuxia commented on FLINK-29651: -- I would like to fix it. > Code gen will fail when the literal

[jira] [Updated] (FLINK-29651) Code gen will fail when the literal specified in user's sql hasn't be escaped

2022-10-16 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-29651: - Description: Can be reproduced with the following code in Flink 1.15:   {code:java} // testTable

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #162: [FLINK-29593] Add QuantileSummary to help calculate approximate quant…

2022-10-16 Thread GitBox
jiangxin369 commented on code in PR #162: URL: https://github.com/apache/flink-ml/pull/162#discussion_r996444598 ## flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java: ## @@ -0,0 +1,359 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

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

2022-10-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-27715: --- Assignee: Yunfeng Zhou (was: Huang Xingbo) > Add more Python ML examples >

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

2022-10-16 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-27715: --- Assignee: Huang Xingbo > Add more Python ML examples > --- > >

[jira] [Created] (FLINK-29651) Code gen will fail when the literal specified in user's sql hasn't be escaped

2022-10-16 Thread luoyuxia (Jira)
luoyuxia created FLINK-29651: Summary: Code gen will fail when the literal specified in user's sql hasn't be escaped Key: FLINK-29651 URL: https://issues.apache.org/jira/browse/FLINK-29651 Project:

[GitHub] [flink] luoyuxia commented on pull request #21058: [FLINK-29350][hive] Add a section for moving planner jar in Hive depe…

2022-10-16 Thread GitBox
luoyuxia commented on PR #21058: URL: https://github.com/apache/flink/pull/21058#issuecomment-1280130367 @wuchong Could you please help merge? -- 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] luoyuxia commented on pull request #21061: [FLINK-29590][hive] Fix literal issue in Hive dialect

2022-10-16 Thread GitBox
luoyuxia commented on PR #21061: URL: https://github.com/apache/flink/pull/21061#issuecomment-1280130262 @wuchong Could you please help merge? -- 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

[jira] [Updated] (FLINK-28985) support create table like view

2022-10-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-28985: - Fix Version/s: 1.17.0 > support create table like view > -- > >

[jira] [Updated] (FLINK-28985) support create table like view

2022-10-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-28985: - Fix Version/s: 1.16.1 (was: 1.17.0) > support create table like view >

[jira] [Updated] (FLINK-28985) support create table like view

2022-10-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-28985: - Affects Version/s: 1.16.0 > support create table like view > -- > >

[GitHub] [flink] flinkbot commented on pull request #21077: [FlINK-29248] Add Scala Async Retry Strategies and ResultPredicates Helper Classes

2022-10-16 Thread GitBox
flinkbot commented on PR #21077: URL: https://github.com/apache/flink/pull/21077#issuecomment-1280069811 ## CI report: * d7a7d794a4bc70fc7247382cbe179b51b6d2fa8c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] czy006 commented on a diff in pull request #21012: [FLINK-29543] Jar Run Rest Handler Support Flink Configuration

2022-10-16 Thread GitBox
czy006 commented on code in PR #21012: URL: https://github.com/apache/flink/pull/21012#discussion_r996454189 ## flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java: ## @@ -211,6 +218,37 @@ void testProvideJobId() throws

[jira] [Commented] (FLINK-29566) Reschedule the cleanup logic if cancel job failed

2022-10-16 Thread Xin Hao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618264#comment-17618264 ] Xin Hao commented on FLINK-29566: - Will submit a PR for that. > Reschedule the cleanup logic if cancel

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #162: [FLINK-29593] Add QuantileSummary to help calculate approximate quant…

2022-10-16 Thread GitBox
jiangxin369 commented on code in PR #162: URL: https://github.com/apache/flink-ml/pull/162#discussion_r996445729 ## flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java: ## @@ -0,0 +1,359 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #162: [FLINK-29593] Add QuantileSummary to help calculate approximate quant…

2022-10-16 Thread GitBox
jiangxin369 commented on code in PR #162: URL: https://github.com/apache/flink-ml/pull/162#discussion_r996444598 ## flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java: ## @@ -0,0 +1,359 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[GitHub] [flink] czy006 commented on a diff in pull request #21012: [FLINK-29543] Jar Run Rest Handler Support Flink Configuration

2022-10-16 Thread GitBox
czy006 commented on code in PR #21012: URL: https://github.com/apache/flink/pull/21012#discussion_r996443211 ## flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java: ## @@ -211,6 +218,37 @@ void testProvideJobId() throws

[GitHub] [flink] czy006 commented on a diff in pull request #21012: [FLINK-29543] Jar Run Rest Handler Support Flink Configuration

2022-10-16 Thread GitBox
czy006 commented on code in PR #21012: URL: https://github.com/apache/flink/pull/21012#discussion_r996443211 ## flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java: ## @@ -211,6 +218,37 @@ void testProvideJobId() throws

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #162: [FLINK-29593] Add QuantileSummary to help calculate approximate quant…

2022-10-16 Thread GitBox
jiangxin369 commented on code in PR #162: URL: https://github.com/apache/flink-ml/pull/162#discussion_r996442270 ## flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java: ## @@ -0,0 +1,359 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #162: [FLINK-29593] Add QuantileSummary to help calculate approximate quant…

2022-10-16 Thread GitBox
jiangxin369 commented on code in PR #162: URL: https://github.com/apache/flink-ml/pull/162#discussion_r996440371 ## flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java: ## @@ -0,0 +1,359 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #162: [FLINK-29593] Add QuantileSummary to help calculate approximate quant…

2022-10-16 Thread GitBox
jiangxin369 commented on code in PR #162: URL: https://github.com/apache/flink-ml/pull/162#discussion_r996440219 ## flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java: ## @@ -0,0 +1,359 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[jira] [Created] (FLINK-29650) Printing the contents of error lines when parsing yaml file may leak sensitive configuration values

2022-10-16 Thread luyuan (Jira)
luyuan created FLINK-29650: -- Summary: Printing the contents of error lines when parsing yaml file may leak sensitive configuration values Key: FLINK-29650 URL: https://issues.apache.org/jira/browse/FLINK-29650

[jira] [Updated] (FLINK-29633) Operator doesn't pass initialSavepointPath as fromSavepoint argument

2022-10-16 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-29633: --- Fix Version/s: kubernetes-operator-1.2.1 > Operator doesn't pass initialSavepointPath as

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #404: [FLINK-29633] Backport to 1.2

2022-10-16 Thread GitBox
gyfora merged PR #404: URL: https://github.com/apache/flink-kubernetes-operator/pull/404 -- 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-14203) Add an abstract class for mappers with rich model.

2022-10-16 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-14203. Resolution: Won't Do > Add an abstract class for mappers with rich model. >

[jira] [Closed] (FLINK-14204) Add the model mapper for Gaussian Mixture model.

2022-10-16 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-14204. Resolution: Won't Do > Add the model mapper for Gaussian Mixture model. >

[jira] [Closed] (FLINK-14390) Add class for SqlOperators, and add sql operations to AlgoOperator, BatchOperator and StreamOperator.

2022-10-16 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-14390. Resolution: Won't Do > Add class for SqlOperators, and add sql operations to AlgoOperator, >

[jira] [Closed] (FLINK-14152) Add class for DocCountVectorizerMapper.

2022-10-16 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-14152. Resolution: Won't Do > Add class for DocCountVectorizerMapper. >

[jira] [Closed] (FLINK-14155) Add a wrapper class of a JSON library to provide the unified json format.

2022-10-16 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-14155. Resolution: Won't Do > Add a wrapper class of a JSON library to provide the unified json format. >

[jira] [Closed] (FLINK-14151) Add class for DocHashIDFVectorizerModelMapper.

2022-10-16 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-14151. Resolution: Won't Do > Add class for DocHashIDFVectorizerModelMapper. >

[jira] [Closed] (FLINK-14154) Add the class for multivariate Gaussian Distribution.

2022-10-16 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-14154. Resolution: Won't Do > Add the class for multivariate Gaussian Distribution. >

[jira] [Closed] (FLINK-13923) Add summarizer and summary for table.

2022-10-16 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-13923. Resolution: Won't Do > Add summarizer and summary for table. > - > >

[jira] [Closed] (FLINK-13915) Add several base classes of summarizer.

2022-10-16 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-13915. Resolution: Won't Do > Add several base classes of summarizer. > ---

[jira] [Closed] (FLINK-12671) Summarizer: summary statistics for Table

2022-10-16 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-12671. Resolution: Won't Do > Summarizer: summary statistics for Table >

[jira] [Closed] (FLINK-13914) Add class for DocHashTFVectorizerMapper.

2022-10-16 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-13914. Resolution: Won't Do > Add class for DocHashTFVectorizerMapper. >

[jira] [Closed] (FLINK-13918) Add class for TokenizerMapper.

2022-10-16 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-13918. Resolution: Won't Do > Add class for TokenizerMapper. > -- > >

[jira] [Closed] (FLINK-13924) Add summarizer and summary for sparse vector and dense vector.

2022-10-16 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-13924. Resolution: Won't Do > Add summarizer and summary for sparse vector and dense vector. >

  1   2   >