[
https://issues.apache.org/jira/browse/FLINK-31211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694395#comment-17694395
]
leo.zhi edited comment on FLINK-31211 at 2/28/23 8:01 AM:
--
I ch
[
https://issues.apache.org/jira/browse/FLINK-31140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694408#comment-17694408
]
Alexis Sarda-Espinosa commented on FLINK-31140:
---
It does, I just wanted to
[
https://issues.apache.org/jira/browse/FLINK-31082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reopened FLINK-31082:
> Setting maven property 'flink.resueForks' to false in table planner module
> --
[
https://issues.apache.org/jira/browse/FLINK-30978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694409#comment-17694409
]
Shengkai Fang commented on FLINK-30978:
---
Hello [~mapohl]. Thanks for sharing this
[
https://issues.apache.org/jira/browse/FLINK-31082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694411#comment-17694411
]
Martijn Visser commented on FLINK-31082:
Re-opened to create backport to release
Zhipeng Zhang created FLINK-31255:
-
Summary: OperatorUtils#createWrappedOperatorConfig fails to wrap
operator config
Key: FLINK-31255
URL: https://issues.apache.org/jira/browse/FLINK-31255
Project: Fl
[
https://issues.apache.org/jira/browse/FLINK-31255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694417#comment-17694417
]
Zhipeng Zhang commented on FLINK-31255:
---
It seems that the bug comes from not unwr
[
https://issues.apache.org/jira/browse/FLINK-30978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-30978:
--
Priority: Major (was: Blocker)
> ExecutorImplITCase.testInterruptExecution hangs waiting for
[
https://issues.apache.org/jira/browse/FLINK-31255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694417#comment-17694417
]
Zhipeng Zhang edited comment on FLINK-31255 at 2/28/23 8:17 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-31253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694418#comment-17694418
]
Chao Tian commented on FLINK-31253:
---
I want to try it. Coule you please assign it to m
[
https://issues.apache.org/jira/browse/FLINK-31246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694419#comment-17694419
]
Wencong Liu commented on FLINK-31246:
-
Hello [~pvary], I'm quite interested in this
[
https://issues.apache.org/jira/browse/FLINK-31140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694379#comment-17694379
]
Tamir Sagi edited comment on FLINK-31140 at 2/28/23 8:23 AM:
-
1996fanrui merged PR #22019:
URL: https://github.com/apache/flink/pull/22019
--
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.ap
[
https://issues.apache.org/jira/browse/FLINK-31221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694424#comment-17694424
]
Rui Fan commented on FLINK-31221:
-
Hi [~slfan1989] , thanks for your fix:)
apache:maste
[
https://issues.apache.org/jira/browse/FLINK-31221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan closed FLINK-31221.
---
Resolution: Fixed
> Fix Typo in YarnConfigOptions
> -
>
> Key: F
[
https://issues.apache.org/jira/browse/FLINK-31221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-31221:
Fix Version/s: 1.18.0
> Fix Typo in YarnConfigOptions
> -
>
>
1996fanrui commented on PR #22020:
URL: https://github.com/apache/flink/pull/22020#issuecomment-1447768293
@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-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694425#comment-17694425
]
dalongliu commented on FLINK-31104:
---
cc [~guoweijie] , can you also help take a look?
[
https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694431#comment-17694431
]
dalongliu commented on FLINK-31104:
---
I also occur the query timeout when running tpcds
swuferhong opened a new pull request, #22045:
URL: https://github.com/apache/flink/pull/22045
## What is the purpose of the change
This pr is a cherry-pick pr aims to alleviate the CI OOM problem mentioned
in issue: https://issues.apache.org/jira/browse/FLINK-18356 in release-
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694438#comment-17694438
]
Yanfei Lei commented on FLINK-31238:
Thanks for your sharing, this drastically reduc
Ran Tao created FLINK-31256:
---
Summary: FLIP-297: Improve Auxiliary Sql Statements
Key: FLINK-31256
URL: https://issues.apache.org/jira/browse/FLINK-31256
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694438#comment-17694438
]
Yanfei Lei edited comment on FLINK-31238 at 2/28/23 8:48 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-31256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31256:
Description: The FLIP design doc can be found at page
https://cwiki.apache.org/confluence/display/FLINK/FL
[
https://issues.apache.org/jira/browse/FLINK-31256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31256:
Component/s: Table SQL / Planner
> FLIP-297: Improve Auxiliary Sql Statements
> --
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694438#comment-17694438
]
Yanfei Lei edited comment on FLINK-31238 at 2/28/23 8:49 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-31256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31256:
Component/s: Table SQL / API
> FLIP-297: Improve Auxiliary Sql Statements
> --
flinkbot commented on PR #22045:
URL: https://github.com/apache/flink/pull/22045#issuecomment-1447795296
## CI report:
* 83f73a810193e4f06984297367c3c050ed7d1542 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694443#comment-17694443
]
Peter Vary commented on FLINK-31246:
Talked with [~gyfora] about this, and he is con
[
https://issues.apache.org/jira/browse/FLINK-31246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694443#comment-17694443
]
Peter Vary edited comment on FLINK-31246 at 2/28/23 8:57 AM:
-
libenchao commented on code in PR #13081:
URL: https://github.com/apache/flink/pull/13081#discussion_r1119750413
##
docs/content/docs/connectors/table/formats/json.md:
##
@@ -241,6 +241,41 @@ The following table lists the type mapping from Flink type
to JSON type.
+Fe
tsreaper commented on code in PR #550:
URL: https://github.com/apache/flink-table-store/pull/550#discussion_r1119644649
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/TableCommit.java:
##
@@ -18,121 +18,55 @@
package org.apache.flink.table.sto
[
https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694450#comment-17694450
]
Martijn Visser commented on FLINK-22793:
Looking forward to your contributor!
[
https://issues.apache.org/jira/browse/FLINK-31211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694449#comment-17694449
]
Martijn Visser commented on FLINK-31211:
[~leo.zhi] Yes, you need to upgrade
>
[
https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694450#comment-17694450
]
Martijn Visser edited comment on FLINK-22793 at 2/28/23 9:02 AM:
-
wangyang0918 commented on PR #21978:
URL: https://github.com/apache/flink/pull/21978#issuecomment-1447831049
Given that `org.codehaus.mojo:versions-maven-plugin:2.8.1` works well for
the current Flink release process, I also could not fully understand why we
need to bump the version.
--
pvary opened a new pull request, #539:
URL: https://github.com/apache/flink-kubernetes-operator/pull/539
## What is the purpose of the change
Currently the Spec Change message contains the full PodTemplate twice.
This makes the message seriously big and also contains very little use
[
https://issues.apache.org/jira/browse/FLINK-31246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31246:
---
Labels: pull-request-available (was: )
> Remove PodTemplate description from the SpecChange
[
https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-31104:
-
Assignee: Weijie Guo
> TPC-DS test timed out in query 36
>
dmvk commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1119751778
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/VertexParallelism.java:
##
@@ -23,14 +23,27 @@
import java.util.Map;
/**
- * Core
weng1424 commented on code in PR #22001:
URL: https://github.com/apache/flink/pull/22001#discussion_r1119652784
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkBatchProgram.scala:
##
@@ -292,6 +293,16 @@ object FlinkBat
JingsongLi merged PR #22043:
URL: https://github.com/apache/flink/pull/22043
--
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.ap
[
https://issues.apache.org/jira/browse/FLINK-31250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31250.
Assignee: Nicholas Jiang
Resolution: Fixed
master: 161014149e803bfd1d3653badb230b2ed36ce3cb
[
https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694462#comment-17694462
]
Weijie Guo commented on FLINK-31104:
The failure case in CI may not be easy to troub
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1119813160
##
flink-tests/src/test/java/org/apache/flink/test/recovery/LocalRecoveryITCase.java:
##
@@ -67,12 +68,14 @@
import java.util.Optional;
import java.util.concurre
dmvk commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1119818006
##
flink-tests/src/test/java/org/apache/flink/test/recovery/LocalRecoveryITCase.java:
##
@@ -67,12 +68,14 @@
import java.util.Optional;
import java.util.concurrent.TimeU
liuyongvs commented on code in PR #21993:
URL: https://github.com/apache/flink/pull/21993#discussion_r1119824562
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java:
##
@@ -31,24 +31,28 @@
imp
Myasuka opened a new pull request, #565:
URL: https://github.com/apache/flink-table-store/pull/565
Current FRocksDB version in flink-table-store is still 6.20.3-ververica-1.0,
which cannot run with Apple's silicon chips.
Newly released 6.20.3-ververica-2.0 FRocksDB could run well with App
[
https://issues.apache.org/jira/browse/FLINK-31226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31226:
---
Labels: pull-request-available (was: )
> Bump the FRocksDB version in table-store's lookup
[
https://issues.apache.org/jira/browse/FLINK-31210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693949#comment-17693949
]
Matthias Pohl edited comment on FLINK-31210 at 2/28/23 10:02 AM:
-
JingsongLi commented on code in PR #550:
URL: https://github.com/apache/flink-table-store/pull/550#discussion_r1119829771
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/TableCommit.java:
##
@@ -18,121 +18,55 @@
package org.apache.flink.table.s
XComp commented on PR #22042:
URL: https://github.com/apache/flink/pull/22042#issuecomment-1447912114
Hi @reswqa , unfortunately, with the release coming up, I'm not having much
capacity right now to pick up another task. Therefore, I cannot promise you to
pick it up soon. I'll keep it on m
FangYongs commented on code in PR #564:
URL: https://github.com/apache/flink-table-store/pull/564#discussion_r1119841157
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/FieldStatsConverters.java:
##
@@ -33,12 +33,14 @@
public class FieldStatsConv
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694475#comment-17694475
]
Yue Ma edited comment on FLINK-31238 at 2/28/23 10:18 AM:
--
[~Ya
[
https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694475#comment-17694475
]
Yue Ma commented on FLINK-31238:
1. IngestExternalFile will use global_seq_no, but when
FangYongs commented on code in PR #564:
URL: https://github.com/apache/flink-table-store/pull/564#discussion_r1119864296
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/data/LazyGenericRow.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache Software
tsreaper commented on code in PR #562:
URL: https://github.com/apache/flink-table-store/pull/562#discussion_r1119793489
##
docs/content/docs/features/append-only-table.md:
##
@@ -0,0 +1,98 @@
+---
+title: "Append Only Table"
+weight: 2
+type: docs
+aliases:
+- /features/append-o
[
https://issues.apache.org/jira/browse/FLINK-31248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31248:
---
Labels: pull-request-available (was: )
> Improve documentation for append-only table
>
[
https://issues.apache.org/jira/browse/FLINK-31244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694485#comment-17694485
]
Xintong Song commented on FLINK-31244:
--
IIRC, the conclusions of previous discussio
[
https://issues.apache.org/jira/browse/FLINK-30829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694486#comment-17694486
]
Xintong Song commented on FLINK-30829:
--
Sorting subtasks by busy/idle/backpressure
[
https://issues.apache.org/jira/browse/FLINK-31243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694087#comment-17694087
]
Amit Gurdasani edited comment on FLINK-31243 at 2/28/23 11:00 AM:
gyfora merged PR #533:
URL: https://github.com/apache/flink-kubernetes-operator/pull/533
--
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
[
https://issues.apache.org/jira/browse/FLINK-30920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-30920.
--
Assignee: Gaurav Miglani
Resolution: Fixed
merged to main f7e353c26254c3ccc4a8c2a291da7697f1fbec
JingsongLi merged PR #565:
URL: https://github.com/apache/flink-table-store/pull/565
--
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...@
[
https://issues.apache.org/jira/browse/FLINK-31226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31226.
Resolution: Fixed
master: 3f56f3b8cf5bd4075be84690bb8e8c677506e8ef
> Bump the FRocksDB version in
JingsongLi commented on code in PR #550:
URL: https://github.com/apache/flink-table-store/pull/550#discussion_r1119923441
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/TableCommit.java:
##
@@ -18,121 +18,55 @@
package org.apache.flink.table.s
JingsongLi commented on code in PR #564:
URL: https://github.com/apache/flink-table-store/pull/564#discussion_r1119935439
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/FieldStatsConverters.java:
##
@@ -33,12 +33,14 @@
public class FieldStatsCon
JingsongLi commented on code in PR #564:
URL: https://github.com/apache/flink-table-store/pull/564#discussion_r1119936701
##
flink-table-store-common/src/main/java/org/apache/flink/table/store/data/LazyGenericRow.java:
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache Software
FangYongs commented on PR #564:
URL:
https://github.com/apache/flink-table-store/pull/564#issuecomment-1448039969
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 specific comment.
T
zhuzhurk closed pull request #22029: [FLINK-29859][e2e] Running TPC-DS with
adaptive batch scheduler supports custom errors check.
URL: https://github.com/apache/flink/pull/22029
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1119952982
##
flink-tests/src/test/java/org/apache/flink/test/recovery/LocalRecoveryITCase.java:
##
@@ -67,12 +68,14 @@
import java.util.Optional;
import java.util.concurre
ZhengYi Weng created FLINK-31257:
Summary: Fix errors in “CSV Formats" page
Key: FLINK-31257
URL: https://issues.apache.org/jira/browse/FLINK-31257
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-25788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-25788:
Parent: FLINK-31256
Issue Type: Sub-task (was: Bug)
> Add show connectors command
[
https://issues.apache.org/jira/browse/FLINK-25788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-25788:
Description:
Currently the only work around to see available connectors is to create a tab
[
https://issues.apache.org/jira/browse/FLINK-25788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-25788:
Description:
Currently the only work around to see available connectors is to create a tab
JingsongLi merged PR #564:
URL: https://github.com/apache/flink-table-store/pull/564
--
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...@
[
https://issues.apache.org/jira/browse/FLINK-31254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31254.
Resolution: Fixed
master: 0a8c3a1c426454258b663ffd52de5bcdc1e8ed20
> Improve the read performance
Jun Zhang created FLINK-31258:
-
Summary: can not get kerberos keytab in flink operator
Key: FLINK-31258
URL: https://issues.apache.org/jira/browse/FLINK-31258
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-29859.
---
Resolution: Fixed
master:
28e75620db7b0794ff1c19f8928ce7d33516ba64
release-1.17:
3de6b337cceda5b4b81ac8d34e
[
https://issues.apache.org/jira/browse/FLINK-31257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694505#comment-17694505
]
ZhengYi Weng commented on FLINK-31257:
--
Hi,[~jark].Could you please assign it to me
[
https://issues.apache.org/jira/browse/FLINK-31257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694506#comment-17694506
]
Jark Wu commented on FLINK-31257:
-
What error do you mean? Could you share the screensho
JingsongLi commented on code in PR #562:
URL: https://github.com/apache/flink-table-store/pull/562#discussion_r1119970575
##
docs/content/docs/features/append-only-table.md:
##
@@ -0,0 +1,98 @@
+---
+title: "Append Only Table"
+weight: 2
+type: docs
+aliases:
+- /features/append
JingsongLi commented on code in PR #562:
URL: https://github.com/apache/flink-table-store/pull/562#discussion_r1119972451
##
docs/content/docs/features/append-only-table.md:
##
@@ -0,0 +1,98 @@
+---
+title: "Append Only Table"
+weight: 2
+type: docs
+aliases:
+- /features/append
JingsongLi commented on code in PR #562:
URL: https://github.com/apache/flink-table-store/pull/562#discussion_r1119974300
##
docs/content/docs/features/primary-key-table.md:
##
@@ -158,12 +154,21 @@ Full compaction changelog producer can produce complete
changelog for any type
Shammon created FLINK-31259:
---
Summary: Gateway supports initialization of catalog at startup
Key: FLINK-31259
URL: https://issues.apache.org/jira/browse/FLINK-31259
Project: Flink
Issue Type: Impro
reswqa commented on PR #22042:
URL: https://github.com/apache/flink/pull/22042#issuecomment-1448085323
Thanks @XComp for your quick reply. Never mind, this is not a very urgent
bug-fix, so I'm happy to wait for you. And also thank you from the bottom of my
heart for your great contribution
[
https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-31259:
-
Assignee: Shammon
> Gateway supports initialization of catalog at startup
> ---
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1119982866
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/VertexParallelism.java:
##
@@ -23,14 +23,27 @@
import java.util.Map;
/**
-
eskabetxe opened a new pull request, #8:
URL: https://github.com/apache/flink-connector-shared-utils/pull/8
this change avoid download flink binary again if tests fails..
as now it uses archive this could be 10m of time
--
This is an automated message from the Apache Git Service.
To re
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1119993003
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java:
##
@@ -1401,7 +1403,9 @@ public void
testTryToAssignSlotsRe
dianfu commented on code in PR #22003:
URL: https://github.com/apache/flink/pull/22003#discussion_r1119985077
##
flink-python/pyflink/datastream/tests/test_data_stream.py:
##
@@ -589,6 +589,40 @@ def process_element2(self, value, ctx:
'CoProcessFunction.Context'):
side
[
https://issues.apache.org/jira/browse/FLINK-31257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694511#comment-17694511
]
ZhengYi Weng commented on FLINK-31257:
--
Hi,[~jark] ,I have put the screenshot into
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1120003300
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotAllocator.java:
##
@@ -54,14 +58,35 @@ public interface SlotAllocator {
[
https://issues.apache.org/jira/browse/FLINK-31257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694514#comment-17694514
]
ZhengYi Weng commented on FLINK-31257:
--
I think it's better to change it to "指定将 nu
Aitozi commented on code in PR #22001:
URL: https://github.com/apache/flink/pull/22001#discussion_r1120009253
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkBatchProgram.scala:
##
@@ -292,6 +293,16 @@ object FlinkBatch
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1119982866
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/VertexParallelism.java:
##
@@ -23,14 +23,27 @@
import java.util.Map;
/**
-
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1119982866
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/VertexParallelism.java:
##
@@ -23,14 +23,27 @@
import java.util.Map;
/**
-
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1120015731
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/SlotAllocator.java:
##
@@ -54,14 +58,35 @@ public interface SlotAllocator {
slfan1989 commented on PR #22020:
URL: https://github.com/apache/flink/pull/22020#issuecomment-1448129413
@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.
Aitozi created FLINK-31260:
--
Summary: PushLocalHashAggIntoScanRule should also work with union
RelNode
Key: FLINK-31260
URL: https://issues.apache.org/jira/browse/FLINK-31260
Project: Flink
Issue T
1 - 100 of 257 matches
Mail list logo