[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #172: [FLINK-29592] Add Estimator and Transformer for RobustScaler

jiangxin369 commented on code in PR #172: URL: https://github.com/apache/flink-ml/pull/172#discussion_r1022450791 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/robustscaler/RobustScalerModel.java: ## @@ -0,0 +1,179 @@ +/* + * Licensed to the Apache Software

[jira] [Updated] (FLINK-29602) Add Transformer for SQLTransformer

[ https://issues.apache.org/jira/browse/FLINK-29602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29602: --- Labels: pull-request-available (was: ) > Add Transformer for SQLTransformer >

[GitHub] [flink-ml] yunfengzhou-hub opened a new pull request, #175: [FLINK-29602] Add Transformer for SQLTransformer

yunfengzhou-hub opened a new pull request, #175: URL: https://github.com/apache/flink-ml/pull/175 ## What is the purpose of the change This PR adds the Transformer for the SQL transformer algorithm. ## Brief change log - Adds Transformer implementation of SQL

[jira] [Created] (FLINK-30027) Fields min and max in BinaryTableStats support lazy deserialization

Shammon created FLINK-30027: --- Summary: Fields min and max in BinaryTableStats support lazy deserialization Key: FLINK-30027 URL: https://issues.apache.org/jira/browse/FLINK-30027 Project: Flink

[GitHub] [flink] snuyanzin commented on a diff in pull request #20746: [FLINK-28893][table] Add built-in conv function.

snuyanzin commented on code in PR #20746: URL: https://github.com/apache/flink/pull/20746#discussion_r1022446011 ## docs/data/sql_functions.yml: ## @@ -228,6 +228,13 @@ arithmetic: - sql: UUID() table: uuid() description: Returns an UUID (Universally Unique

[GitHub] [flink] link3280 commented on pull request #21292: [FLINK-28617][SQL Gateway] Support stop job statement in SqlGatewayService

link3280 commented on PR #21292: URL: https://github.com/apache/flink/pull/21292#issuecomment-1314918042 @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.

[GitHub] [flink] houhang1005 commented on pull request #21268: [FLINK-29952][table-api]Append the detail of the exception when drop tamporary table.

houhang1005 commented on PR #21268: URL: https://github.com/apache/flink/pull/21268#issuecomment-1314914903 @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

[GitHub] [flink] gaborgsomogyi commented on a diff in pull request #21294: [FLINK-29704][runtime][security] E2E test for delegation token framework

gaborgsomogyi commented on code in PR #21294: URL: https://github.com/apache/flink/pull/21294#discussion_r1022432629 ## flink-runtime/src/main/java/org/apache/flink/runtime/security/token/DelegationTokenUpdater.java: ## @@ -38,18 +38,18 @@ public static void

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #172: [FLINK-29592] Add Estimator and Transformer for RobustScaler

yunfengzhou-hub commented on code in PR #172: URL: https://github.com/apache/flink-ml/pull/172#discussion_r1022262117 ## flink-ml-python/pyflink/examples/ml/feature/robustscaler_example.py: ## @@ -0,0 +1,74 @@

[GitHub] [flink] snuyanzin commented on pull request #21203: [FLINK-21239][Table SQL/API] Upgrade Calcite to 1.28.0

snuyanzin commented on PR #21203: URL: https://github.com/apache/flink/pull/21203#issuecomment-1314904648 Current failure is related to https://issues.apache.org/jira/browse/FLINK-24119 There are some fixes however this branch does not include them since it is not rebased... -- This

[GitHub] [flink] gaborgsomogyi commented on a diff in pull request #21294: [FLINK-29704][runtime][security] E2E test for delegation token framework

gaborgsomogyi commented on code in PR #21294: URL: https://github.com/apache/flink/pull/21294#discussion_r1022432629 ## flink-runtime/src/main/java/org/apache/flink/runtime/security/token/DelegationTokenUpdater.java: ## @@ -38,18 +38,18 @@ public static void

[jira] [Closed] (FLINK-28552) GenerateUtils#generateCompare supports MULTISET and MAP

[ https://issues.apache.org/jira/browse/FLINK-28552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28552. Assignee: Nicholas Jiang Resolution: Fixed master: dbe49f7ab6b936a51c09a066c8212df96e744324

[GitHub] [flink-table-store] JingsongLi merged pull request #375: [FLINK-28552] GenerateUtils#generateCompare supports MULTISET and MAP

JingsongLi merged PR #375: URL: https://github.com/apache/flink-table-store/pull/375 -- 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:

[GitHub] [flink] snuyanzin commented on pull request #21203: [FLINK-21239][Table SQL/API] Upgrade Calcite to 1.28.0

snuyanzin commented on PR #21203: URL: https://github.com/apache/flink/pull/21203#issuecomment-1314873046 @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

[jira] [Created] (FLINK-30026) Support database table include option in debezium-json

Zhiwen Sun created FLINK-30026: -- Summary: Support database table include option in debezium-json Key: FLINK-30026 URL: https://issues.apache.org/jira/browse/FLINK-30026 Project: Flink Issue

[jira] [Commented] (FLINK-30018) NPE error in generated StreamExecCalc

[ https://issues.apache.org/jira/browse/FLINK-30018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634188#comment-17634188 ] luoyuxia commented on FLINK-30018: -- [~jackwangcs] Thanks for reporting. Could you please share us the

[jira] [Comment Edited] (FLINK-29922) Table store hive catalog support create external table

[ https://issues.apache.org/jira/browse/FLINK-29922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634181#comment-17634181 ] Jingsong Lee edited comment on FLINK-29922 at 11/15/22 6:41 AM: master:

[GitHub] [flink] yuzelin commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

yuzelin commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1022361091 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java: ## @@ -79,6 +82,32 @@ public void

[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=17634185#comment-17634185 ] Qingsheng Ren commented on FLINK-26974: ---

[jira] [Assigned] (FLINK-27838) Support timeout mechansim for executeStatement API

[ https://issues.apache.org/jira/browse/FLINK-27838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-27838: - Assignee: yuzelin > Support timeout mechansim for executeStatement API >

[jira] [Closed] (FLINK-29922) Table store hive catalog support create external table

[ https://issues.apache.org/jira/browse/FLINK-29922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29922. Fix Version/s: table-store-0.3.0 Assignee: konwu Resolution: Fixed master:

[GitHub] [flink] yuzelin commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

yuzelin commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1022368927 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java: ## @@ -79,6 +82,32 @@ public void

[GitHub] [flink] yuzelin commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

yuzelin commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1022368927 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java: ## @@ -79,6 +82,32 @@ public void

[GitHub] [flink] yuzelin commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

yuzelin commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1022368927 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java: ## @@ -79,6 +82,32 @@ public void

[GitHub] [flink-table-store] JingsongLi merged pull request #357: [FLINK-29922] Support create external table for hive catalog

JingsongLi merged PR #357: URL: https://github.com/apache/flink-table-store/pull/357 -- 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:

[GitHub] [flink] snuyanzin commented on pull request #21203: [FLINK-21239][Table SQL/API] Upgrade Calcite to 1.28.0

snuyanzin commented on PR #21203: URL: https://github.com/apache/flink/pull/21203#issuecomment-1314832541 @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

[jira] [Commented] (FLINK-28394) Python py36-cython: InvocationError for command install_command.sh fails with exit code 1

[ https://issues.apache.org/jira/browse/FLINK-28394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634177#comment-17634177 ] Huang Xingbo commented on FLINK-28394: -- `Python py36-cython` is not the cause of the actual error.

[GitHub] [flink] yuzelin commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

yuzelin commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1022361091 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java: ## @@ -79,6 +82,32 @@ public void

[GitHub] [flink] link3280 commented on pull request #21292: [FLINK-28617][SQL Gateway] Support stop job statement in SqlGatewayService

link3280 commented on PR #21292: URL: https://github.com/apache/flink/pull/21292#issuecomment-1314826387 @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.

[GitHub] [flink] yuzelin commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

yuzelin commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1022353242 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java: ## @@ -311,8 +340,29 @@ public GatewayInfo

[GitHub] [flink] vvcephei commented on pull request #21278: [FLINK-29962] Exclude jamon 2.3.1 from dependencies

vvcephei commented on PR #21278: URL: https://github.com/apache/flink/pull/21278#issuecomment-1314788448 Thanks, @jgrier ! -- 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.

[GitHub] [flink] yuzelin commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

yuzelin commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1022313111 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java: ## @@ -311,8 +340,29 @@ public GatewayInfo

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #375: [FLINK-28552] GenerateUtils#generateCompare supports MULTISET and MAP

JingsongLi commented on code in PR #375: URL: https://github.com/apache/flink-table-store/pull/375#discussion_r1022311783 ## flink-table-store-format/src/main/java/org/apache/flink/table/store/format/orc/OrcFileFormat.java: ## @@ -111,7 +113,7 @@ public BulkFormat

[GitHub] [flink] yuzelin commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

yuzelin commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1022294537 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/SqlGatewayServiceITCase.java: ## @@ -157,6 +169,80 @@ public void

[GitHub] [flink] yuzelin commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

yuzelin commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1022288458 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/SqlGatewayServiceITCase.java: ## @@ -157,6 +169,80 @@ public void

[GitHub] [flink] yuzelin commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

yuzelin commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1022288458 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/SqlGatewayServiceITCase.java: ## @@ -157,6 +169,80 @@ public void

[jira] [Comment Edited] (FLINK-29298) LocalBufferPool request buffer from NetworkBufferPool hanging

[ https://issues.apache.org/jira/browse/FLINK-29298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634138#comment-17634138 ] Weijie Guo edited comment on FLINK-29298 at 11/15/22 3:32 AM: -- [~AlexXXX]

[jira] [Commented] (FLINK-29298) LocalBufferPool request buffer from NetworkBufferPool hanging

[ https://issues.apache.org/jira/browse/FLINK-29298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634138#comment-17634138 ] Weijie Guo commented on FLINK-29298: [~AlexXXX] This pr has not been reviewed, so it may not be the

[GitHub] [flink] yuzelin commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

yuzelin commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1022277824 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java: ## @@ -84,6 +90,30 @@ public

[jira] [Assigned] (FLINK-29965) Support Spark/Hive with S3

[ https://issues.apache.org/jira/browse/FLINK-29965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29965: Assignee: Jane Chan > Support Spark/Hive with S3 > -- > >

[GitHub] [flink] JerryYue-M commented on pull request #21197: [FLINK-29801] OperatorCoordinator need open the way to operate metric…

JerryYue-M commented on PR #21197: URL: https://github.com/apache/flink/pull/21197#issuecomment-1314699793 @zhuzhurk all your comments had resolved and no checkstyle and compile problems, can you take a look at those new changes -- This is an automated message from the Apache Git

[GitHub] [flink] JerryYue-M commented on pull request #21197: [FLINK-29801] OperatorCoordinator need open the way to operate metric…

JerryYue-M commented on PR #21197: URL: https://github.com/apache/flink/pull/21197#issuecomment-1314697589 @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

[jira] [Commented] (FLINK-29298) LocalBufferPool request buffer from NetworkBufferPool hanging

[ https://issues.apache.org/jira/browse/FLINK-29298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634128#comment-17634128 ] AlexHu commented on FLINK-29298: I tested the new github commit, but it still exists the same problem.

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #172: [FLINK-29592] Add Estimator and Transformer for RobustScaler

yunfengzhou-hub commented on code in PR #172: URL: https://github.com/apache/flink-ml/pull/172#discussion_r1022233623 ## flink-ml-lib/src/test/java/org/apache/flink/ml/feature/RobustScalerTest.java: ## @@ -0,0 +1,318 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[jira] [Commented] (FLINK-29585) Migrate TableSchema to Schema for Hive connector

[ https://issues.apache.org/jira/browse/FLINK-29585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634112#comment-17634112 ] Aitozi commented on FLINK-29585: fyi, I'm trying to work on this now. I will ping you for review after I

[GitHub] [flink] 1996fanrui commented on a diff in pull request #21304: [FLINK-30003][rpc] Wait the scheduler future is done before check

1996fanrui commented on code in PR #21304: URL: https://github.com/apache/flink/pull/21304#discussion_r1022244913 ## flink-rpc/flink-rpc-akka/src/test/java/org/apache/flink/runtime/rpc/akka/ContextClassLoadingSettingTest.java: ## @@ -157,22 +161,26 @@ void

[jira] [Closed] (FLINK-30013) Add data type compatibility check in SchemaChange.updateColumnType

[ https://issues.apache.org/jira/browse/FLINK-30013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30013. Fix Version/s: table-store-0.3.0 Assignee: Shammon Resolution: Fixed master:

[GitHub] [flink-table-store] JingsongLi merged pull request #378: [FLINK-30013] Add check update column type

JingsongLi merged PR #378: URL: https://github.com/apache/flink-table-store/pull/378 -- 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:

[GitHub] [flink] lincoln-lil commented on pull request #20745: [FLINK-28988] Don't push above filters down into the right table for temporal join

lincoln-lil commented on PR #20745: URL: https://github.com/apache/flink/pull/20745#issuecomment-1314650211 > Hi @lincoln-lil, I have updated the PR accordingly, please have a look. BTW, is there a principle that filters can not be pushed down into a temporal table? There's no

[GitHub] [flink] liuzhuang2017 commented on pull request #21255: [hotfix][docs] Update the missing parts of this fault_tolerance Chinese documentation.

liuzhuang2017 commented on PR #21255: URL: https://github.com/apache/flink/pull/21255#issuecomment-1314638280 @MartijnVisser ，Thank you very much for your review, I have revised her as you suggested. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #174: [FLINK-29604] Add Estimator and Transformer for CountVectorizer

yunfengzhou-hub commented on code in PR #174: URL: https://github.com/apache/flink-ml/pull/174#discussion_r1021271301 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/countvectorizer/CountVectorizerModelParams.java: ## @@ -0,0 +1,68 @@ +/* + * Licensed to the Apache

[GitHub] [flink] liuzhuang2017 commented on pull request #21256: [hotfix][flink-runtime] Fix the typo of RecordingChannelStateWriter class.

liuzhuang2017 commented on PR #21256: URL: https://github.com/apache/flink/pull/21256#issuecomment-1314621391 @MartijnVisser ,Thank you for your patient suggestion, I will pay attention to what you mentioned later. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] snuyanzin commented on pull request #21203: [FLINK-21239][Table SQL/API] Upgrade Calcite to 1.28.0

snuyanzin commented on PR #21203: URL: https://github.com/apache/flink/pull/21203#issuecomment-1314550031 @twalthr thanks for your feedback I adapted PR to use Janino 3.0.11 (however it requires to copy/paste and change 4 Calcite classes which could be removed once Janino is upgraded)

[GitHub] [flink] snuyanzin commented on pull request #21150: [hotfix] Replace deprecated kafka-clients methods

snuyanzin commented on PR #21150: URL: https://github.com/apache/flink/pull/21150#issuecomment-1314523103 @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

[jira] [Updated] (FLINK-29804) Support convertion of Correlate to Join if correlation variable is unused introduced in Calcite 1.28

[ https://issues.apache.org/jira/browse/FLINK-29804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-29804: Description: It was introduced in https://issues.apache.org/jira/browse/CALCITE-4668 and

[jira] [Updated] (FLINK-30004) Cannot resume deployment after suspend with savepoint due to leftover confgmaps

[ https://issues.apache.org/jira/browse/FLINK-30004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30004: --- Labels: pull-request-available (was: ) > Cannot resume deployment after suspend with

[GitHub] [flink-kubernetes-operator] tweise opened a new pull request, #440: [FLINK-30004] Cleanup deployment after savepoint for Flink versions < 1.15

tweise opened a new pull request, #440: URL: https://github.com/apache/flink-kubernetes-operator/pull/440 ## What is the purpose of the change * Cleanup underlying deployment resources after cancel with savepoint. Flink version < 1.15 is supposed to do that automatically but we see

[GitHub] [flink] flinkbot commented on pull request #21322: [FLINK-30025][table] the max column width is resizable while printing the query result to the client console.

flinkbot commented on PR #21322: URL: https://github.com/apache/flink/pull/21322#issuecomment-1314464135 ## CI report: * 87ad12edc206cf1879012b2fddadec758a9e29b7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-30025) table.execute().print() can only use the default max column width

[ https://issues.apache.org/jira/browse/FLINK-30025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30025: --- Labels: pull-request-available (was: ) > table.execute().print() can only use the default

[GitHub] [flink] JingGe opened a new pull request, #21322: [FLINK-30025][table] the max column width is resizable while printing the query result to the client console.

JingGe opened a new pull request, #21322: URL: https://github.com/apache/flink/pull/21322 ## What is the purpose of the change Currently, the default value 30 of `DEFAULT_MAX_COLUMN_WIDTH` in `PrintStyle` has been used when table.execute().print() has been called. There is no way to

[GitHub] [flink] liuml07 commented on a diff in pull request #20935: [FLINK-29961][doc] Make referencing custom image clearer for Docker

liuml07 commented on code in PR #20935: URL: https://github.com/apache/flink/pull/20935#discussion_r1022040612 ## docs/content.zh/docs/deployment/resource-providers/standalone/docker.md: ## @@ -405,16 +405,24 @@ services: ``` You can then start creating tables and queries

[jira] [Updated] (FLINK-29959) Use optimistic locking when patching resource status

[ https://issues.apache.org/jira/browse/FLINK-29959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29959: --- Labels: pull-request-available (was: ) > Use optimistic locking when patching resource

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #439: [FLINK-29959] Use optimistic locking when updating the status

gyfora opened a new pull request, #439: URL: https://github.com/apache/flink-kubernetes-operator/pull/439 ## What is the purpose of the change Currently the operator uses `patchStatus()` without any resource version locking to update the Flink resources. This means that the operator

[GitHub] [flink] gaborgsomogyi commented on pull request #21294: [FLINK-29704][runtime][security] E2E test for delegation token framework

gaborgsomogyi commented on PR #21294: URL: https://github.com/apache/flink/pull/21294#issuecomment-1314299877 @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

[GitHub] [flink] gaborgsomogyi commented on pull request #21294: [FLINK-29704][runtime][security] E2E test for delegation token framework

gaborgsomogyi commented on PR #21294: URL: https://github.com/apache/flink/pull/21294#issuecomment-1314299718 Pulsar test flaky -- 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

[GitHub] [flink] mbalassi commented on a diff in pull request #21294: [FLINK-29704][runtime][security] E2E test for delegation token framework

mbalassi commented on code in PR #21294: URL: https://github.com/apache/flink/pull/21294#discussion_r1021992440 ## flink-runtime/src/main/java/org/apache/flink/runtime/security/token/DelegationTokenUpdater.java: ## @@ -38,18 +38,18 @@ public static void

[jira] [Commented] (FLINK-25756) Dedicated Opensearch connectors

[ https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634015#comment-17634015 ] Andriy Redko commented on FLINK-25756: -- Retargeting to

[jira] [Created] (FLINK-30025) table.execute().print() can only use the default max column width

Jing Ge created FLINK-30025: --- Summary: table.execute().print() can only use the default max column width Key: FLINK-30025 URL: https://issues.apache.org/jira/browse/FLINK-30025 Project: Flink

[jira] [Assigned] (FLINK-30025) table.execute().print() can only use the default max column width

[ https://issues.apache.org/jira/browse/FLINK-30025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-30025: --- Assignee: Jing Ge > table.execute().print() can only use the default max column width >

[GitHub] [flink-connector-opensearch] reta commented on pull request #1: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

reta commented on PR #1: URL: https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1314252591 @MartijnVisser the POMs and CI scripts have been updated accordingly -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] reta closed pull request #18541: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

reta closed pull request #18541: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors URL: https://github.com/apache/flink/pull/18541 -- 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

[GitHub] [flink] reta commented on pull request #18541: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

reta commented on PR #18541: URL: https://github.com/apache/flink/pull/18541#issuecomment-1314251701 @MartijnVisser I am closing this one in favor of https://github.com/apache/flink-connector-opensearch/pull/1 -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-29974) Session jobs in FINISHED/FAILED state cannot be suspended

[ https://issues.apache.org/jira/browse/FLINK-29974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17633992#comment-17633992 ] Sriram Ganesh commented on FLINK-29974: --- [~gyfora] -

[jira] [Updated] (FLINK-29974) Session jobs in FINISHED/FAILED state cannot be suspended

[ https://issues.apache.org/jira/browse/FLINK-29974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29974: --- Labels: pull-request-available (was: ) > Session jobs in FINISHED/FAILED state cannot be

[GitHub] [flink-kubernetes-operator] rgsriram opened a new pull request, #438: [FLINK-29974] Not allowing the cancelling the which are already in the completed state.

rgsriram opened a new pull request, #438: URL: https://github.com/apache/flink-kubernetes-operator/pull/438 ## What is the purpose of the change *Allowing the only required job can be cancelled.* ## Brief change log - *Changed the `AbstractFlinkService` class

[GitHub] [flink] jnh5y commented on a diff in pull request #21187: [FLINK-27837][sql-gateway] Support statement set in the SQL Gateway

jnh5y commented on code in PR #21187: URL: https://github.com/apache/flink/pull/21187#discussion_r1021916806 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/context/SessionContextTest.java: ## @@ -133,6 +138,79 @@ public void

[jira] [Updated] (FLINK-24235) Only support reporter factories for instantiation

[ https://issues.apache.org/jira/browse/FLINK-24235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24235: - Release Note: Configuring reporters by their class is no longer supported. Reporter

[jira] [Closed] (FLINK-24235) Only support reporter factories for instantiation

[ https://issues.apache.org/jira/browse/FLINK-24235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24235. Resolution: Fixed master: 3c9a394c608125827d224180c44128718972a82c > Only support

[GitHub] [flink] zentol merged pull request #21296: [FLINK-24235][metrics] Only support reporters via factories

zentol merged PR #21296: URL: https://github.com/apache/flink/pull/21296 -- 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-30020) Use separate Prometheus CollectorRegistries

[ https://issues.apache.org/jira/browse/FLINK-30020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-30020: - Release Note: The PrometheusReporters now use a separate CollectorRegistry for each

[jira] [Updated] (FLINK-30020) Use separate Prometheus CollectorRegistries

[ https://issues.apache.org/jira/browse/FLINK-30020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-30020: - Release Note: The PrometheusReporters now use a separate CollectorRegistry for each

[jira] [Closed] (FLINK-30020) Use separate Prometheus CollectorRegistries

[ https://issues.apache.org/jira/browse/FLINK-30020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-30020. Resolution: Fixed master: 4f8a11c48832dd7f8f0804e34aeedd7abd806ef6 > Use separate

[GitHub] [flink] zentol merged pull request #21317: [FLINK-30020][prometheus] Use separate CollectorRegistry

zentol merged PR #21317: URL: https://github.com/apache/flink/pull/21317 -- 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:

[GitHub] [flink] jnh5y commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

jnh5y commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1021878225 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java: ## @@ -79,6 +82,32 @@ public void

[GitHub] [flink] jnh5y commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

jnh5y commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1021876246 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java: ## @@ -79,6 +82,32 @@ public void

[GitHub] [flink] jnh5y commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

jnh5y commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1021874117 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java: ## @@ -79,6 +82,32 @@ public void

[GitHub] [flink] jnh5y commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

jnh5y commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1021870936 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java: ## @@ -311,8 +340,29 @@ public GatewayInfo

[GitHub] [flink] jnh5y commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

jnh5y commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1021869458 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java: ## @@ -311,8 +340,29 @@ public GatewayInfo

[jira] [Comment Edited] (FLINK-29959) Use optimistic locking when patching resource status

[ https://issues.apache.org/jira/browse/FLINK-29959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17633948#comment-17633948 ] Gyula Fora edited comment on FLINK-29959 at 11/14/22 5:10 PM: -- There are 2

[jira] [Commented] (FLINK-29959) Use optimistic locking when patching resource status

[ https://issues.apache.org/jira/browse/FLINK-29959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17633948#comment-17633948 ] Gyula Fora commented on FLINK-29959: There are 2 main problems that we target here: # Status

[GitHub] [flink] jnh5y commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

jnh5y commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1021817966 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/SqlGatewayServiceITCase.java: ## @@ -157,6 +169,80 @@ public void

[GitHub] [flink] jnh5y commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

jnh5y commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1021816197 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/SqlGatewayServiceITCase.java: ## @@ -157,6 +169,80 @@ public void

[GitHub] [flink] jnh5y commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

jnh5y commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1021808704 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java: ## @@ -84,6 +90,30 @@ public

[GitHub] [flink] gaborgsomogyi commented on pull request #21294: [FLINK-29704][runtime][security] E2E test for delegation token framework

gaborgsomogyi commented on PR #21294: URL: https://github.com/apache/flink/pull/21294#issuecomment-1314021449 Rebased to the latest master in order to see that it works even if old DT framework deleted. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Closed] (FLINK-28330) Remove old delegation token framework code when new is working fine

[ https://issues.apache.org/jira/browse/FLINK-28330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-28330. -- Resolution: Fixed  

[jira] [Updated] (FLINK-28330) Remove old delegation token framework code when new is working fine

[ https://issues.apache.org/jira/browse/FLINK-28330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-28330: --- Fix Version/s: 1.17.0 > Remove old delegation token framework code when new is working fine

[GitHub] [flink] mbalassi merged pull request #21147: [FLINK-28330][runtime][security] Remove old delegation token framework code

mbalassi merged PR #21147: URL: https://github.com/apache/flink/pull/21147 -- 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:

[GitHub] [flink] mbalassi commented on pull request #21147: [FLINK-28330][runtime][security] Remove old delegation token framework code

mbalassi commented on PR #21147: URL: https://github.com/apache/flink/pull/21147#issuecomment-1313937515 @gaborgsomogyi verified locally via the k8s operator. Will fix the typo and merge. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Resolved] (FLINK-29444) Setup release scripts

[ https://issues.apache.org/jira/browse/FLINK-29444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-29444. --- Resolution: Done > Setup release scripts > - > > Key:

[jira] [Resolved] (FLINK-29667) Upgrade DynamoDB Connector dependencies from SNAPSHOT to release 1.16

[ https://issues.apache.org/jira/browse/FLINK-29667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-29667. --- Resolution: Fixed > Upgrade DynamoDB Connector dependencies from SNAPSHOT to release 1.16 >

  1   2   3   >