Yangze Guo created FLINK-32879:
--
Summary: slotmanager.max-total-resource.cpu/memory should be
ignored in standalone mode.
Key: FLINK-32879
URL: https://issues.apache.org/jira/browse/FLINK-32879
Project:
[
https://issues.apache.org/jira/browse/FLINK-32485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754874#comment-17754874
]
Hangxiang Yu commented on FLINK-32485:
--
Hi, [~taoran]
Changelog test code has not been referenced
jiangxin369 commented on PR #248:
URL: https://github.com/apache/flink-ml/pull/248#issuecomment-1679955970
@zhipeng93 Thanks for the review. I've updated the PR, could you have
another look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
jiangxin369 commented on code in PR #248:
URL: https://github.com/apache/flink-ml/pull/248#discussion_r1295375489
##
flink-ml-iteration/flink-ml-iteration-common/src/main/java/org/apache/flink/iteration/operator/feedback/MpscQueue.java:
##
@@ -0,0 +1,128 @@
+/*
+ * Licensed to
WencongLiu commented on code in PR #23179:
URL: https://github.com/apache/flink/pull/23179#discussion_r1295362290
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyPayloadQueue.java:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the
WencongLiu commented on PR #23179:
URL: https://github.com/apache/flink/pull/23179#issuecomment-1679938917
The last three fixup commits has been updated in force.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
WencongLiu commented on code in PR #23179:
URL: https://github.com/apache/flink/pull/23179#discussion_r1295362290
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/netty/NettyPayloadQueue.java:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the
flinkbot commented on PR #23223:
URL: https://github.com/apache/flink/pull/23223#issuecomment-1679932288
## CI report:
* 17b609b08bc2fa124b11a82ccbbfbd7b21a15f33 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu closed FLINK-27311.
Resolution: Not A Bug
Hi [~JonathanDiamant] , I think it should not happen IIUC.
Just as [~yunta]
masteryhx commented on PR #20689:
URL: https://github.com/apache/flink/pull/20689#issuecomment-1679928280
Hi @ChangjiGuo , Thanks for the effort.
I think it makes sense, do you have plan to complete this in the next
release ?
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-32873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32873:
---
Labels: pull-request-available (was: )
> Add configuration to allow disabling SQL query
bvarghese1 opened a new pull request, #23223:
URL: https://github.com/apache/flink/pull/23223
## What is the purpose of the change
Add a config to allow disabling QUERY hints -
flinkbot commented on PR #23222:
URL: https://github.com/apache/flink/pull/23222#issuecomment-1679922166
## CI report:
* d5cda8b7c683b09931a977546bc70c542bd896b9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
reswqa commented on code in PR #23179:
URL: https://github.com/apache/flink/pull/23179#discussion_r1295350783
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReaderImpl.java:
##
@@ -329,13 +327,15 @@ private Optional
reswqa commented on code in PR #23179:
URL: https://github.com/apache/flink/pull/23179#discussion_r1295350734
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReaderImpl.java:
##
@@ -329,13 +327,15 @@ private Optional
xuzifu666 commented on PR #23220:
URL: https://github.com/apache/flink/pull/23220#issuecomment-1679917396
@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
[
https://issues.apache.org/jira/browse/FLINK-32876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32876:
---
Labels: pull-request-available (was: )
> ExecutionTimeBasedSlowTaskDetector treats
JunRuiLee opened a new pull request, #23222:
URL: https://github.com/apache/flink/pull/23222
## What is the purpose of the change
Make ExecutionTimeBasedSlowTaskDetector not classify ExecutionVertex that is
still in the CREATED state as slow task.
## Brief change
xuzifu666 closed pull request #23220: [FLINK-32871][SQL] Support BuiltInMethod
TO_TIMESTAMP with timezon options
URL: https://github.com/apache/flink/pull/23220
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
WencongLiu commented on PR #22341:
URL: https://github.com/apache/flink/pull/22341#issuecomment-1679905718
Thanks for your patient review. @XComp I have added a fixup commit. PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
1996fanrui commented on PR #23203:
URL: https://github.com/apache/flink/pull/23203#issuecomment-1679903749
Hi @XComp , I have reorganized the second and the third commit, and the
total changes of this PR are totally same[1]. Please help double check in your
free time, thanks~
Jayadeep Jayaraman created FLINK-32878:
--
Summary: Add entropy to gcs path for better scalability
Key: FLINK-32878
URL: https://issues.apache.org/jira/browse/FLINK-32878
Project: Flink
WencongLiu commented on code in PR #22341:
URL: https://github.com/apache/flink/pull/22341#discussion_r1295337708
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java:
##
@@ -261,34 +261,69 @@ public void grantLeadership(UUID
WencongLiu commented on code in PR #22341:
URL: https://github.com/apache/flink/pull/22341#discussion_r1295337708
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java:
##
@@ -261,34 +261,69 @@ public void grantLeadership(UUID
WencongLiu commented on code in PR #22341:
URL: https://github.com/apache/flink/pull/22341#discussion_r1295337613
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java:
##
@@ -488,18 +523,21 @@ private boolean isRunning() {
WencongLiu commented on code in PR #22341:
URL: https://github.com/apache/flink/pull/22341#discussion_r1295337443
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java:
##
@@ -261,34 +261,69 @@ public void grantLeadership(UUID
WencongLiu commented on code in PR #22341:
URL: https://github.com/apache/flink/pull/22341#discussion_r1295337267
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunner.java:
##
@@ -261,34 +261,69 @@ public void grantLeadership(UUID
[
https://issues.apache.org/jira/browse/FLINK-32876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang reassigned FLINK-32876:
--
Assignee: Junrui Li
> ExecutionTimeBasedSlowTaskDetector treats unscheduled tasks as slow
[
https://issues.apache.org/jira/browse/FLINK-32876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Li updated FLINK-32876:
--
Description:
When we enable speculative execution and configure job with the following
[
https://issues.apache.org/jira/browse/FLINK-32876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Li updated FLINK-32876:
--
Description:
When we enable speculative execution and configure job with the following
[
https://issues.apache.org/jira/browse/FLINK-32790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia resolved FLINK-32790.
--
Resolution: Fixed
[~hackergin] Thanks for helping. Closing...
> Release Testing: Verify FLIP-311:
[
https://issues.apache.org/jira/browse/FLINK-32599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu closed FLINK-32599.
Resolution: Fixed
Since it has been fixed and #flink-dev-benchmarks channel works well now, I
[
https://issues.apache.org/jira/browse/FLINK-32771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754838#comment-17754838
]
Weihua Hu commented on FLINK-32771:
---
master: b3557cfdc0a2897356027c16d97161c11680c802
> Remove the
Jayadeep Jayaraman created FLINK-32877:
--
Summary: Support for HTTP connect and timeout options while writes
in GCS connector
Key: FLINK-32877
URL: https://issues.apache.org/jira/browse/FLINK-32877
[
https://issues.apache.org/jira/browse/FLINK-32771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu resolved FLINK-32771.
---
Resolution: Fixed
> Remove the invalid config option slotmanager.request-timeout
>
huwh closed pull request #23210: [FLINK-32771][SlotManager] Remove the invalid
config option slotmanager.request-timeout
URL: https://github.com/apache/flink/pull/23210
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
Junrui Li created FLINK-32876:
-
Summary: ExecutionTimeBasedSlowTaskDetector treats unscheduled
tasks as slow tasks and causes speculative execution to fail.
Key: FLINK-32876
URL:
KarmaGYZ commented on code in PR #23201:
URL: https://github.com/apache/flink/pull/23201#discussion_r1294245482
##
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManagerBuilder.java:
##
@@ -45,6 +45,7 @@ public class
[
https://issues.apache.org/jira/browse/FLINK-32799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754832#comment-17754832
]
luoyuxia edited comment on FLINK-32799 at 8/16/23 2:15 AM:
---
After FLINK-26603,
[
https://issues.apache.org/jira/browse/FLINK-32799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754832#comment-17754832
]
luoyuxia commented on FLINK-32799:
--
After FLINK-26603, to use hive dialect, we then won't need to swap
luoyuxia commented on code in PR #23130:
URL: https://github.com/apache/flink/pull/23130#discussion_r1295300857
##
docs/content.zh/docs/dev/table/sql/call.md:
##
@@ -0,0 +1,118 @@
+---
+title: "CALL 语句"
+weight: 19
+type: docs
+aliases:
+- /zh/dev/table/sql/call.html
+---
+
+
luoyuxia commented on code in PR #23130:
URL: https://github.com/apache/flink/pull/23130#discussion_r1295298761
##
docs/content.zh/docs/dev/table/procedures.md:
##
@@ -0,0 +1,541 @@
+---
+title: "存储过程"
+is_beta: true
+weight: 50
+type: docs
+aliases:
+ -
xuzifu666 commented on PR #23220:
URL: https://github.com/apache/flink/pull/23220#issuecomment-1679844161
@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
xuzifu666 closed pull request #23220: [FLINK-32871][SQL] Support BuiltInMethod
TO_TIMESTAMP with timezon options
URL: https://github.com/apache/flink/pull/23220
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
deepyaman commented on code in PR #23141:
URL: https://github.com/apache/flink/pull/23141#discussion_r1295230147
##
flink-python/dev/dev-requirements.txt:
##
@@ -15,20 +15,20 @@
pip>=20.3
setuptools>=18.0
wheel
-apache-beam==2.43.0
-cython==0.29.24
[
https://issues.apache.org/jira/browse/FLINK-21383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21383:
---
Labels: auto-deprioritized-major stale-minor usability (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-21608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21608:
---
Labels: auto-deprioritized-major stale-minor test-stability (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-21364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21364:
---
Labels: auto-deprioritized-major pull-request-available stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-29452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-29452:
---
Labels: pull-request-available stale-assigned starter (was:
pull-request-available
[
https://issues.apache.org/jira/browse/FLINK-21513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21513:
---
Labels: auto-deprioritized-major reactive stale-minor (was:
auto-deprioritized-major
[
https://issues.apache.org/jira/browse/FLINK-22336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-22336:
---
Labels: auto-deprioritized-major stale-minor (was:
auto-deprioritized-major)
I am the
[
https://issues.apache.org/jira/browse/FLINK-21693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21693:
---
Labels: auto-deprioritized-major stale-minor (was:
auto-deprioritized-major)
I am the
[
https://issues.apache.org/jira/browse/FLINK-21834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21834:
---
Labels: auto-deprioritized-critical auto-deprioritized-major stale-minor
test-stability
[
https://issues.apache.org/jira/browse/FLINK-29177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-29177:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-21995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21995:
---
Labels: auto-deprioritized-major auto-deprioritized-minor stale-minor
test-stability (was:
[
https://issues.apache.org/jira/browse/FLINK-22090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-22090:
---
Labels: auto-deprioritized-critical auto-deprioritized-major
auto-deprioritized-minor
[
https://issues.apache.org/jira/browse/FLINK-29497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-29497:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-22588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-22588:
---
Labels: pull-request-available stale-minor (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-29563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-29563:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-29339:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-22679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-22679:
---
Labels: auto-deprioritized-minor pull-request-available stale-minor (was:
[
https://issues.apache.org/jira/browse/FLINK-29398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-29398:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-29481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-29481:
---
Labels: features pull-request-available stale-assigned (was: features
[
https://issues.apache.org/jira/browse/FLINK-29516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-29516:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-29571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-29571:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-29565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-29565:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-29610:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the
[
https://issues.apache.org/jira/browse/FLINK-32874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754770#comment-17754770
]
Sergey Nuyanzin edited comment on FLINK-32874 at 8/15/23 9:35 PM:
--
dannycranmer closed pull request #669: MongoDB connector v1.0.2
URL: https://github.com/apache/flink-web/pull/669
--
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-32874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754770#comment-17754770
]
Sergey Nuyanzin commented on FLINK-32874:
-
[~satanicmechanic] could you please clarify where
Allison Chang created FLINK-32875:
-
Summary: Enable limiting number of retained jobs for the local job
archive directory in flink history server
Key: FLINK-32875
URL:
gyfora merged PR #666:
URL: https://github.com/apache/flink-web/pull/666
--
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:
afedulov commented on PR #23221:
URL: https://github.com/apache/flink/pull/23221#issuecomment-1679355381
Thanks @snuyanzin, I added the respective section to `docs/content.zh`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Morey Straus created FLINK-32874:
Summary: Update Janino to current
Key: FLINK-32874
URL: https://issues.apache.org/jira/browse/FLINK-32874
Project: Flink
Issue Type: Technical Debt
1996fanrui commented on PR #23203:
URL: https://github.com/apache/flink/pull/23203#issuecomment-1679275711
> It's actually not that tricky to do it using Intellij features.
Let me try to reorginaze the second and the third commit tomorrow, and fix
the odd `isTrue` togother, thank
[
https://issues.apache.org/jira/browse/FLINK-32873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bonnie Varghese updated FLINK-32873:
Description:
Platform providers may want to disable hints completely for security
Bonnie Varghese created FLINK-32873:
---
Summary: Add configuration to allow disabling SQL query hints
Key: FLINK-32873
URL: https://issues.apache.org/jira/browse/FLINK-32873
Project: Flink
XComp commented on code in PR #23195:
URL: https://github.com/apache/flink/pull/23195#discussion_r1294822852
##
tools/ci/verify_bundled_optional.sh:
##
@@ -19,22 +19,16 @@
## Checks that all bundled dependencies are marked as optional in the poms
MVN_CLEAN_COMPILE_OUT=$1
[
https://issues.apache.org/jira/browse/FLINK-24803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754699#comment-17754699
]
Xin Chen commented on FLINK-24803:
--
[~twalthr] Thank you. And I am sorry what config option do you
XComp commented on code in PR #23203:
URL: https://github.com/apache/flink/pull/23203#discussion_r1294810107
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/WaitingForResourcesTest.java:
##
@@ -236,22 +234,23 @@ public void
zentol commented on code in PR #23195:
URL: https://github.com/apache/flink/pull/23195#discussion_r1294815629
##
tools/ci/verify_bundled_optional.sh:
##
@@ -19,22 +19,16 @@
## Checks that all bundled dependencies are marked as optional in the poms
MVN_CLEAN_COMPILE_OUT=$1
XComp commented on code in PR #23203:
URL: https://github.com/apache/flink/pull/23203#discussion_r1294801460
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/StateTest.java:
##
@@ -18,85 +18,71 @@
package org.apache.flink.runtime.scheduler.adaptive;
[
https://issues.apache.org/jira/browse/FLINK-24803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754687#comment-17754687
]
Timo Walther commented on FLINK-24803:
--
If you like the old casting behavior, we provide a config
[
https://issues.apache.org/jira/browse/FLINK-24803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754686#comment-17754686
]
Timo Walther commented on FLINK-24803:
--
I answered in
zentol commented on PR #23195:
URL: https://github.com/apache/flink/pull/23195#issuecomment-1679154000
> Additionally, I would like to have a separate section (maybe ## Continuous
Integration?) next to ## Building Apache Flink from Source in Flink's
README.md. WDYT?
I think that we
1996fanrui commented on code in PR #23203:
URL: https://github.com/apache/flink/pull/23203#discussion_r1294785979
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/StateTest.java:
##
@@ -18,85 +18,71 @@
package
twalthr commented on PR #18221:
URL: https://github.com/apache/flink/pull/18221#issuecomment-1679140400
@YasuoStudyJava we followed the Postgres behavior here. Also, we should make
it explicit in the output whether the column is a `BYTES` column or `ARRAY`. AFAIK the new logic distinguishes
zentol commented on code in PR #23195:
URL: https://github.com/apache/flink/pull/23195#discussion_r1294775040
##
tools/ci/compile.sh:
##
@@ -69,34 +80,38 @@ fi
echo " Checking Javadocs "
+javadoc_output=/tmp/javadoc.out
+
# use the same invocation
zentol commented on code in PR #23195:
URL: https://github.com/apache/flink/pull/23195#discussion_r1294773109
##
tools/ci/compile.sh:
##
@@ -18,37 +18,48 @@
#
-# This file contains tooling for
zentol commented on code in PR #23195:
URL: https://github.com/apache/flink/pull/23195#discussion_r1294770709
##
tools/ci/maven-utils.sh:
##
@@ -21,12 +21,10 @@ function run_mvn {
MVN_CMD="${M2_HOME}/bin/mvn"
fi
- ARGS=$@
-
1996fanrui commented on code in PR #23203:
URL: https://github.com/apache/flink/pull/23203#discussion_r1294754457
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/StateWithoutExecutionGraphTest.java:
##
@@ -0,0 +1,97 @@
+/*
+ * Licensed to the Apache
1996fanrui commented on code in PR #23203:
URL: https://github.com/apache/flink/pull/23203#discussion_r1294724607
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/StateWithoutExecutionGraphTest.java:
##
@@ -0,0 +1,104 @@
+/*
+ * Licensed to the Apache
1996fanrui commented on code in PR #23203:
URL: https://github.com/apache/flink/pull/23203#discussion_r1294723857
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/MockStateWithoutExecutionGraphContext.java:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the
XComp commented on code in PR #23203:
URL: https://github.com/apache/flink/pull/23203#discussion_r1294717113
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/StateTest.java:
##
@@ -18,85 +18,71 @@
package org.apache.flink.runtime.scheduler.adaptive;
XComp commented on code in PR #23203:
URL: https://github.com/apache/flink/pull/23203#discussion_r1294712686
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/MockStateWithoutExecutionGraphContext.java:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache
1996fanrui commented on code in PR #23203:
URL: https://github.com/apache/flink/pull/23203#discussion_r1294710350
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/WaitingForResourcesTest.java:
##
@@ -328,19 +260,17 @@ public void
XComp commented on code in PR #23203:
URL: https://github.com/apache/flink/pull/23203#discussion_r1294709705
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/StateWithoutExecutionGraphTest.java:
##
@@ -0,0 +1,104 @@
+/*
+ * Licensed to the Apache
XComp commented on code in PR #23203:
URL: https://github.com/apache/flink/pull/23203#discussion_r1294708619
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/StateWithoutExecutionGraphTest.java:
##
@@ -0,0 +1,104 @@
+/*
+ * Licensed to the Apache
XComp commented on code in PR #23203:
URL: https://github.com/apache/flink/pull/23203#discussion_r1294696497
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/WaitingForResourcesTest.java:
##
@@ -328,19 +260,17 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-25938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu closed FLINK-25938.
Resolution: Cannot Reproduce
Since the issue was not reproduced beyond one year, I just closed
1 - 100 of 245 matches
Mail list logo
