[
https://issues.apache.org/jira/browse/FLINK-29763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-29763:
---
Labels: test-stability (was: )
> TaskManager heatbeat timeout exception in Github CI for py
[
https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624233#comment-17624233
]
Martijn Visser commented on FLINK-28985:
[~godfreyhe] WDYT?
> support create ta
gyfora commented on PR #412:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/412#issuecomment-1291594234
The content of the Helm Values.yaml in the working branch is intended to use
it with your local operator image.
I don't think we should set this to the apache repo..
gyfora commented on code in PR #407:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/407#discussion_r1005299938
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractJobReconciler.java:
##
@@ -253,4 +281,14 @
MartijnVisser commented on PR #21048:
URL: https://github.com/apache/flink/pull/21048#issuecomment-1291601116
@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
pvary commented on code in PR #407:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/407#discussion_r1005314178
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractJobReconciler.java:
##
@@ -253,4 +281,14 @@
gyfora opened a new pull request, #413:
URL: https://github.com/apache/flink-kubernetes-operator/pull/413
Attempt at debugging flaky test
--
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
snuyanzin commented on PR #21153:
URL: https://github.com/apache/flink/pull/21153#issuecomment-1291623141
@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.
gyfora commented on PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#issuecomment-1291626292
+1 for having a more concise stacktrace (as a String).
This will greately reduce the json size and will make it much more human
readable and easier to use. If we lat
[
https://issues.apache.org/jira/browse/FLINK-29759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Decuq updated FLINK-29759:
Description:
Hello,
I would like to use LEFT JOIN in order to implement a non blocking jo
[
https://issues.apache.org/jira/browse/FLINK-29759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624282#comment-17624282
]
Alexandre Decuq edited comment on FLINK-29759 at 10/26/22 8:02 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-29759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624282#comment-17624282
]
Alexandre Decuq commented on FLINK-29759:
-
[~luoyuxia] not the same nullability
zhuangchong opened a new pull request, #334:
URL: https://github.com/apache/flink-table-store/pull/334
Add maven wrapper
--
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
[
https://issues.apache.org/jira/browse/FLINK-29759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624282#comment-17624282
]
Alexandre Decuq edited comment on FLINK-29759 at 10/26/22 8:12 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-29674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624290#comment-17624290
]
hongcha commented on FLINK-29674:
-
[~martijnvisser] [~coderap] I looked at the part of t
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624291#comment-17624291
]
Martijn Visser commented on FLINK-24119:
[~mason6345] Do you have the bandwidth
[
https://issues.apache.org/jira/browse/FLINK-29758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624293#comment-17624293
]
Alexandre Decuq commented on FLINK-29758:
-
[~martijnvisser] Ok thanks for your q
liuyongvs commented on PR #21157:
URL: https://github.com/apache/flink/pull/21157#issuecomment-1291672432
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.
To unsubsc
JingsongLi commented on PR #334:
URL:
https://github.com/apache/flink-table-store/pull/334#issuecomment-1291675343
Thanks @zhuangchong for the contribution, do you have a detailed context?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
HuangXingBo closed pull request #21157: [FLINK-29479][python][hotfix] Fix the
testPythonSystemEnvEnabled in PythonOptionsTest
URL: https://github.com/apache/flink/pull/21157
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
waywtdcc opened a new pull request, #21158:
URL: https://github.com/apache/flink/pull/21158
…types
## What is the purpose of the change
*Support language: create table like *
## Brief change log
*Support language: create table like *
## Verifying t
waywtdcc closed pull request #21078: [FLINK-28985][planner]sql like statement
supports views
URL: https://github.com/apache/flink/pull/21078
--
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
waywtdcc closed pull request #21158: [FLINK-28985][table]sql like statement
supports views
URL: https://github.com/apache/flink/pull/21158
--
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
darenwkt commented on PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#issuecomment-1291703643
Hi @morhidi,
I have updated the stackTrace to be a string and added a ConfigOption to
limit the length of the stackTrace string.
Regarding the concern on de
waywtdcc opened a new pull request, #21159:
URL: https://github.com/apache/flink/pull/21159
## What is the purpose of the change
*Support language: create table like view, in jira
:https://issues.apache.org/jira/projects/FLINK/issues/FLINK-28985*
## Brief change lo
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yordan Pavlov updated FLINK-16419:
--
Attachment: tm0-transaction.log
> Avoid to recommit transactions which are known committed suc
gaborgsomogyi opened a new pull request, #21160:
URL: https://github.com/apache/flink/pull/21160
## What is the purpose of the change
`HadoopModule` is quite complex and contains reflection which can be
simplified. In this PR I've made this simplification keeping the original
functio
flinkbot commented on PR #21159:
URL: https://github.com/apache/flink/pull/21159#issuecomment-1291718082
## CI report:
* f5c9eb1583a8faef6cbb53b08d78a53230a36194 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29761:
---
Labels: pull-request-available security (was: security)
> Simplify HadoopModule
> -
[
https://issues.apache.org/jira/browse/FLINK-29759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624312#comment-17624312
]
Alexandre Decuq commented on FLINK-29759:
-
[~martijnvisser] I tried also to set
[
https://issues.apache.org/jira/browse/FLINK-29759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624312#comment-17624312
]
Alexandre Decuq edited comment on FLINK-29759 at 10/26/22 8:59 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-29759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624282#comment-17624282
]
Alexandre Decuq edited comment on FLINK-29759 at 10/26/22 9:03 AM:
---
Aqib Mehmood created FLINK-29765:
Summary: SQL query not executing properly
Key: FLINK-29765
URL: https://issues.apache.org/jira/browse/FLINK-29765
Project: Flink
Issue Type: Bug
Affects
[
https://issues.apache.org/jira/browse/FLINK-29759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624282#comment-17624282
]
Alexandre Decuq edited comment on FLINK-29759 at 10/26/22 9:04 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-29759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624282#comment-17624282
]
Alexandre Decuq edited comment on FLINK-29759 at 10/26/22 9:05 AM:
---
flinkbot commented on PR #21160:
URL: https://github.com/apache/flink/pull/21160#issuecomment-1291728233
## CI report:
* 6d3989d4e4ea6bbe429b0f8d6b358c360fbe261e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624282#comment-17624282
]
Alexandre Decuq edited comment on FLINK-29759 at 10/26/22 9:06 AM:
---
snuyanzin opened a new pull request, #21161:
URL: https://github.com/apache/flink/pull/21161
## What is the purpose of the change
Migrate flink-connector-base module to AssertJ and JUnit 5 following the
[JUnit 5 Migration
Guide](https://docs.google.com/document/d/1514Wa_aNB9b
[
https://issues.apache.org/jira/browse/FLINK-25546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25546:
---
Labels: pull-request-available starter (was: starter)
> [JUnit5 Migration] Module: flink-co
wanglijie95 opened a new pull request, #21162:
URL: https://github.com/apache/flink/pull/21162
## What is the purpose of the change
Support flexible subpartion range division
## Verifying this change
Add some tests
## Does this pull request potentially affect one of the fo
[
https://issues.apache.org/jira/browse/FLINK-29665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29665:
---
Labels: pull-request-available (was: )
> Support flexible subpartition range divisions
> --
[
https://issues.apache.org/jira/browse/FLINK-29765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-29765:
---
Priority: Major (was: Blocker)
> SQL query not executing properly
> ---
[
https://issues.apache.org/jira/browse/FLINK-29765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-29765:
---
Component/s: Table SQL / Planner
> SQL query not executing properly
> --
[
https://issues.apache.org/jira/browse/FLINK-29765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624313#comment-17624313
]
Martijn Visser commented on FLINK-29765:
[~godfreyhe] [~jark] WDYT?
> SQL quer
gaborgsomogyi commented on code in PR #21160:
URL: https://github.com/apache/flink/pull/21160#discussion_r1005425742
##
flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/HadoopModule.java:
##
@@ -69,71 +60,34 @@ public void install() throws SecurityInstallExc
gaborgsomogyi commented on code in PR #21160:
URL: https://github.com/apache/flink/pull/21160#discussion_r1005428465
##
flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/HadoopModule.java:
##
@@ -69,71 +60,34 @@ public void install() throws SecurityInstallExc
flinkbot commented on PR #21161:
URL: https://github.com/apache/flink/pull/21161#issuecomment-1291746389
## CI report:
* 055a599e7aa15cbba481dab85aeeb2d9f5112ee7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21162:
URL: https://github.com/apache/flink/pull/21162#issuecomment-1291747391
## CI report:
* a90c3f20d260ec8f0b9b3ecee2aedec908ff04d1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624314#comment-17624314
]
Martijn Visser commented on FLINK-19358:
[~gvijay452] It would a breaking change
[
https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624315#comment-17624315
]
Yordan Pavlov commented on FLINK-16419:
---
Let me try to provide some more info on h
Myasuka merged PR #20860:
URL: https://github.com/apache/flink/pull/20860
--
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-29347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-29347:
-
Fix Version/s: 1.17.0
> Failed to restore from list state with empty protobuf object
> -
[
https://issues.apache.org/jira/browse/FLINK-29347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-29347.
--
Resolution: Fixed
merged in master: db46d434820e8cd964ea97ab2396d8dc9b43ad9f ...
d3c7fc9be6aa13872fa2
Myasuka merged PR #20965:
URL: https://github.com/apache/flink/pull/20965
--
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-29244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-29244.
--
Fix Version/s: 1.17.0
Resolution: Fixed
merged in master: de5409afbb003b108518ac5cc2e5ba215063c
1996fanrui commented on PR #21149:
URL: https://github.com/apache/flink/pull/21149#issuecomment-1291765606
@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
fsk119 commented on code in PR #20652:
URL: https://github.com/apache/flink/pull/20652#discussion_r1005314845
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala:
##
@@ -408,6 +408,336 @@ class TableEnvironmentTest {
tab
[
https://issues.apache.org/jira/browse/FLINK-29244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-29244:
-
Fix Version/s: 1.16.1
> Add metric lastMaterializationDuration to ChangelogMaterializationMetricGroup
>
[
https://issues.apache.org/jira/browse/FLINK-29244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624329#comment-17624329
]
Yun Tang commented on FLINK-29244:
--
merged in release-1.16: 969967c160bf13a3948df941c4b
HuangXingBo closed pull request #137: Add GPG key for 1.16.0 release
URL: https://github.com/apache/flink-docker/pull/137
--
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 uns
snuyanzin commented on code in PR #18927:
URL: https://github.com/apache/flink/pull/18927#discussion_r1005475075
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java:
##
@@ -702,14 +698,14 @@ private void closeTerminal() {
}
wangyang0918 commented on PR #21145:
URL: https://github.com/apache/flink/pull/21145#issuecomment-1291794197
@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 comme
JingsongLi commented on code in PR #332:
URL: https://github.com/apache/flink-table-store/pull/332#discussion_r1005473806
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/compact/FullChangelogMergeTreeCompactRewriter.java:
##
@@ -0,0 +1,135 @@
snuyanzin commented on code in PR #18927:
URL: https://github.com/apache/flink/pull/18927#discussion_r1005475075
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java:
##
@@ -702,14 +698,14 @@ private void closeTerminal() {
}
snuyanzin commented on code in PR #18927:
URL: https://github.com/apache/flink/pull/18927#discussion_r1005475075
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java:
##
@@ -702,14 +698,14 @@ private void closeTerminal() {
}
steveloughran commented on code in PR #21160:
URL: https://github.com/apache/flink/pull/21160#discussion_r1005501511
##
flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/HadoopModule.java:
##
@@ -69,71 +60,34 @@ public void install() throws SecurityInstallExc
steveloughran commented on code in PR #21160:
URL: https://github.com/apache/flink/pull/21160#discussion_r1005503883
##
flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/HadoopModule.java:
##
@@ -69,71 +60,34 @@ public void install() throws SecurityInstallExc
snuyanzin commented on code in PR #19897:
URL: https://github.com/apache/flink/pull/19897#discussion_r1005519182
##
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvRowDeSerializationSchemaTest.java:
##
@@ -40,7 +40,7 @@
import static org.assertj.core.api.A
[
https://issues.apache.org/jira/browse/FLINK-26390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-26390:
-
Assignee: Sergey Nuyanzin
> InputStream is not closed at CliClient#executeFile
> --
carloscastrojumo commented on code in PR #20982:
URL: https://github.com/apache/flink/pull/20982#discussion_r1005523142
##
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesJobManagerFactoryTest.java:
##
@@ -468,4 +468,37 @@ void testSetJobM
zhuangchong commented on PR #334:
URL:
https://github.com/apache/flink-table-store/pull/334#issuecomment-1291847927
> Thanks @zhuangchong for the contribution, do you have a detailed context?
ok, added.
--
This is an automated message from the Apache Git Service.
To respond to the
snuyanzin commented on PR #19897:
URL: https://github.com/apache/flink/pull/19897#issuecomment-1291851895
thanks for addressing comments
I noticed that there is a bunch of classes still relying on junit4
`org.apache.flink.formats.csv.CsvFileCompactionITCase`
`org.apache.flink.formats
[
https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624367#comment-17624367
]
Salva commented on FLINK-29480:
---
Thanks for your reply [~leonard] [~renqs] ! Sure, I'm gla
JingsongLi commented on code in PR #329:
URL: https://github.com/apache/flink-table-store/pull/329#discussion_r1005534682
##
docs/content/docs/engines/build.md:
##
@@ -50,6 +50,12 @@ You can find Flink 1.15 bundled jar in
`./flink-table-store-dist/target/flink-ta
To build wi
gaborgsomogyi commented on PR #21160:
URL: https://github.com/apache/flink/pull/21160#issuecomment-1291861702
@steveloughran So if I understand correctly it would be better to use the
original UGI calls instead of the other APIs because:
* The ticket cache part has major differences
*
lindong28 commented on code in PR #164:
URL: https://github.com/apache/flink-ml/pull/164#discussion_r1005520306
##
docs/content/docs/development/build-and-install.md:
##
@@ -61,9 +61,13 @@ from the root directory of Flink ML:
./flink-ml-dist/target/flink-ml-*-bin/flink-ml*/
``
HuangXingBo closed pull request #138: Update Dockerfiles for 1.16.0 release
URL: https://github.com/apache/flink-docker/pull/138
--
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-29737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624376#comment-17624376
]
yuzelin commented on FLINK-29737:
-
Thanks for your idea. I have some points about this f
wangyang0918 commented on code in PR #20982:
URL: https://github.com/apache/flink/pull/20982#discussion_r1005550293
##
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/decorators/DecoratorWithPodTemplateTestBase.java:
##
@@ -215,4 +215,18 @@ void testMainCon
JingsongLi merged PR #334:
URL: https://github.com/apache/flink-table-store/pull/334
--
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...@
wangyang0918 commented on code in PR #20982:
URL: https://github.com/apache/flink/pull/20982#discussion_r1005554023
##
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/decorators/DecoratorWithPodTemplateTestBase.java:
##
@@ -215,4 +215,18 @@ void testMainCon
wangyang0918 merged PR #21145:
URL: https://github.com/apache/flink/pull/21145
--
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.
wangyang0918 commented on PR #21145:
URL: https://github.com/apache/flink/pull/21145#issuecomment-1291887688
@liuyongvs Could you please create a backport PR for release-1.15 and
release-1.16?
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
[
https://issues.apache.org/jira/browse/FLINK-29749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-29749:
--
Fix Version/s: 1.15.3
1.16.1
> flink info command support dynamic properties
>
JingsongLi merged PR #326:
URL: https://github.com/apache/flink-table-store/pull/326
--
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-29702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29702.
Fix Version/s: table-store-0.3.0
Assignee: Shammon
Resolution: Fixed
master: 8af95
Myasuka commented on PR #20917:
URL: https://github.com/apache/flink/pull/20917#issuecomment-1291899565
@liuml07 Please refine the commit message to `[hotfix][doc] Refine code
examples in data_stream_api ` before I merge this PR.
--
This is an automated message from the Apache Git Service
Weijie Guo created FLINK-29766:
--
Summary: Speculative execution supports hybrid shuffle mode.
Key: FLINK-29766
URL: https://issues.apache.org/jira/browse/FLINK-29766
Project: Flink
Issue Type: I
Weijie Guo created FLINK-29767:
--
Summary: Adaptive batch scheduler supports hybrid shuffle
Key: FLINK-29767
URL: https://issues.apache.org/jira/browse/FLINK-29767
Project: Flink
Issue Type: Sub-
snuyanzin commented on code in PR #20991:
URL: https://github.com/apache/flink/pull/20991#discussion_r1005571712
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java:
##
@@ -79,7 +79,8 @@
*/
@SuppressWarnings("
[
https://issues.apache.org/jira/browse/FLINK-29766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-29766:
---
Labels: Umbrella (was: )
> Speculative execution supports hybrid shuffle mode.
> --
snuyanzin commented on code in PR #20991:
URL: https://github.com/apache/flink/pull/20991#discussion_r1005571712
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java:
##
@@ -79,7 +79,8 @@
*/
@SuppressWarnings("
[
https://issues.apache.org/jira/browse/FLINK-29766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-29766:
---
Summary: Speculative execution supports hybrid shuffle mode (was:
Speculative execution supports hy
[
https://issues.apache.org/jira/browse/FLINK-29766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-29766:
---
Summary: Speculative execution should also work in hybrid shuffle mode
(was: Speculative execution
[
https://issues.apache.org/jira/browse/FLINK-14317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624394#comment-17624394
]
Adrian Zhong commented on FLINK-14317:
--
The code is not suitable for common users,
Weijie Guo created FLINK-29768:
--
Summary: Hybrid shuffle supports the update of ResultPartition
information
Key: FLINK-29768
URL: https://issues.apache.org/jira/browse/FLINK-29768
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-29768:
---
Affects Version/s: 1.17.0
> Hybrid shuffle supports the update of ResultPartition information
>
[
https://issues.apache.org/jira/browse/FLINK-29768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-29768:
---
Component/s: Runtime / Coordination
> Hybrid shuffle supports the update of ResultPartition informat
[
https://issues.apache.org/jira/browse/FLINK-29767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-29767:
---
Affects Version/s: 1.17.0
> Adaptive batch scheduler supports hybrid shuffle
> -
[
https://issues.apache.org/jira/browse/FLINK-29767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-29767:
---
Component/s: Runtime / Coordination
> Adaptive batch scheduler supports hybrid shuffle
> ---
1 - 100 of 265 matches
Mail list logo
