fsk119 commented on code in PR #21665:
URL: https://github.com/apache/flink/pull/21665#discussion_r1071869840
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliView.java:
##
@@ -361,25 +364,52 @@ protected int getHeight() {
return height
fsk119 commented on code in PR #21665:
URL: https://github.com/apache/flink/pull/21665#discussion_r1071869134
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/CollectResultBase.java:
##
@@ -29,23 +29,28 @@
/** A result that work
1996fanrui commented on PR #21690:
URL: https://github.com/apache/flink/pull/21690#issuecomment-1384981749
> Hi @1996fanrui, yes I agree we should use Supplier canEmitBatchOfRecords.
>
> I believe `canEmitBatchOfRecords` can be passed to `SourceOperator`
similar to how `mailboxHasMail
[
https://issues.apache.org/jira/browse/FLINK-30710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30710.
Fix Version/s: table-store-0.4.0
Assignee: Shammon
Resolution: Fixed
master: 6fb52
luoyuxia commented on code in PR #21676:
URL: https://github.com/apache/flink/pull/21676#discussion_r1071864297
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/DeleteTableITCase.java:
##
@@ -0,0 +1,89 @@
+/*
+ * Licensed to the A
JingsongLi merged PR #486:
URL: https://github.com/apache/flink-table-store/pull/486
--
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-30711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reassigned FLINK-30711:
Assignee: yuzelin
> Support dropping partition via Flink action
> ---
fsk119 commented on code in PR #21665:
URL: https://github.com/apache/flink/pull/21665#discussion_r1071859452
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/LocalExecutor.java:
##
@@ -75,15 +69,13 @@ public class LocalExecutor implement
xuyangzhong commented on code in PR #21665:
URL: https://github.com/apache/flink/pull/21665#discussion_r1071820866
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/ResultDescriptor.java:
##
@@ -20,46 +20,66 @@
import org.apache.flink.api.com
HuangXingBo closed pull request #21380: [FLINK-30169][python][doc] Adds
switcher.json file
URL: https://github.com/apache/flink/pull/21380
--
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 specifi
[
https://issues.apache.org/jira/browse/FLINK-30508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677640#comment-17677640
]
Shengkai Fang commented on FLINK-30508:
---
Sorry for the late response. I will take
[
https://issues.apache.org/jira/browse/FLINK-30508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-30508:
-
Assignee: Shengkai Fang
> CliClientITCase.testSqlStatements failed with output not matc
[
https://issues.apache.org/jira/browse/FLINK-30637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo resolved FLINK-30637.
--
Fix Version/s: 1.16.1
1.15.4
Assignee: Xin Chen
Resolution:
flinkbot commented on PR #21701:
URL: https://github.com/apache/flink/pull/21701#issuecomment-1384930283
## CI report:
* 44ccbc37c1235fa9459baf9f3eb86c6c4a7d1668 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-29421:
-
Fix Version/s: 1.17.0
> Support python 3.10
> ---
>
> Key: FLINK
[
https://issues.apache.org/jira/browse/FLINK-29421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-29421:
Assignee: Huang Xingbo
> Support python 3.10
> ---
>
> Ke
xintongsong opened a new pull request, #21701:
URL: https://github.com/apache/flink/pull/21701
…sink ABFS support.
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way w
HuangXingBo closed pull request #21649: [FLINK-30637] [Python] Try to replace
'is' with '==' to ensure matching the window type of overwindow correctly
URL: https://github.com/apache/flink/pull/21649
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
flinkbot commented on PR #21700:
URL: https://github.com/apache/flink/pull/21700#issuecomment-1384918983
## CI report:
* 602ab508ca70bbe63c0dc47cd16c78925a8cc0b5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21699:
URL: https://github.com/apache/flink/pull/21699#issuecomment-1384918897
## CI report:
* cd5e2c478e213f32b4031d46ca15829548aff8fe UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
link3280 commented on PR #21700:
URL: https://github.com/apache/flink/pull/21700#issuecomment-1384918159
cc @XComp @fsk119 @yuzelin
--
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 c
[
https://issues.apache.org/jira/browse/FLINK-30677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30677:
---
Labels: pull-request-available test-stability (was: test-stability)
> SqlGatewayServiceStat
link3280 opened a new pull request, #21700:
URL: https://github.com/apache/flink/pull/21700
## What is the purpose of the change
SqlGatewayServiceStatementITCase.testFlinkSqlStatements may fail due to
`java.util.NoSuchElementException`. The cause is unsecured access to iterators
in t
[
https://issues.apache.org/jira/browse/FLINK-29421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29421:
---
Labels: pull-request-available (was: )
> Support python 3.10
> ---
>
>
HuangXingBo opened a new pull request, #21699:
URL: https://github.com/apache/flink/pull/21699
## Contribution Checklist
## What is the purpose of the change
*This pull request will support python 3.10*
## Brief change log
- *Update `pemja` to `0.3.0`*
-
flinkbot commented on PR #21698:
URL: https://github.com/apache/flink/pull/21698#issuecomment-1384915235
## CI report:
* 863dbb9c5013c425b4dd998b5a5092b7ccd8316e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-30712:
--
Description:
After [FLINK-30469|https://issues.apache.org/jira/browse/FLINK-30469], the
network memor
[
https://issues.apache.org/jira/browse/FLINK-30712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan reassigned FLINK-30712:
-
Assignee: Yuxin Tan
> Update network memory configuration docs
> -
Yuxin Tan created FLINK-30712:
-
Summary: Update network memory configuration docs
Key: FLINK-30712
URL: https://issues.apache.org/jira/browse/FLINK-30712
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-30665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30665:
---
Labels: pull-request-available (was: )
> Add implementation for Update
> --
luoyuxia opened a new pull request, #21698:
URL: https://github.com/apache/flink/pull/21698
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them o
yuzelin created FLINK-30711:
---
Summary: Support dropping partition via Flink action
Key: FLINK-30711
URL: https://issues.apache.org/jira/browse/FLINK-30711
Project: Flink
Issue Type: New Feature
lindong28 commented on PR #21690:
URL: https://github.com/apache/flink/pull/21690#issuecomment-1384903316
Hi @1996fanrui, yes I agree we should use Supplier
canEmitBatchOfRecords.
I believe `canEmitBatchOfRecords` can be passed to `SourceOperator` similar
to how `mailboxHasMail ` is
[
https://issues.apache.org/jira/browse/FLINK-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677629#comment-17677629
]
Yun Tang commented on FLINK-30533:
--
[~lindong] Thanks for the feedback and we can see t
[
https://issues.apache.org/jira/browse/FLINK-29351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reopened FLINK-29351:
--
> Enable input buffer floating for blocking shuffle
>
[
https://issues.apache.org/jira/browse/FLINK-30601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677626#comment-17677626
]
Lijie Wang commented on FLINK-30601:
Done via master 4e3cd986cd4304c699d5c7d368ffd6e
[
https://issues.apache.org/jira/browse/FLINK-29351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-29351.
Fix Version/s: (was: 1.17.0)
Resolution: Won't Do
Subsumed by FLIP-266 (FLINK-30469).
[
https://issues.apache.org/jira/browse/FLINK-29351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-29351.
Resolution: Resolved
> Enable input buffer floating for blocking shuffle
> ---
[
https://issues.apache.org/jira/browse/FLINK-30601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang closed FLINK-30601.
--
Resolution: Done
> Omit "setKeyContextElement" call for non-keyed stream/operators to improve
> perfo
wanglijie95 closed pull request #21621: [FLINK-30601][runtime] Omit
"setKeyContextElement" call for non-keyed stream/operators to improve
performance
URL: https://github.com/apache/flink/pull/21621
--
This is an automated message from the Apache Git Service.
To respond to the message, please
1996fanrui commented on PR #21690:
URL: https://github.com/apache/flink/pull/21690#issuecomment-1384889755
Hi @lindong28 , thanks for your quick feedback.
I want to check with you the first question: No matter which class
canEmitBatchOfRecords is added to, we should use `Supplier
can
[
https://issues.apache.org/jira/browse/FLINK-30469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reopened FLINK-30469:
--
> FLIP-266: Simplify network memory configurations for TaskManager
> -
[
https://issues.apache.org/jira/browse/FLINK-30469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-30469.
Fix Version/s: 1.17.0
Release Note:
The default value of `taskmanager.memory.network.max` has
[
https://issues.apache.org/jira/browse/FLINK-30709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-30709:
Assignee: Rui Fan
> NetworkInput#emitNext() should push records to DataOutput in a while loop
> -
zjureel commented on code in PR #486:
URL: https://github.com/apache/flink-table-store/pull/486#discussion_r1071773731
##
flink-table-store-spark/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java:
##
@@ -487,4 +487,23 @@ private void
innerTestNestedTypeFilte
[
https://issues.apache.org/jira/browse/FLINK-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677607#comment-17677607
]
Rui Fan edited comment on FLINK-30533 at 1/17/23 6:07 AM:
--
Hi [
lindong28 commented on PR #21690:
URL: https://github.com/apache/flink/pull/21690#issuecomment-1384878158
Hi @1996fanrui, thanks for the explanation.
Regarding the 1st point mentioned above, yes `canEmitBatchOfRecords()` is
related to emit int the sense that it mangaes the "control fl
JingsongLi commented on code in PR #486:
URL: https://github.com/apache/flink-table-store/pull/486#discussion_r1071768327
##
flink-table-store-spark/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java:
##
@@ -487,4 +487,23 @@ private void
innerTestNestedTypeFi
[
https://issues.apache.org/jira/browse/FLINK-30577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677617#comment-17677617
]
James Busche commented on FLINK-30577:
--
I hadn't heard back from [~tagarr] to see i
[
https://issues.apache.org/jira/browse/FLINK-30710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30710:
---
Labels: pull-request-available (was: )
> Fix invalid field id for nested type in spark cata
zjureel opened a new pull request, #486:
URL: https://github.com/apache/flink-table-store/pull/486
Fix invalid field ind for nested type in spark ddl
--
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
[
https://issues.apache.org/jira/browse/FLINK-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677612#comment-17677612
]
Dong Lin commented on FLINK-30533:
--
Hi [~yunta], I run the benchmark again without and
Shammon created FLINK-30710:
---
Summary: Fix invalid field id for nested type in spark catalog
Key: FLINK-30710
URL: https://issues.apache.org/jira/browse/FLINK-30710
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-30533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677607#comment-17677607
]
Rui Fan commented on FLINK-30533:
-
Hi [~lindong] [~pnowojski] , thanks for your contribu
1996fanrui commented on PR #21690:
URL: https://github.com/apache/flink/pull/21690#issuecomment-1384851783
Hi @lindong28 , thanks a lot for your review and discuss here.
> Could you explain what is the benefit for this refactor?
As I understand, there are two reasons for adding
flinkbot commented on PR #21697:
URL: https://github.com/apache/flink/pull/21697#issuecomment-1384847007
## CI report:
* 328510c28779d64fa249c33f6a1014fb7c7f6ddf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30709:
---
Labels: pull-request-available (was: )
> NetworkInput#emitNext() should push records to Dat
1996fanrui opened a new pull request, #21697:
URL: https://github.com/apache/flink/pull/21697
## What is the purpose of the change
Improve Flink performance by reducing the average depth of the call stack
needed to produce a record for NetworkInput.
## Brief change log
N
Rui Fan created FLINK-30709:
---
Summary: NetworkInput#emitNext() should push records to DataOutput
in a while loop
Key: FLINK-30709
URL: https://issues.apache.org/jira/browse/FLINK-30709
Project: Flink
lsyldliu commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1071672649
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchCompactCoordinator.java:
##
@@ -0,0 +1,153 @@
+/*
+ *
lsyldliu commented on PR #21629:
URL: https://github.com/apache/flink/pull/21629#issuecomment-1384812979
@fsk119 Thanks for reviewing, the test has been added.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
SinBex commented on PR #21695:
URL: https://github.com/apache/flink/pull/21695#issuecomment-1384800940
@zhuzhurk Hi, Can u help me to review it? thanks a lot
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
flinkbot commented on PR #21696:
URL: https://github.com/apache/flink/pull/21696#issuecomment-1384800345
## CI report:
* c4b7c8b36c49c1ad95efe1e3af6bdfdbd210506d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21695:
URL: https://github.com/apache/flink/pull/21695#issuecomment-1384800296
## CI report:
* b491f2cb53a69bedfadca4c3e3b10a5d7cf89cc8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677587#comment-17677587
]
Wencong Liu commented on FLINK-30257:
-
Thanks [~martijnvisser], I've opened a pull r
[
https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30257:
---
Labels: pull-request-available test-stability (was: test-stability)
> SqlClientITCase#testM
[
https://issues.apache.org/jira/browse/FLINK-30707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30707:
---
Labels: pull-request-available (was: )
> Let speculative execution take input data amount i
WencongLiu opened a new pull request, #21696:
URL: https://github.com/apache/flink/pull/21696
## What is the purpose of the change
*fix SqlClientITCase#testMatchRecognize*
## Brief change log
- *make verifyNumberOfResultRecords wait until get the expected nu
SinBex opened a new pull request, #21695:
URL: https://github.com/apache/flink/pull/21695
## What is the purpose of the change
The default slowTaskDetector in speculative execution is based on execution
time now, if the data amount allocated to each subtask is uneven, time-bas
JingsongLi commented on code in PR #484:
URL: https://github.com/apache/flink-table-store/pull/484#discussion_r1071702317
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/CoreOptions.java:
##
@@ -401,6 +401,12 @@ public class CoreOptions implements Serializab
lincoln-lil commented on code in PR #21676:
URL: https://github.com/apache/flink/pull/21676#discussion_r1071693761
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java:
##
@@ -1492,6 +1500,41 @@ private Operation
[
https://issues.apache.org/jira/browse/FLINK-30707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-30707:
Summary: Let speculative execution take input data amount into account when
detecting slow tasks (was: Le
[
https://issues.apache.org/jira/browse/FLINK-30707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677584#comment-17677584
]
Zhu Zhu commented on FLINK-30707:
-
Thanks for the proposal! [~xiasun]
I have assigned yo
[
https://issues.apache.org/jira/browse/FLINK-30707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-30707:
---
Assignee: xingbe
> Let speculative execution takes input data amount into account when detecting
>
fsk119 commented on code in PR #21677:
URL: https://github.com/apache/flink/pull/21677#discussion_r1070749450
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/statement/FetchResultsHandler.java:
##
@@ -63,17 +70,27 @@ protected Completab
luoyuxia commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1071700619
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchCompactOperator.java:
##
@@ -0,0 +1,145 @@
+/*
+ * Lic
Jie Han created FLINK-30708:
---
Summary: Typo problem of the doc `Determinism In Continuous
Queries`
Key: FLINK-30708
URL: https://issues.apache.org/jira/browse/FLINK-30708
Project: Flink
Issue Type
reswqa commented on PR #21553:
URL: https://github.com/apache/flink/pull/21553#issuecomment-1384778651
@ZhongFuCheng3y In fact, the pull request has been closed because
@MartijnVisser doesn't think it needs to be fixed.
--
This is an automated message from the Apache Git Service.
To respo
[
https://issues.apache.org/jira/browse/FLINK-30707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677583#comment-17677583
]
xingbe commented on FLINK-30707:
[~zhuzh] Could you please assign this ticket to me? Tha
luoyuxia commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1071697576
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchCompactOperator.java:
##
@@ -0,0 +1,145 @@
+/*
+ * Lic
[
https://issues.apache.org/jira/browse/FLINK-30707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xingbe updated FLINK-30707:
---
Summary: Let speculative execution takes input data amount into account
when detecting slow tasks (was: Let
[
https://issues.apache.org/jira/browse/FLINK-30695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-30695:
-
Description:
In current design for compact files in Hive sink, there's a coordinator
operator that coll
xingbe created FLINK-30707:
--
Summary: Let speculative execution takes input number bytes into
account when detecting slow tasks
Key: FLINK-30707
URL: https://issues.apache.org/jira/browse/FLINK-30707
Project
gj199575 commented on PR #20467:
URL: https://github.com/apache/flink/pull/20467#issuecomment-1384771917
I have a question.
which mode the code worked for ?
flink on k8s session 、 flink on k8s per-job、 flink on k8s application or
flink on k8s native？
thank you
--
This i
gj199575 commented on PR #20467:
URL: https://github.com/apache/flink/pull/20467#issuecomment-1384771055
I hava a question.
--
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.
luoyuxia commented on PR #21257:
URL: https://github.com/apache/flink/pull/21257#issuecomment-1384765248
@lsyldliu Thanks for your reviewing. I have addressed your comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-30431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677580#comment-17677580
]
Sai Nadendla commented on FLINK-30431:
--
Hi [~jiabao.sun],
Great to see the quick PR
[
https://issues.apache.org/jira/browse/FLINK-30469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan closed FLINK-30469.
-
> FLIP-266: Simplify network memory configurations for TaskManager
> ---
[ https://issues.apache.org/jira/browse/FLINK-30469 ]
Yuxin Tan deleted comment on FLINK-30469:
---
was (Author: tanyuxin):
master (1.17): ae8de97ef2acc798dae34ad2096ece8886bcf308
> FLIP-266: Simplify network memory configurations for TaskManager
>
[
https://issues.apache.org/jira/browse/FLINK-30469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan resolved FLINK-30469.
---
Resolution: Resolved
master (1.17): ae8de97ef2acc798dae34ad2096ece8886bcf308
> FLIP-266: Simplify n
TanYuxin-tyx closed pull request #21618: [FLINK-30472][network] Modify the
default value of the max network memory config option
URL: https://github.com/apache/flink/pull/21618
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
TanYuxin-tyx commented on PR #21618:
URL: https://github.com/apache/flink/pull/21618#issuecomment-1384758099
The pr is reviewed at https://github.com/apache/flink/pull/21620.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
TanYuxin-tyx commented on PR #21612:
URL: https://github.com/apache/flink/pull/21612#issuecomment-1384757668
The pr is reviewed at https://github.com/apache/flink/pull/21620.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
TanYuxin-tyx commented on code in PR #21612:
URL: https://github.com/apache/flink/pull/21612#discussion_r1071682166
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SsgNetworkMemoryCalculationUtils.java:
##
@@ -93,28 +93,27 @@ public static void enrichNetworkMem
TanYuxin-tyx closed pull request #21612: [FLINK-30471][network] Optimize the
enriching network memory process in SsgNetworkMemoryCalculationUtils
URL: https://github.com/apache/flink/pull/21612
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-30472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-30472.
Fix Version/s: 1.17.0
Resolution: Done
master (1.17): afdf4a73e43f2e6f5b2dd984aa3471f32658f
[
https://issues.apache.org/jira/browse/FLINK-30471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-30471.
Fix Version/s: 1.17.0
Resolution: Done
master (1.17): fc7defb14d11e270d539ee0d80a2076ae55a4
[
https://issues.apache.org/jira/browse/FLINK-30473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-30473.
Fix Version/s: 1.17.0
Resolution: Done
master (1.17): ae8de97ef2acc798dae34ad2096ece8886bcf
[
https://issues.apache.org/jira/browse/FLINK-30659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677571#comment-17677571
]
dalongliu commented on FLINK-30659:
---
I think this module should be dropped directly, h
xintongsong closed pull request #21620: [FLINK-30473][network] Optimize the
InputGate network memory management for TaskManager
URL: https://github.com/apache/flink/pull/21620
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
1 - 100 of 301 matches
Mail list logo
