[
https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695584#comment-17695584
]
Shengkai Fang edited comment on FLINK-31092 at 3/2/23 9:31 AM:
---
After
[
https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695585#comment-17695585
]
Weijie Guo commented on FLINK-31104:
Hi all,
To be honest, the root cause of this ticket is
flinkbot commented on PR #22069:
URL: https://github.com/apache/flink/pull/22069#issuecomment-1451565050
## CI report:
* cd513e483c05da1348202e68c7dc2225bc75d682 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695612#comment-17695612
]
Weijie Guo edited comment on FLINK-29884 at 3/2/23 9:50 AM:
[~mapohl] Thanks
Matthias Pohl created FLINK-31297:
-
Summary:
FineGrainedSlotManagerTest.testTaskManagerRegistrationDeductPendingTaskManager
untable when running it a single time
Key: FLINK-31297
URL:
[
https://issues.apache.org/jira/browse/FLINK-31256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-31256:
Summary: [Umbrella] FLIP-297: Improve Auxiliary Sql Statements (was:
FLIP-297: Improve Auxiliary Sql
[
https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695640#comment-17695640
]
Matthias Pohl edited comment on FLINK-31092 at 3/2/23 11:08 AM:
{quote}
flinkbot commented on PR #22071:
URL: https://github.com/apache/flink/pull/22071#issuecomment-1451771158
## CI report:
* 46c50ade6726d80a06f0bb9c5021caf1cc4baf9f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695705#comment-17695705
]
David Morávek commented on FLINK-29852:
---
Master: 758ce72158922e00ed7078e00706f8502145e461
>
mateczagany commented on PR #538:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/538#issuecomment-1451835015
@gyfora it seems the autoscaler tests are still not included in the e2e CI
actions, is that intentional?
[
https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695585#comment-17695585
]
Weijie Guo edited comment on FLINK-31104 at 3/2/23 9:34 AM:
Hi all,
To be
[
https://issues.apache.org/jira/browse/FLINK-29884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695612#comment-17695612
]
Weijie Guo edited comment on FLINK-29884 at 3/2/23 9:48 AM:
[~mapohl] Thanks
[
https://issues.apache.org/jira/browse/FLINK-29884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695612#comment-17695612
]
Weijie Guo edited comment on FLINK-29884 at 3/2/23 9:48 AM:
[~mapohl] Thanks
[
https://issues.apache.org/jira/browse/FLINK-31288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-31288:
--
Priority: Blocker (was: Major)
> Disable overdraft buffer for batch shuffle
>
[
https://issues.apache.org/jira/browse/FLINK-31288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-31288:
--
Affects Version/s: 1.17.0
> Disable overdraft buffer for batch shuffle
>
[
https://issues.apache.org/jira/browse/FLINK-31288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31288:
---
Affects Version/s: 1.16.1
> Disable overdraft buffer for batch shuffle
>
[
https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31092:
--
Description:
We're experiencing an OutOfMemoryError where the heap space reaches the upper
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695636#comment-17695636
]
xzw0223 commented on FLINK-31297:
-
After adding the PendingTaskManager, the pending is cleaned up in the
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695644#comment-17695644
]
Weijie Guo commented on FLINK-31297:
Thanks [~mapohl] for reporting this, I will take a look at this
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-31297:
--
Assignee: Weijie Guo
>
Aitozi commented on code in PR #21522:
URL: https://github.com/apache/flink/pull/21522#discussion_r1122955305
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java:
##
@@ -558,14 +559,14 @@ private HadoopFileSystemFactory
[
https://issues.apache.org/jira/browse/FLINK-31249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695686#comment-17695686
]
renxiang zhou commented on FLINK-31249:
---
[~Yanfei Lei] [~masteryhx] Count you please have a look
dmvk commented on code in PR #22022:
URL: https://github.com/apache/flink/pull/22022#discussion_r1123044415
##
flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/graph/TestEventSource.java:
##
@@ -103,6 +110,14 @@ private void ack(TestCommand cmd) {
godfreyhe closed pull request #22024: [FLINK-30989][table] Fix some options
don't take effect in batch mode
URL: https://github.com/apache/flink/pull/22024
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
[
https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695585#comment-17695585
]
Weijie Guo edited comment on FLINK-31104 at 3/2/23 9:33 AM:
Hi all,
To be
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-31297:
--
Assignee: Weihua Hu (was: Weijie Guo)
>
Maximilian Michels created FLINK-31299:
--
Summary: PendingRecords metric might not be available
Key: FLINK-31299
URL: https://issues.apache.org/jira/browse/FLINK-31299
Project: Flink
reswqa opened a new pull request, #22076:
URL: https://github.com/apache/flink/pull/22076
Backport FLINK-31288 to release-1.16.
--
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-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695584#comment-17695584
]
Shengkai Fang edited comment on FLINK-31092 at 3/2/23 9:32 AM:
---
After
[
https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695609#comment-17695609
]
Shengkai Fang commented on FLINK-31092:
---
> I guess, your proposal wouldn't work: It looks like
reswqa opened a new pull request, #22070:
URL: https://github.com/apache/flink/pull/22070
Backport FLINK-29884 to release-1.16.
--
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-29884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695612#comment-17695612
]
Weijie Guo edited comment on FLINK-29884 at 3/2/23 9:49 AM:
[~mapohl] Thanks
flinkbot commented on PR #22070:
URL: https://github.com/apache/flink/pull/22070#issuecomment-1451588775
## CI report:
* 43958a713d363ebabd1e31a5c2a9eb37b00deb0a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695624#comment-17695624
]
Qingsheng Ren commented on FLINK-31104:
---
Thanks for the investigation and feedback [~Weijie Guo] !
[
https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31104:
--
Priority: Critical (was: Blocker)
> TPC-DS test timed out in query 36
>
[
https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695656#comment-17695656
]
Jark Wu commented on FLINK-31275:
-
Thank you [~zjureel], I think the lineage information of tables and
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695657#comment-17695657
]
Weijie Guo commented on FLINK-31297:
[~mapohl] By offline discuss with [~huwh], this is just a test
gaoyunhaii commented on PR #21736:
URL: https://github.com/apache/flink/pull/21736#issuecomment-1451676533
Hi @XComp very thanks for the review! The CI failure is due to that now we
have change the test versions to be [xx, recently published version] for all
the migration tests, now the
liuyongvs commented on code in PR #21993:
URL: https://github.com/apache/flink/pull/21993#discussion_r1122959202
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/ArrayElementArgumentTypeStrategy.java:
##
@@ -31,24 +31,28 @@
[
https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695670#comment-17695670
]
Shengkai Fang commented on FLINK-31092:
---
+1 to refactor this.
> Hive ITCases fail with
[
https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695671#comment-17695671
]
Shammon commented on FLINK-31275:
-
Thanks [~jark], please assign this issue to me and I will create a
liuyongvs commented on PR #21978:
URL: https://github.com/apache/flink/pull/21978#issuecomment-1451788589
after offline discussion with @wangyang0918 , we both think it is in need.
@zentol
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
dmvk opened a new pull request, #22074:
URL: https://github.com/apache/flink/pull/22074
Backport of https://github.com/apache/flink/pull/22066
--
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
dmvk merged PR #22066:
URL: https://github.com/apache/flink/pull/22066
--
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:
echauchot commented on PR #21636:
URL: https://github.com/apache/flink/pull/21636#issuecomment-1451865056
@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-29884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695612#comment-17695612
]
Weijie Guo commented on FLINK-29884:
[~mapohl] Thanks for reopening this, I have created the
[
https://issues.apache.org/jira/browse/FLINK-30978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695628#comment-17695628
]
Matthias Pohl commented on FLINK-30978:
---
[
https://issues.apache.org/jira/browse/FLINK-31288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695629#comment-17695629
]
Qingsheng Ren commented on FLINK-31288:
---
Marked as blocker of 1.17 since we need to wait for this
rkhachatryan commented on code in PR #22022:
URL: https://github.com/apache/flink/pull/22022#discussion_r1122972996
##
flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/graph/TestEventSource.java:
##
@@ -103,6 +110,14 @@ private void ack(TestCommand cmd) {
[
https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Godfrey He reopened FLINK-30989:
> Configuration table.exec.spill-compression.block-size not take effect in
> batch job
>
[
https://issues.apache.org/jira/browse/FLINK-31295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695586#comment-17695586
]
Gabor Somogyi commented on FLINK-31295:
---
Have you tested the latest master? Please see
[
https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-31092:
-
Assignee: Shengkai Fang (was: luoyuxia)
> Hive ITCases fail with OutOfMemoryError
>
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31297:
--
Description:
We noticed a weird test-instability in
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695615#comment-17695615
]
Matthias Pohl commented on FLINK-31297:
---
[~huwh] may you have a look at it?
>
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1122893111
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraph.java:
##
@@ -143,7 +143,7 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695659#comment-17695659
]
Matthias Pohl commented on FLINK-31297:
---
Thanks for your verification :)
>
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695659#comment-17695659
]
Matthias Pohl edited comment on FLINK-31297 at 3/2/23 11:05 AM:
Thanks
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695659#comment-17695659
]
Matthias Pohl edited comment on FLINK-31297 at 3/2/23 11:05 AM:
Thanks
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695659#comment-17695659
]
Matthias Pohl edited comment on FLINK-31297 at 3/2/23 11:06 AM:
Thanks
loserwang1024 opened a new pull request, #22071:
URL: https://github.com/apache/flink/pull/22071
## What is the purpose of the change
As described in
[FLINK-31208](https://issues.apache.org/jira/browse/FLINK-31208?filter=-2), an
override method named pauseOrResumeSplits in
flinkbot commented on PR #22072:
URL: https://github.com/apache/flink/pull/22072#issuecomment-1451813802
## CI report:
* dc846d8bf7022b8993d08bf8f63dff4eda5032a0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31299:
---
Labels: pull-request-available (was: )
> PendingRecords metric might not be available
>
godfreyhe commented on code in PR #22031:
URL: https://github.com/apache/flink/pull/22031#discussion_r1123080762
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveSumAggFunction.java:
##
@@ -88,27 +97,27 @@ public Expression[]
dmvk commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1122815464
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java:
##
@@ -784,7 +789,7 @@ public ArchivedExecutionGraph
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695615#comment-17695615
]
Matthias Pohl edited comment on FLINK-31297 at 3/2/23 9:54 AM:
---
I can
[
https://issues.apache.org/jira/browse/FLINK-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31104:
--
Affects Version/s: 1.16.1
> TPC-DS test timed out in query 36
>
Aitozi commented on PR #21522:
URL: https://github.com/apache/flink/pull/21522#issuecomment-1451614127
I'm revisiting this pr now.
--
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-31104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695585#comment-17695585
]
Weijie Guo edited comment on FLINK-31104 at 3/2/23 10:13 AM:
-
Hi all,
To be
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31297:
--
Priority: Critical (was: Blocker)
>
rkhachatryan commented on code in PR #22022:
URL: https://github.com/apache/flink/pull/22022#discussion_r1122982354
##
flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/TestJobExecutor.java:
##
@@ -164,22 +164,23 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-31208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31208:
---
Labels: pull-request-available starter (was: starter)
> KafkaSourceReader overrides
[
https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31092:
---
Labels: pull-request-available test-stability (was: test-stability)
> Hive ITCases fail
fsk119 opened a new pull request, #22072:
URL: https://github.com/apache/flink/pull/22072
## What is the purpose of the change
*Fix test OOM in the Hive Module. There are two problems in the test:*
*1. Gateway doesn't wait for all tasks finished before releasing the
dmvk opened a new pull request, #22073:
URL: https://github.com/apache/flink/pull/22073
Backport of https://github.com/apache/flink/pull/22066
--
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
[
https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695584#comment-17695584
]
Shengkai Fang commented on FLINK-31092:
---
After discussing with [~lsy] , I think we get why the
[
https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695598#comment-17695598
]
Shammon commented on FLINK-31275:
-
[~jark] As described in FLIP-276, we'd like to store the relationship
Aitozi commented on PR #22044:
URL: https://github.com/apache/flink/pull/22044#issuecomment-1451591776
> However, for these batch jobs with high parallelism in produce
environment, the amount of data in single parallelism is almost less than
500. Therefore, after testing, we found that
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31297:
--
Description:
We noticed a weird test-instability in
Matthias Pohl created FLINK-31298:
-
Summary:
ConnectionUtilsTest.testFindConnectingAddressWhenGetLocalHostThrows swallows
IllegalArgumentException
Key: FLINK-31298
URL:
[
https://issues.apache.org/jira/browse/FLINK-31298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31298:
--
Labels: starter test-stability (was: test-stability)
>
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31297:
---
Summary:
FineGrainedSlotManagerTest.testTaskManagerRegistrationDeductPendingTaskManager
unstable
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695649#comment-17695649
]
Weijie Guo commented on FLINK-31297:
[~xzw0223] Thanks for looking into this, but I do not think
[
https://issues.apache.org/jira/browse/FLINK-31297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695649#comment-17695649
]
Weijie Guo edited comment on FLINK-31297 at 3/2/23 10:38 AM:
-
[~xzw0223]
[
https://issues.apache.org/jira/browse/FLINK-31239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Godfrey He reassigned FLINK-31239:
--
Assignee: dalongliu
> Fix sum function can't get the corrected value when the argument type
flinkbot commented on PR #22075:
URL: https://github.com/apache/flink/pull/22075#issuecomment-1451840769
## CI report:
* 0db695367391271c262f73cb53e86251d62e02c9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #22076:
URL: https://github.com/apache/flink/pull/22076#issuecomment-1451849742
## CI report:
* d0cedf2fabfa5099f87f96560e37a4cc69feecd3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Godfrey He closed FLINK-30989.
--
Resolution: Fixed
Fixed in
1.18.0: b4d43b47c993b7b4d5e4f7a78610c54124fcbcb4
1.17.0:
[
https://issues.apache.org/jira/browse/FLINK-30989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Godfrey He updated FLINK-30989:
---
Fix Version/s: 1.17.0
1.18.0
> Configuration
dmvk commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1122833790
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraph.java:
##
@@ -143,7 +143,7 @@ private void handleExecutionGraphCreation(
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1122889885
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java:
##
@@ -784,7 +789,7 @@ public ArchivedExecutionGraph
rkhachatryan commented on code in PR #21981:
URL: https://github.com/apache/flink/pull/21981#discussion_r1122889605
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/JobAllocationsInformation.java:
##
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695640#comment-17695640
]
Matthias Pohl commented on FLINK-31092:
---
Good pointer: I guess, the error handling could be
Aitozi commented on code in PR #21522:
URL: https://github.com/apache/flink/pull/21522#discussion_r1122954392
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java:
##
@@ -558,14 +559,14 @@ private HadoopFileSystemFactory
rkhachatryan commented on PR #22022:
URL: https://github.com/apache/flink/pull/22022#issuecomment-1451752308
Thanks for the review @dmvk!
I've updated the both commit messages and marked `scheduledCommands` as
`volatile`.
> For the second commit
>> Otherwise, any command
reswqa commented on PR #22067:
URL: https://github.com/apache/flink/pull/22067#issuecomment-1451817638
Very thanks @1996fanrui for the quick review, merged % CI green.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
flinkbot commented on PR #22073:
URL: https://github.com/apache/flink/pull/22073#issuecomment-1451830416
## CI report:
* 6d23ea6c6d0248029404039b15bb4f9cefc57db9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #22074:
URL: https://github.com/apache/flink/pull/22074#issuecomment-1451830625
## CI report:
* a2489a91efb8b261f5f4bccb21a0e8d13c15868f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mxm opened a new pull request, #542:
URL: https://github.com/apache/flink-kubernetes-operator/pull/542
The Kafka pendingRecords metric is only initialized on receiving the first
record. For empty topics or checkpointed topics without any incoming data, the
metric won't appear.
We
reswqa opened a new pull request, #22075:
URL: https://github.com/apache/flink/pull/22075
Backport FLINK-31288 to release-1.17.
--
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
MartijnVisser commented on code in PR #614:
URL: https://github.com/apache/flink-web/pull/614#discussion_r1123169300
##
docs/content.zh/community.md:
##
@@ -170,43 +170,7 @@ Committer 们会关注 [Stack
Overflow](http://stackoverflow.com/questions/tagge
我们使用 Jira 进行所有代码相关的 issues 追踪
1 - 100 of 357 matches
Mail list logo
