JingsongLi closed pull request #569: [FLINK-31269] Split hive connector to each
module of each version
URL: https://github.com/apache/flink-table-store/pull/569
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
gaoyunhaii commented on PR #21736:
URL: https://github.com/apache/flink/pull/21736#issuecomment-1459669377
Hi @XComp the option of having the information in the resource direction
looks good to me, I'll update the PR and also squash the commits.
--
This is an automated message from the A
[
https://issues.apache.org/jira/browse/FLINK-31307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697765#comment-17697765
]
Yun Tang commented on FLINK-31307:
--
What's the meaning of {{2.2.1}} after {{frocksdbjni
WencongLiu commented on PR #22128:
URL: https://github.com/apache/flink/pull/22128#issuecomment-1459661390
cc @reswqa
--
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 un
WencongLiu commented on PR #22129:
URL: https://github.com/apache/flink/pull/22129#issuecomment-1459661015
cc @reswqa
--
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 un
WencongLiu commented on PR #22129:
URL: https://github.com/apache/flink/pull/22129#issuecomment-1459660239
cc @reswqa
--
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 un
flinkbot commented on PR #22129:
URL: https://github.com/apache/flink/pull/22129#issuecomment-1459658319
## CI report:
* 9cb47c24198a1806cffbfd41515500284f92d486 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #22128:
URL: https://github.com/apache/flink/pull/22128#issuecomment-1459658196
## CI report:
* 6e3d0b7ae2fc6cea17d3822b4fcf6844c927171e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
WencongLiu opened a new pull request, #22129:
URL: https://github.com/apache/flink/pull/22129
fix ConnectionUtilsTest.testFindConnectingAddressWhenGetLocalHostThrows
swallows IllegalArgumentException
--
This is an automated message from the Apache Git Service.
To respond to the message, p
WencongLiu opened a new pull request, #22128:
URL: https://github.com/apache/flink/pull/22128
fix ConnectionUtilsTest.testFindConnectingAddressWhenGetLocalHostThrows
swallows IllegalArgumentException
--
This is an automated message from the Apache Git Service.
To respond to the message, p
lincoln-lil commented on code in PR #22127:
URL: https://github.com/apache/flink/pull/22127#discussion_r1129043195
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationManager.java:
##
@@ -183,12 +190,15 @@ public ResultSet fet
[
https://issues.apache.org/jira/browse/FLINK-30829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-30829.
--
Fix Version/s: 1.18.0
Resolution: Fixed
master(1.18) via ed30a4f906f35654745ca2f694b540ed50e0e1
[
https://issues.apache.org/jira/browse/FLINK-30829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-30829:
---
Affects Version/s: 1.18.0
> Make the backpressure tab could be sort by the backpressure level
>
reswqa commented on PR #22108:
URL: https://github.com/apache/flink/pull/22108#issuecomment-1459628828
Thanks @yangjunhan, meged.
--
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
reswqa merged PR #22108:
URL: https://github.com/apache/flink/pull/22108
--
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-31356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697746#comment-17697746
]
Yanfei Lei commented on FLINK-31356:
Did any POJO fields update when restoring? Is i
reswqa commented on PR #22108:
URL: https://github.com/apache/flink/pull/22108#issuecomment-1459620850
@yangjunhan, Would you mind taking a look at this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
[
https://issues.apache.org/jira/browse/FLINK-31298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697743#comment-17697743
]
Weijie Guo commented on FLINK-31298:
master(1.18) via 7c5b7be5bc165a9799f10b5761a6ff
reswqa commented on PR #22110:
URL: https://github.com/apache/flink/pull/22110#issuecomment-1459617373
@WencongLiu We should backport this to relase-1.16 and release-1.17 also.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/FLINK-27258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jia Fan closed FLINK-27258.
---
Resolution: Invalid
> Deployment Chinese document malformed text
> -
reswqa merged PR #22110:
URL: https://github.com/apache/flink/pull/22110
--
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
yuzelin commented on PR #584:
URL:
https://github.com/apache/flink-table-store/pull/584#issuecomment-1459614486
The same problem I have met before. I've pushed some commits to try to solve
the problem. You can rebase master.
--
This is an automated message from the Apache Git Service.
To
reswqa commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1129022590
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java:
##
@@ -242,23 +243,206 @@ public void testRecycleAfterDestroy() {
reswqa commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1129022590
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java:
##
@@ -242,23 +243,206 @@ public void testRecycleAfterDestroy() {
reswqa commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1129012456
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -503,12 +508,11 @@ private void onGlobalPoolAvailable() {
reswqa commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1129012456
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -503,12 +508,11 @@ private void onGlobalPoolAvailable() {
reswqa commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1129012456
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -503,12 +508,11 @@ private void onGlobalPoolAvailable() {
reswqa commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1129012456
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -503,12 +508,11 @@ private void onGlobalPoolAvailable() {
1996fanrui commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1128996203
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -503,12 +508,11 @@ private void onGlobalPoolAvailable() {
[
https://issues.apache.org/jira/browse/FLINK-31351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697736#comment-17697736
]
Shengkai Fang commented on FLINK-31351:
---
I think the main cause is that the Thread
FangYongs commented on PR #426:
URL:
https://github.com/apache/flink-table-store/pull/426#issuecomment-1459593126
Hi @JingsongLi I have updated this PR, please help to review it again, thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
[
https://issues.apache.org/jira/browse/FLINK-31365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31365.
Fix Version/s: table-store-0.4.0
Assignee: yuzelin
Resolution: Fixed
master: 65335
[
https://issues.apache.org/jira/browse/FLINK-31365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31365:
---
Labels: pull-request-available (was: )
> Simplify FlinkActionsE2ETest#testMergeInto
> -
JingsongLi merged PR #587:
URL: https://github.com/apache/flink-table-store/pull/587
--
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...@
1996fanrui commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1128996203
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -503,12 +508,11 @@ private void onGlobalPoolAvailable() {
FangYongs commented on PR #569:
URL:
https://github.com/apache/flink-table-store/pull/569#issuecomment-1459580158
> >
>
> Have you tried to setup metastore in hive-2.1-cdh-6.3, and use
flink-table-store-hive-catalog.jar in Flink side?
Hi @JingsongLi I also test for hive-2.1.
FangYongs commented on PR #569:
URL:
https://github.com/apache/flink-table-store/pull/569#issuecomment-1459579297
Thanks @tsreaper DONE
--
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
1996fanrui commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1128996203
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -503,12 +508,11 @@ private void onGlobalPoolAvailable() {
fsk119 commented on PR #16532:
URL: https://github.com/apache/flink/pull/16532#issuecomment-1459564895
@snuyanzin Sorry for the late response. I think SqlGatewayE2ECase is a good
point to restart the work. We have introduced a hive docker in the test.
--
This is an automated message from
wuchong merged PR #22104:
URL: https://github.com/apache/flink/pull/22104
--
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.apach
[
https://issues.apache.org/jira/browse/FLINK-31311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31311.
Resolution: Fixed
master: e715ac81a906e8f1b285d3847cc75879bb54d062
> Supports Bounded Watermark s
JingsongLi merged PR #576:
URL: https://github.com/apache/flink-table-store/pull/576
--
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...@
flinkbot commented on PR #22127:
URL: https://github.com/apache/flink/pull/22127#issuecomment-1459422574
## CI report:
* 2331a3f92229c2cd6dfd0f2dc418f77fbc83e4c3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yuzelin created FLINK-31365:
---
Summary: Simplify FlinkActionsE2ETest#testMergeInto
Key: FLINK-31365
URL: https://issues.apache.org/jira/browse/FLINK-31365
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-31351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31351:
---
Labels: pull-request-available test-stability (was: test-stability)
> HiveServer2EndpointIT
fsk119 opened a new pull request, #22127:
URL: https://github.com/apache/flink/pull/22127
## What is the purpose of the change
*We should not stop the thread by force because it may cause an inconsistent
state. So we just notify the users it has the possibility to cause resour
[
https://issues.apache.org/jira/browse/FLINK-31351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-31351:
-
Assignee: Shengkai Fang
> HiveServer2EndpointITCase.testExecuteStatementInSyncModeWithR
reswqa closed pull request #22122: [BP-1.17][FLINK-31346][runtime] IO scheduler
does not throw TimeoutException if numRequestedBuffers is greater than 0.
URL: https://github.com/apache/flink/pull/22122
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
reswqa commented on PR #22122:
URL: https://github.com/apache/flink/pull/22122#issuecomment-1459371675
closed via 54c67e5e08c11ef9a538abbf14618f9e27be18f7.
--
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
reswqa commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1128947802
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java:
##
@@ -242,23 +243,206 @@ public void testRecycleAfterDestroy() {
zhangjun0x01 commented on PR #584:
URL:
https://github.com/apache/flink-table-store/pull/584#issuecomment-1459354880
> @zhangjun0x01 Can we consider to use bucket number as streaming default
parallelism? And use parallelism inference only for batch source.
ok
--
This is an automat
zhangjun0x01 commented on PR #584:
URL:
https://github.com/apache/flink-table-store/pull/584#issuecomment-1459353387
> I guess why there are test failures is because too much parallelism has
been derived, resulting in scheduling failures.
Should we disable parallelism inference in de
masteryhx commented on code in PR #21835:
URL: https://github.com/apache/flink/pull/21835#discussion_r1128942248
##
flink-core/src/main/java/org/apache/flink/api/common/state/StateTtlConfig.java:
##
@@ -437,18 +465,43 @@ public boolean runCleanupForEveryRecord() {
[
https://issues.apache.org/jira/browse/FLINK-30983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-30983:
-
Fix Version/s: 1.17.0
1.18.0
> the security.ssl.algorithms configuration does not tak
masteryhx commented on code in PR #21835:
URL: https://github.com/apache/flink/pull/21835#discussion_r1128940896
##
flink-core/src/main/java/org/apache/flink/api/common/state/StateTtlConfig.java:
##
@@ -298,12 +298,40 @@ public Builder cleanupInRocksdbCompactFilter(long
queryTi
JingsongLi commented on PR #584:
URL:
https://github.com/apache/flink-table-store/pull/584#issuecomment-1459327789
@zhangjun0x01 Can we consider to use bucket number as default parallelism?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
JunRuiLee commented on code in PR #22098:
URL: https://github.com/apache/flink/pull/22098#discussion_r1128940538
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultPreferredLocationsRetriever.java:
##
@@ -95,8 +95,7 @@ private CompletableFuture>
getPreferr
huwh commented on code in PR #22098:
URL: https://github.com/apache/flink/pull/22098#discussion_r1128938614
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultPreferredLocationsRetriever.java:
##
@@ -95,8 +95,7 @@ private CompletableFuture>
getPreferredLoc
reswqa commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1128937275
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -503,12 +508,11 @@ private void onGlobalPoolAvailable() {
reswqa commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1128937275
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -503,12 +508,11 @@ private void onGlobalPoolAvailable() {
reswqa commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1128937275
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -503,12 +508,11 @@ private void onGlobalPoolAvailable() {
flinkbot commented on PR #22126:
URL: https://github.com/apache/flink/pull/22126#issuecomment-1459297877
## CI report:
* 79c14fdf6cfa1d56740e66d78e7b737b803e7591 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31363:
---
Labels: pull-request-available (was: )
> KafkaSink failed to commit transactions under EXAC
lightzhao opened a new pull request, #22126:
URL: https://github.com/apache/flink/pull/22126
## What is the purpose of the change
[FLINK-31363](https://issues.apache.org/jira/projects/FLINK/issues/FLINK-31363)
When KafkaSink starts Exactly once and no data is writte
Ming Li created FLINK-31364:
---
Summary: [Flink] add metrics for TableStore
Key: FLINK-31364
URL: https://issues.apache.org/jira/browse/FLINK-31364
Project: Flink
Issue Type: Improvement
Co
reswqa commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1128926904
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -669,6 +669,13 @@ public void setNumBuffers(int numBuffers) {
masteryhx commented on PR #21635:
URL: https://github.com/apache/flink/pull/21635#issuecomment-1459246416
> Hey @masteryhx, do you plan to work on that for 1.18?
Sure, I'd like to. Thanks a lot for the reminder.
Big sorry for the delayed update due to my personal business last month
[
https://issues.apache.org/jira/browse/FLINK-31359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697703#comment-17697703
]
Weijie Guo edited comment on FLINK-31359 at 3/8/23 3:00 AM:
[
https://issues.apache.org/jira/browse/FLINK-31359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31359.
--
Resolution: Fixed
master(1.18) via eff9b16799f162f31058be5acac567943a446dea.
> HsResultPartitionTest
[
https://issues.apache.org/jira/browse/FLINK-31359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31359:
---
Fix Version/s: 1.18.0
> HsResultPartitionTest fails with fatal error
> -
JunRuiLee commented on PR #22098:
URL: https://github.com/apache/flink/pull/22098#issuecomment-1459238292
@huwh @zhuzhurk Thanks for review this pr and I've addressed comments, PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
reswqa merged PR #22125:
URL: https://github.com/apache/flink/pull/22125
--
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
lightzhao created FLINK-31363:
-
Summary: KafkaSink failed to commit transactions under
EXACTLY_ONCE semantics
Key: FLINK-31363
URL: https://issues.apache.org/jira/browse/FLINK-31363
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697698#comment-17697698
]
Wencong Liu commented on FLINK-31298:
-
cc [~mapohl]
> ConnectionUtilsTest.testFind
WencongLiu commented on PR #22121:
URL: https://github.com/apache/flink/pull/22121#issuecomment-1459222793
@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
1996fanrui commented on code in PR #22084:
URL: https://github.com/apache/flink/pull/22084#discussion_r1128900085
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -503,12 +508,11 @@ private void onGlobalPoolAvailable() {
Fanoid commented on code in PR #210:
URL: https://github.com/apache/flink-ml/pull/210#discussion_r1128905027
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/sharedstorage/SharedStorage.java:
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
Fanoid commented on code in PR #210:
URL: https://github.com/apache/flink-ml/pull/210#discussion_r1128889422
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/sharedstorage/SharedStorage.java:
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
TanYuxin-tyx commented on PR #22125:
URL: https://github.com/apache/flink/pull/22125#issuecomment-1459208813
This change LGTM.
I found similar solutions to the issue, e.g., in SchedulerFactory,
KubernetesLeaderElector, etc.
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-31346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697402#comment-17697402
]
Weijie Guo edited comment on FLINK-31346 at 3/8/23 2:34 AM:
Fanoid commented on code in PR #210:
URL: https://github.com/apache/flink-ml/pull/210#discussion_r1128889422
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/sharedstorage/SharedStorage.java:
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
Fanoid commented on code in PR #210:
URL: https://github.com/apache/flink-ml/pull/210#discussion_r1128873310
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/sharedstorage/SharedStorageContextImpl.java:
##
@@ -0,0 +1,117 @@
+/*
+ * Licensed to the Apache Software Founda
[
https://issues.apache.org/jira/browse/FLINK-31343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31343.
Resolution: Fixed
master: d1c224890dad80c1d7664dc3011534b3ae1679f9
> Remove JMH dependency in fli
JingsongLi merged PR #585:
URL: https://github.com/apache/flink-table-store/pull/585
--
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...@
FangYongs commented on PR #585:
URL:
https://github.com/apache/flink-table-store/pull/585#issuecomment-1459150128
Thanks @JingsongLi LGTM +1
--
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
LadyForest commented on PR #21452:
URL: https://github.com/apache/flink/pull/21452#issuecomment-1459148347
> @LadyForest this change looks reasonable however now there are some
conflicts... Do you mind if I ask you to rebase?
Sure. I'll do the rebase.
--
This is an automated messa
Fanoid commented on code in PR #210:
URL: https://github.com/apache/flink-ml/pull/210#discussion_r1128853646
##
flink-ml-lib/src/main/java/org/apache/flink/ml/common/gbt/operators/CalcLocalSplitsOperator.java:
##
@@ -0,0 +1,129 @@
+/*
+ * Licensed to the Apache Software Foundati
Fanoid commented on code in PR #210:
URL: https://github.com/apache/flink-ml/pull/210#discussion_r1128853646
##
flink-ml-lib/src/main/java/org/apache/flink/ml/common/gbt/operators/CalcLocalSplitsOperator.java:
##
@@ -0,0 +1,129 @@
+/*
+ * Licensed to the Apache Software Foundati
fsk119 closed pull request #21638: [FLINK-29948][rest] Add rootCause in the
ErrorResponseBody
URL: https://github.com/apache/flink/pull/21638
--
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 spec
weifonghsia commented on PR #22085:
URL: https://github.com/apache/flink/pull/22085#issuecomment-1459075862
@MartijnVisser - Would you be able to review this PR?
Fairly small doc change
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-31362:
---
Description:
In Calcite 1.33.0, C-style escape strings have been supported. We could
leverage it to enhance
gyfora commented on code in PR #546:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/546#discussion_r1128753730
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/metrics/MetricAggregator.java:
##
@@ -34,7 +33,11
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-31362:
---
Component/s: Table SQL / API
(was: Documentation)
> Upgrade to Calcite version to 1.33.
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-31362:
---
Summary: Upgrade to Calcite version to 1.33.0 (was: Add document about how
to use C-style escape strings)
[
https://issues.apache.org/jira/browse/FLINK-31362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-31362:
---
Description:
In Calcite 1.33.0, C-style escape strings have been supported. We should
outline its usage in
Aitozi created FLINK-31362:
--
Summary: Add document about how to use C-style escape strings
Key: FLINK-31362
URL: https://issues.apache.org/jira/browse/FLINK-31362
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-31361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697645#comment-17697645
]
David Anderson commented on FLINK-31361:
I'm using the sql-client to create the
David Anderson created FLINK-31361:
--
Summary: job created by sql-client can't authenticate to kafka,
can't find org.apache.kafka.common.security.plain.PlainLoginModule
Key: FLINK-31361
URL: https://issues.apache.
[
https://issues.apache.org/jira/browse/FLINK-30609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-30609:
--
Assignee: Prabcs (was: Matyas Orhidi)
> Add ephemeral storage to CRD
> -
[
https://issues.apache.org/jira/browse/FLINK-30609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697635#comment-17697635
]
Gyula Fora commented on FLINK-30609:
[~morhidi] do you mind if [~pbharaj] takes over
1 - 100 of 221 matches
Mail list logo