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 Foundatio
[
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
> -
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 transforme
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
Is
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 Identifi
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.
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 commen
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 addCurrentUserCreden
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 @@
+
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 i
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 addCurrentUserCreden
[
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
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: issues-unsubscr...@
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 speci
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 Type
[
https://issues.apache.org/jira/browse/FLINK-30018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634188#comment-17634188
]
luoyuxia commented on FLINK-30018:
--
[~jackwangcs] Thanks for reporting. Could you pleas
[
https://issues.apache.org/jira/browse/FLINK-29922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634181#comment-17634181
]
Jingsong Lee edited comment on FLINK-29922 at 11/15/22 6:41 AM:
--
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 closeSession(Session
[
https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634185#comment-17634185
]
Qingsheng Ren commented on FLINK-26974:
---
https://dev.azure.com/apache-flink/apache
[
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
> --
[
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:
feffebd
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 closeSession(Session
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 closeSession(Session
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 closeSession(Session
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: issues-unsubscr...@
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 speci
[
https://issues.apache.org/jira/browse/FLINK-28394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634177#comment-17634177
]
Huang Xingbo commented on FLINK-28394:
--
`Python py36-cython` is not the cause of th
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 closeSession(Session
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.
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 getGatewayI
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.
T
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 getGatewayI
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
createReaderF
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 testOpenSessionW
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 testOpenSessionW
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 testOpenSessionW
[
https://issues.apache.org/jira/browse/FLINK-29298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634138#comment-17634138
]
Weijie Guo edited comment on FLINK-29298 at 11/15/22 3:32 AM:
[
https://issues.apache.org/jira/browse/FLINK-29298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634138#comment-17634138
]
Weijie Guo commented on FLINK-29298:
[~AlexXXX] This pr has not been reviewed, so it
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 OperationExecutor(S
[
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
> --
>
>
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 Serv
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 comment
[
https://issues.apache.org/jira/browse/FLINK-29298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634128#comment-17634128
]
AlexHu commented on FLINK-29298:
I tested the new github commit, but it still exists the
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) un
[
https://issues.apache.org/jira/browse/FLINK-29585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634112#comment-17634112
]
Aitozi commented on FLINK-29585:
fyi, I'm trying to work on this now. I will ping you fo
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
testAkkaRpcService_Sc
[
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: 13d2c
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: issues-unsubscr...@
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 specif
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, p
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 Sof
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 to
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) and
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 speci
[
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
[
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 savepo
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 in
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`
[
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 m
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
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
[
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 stat
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 o
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 comm
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 commen
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 addCurrentUserCredentials
[
https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634015#comment-17634015
]
Andriy Redko commented on FLINK-25756:
--
Retargeting to https://github.com/apache/fl
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
Iss
[
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
> --
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 G
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 to
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
[
https://issues.apache.org/jira/browse/FLINK-29974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17633992#comment-17633992
]
Sriram Ganesh commented on FLINK-29974:
---
[~gyfora] - [https://github.com/apache/fl
[
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 su
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 `CancelSes
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 testSetAndReset
[
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 impl
[
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 reporte
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: issues-unsubscr...@flink.apache
[
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 repo
[
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 repo
[
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 Prometh
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: issues-unsubscr...@flink.apache
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 closeSession(SessionHa
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 closeSession(SessionHa
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 closeSession(SessionHa
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 getGatewayInf
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 getGatewayInf
[
https://issues.apache.org/jira/browse/FLINK-29959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17633948#comment-17633948
]
Gyula Fora edited comment on FLINK-29959 at 11/14/22 5:10 PM:
[
https://issues.apache.org/jira/browse/FLINK-29959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17633948#comment-17633948
]
Gyula Fora commented on FLINK-29959:
There are 2 main problems that we target here:
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 testOpenSessionWit
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 testOpenSessionWit
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 OperationExecutor(Ses
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 message
[
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
[{{480e6ed}}|https://github.com/apache/flink/commit/480e6edf9732f8334ef757
[
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
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: issues-unsubscr...@flink.apac
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 on
[
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: FL
[
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 - 100 of 260 matches
Mail list logo
