TanYuxin-tyx commented on PR #22443:
URL: https://github.com/apache/flink/pull/22443#issuecomment-1518498947
@reswqa @MartijnVisser @liuyongvs Thanks for reviewing.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
tzulitai closed pull request #632: Add Flink Kafka Connector v3.0.0
URL: https://github.com/apache/flink-web/pull/632
--
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
tzulitai closed pull request #606: Flink Kafka Connector 3.0.0
URL: https://github.com/apache/flink-web/pull/606
--
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
VinayLondhe14 commented on PR #18730:
URL: https://github.com/apache/flink/pull/18730#issuecomment-1518395452
Is there a particular reason this PR has not been merged?
--
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 #22451:
URL: https://github.com/apache/flink/pull/22451#issuecomment-1518370390
## CI report:
* 639c2246b369dfa275e193207fd2cb7e74bb7870 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31880:
---
Labels: pull-request-available (was: )
> Bad Test in OrcColumnarRowSplitReaderTest
>
kurtostfeld opened a new pull request, #22451:
URL: https://github.com/apache/flink/pull/22451
## What is the purpose of the change
Fix the broken unit test so that unit tests pass.
## Brief change log
Very simple self-explanatory single file fix.
## Verifying
Kurt Ostfeld created FLINK-31880:
Summary: Bad Test in OrcColumnarRowSplitReaderTest
Key: FLINK-31880
URL: https://issues.apache.org/jira/browse/FLINK-31880
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-31828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715160#comment-17715160
]
Vladimir Matveev commented on FLINK-31828:
--
Hi [~aitozi], thank you for the quick response!
XComp commented on code in PR #22422:
URL: https://github.com/apache/flink/pull/22422#discussion_r1174080585
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/LeaderElectionEventHandler.java:
##
@@ -39,12 +40,29 @@ public interface
[
https://issues.apache.org/jira/browse/FLINK-31848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715115#comment-17715115
]
Shuiqiang Chen edited comment on FLINK-31848 at 4/21/23 6:32 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-31848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715115#comment-17715115
]
Shuiqiang Chen edited comment on FLINK-31848 at 4/21/23 6:31 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-31848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715115#comment-17715115
]
Shuiqiang Chen edited comment on FLINK-31848 at 4/21/23 6:29 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-31848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715115#comment-17715115
]
Shuiqiang Chen edited comment on FLINK-31848 at 4/21/23 6:18 PM:
-
Feroze Daud created FLINK-31879:
---
Summary: org.apache.avro.util.Utf8 cannot be serialized with avro
when used in state
Key: FLINK-31879
URL: https://issues.apache.org/jira/browse/FLINK-31879
Project:
[
https://issues.apache.org/jira/browse/FLINK-31848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715115#comment-17715115
]
Shuiqiang Chen commented on FLINK-31848:
[~martijnvisser][~zju_zsx][~jark] Thanks for your
reswqa commented on code in PR #22424:
URL: https://github.com/apache/flink/pull/22424#discussion_r1174029242
##
flink-runtime/src/test/java/org/apache/flink/runtime/clusterframework/types/LocationPreferenceSlotSelectionStrategyTest.java:
##
@@ -134,39 +139,57 @@ private
[
https://issues.apache.org/jira/browse/FLINK-31873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eric Xiao updated FLINK-31873:
--
Description:
When turning on Flink reactive mode, it is suggested to convert all
{{setParallelism}}
[
https://issues.apache.org/jira/browse/FLINK-31828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715111#comment-17715111
]
Aitozi commented on FLINK-31828:
Hi [~netvl] Thanks for this detailed bug report.
I have reproduced
[
https://issues.apache.org/jira/browse/FLINK-31878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31878:
---
Priority: Minor (was: Major)
> Fix the wrong name of PauseOrResumeSplitsTask#toString in connector
[
https://issues.apache.org/jira/browse/FLINK-31878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31878.
--
Fix Version/s: 1.18.0
Resolution: Fixed
master(1.18) via
reswqa merged PR #22443:
URL: https://github.com/apache/flink/pull/22443
--
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:
[
https://issues.apache.org/jira/browse/FLINK-31398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31398.
--
Fix Version/s: 1.17.1
Resolution: Fixed
> Don't wrap with TemporaryClassLoaderContext in
[
https://issues.apache.org/jira/browse/FLINK-31398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714809#comment-17714809
]
Weijie Guo edited comment on FLINK-31398 at 4/21/23 5:17 PM:
-
master(1.18)
reswqa merged PR #22444:
URL: https://github.com/apache/flink/pull/22444
--
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:
[
https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715100#comment-17715100
]
Chalres Tan commented on FLINK-29692:
-
re [~jark]: Thanks for the response. The example query you
[
https://issues.apache.org/jira/browse/FLINK-24998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715086#comment-17715086
]
Chesnay Schepler edited comment on FLINK-24998 at 4/21/23 4:42 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-24998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715086#comment-17715086
]
Chesnay Schepler commented on FLINK-24998:
--
[~schoeneu] That is a good find. I _think_ I used
[
https://issues.apache.org/jira/browse/FLINK-24998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-24998:
Assignee: Chesnay Schepler
> SIGSEGV in Kryo / C2 CompilerThread on Java 17
>
[
https://issues.apache.org/jira/browse/FLINK-31827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715078#comment-17715078
]
Gyula Fora commented on FLINK-31827:
The first fix on the operator side is merged for this:
gyfora merged PR #571:
URL: https://github.com/apache/flink-kubernetes-operator/pull/571
--
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:
XComp commented on code in PR #22422:
URL: https://github.com/apache/flink/pull/22422#discussion_r1173943821
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/LeaderElectionEventHandler.java:
##
@@ -39,12 +40,29 @@ public interface
XComp commented on code in PR #22422:
URL: https://github.com/apache/flink/pull/22422#discussion_r1173929303
##
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionServiceTest.java:
##
@@ -130,22 +137,101 @@ void
[
https://issues.apache.org/jira/browse/FLINK-31866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31866:
---
Labels: pull-request-available (was: )
> Autoscaler metric trimming reduces the number of
mxm opened a new pull request, #573:
URL: https://github.com/apache/flink-kubernetes-operator/pull/573
The autoscaler uses a ConfigMap to store past metric observations which is
used to re-initialize the autoscaler state in case of failures or upgrades.
Whenever trimming of the
fredia commented on code in PR #22257:
URL: https://github.com/apache/flink/pull/22257#discussion_r1173259129
##
flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.17-rocksdb-checkpoint/0193581b-bd07-4b9d-b5d3-a6c986164fa4:
##
@@ -0,0 +1,362 @@
+#
liuyongvs commented on PR #22450:
URL: https://github.com/apache/flink/pull/22450#issuecomment-1517949017
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
[
https://issues.apache.org/jira/browse/FLINK-31866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-31866:
---
Summary: Autoscaler metric trimming reduces the number of metric
observations on
[
https://issues.apache.org/jira/browse/FLINK-24998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715038#comment-17715038
]
Urs Schoenenberger commented on FLINK-24998:
[~chesnay] is this issue still reproducible
[
https://issues.apache.org/jira/browse/FLINK-31866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-31866:
---
Summary: Autoscaler metric trimming reduces the numbet of metric
observations on
[
https://issues.apache.org/jira/browse/FLINK-31873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eric Xiao updated FLINK-31873:
--
Description:
When turning on Flink reactive mode, it is suggested to convert all
{{setParallelism}}
zentol commented on code in PR #22422:
URL: https://github.com/apache/flink/pull/22422#discussion_r1173821559
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/LeaderElectionEventHandler.java:
##
@@ -39,12 +40,29 @@ public interface
[
https://issues.apache.org/jira/browse/FLINK-31873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715028#comment-17715028
]
Eric Xiao commented on FLINK-31873:
---
Thanks [~martijnvisser] and [~luoyuxia], I will start with
zentol commented on code in PR #22422:
URL: https://github.com/apache/flink/pull/22422#discussion_r1173807106
##
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionServiceTest.java:
##
@@ -130,22 +137,101 @@ void
XComp commented on code in PR #22422:
URL: https://github.com/apache/flink/pull/22422#discussion_r1173806764
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/LeaderElectionEventHandler.java:
##
@@ -39,12 +40,29 @@ public interface
XComp commented on code in PR #22422:
URL: https://github.com/apache/flink/pull/22422#discussion_r1173805207
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/LeaderElectionEventHandler.java:
##
@@ -39,12 +40,29 @@ public interface
XComp commented on code in PR #22422:
URL: https://github.com/apache/flink/pull/22422#discussion_r1173805207
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/LeaderElectionEventHandler.java:
##
@@ -39,12 +40,29 @@ public interface
zentol commented on code in PR #22422:
URL: https://github.com/apache/flink/pull/22422#discussion_r1173801508
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/LeaderElectionEventHandler.java:
##
@@ -39,12 +40,29 @@ public interface
zentol commented on code in PR #22422:
URL: https://github.com/apache/flink/pull/22422#discussion_r1173801508
##
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/LeaderElectionEventHandler.java:
##
@@ -39,12 +40,29 @@ public interface
snuyanzin commented on code in PR #22257:
URL: https://github.com/apache/flink/pull/22257#discussion_r117377
##
flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.17-rocksdb-checkpoint/0193581b-bd07-4b9d-b5d3-a6c986164fa4:
##
@@ -0,0 +1,362 @@
XComp commented on code in PR #22257:
URL: https://github.com/apache/flink/pull/22257#discussion_r1173766452
##
flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.17-rocksdb-checkpoint/0193581b-bd07-4b9d-b5d3-a6c986164fa4:
##
@@ -0,0 +1,362 @@
+#
[
https://issues.apache.org/jira/browse/FLINK-30651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb resolved FLINK-30651.
Resolution: Invalid
> Move utility methods to CatalogTest and remove CatalogTestUtils class
>
flinkbot commented on PR #22450:
URL: https://github.com/apache/flink/pull/22450#issuecomment-1517826614
## CI report:
* e7a3e7051dd0a041fc4e5ab2e68238c183b59a34 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yangjf2019 commented on PR #567:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/567#issuecomment-1517823027
I found that the exception is generated when I commit
`e2e-tests/data/flinkdep-cr.yaml` and run `default/flink-example-statemachine`,
do we need to upgrade the flink
flinkbot commented on PR #22449:
URL: https://github.com/apache/flink/pull/22449#issuecomment-1517819883
## CI report:
* f7e156ab4e74d487e3047bc8ac86182c69d82d15 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek resolved FLINK-31723.
---
Fix Version/s: 1.18.0
Resolution: Fixed
>
charlesdong1991 opened a new pull request, #22450:
URL: https://github.com/apache/flink/pull/22450
Remove seemingly duplicate sentence in docker deployment page
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-31723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714997#comment-17714997
]
David Morávek commented on FLINK-31723:
---
master: 378d3ca0d4b487b1ebc9354e9ebe8952cc3a9d11
dmvk merged PR #22435:
URL: https://github.com/apache/flink/pull/22435
--
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:
[
https://issues.apache.org/jira/browse/FLINK-31752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31752:
---
Labels: pull-request-available (was: )
> SourceOperatorStreamTask increments numRecordsOut
yunfengzhou-hub opened a new pull request, #22449:
URL: https://github.com/apache/flink/pull/22449
## What is the purpose of the change
This pull request fixes the bug that the metric numRecordsOut is increased
twice in `SourceOperatorStreamTask` and in `ChainingOutput`, which was
[
https://issues.apache.org/jira/browse/FLINK-31848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714995#comment-17714995
]
Jark Wu commented on FLINK-31848:
-
[~csq] do you have a simple case to reproduce the wrong result (and
[
https://issues.apache.org/jira/browse/FLINK-31869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-31869.
--
Fix Version/s: kubernetes-operator-1.5.0
Resolution: Fixed
Merged to main
[
https://issues.apache.org/jira/browse/FLINK-31874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-31874:
Fix Version/s: 1.18.0
> Support truncate table statement in batch mode
>
[
https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714985#comment-17714985
]
Jark Wu commented on FLINK-29692:
-
Hi [~charles-tan], thank you for sharing your use case. I'm just
[
https://issues.apache.org/jira/browse/FLINK-31869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31869:
---
Labels: pull-request-available (was: )
> test_multi_sessionjob.sh gets stuck very
gyfora merged PR #572:
URL: https://github.com/apache/flink-kubernetes-operator/pull/572
--
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:
[
https://issues.apache.org/jira/browse/FLINK-31869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-31869:
--
Assignee: Gyula Fora
> test_multi_sessionjob.sh gets stuck very frequently
>
[
https://issues.apache.org/jira/browse/FLINK-30609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-30609.
--
Resolution: Fixed
merged to main bad872d04e324fde2b6396e18bae5a37d804f59b
> Add ephemeral storage to
gyfora merged PR #561:
URL: https://github.com/apache/flink-kubernetes-operator/pull/561
--
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:
[
https://issues.apache.org/jira/browse/FLINK-30852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Kalashnikov updated FLINK-30852:
--
Fix Version/s: 1.17.1
> TaskTest.testCleanupWhenSwitchToInitializationFails reports
[
https://issues.apache.org/jira/browse/FLINK-30852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Kalashnikov resolved FLINK-30852.
---
Resolution: Fixed
> TaskTest.testCleanupWhenSwitchToInitializationFails reports
[
https://issues.apache.org/jira/browse/FLINK-30852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714961#comment-17714961
]
Anton Kalashnikov commented on FLINK-30852:
---
merged to release-1.17:
akalash merged PR #22436:
URL: https://github.com/apache/flink/pull/22436
--
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:
[
https://issues.apache.org/jira/browse/FLINK-28386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714956#comment-17714956
]
Piotr Nowojski commented on FLINK-28386:
[~zlzhang0122] Checkpoint could be used just to make
[
https://issues.apache.org/jira/browse/FLINK-31846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-31846.
--
Resolution: Duplicate
I will close this ticket, as I think it just duplicates FLINK-28386,
[
https://issues.apache.org/jira/browse/FLINK-31846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714946#comment-17714946
]
Piotr Nowojski edited comment on FLINK-31846 at 4/21/23 11:33 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-31846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714946#comment-17714946
]
Piotr Nowojski edited comment on FLINK-31846 at 4/21/23 11:32 AM:
--
Aitozi commented on PR #22378:
URL: https://github.com/apache/flink/pull/22378#issuecomment-1517684780
ping @luoyuxia
--
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
1996fanrui commented on PR #22392:
URL: https://github.com/apache/flink/pull/22392#issuecomment-1517672547
> Thanks for the fix!
>
> Can you add a small unit test? Apart of that LGTM Feel free to merge after
adding the unit test and with green azure :)
Thanks for the quick
[
https://issues.apache.org/jira/browse/FLINK-31846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714946#comment-17714946
]
Piotr Nowojski edited comment on FLINK-31846 at 4/21/23 11:08 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-31846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714946#comment-17714946
]
Piotr Nowojski commented on FLINK-31846:
{quote}
f the final checkpoint cannot be cancelled, can
dmvk commented on PR #22441:
URL: https://github.com/apache/flink/pull/22441#issuecomment-1517640808
What's the motivation behind the PR? Is this just a cosmetic thing, or is
there something broken? If cosmetic, I'd expect this to be the other way
around, using the unboxed types that
flinkbot commented on PR #22448:
URL: https://github.com/apache/flink/pull/22448#issuecomment-1517637993
## CI report:
* f71e3afff45ea49d2ecd060476dc77b90afe3255 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
wsry commented on PR #22448:
URL: https://github.com/apache/flink/pull/22448#issuecomment-1517633083
This is a cherry picked PR, will merge after tests pass.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-31803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714937#comment-17714937
]
David Morávek commented on FLINK-31803:
---
master: c2ab806a3624471bb36f87ba98d51f672b7894fe
>
[
https://issues.apache.org/jira/browse/FLINK-31803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek resolved FLINK-31803.
---
Fix Version/s: 1.18.0
Resolution: Fixed
>
dmvk merged PR #22408:
URL: https://github.com/apache/flink/pull/22408
--
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:
reswqa commented on PR #22432:
URL: https://github.com/apache/flink/pull/22432#issuecomment-1517630686
Hi @pnowojski, Would you mind taking a look at this in you free time as you
have been reviewed the original
[PR](https://github.com/apache/flink/pull/13109).
--
This is an automated
wsry opened a new pull request, #22448:
URL: https://github.com/apache/flink/pull/22448
## What is the purpose of the change
Currently, the SortMergeResultPartition may allocate more network buffers
than the guaranteed size of the LocalBufferPool. As a result, some result
partitions
flinkbot commented on PR #22447:
URL: https://github.com/apache/flink/pull/22447#issuecomment-1517625986
## CI report:
* 62fc6fa527aaf68ee2e2d582a56107ad52fd8714 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31764:
---
Labels: pull-request-available (was: )
> Get rid of
reswqa opened a new pull request, #22447:
URL: https://github.com/apache/flink/pull/22447
## What is the purpose of the change
*After [FLINK-31763](https://issues.apache.org/jira/browse/FLINK-31763), we
don't need the specific field `numberOfRequestedOverdraftMemorySegments` to
[
https://issues.apache.org/jira/browse/FLINK-31878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-31878:
--
Fix Version/s: (was: 1.18.0)
> Fix the wrong name of PauseOrResumeSplitsTask#toString in
[
https://issues.apache.org/jira/browse/FLINK-31878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-31878:
--
Affects Version/s: 1.18.0
> Fix the wrong name of PauseOrResumeSplitsTask#toString in connector
TanYuxin-tyx commented on code in PR #22395:
URL: https://github.com/apache/flink/pull/22395#discussion_r1173578262
##
docs/layouts/shortcodes/py_connector_download_link.html:
##
@@ -0,0 +1,62 @@
+{{/*
+Licensed to the Apache Software Foundation (ASF) under one
+or more
pvary commented on PR #22437:
URL: https://github.com/apache/flink/pull/22437#issuecomment-1517549223
Thanks @zhuzhurk for the guidance and commit!
--
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
MartijnVisser commented on PR #22443:
URL: https://github.com/apache/flink/pull/22443#issuecomment-1517539242
Wouldn't this break all connectors that have implemented this method
already, like Kafka?
--
This is an automated message from the Apache Git Service.
To respond to the message,
flinkbot commented on PR #22446:
URL: https://github.com/apache/flink/pull/22446#issuecomment-1517536013
## CI report:
* e0086f25a4e965cbbc5030c7e9517f91d1991e4a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
chachae opened a new pull request, #22446:
URL: https://github.com/apache/flink/pull/22446
Cherry pick https://github.com/apache/flink/pull/19994 and
https://github.com/apache/flink/pull/20526 to release-1.15
--
This is an automated message from the Apache Git Service.
To respond to
1 - 100 of 145 matches
Mail list logo
