PrabhuJoseph commented on PR #23700:
URL: https://github.com/apache/flink/pull/23700#issuecomment-1809695196
Thanks @dianfu and @ColtenP for the review.
--
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-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785777#comment-17785777
]
Matthias Pohl commented on FLINK-32523:
---
[
https://issues.apache.org/jira/browse/FLINK-33082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785776#comment-17785776
]
Matthias Pohl commented on FLINK-33082:
---
[
https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785775#comment-17785775
]
Matthias Pohl commented on FLINK-18356:
---
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785774#comment-17785774
]
Matthias Pohl commented on FLINK-31278:
---
There is a 137 in the table module as well (which is
[
https://issues.apache.org/jira/browse/FLINK-32972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785773#comment-17785773
]
Matthias Pohl commented on FLINK-32972:
---
[
https://issues.apache.org/jira/browse/FLINK-31278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785772#comment-17785772
]
Matthias Pohl commented on FLINK-31278:
---
flinkbot commented on PR #23708:
URL: https://github.com/apache/flink/pull/23708#issuecomment-1809673993
## CI report:
* e5594277547c13c70d54f205a898de6718ccd871 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JunRuiLee opened a new pull request, #23708:
URL: https://github.com/apache/flink/pull/23708
only for ci.
--
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,
flinkbot commented on PR #23707:
URL: https://github.com/apache/flink/pull/23707#issuecomment-1809658542
## CI report:
* 851df93825cd24aec6eecc63aa3aa7f6b9f723db UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33532:
---
Labels: pull-request-available (was: )
> Move the serialization of ShuffleDescriptorGroup
caodizhou opened a new pull request, #23707:
URL: https://github.com/apache/flink/pull/23707
## What is the purpose of the change
Support configured akka remote dispatcher thread pool size.
## Brief change log
- Add config
[
https://issues.apache.org/jira/browse/FLINK-31449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785760#comment-17785760
]
lincoln lee commented on FLINK-31449:
-
[~huwh] Any updates to this since it marked as a blocker? If
1996fanrui commented on code in PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1392008277
##
flink-autoscaler/src/test/java/org/apache/flink/autoscaler/JobAutoScalerImplTest.java:
##
@@ -299,60 +296,15 @@ void testAutoscalerDisabled()
flinkbot commented on PR #23706:
URL: https://github.com/apache/flink/pull/23706#issuecomment-1809576519
## CI report:
* d4bddad7592207fcbcbb139c08feb927479cd91b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32299:
---
Labels: pull-request-available (was: )
> Upload python jar when sql contains python udf
KarmaGYZ opened a new pull request, #23706:
URL: https://github.com/apache/flink/pull/23706
… jar
## What is the purpose of the change
Upload python jar only when sql contains python udf jar.
## Brief change log
- Do not add python jar in the
1996fanrui commented on PR #23658:
URL: https://github.com/apache/flink/pull/23658#issuecomment-1809570312
> Sorry that I was on a trip last week and did not have a chance to take a
look. The change looks good to me. Just one minor comment that it's better to
annotate
[
https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785738#comment-17785738
]
Shengkai Fang commented on FLINK-33251:
---
I can not reproduce this problem in my local machine with
zhuzhurk commented on PR #23658:
URL: https://github.com/apache/flink/pull/23658#issuecomment-1809516092
Sorry that I was on a trip last week and did not have a chance to take a
look. The change looks good to me. Just one minor comment that it's better to
annotate
X-czh commented on code in PR #23698:
URL: https://github.com/apache/flink/pull/23698#discussion_r1391955874
##
flink-runtime-web/web-dashboard/src/app/interfaces/job-exception.ts:
##
@@ -44,7 +44,8 @@ export interface ExceptionInfo {
stacktrace: string;
timestamp:
[
https://issues.apache.org/jira/browse/FLINK-33539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-33539:
Attachment: image-2023-11-14-11-47-52-499.png
> Potential regression (Nov. 7th): listAddAll on
[
https://issues.apache.org/jira/browse/FLINK-33539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785735#comment-17785735
]
Zakelly Lan commented on FLINK-33539:
-
!image-2023-11-14-11-47-52-499.png|width=1383,height=304!
>
[
https://issues.apache.org/jira/browse/FLINK-33539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785734#comment-17785734
]
Zakelly Lan commented on FLINK-33539:
-
Seems introduced by FLINK-5865 (cee2611e). Manually triggered
[
https://issues.apache.org/jira/browse/FLINK-31483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785733#comment-17785733
]
Hilmi Al Fatih commented on FLINK-31483:
Hi [~ruibin] [~ruanhang1993] Any update on this topic?
[
https://issues.apache.org/jira/browse/FLINK-33539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-33539:
Description:
!image-2023-11-14-10-56-36-189.png|width=981,height=228!
There is a drop from
Zakelly Lan created FLINK-33539:
---
Summary: Potential regression (Nov. 7th): listAddAll on RocksDB
with Java8
Key: FLINK-33539
URL: https://issues.apache.org/jira/browse/FLINK-33539
Project: Flink
ruanhang1993 commented on PR #23628:
URL: https://github.com/apache/flink/pull/23628#issuecomment-1809482399
> I am wondering the reason you delete it.
The kafka documents have been moved to the project `flink-connector-kafka`
and we do not need these documents now.
--
This is an
[
https://issues.apache.org/jira/browse/FLINK-33529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-33529:
Affects Version/s: 1.17.2
> PyFlink fails with "No module named 'cloudpickle"
>
[
https://issues.apache.org/jira/browse/FLINK-33529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-33529.
---
Fix Version/s: 1.19.0
1.18.1
1.17.3
Resolution: Fixed
>
[
https://issues.apache.org/jira/browse/FLINK-33529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785727#comment-17785727
]
Dian Fu commented on FLINK-33529:
-
Fixed in:
* master via 34d9594ab1e5412371b77912f120b7949c92dcdd
*
huwh commented on code in PR #23698:
URL: https://github.com/apache/flink/pull/23698#discussion_r1391925135
##
flink-runtime-web/web-dashboard/src/app/interfaces/job-exception.ts:
##
@@ -44,7 +44,8 @@ export interface ExceptionInfo {
stacktrace: string;
timestamp: number;
[
https://issues.apache.org/jira/browse/FLINK-33529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-33529:
---
Assignee: Prabhu Joseph
> PyFlink fails with "No module named 'cloudpickle"
>
dianfu closed pull request #23700: [FLINK-33529][python] Updated
GET_SITE_PACKAGES_SCRIPT to include pur…
URL: https://github.com/apache/flink/pull/23700
--
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
victor09091 opened a new pull request, #23494:
URL: https://github.com/apache/flink/pull/23494
## What is the purpose of the change
*we could rely on the latest minikube version and find some potential
incompatible problems with new K8s versions.*
ljw-hit commented on PR #23323:
URL: https://github.com/apache/flink/pull/23323#issuecomment-1809447787
@zhougit86 Thank you for your patience. The ability to split protobuf code
has been merged with commit a2ec4c. You can rebase and resolve any code
conflicts. Let's work together to merge
Sxnan commented on PR #23521:
URL: https://github.com/apache/flink/pull/23521#issuecomment-1809430382
@xintongsong Could you help review this PR?
--
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
[
https://issues.apache.org/jira/browse/FLINK-33483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785718#comment-17785718
]
Xin Chen commented on FLINK-33483:
--
Hi [~mapohl] yes, this is not a question in recent version. But I
[
https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785708#comment-17785708
]
Dian Fu commented on FLINK-33528:
-
Yes, I think so.
> Externalize Python connector code
>
varun1729DD commented on PR #23687:
URL: https://github.com/apache/flink/pull/23687#issuecomment-1809396620
> @varun1729DD let's start with the enumerator. I'm probably missing
something. From the logs that you had posted in JIRA, it appears that all
events are processed by the same thread
flinkbot commented on PR #23705:
URL: https://github.com/apache/flink/pull/23705#issuecomment-1809352435
## CI report:
* 5da79c8ce54ac2a4a224c5eada3af0bd5ec6027c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23704:
URL: https://github.com/apache/flink/pull/23704#issuecomment-1809352323
## CI report:
* 16d94bb172479392c14d2859a59691c7077a90ee UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
bvarghese1 commented on code in PR #23660:
URL: https://github.com/apache/flink/pull/23660#discussion_r1391843797
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/SortTestPrograms.java:
##
@@ -0,0 +1,121 @@
+/*
+ *
snuyanzin opened a new pull request, #23705:
URL: https://github.com/apache/flink/pull/23705
Updating the japicmp base version. Verification of API changes happened in
FLINK-32927
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-33536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785702#comment-17785702
]
Prabhu Joseph commented on FLINK-33536:
---
Thanks [~samrat007].
> Flink Table API CSV streaming
[
https://issues.apache.org/jira/browse/FLINK-32913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32913:
---
Labels: pull-request-available (was: )
> Update japicmp configuration
>
snuyanzin opened a new pull request, #23704:
URL: https://github.com/apache/flink/pull/23704
Updating the japicmp base version. Verification of API changes happened in
FLINK-32927
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-32919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785689#comment-17785689
]
Sergey Nuyanzin commented on FLINK-32919:
-
done within
[
https://issues.apache.org/jira/browse/FLINK-32919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-32919.
-
Resolution: Fixed
> Updates the docs stable version
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-32916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785688#comment-17785688
]
Sergey Nuyanzin commented on FLINK-32916:
-
Announcement in the mailing list:
[
https://issues.apache.org/jira/browse/FLINK-32916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-32916.
-
Resolution: Fixed
> Apache mailing lists announcements
>
[
https://issues.apache.org/jira/browse/FLINK-32914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-32914.
-
Resolution: Fixed
> Merge website pull request
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-32914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785687#comment-17785687
]
Sergey Nuyanzin commented on FLINK-32914:
-
The website is on and correctly shows 1.18.0
[
https://issues.apache.org/jira/browse/FLINK-32924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785684#comment-17785684
]
Sergey Nuyanzin commented on FLINK-32924:
-
PR for release notes has been created and reviewed
[
https://issues.apache.org/jira/browse/FLINK-32924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-32924.
-
Resolution: Fixed
> Review Release Notes in JIRA
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-32923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-32923.
-
Resolution: Fixed
> Triage release-blocking issues in JIRA
>
[
https://issues.apache.org/jira/browse/FLINK-32923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785683#comment-17785683
]
Sergey Nuyanzin commented on FLINK-32923:
-
All blockers of 1.18.0 has been swiped out.
>
flinkbot commented on PR #23703:
URL: https://github.com/apache/flink/pull/23703#issuecomment-1809204776
## CI report:
* 0f49126940dd44114bc8d2a49c26a482ea858cf5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
varun1729DD commented on code in PR #23687:
URL: https://github.com/apache/flink/pull/23687#discussion_r1391750438
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java:
##
@@ -361,7 +394,7 @@
varun1729DD opened a new pull request, #23703:
URL: https://github.com/apache/flink/pull/23703
(no comment)
--
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,
snuyanzin commented on PR #23553:
URL: https://github.com/apache/flink/pull/23553#issuecomment-1809183659
>Using Java 11 the tests pass, using Java 8 they fail (as in CI).
>Is this a known issue?
not sure wether this is your issue or not some time ago we've faced this
afedulov commented on PR #23553:
URL: https://github.com/apache/flink/pull/23553#issuecomment-1809168702
@zentol I can confirm that the reason for the discrepancy in the local and
the remote Architecture Tests execution is the Java version. Using Java 11 the
tests pass, using Java 8 they
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785672#comment-17785672
]
Lim Qing Wei commented on FLINK-33365:
--
Hi [~davidradl] ,
if you can work on this that's better,
jnh5y commented on code in PR #23680:
URL: https://github.com/apache/flink/pull/23680#discussion_r1391719912
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/JoinTestPrograms.java:
##
@@ -0,0 +1,274 @@
+/*
+ * Licensed to
gyfora commented on code in PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1391694357
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ConfigMapStore.java:
##
@@ -44,13 +43,44 @@ public class
[
https://issues.apache.org/jira/browse/FLINK-33536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785634#comment-17785634
]
Samrat Deb commented on FLINK-33536:
Hello [~prabhujoseph] and [~martijnvisser] ,
I was able to
Brian Lehman created FLINK-33538:
Summary: Create a "best match" option for CEP when using the
optional operator in the Pattern API
Key: FLINK-33538
URL: https://issues.apache.org/jira/browse/FLINK-33538
mxm commented on code in PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1391538017
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ConfigMapStore.java:
##
@@ -67,19 +67,14 @@ protected Optional
mxm commented on PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#issuecomment-1808809666
Please have a look at the new implementation. Also see:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1391538017
--
This is an automated message
mxm commented on code in PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1391538017
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ConfigMapStore.java:
##
@@ -67,19 +67,14 @@ protected Optional
[
https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785621#comment-17785621
]
Yi Zhang commented on FLINK-18473:
--
[~yunta] [~fanrui] the current logic of picking from multiple
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785563#comment-17785563
]
david radley edited comment on FLINK-33365 at 11/13/23 6:18 PM:
[~Sergey
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785563#comment-17785563
]
david radley edited comment on FLINK-33365 at 11/13/23 6:18 PM:
[~Sergey
gyfora commented on code in PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1391499500
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java:
##
@@ -121,37 +120,10 @@ public void cleanup(KEY jobKey) {
}
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785563#comment-17785563
]
david radley edited comment on FLINK-33365 at 11/13/23 6:13 PM:
[~Sergey
[
https://issues.apache.org/jira/browse/FLINK-29288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785600#comment-17785600
]
Trystan commented on FLINK-29288:
-
That seems to be the difference. It seems like using native
[
https://issues.apache.org/jira/browse/FLINK-32922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-32922:
---
Assignee: Sergey Nuyanzin
> Review and update documentation
>
flinkbot commented on PR #23702:
URL: https://github.com/apache/flink/pull/23702#issuecomment-1808703707
## CI report:
* 51dc4a71864dbea056dbf79fc4fc1dd59dc88615 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23701:
URL: https://github.com/apache/flink/pull/23701#issuecomment-1808702755
## CI report:
* 5b9ee1b0b73bb0c35085e9677c34e7c11014b2e9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Robin Moffatt created FLINK-33537:
-
Summary: Docs version nav is missing 1.18 as an option
Key: FLINK-33537
URL: https://issues.apache.org/jira/browse/FLINK-33537
Project: Flink
Issue Type:
snuyanzin opened a new pull request, #23702:
URL: https://github.com/apache/flink/pull/23702
## What is the purpose of the change
This pull requests updates the snapshot compatibility matrix for release
1.18.
Please note that 1.18 drops snapshot compatibility before 1.8 (same
[
https://issues.apache.org/jira/browse/FLINK-32922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32922:
---
Labels: pull-request-available (was: )
> Review and update documentation
>
snuyanzin opened a new pull request, #23701:
URL: https://github.com/apache/flink/pull/23701
## What is the purpose of the change
This pull requests updates the snapshot compatibility matrix for release
1.18.
Please note that 1.18 drops snapshot compatibility before 1.8 (same
[
https://issues.apache.org/jira/browse/FLINK-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-33531:
Description:
It seems starting 02.11.2023 every master nightly fails with this (that's
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785563#comment-17785563
]
david radley edited comment on FLINK-33365 at 11/13/23 5:08 PM:
[~Sergey
[
https://issues.apache.org/jira/browse/FLINK-29288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785575#comment-17785575
]
Yaroslav Tkachenko commented on FLINK-29288:
Standalone mode. I think it may not run in
[
https://issues.apache.org/jira/browse/FLINK-33536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785573#comment-17785573
]
Prabhu Joseph commented on FLINK-33536:
---
We are using flink-s3-fs-hadoop-1.18.0.jar.
> Flink
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785563#comment-17785563
]
david radley edited comment on FLINK-33365 at 11/13/23 4:45 PM:
[~Sergey
[
https://issues.apache.org/jira/browse/FLINK-33365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785563#comment-17785563
]
david radley commented on FLINK-33365:
--
[~Sergey Nuyanzin] [~qingwei91] thanks for you input. The 2
tweise commented on PR #23687:
URL: https://github.com/apache/flink/pull/23687#issuecomment-1808466482
@varun1729DD let's start with the enumerator. I'm probably missing
something. From the logs that you had posted in JIRA, it appears that all
events are processed by the same thread
tweise commented on code in PR #23687:
URL: https://github.com/apache/flink/pull/23687#discussion_r1391323161
##
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java:
##
@@ -361,7 +394,7 @@ public Map
[
https://issues.apache.org/jira/browse/FLINK-33402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785549#comment-17785549
]
Thomas Weise commented on FLINK-33402:
--
[~varun1729dd] thanks for investigating this. It would be
[
https://issues.apache.org/jira/browse/FLINK-33536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785546#comment-17785546
]
Martijn Visser commented on FLINK-33536:
Which S3 plugin was used here?
> Flink Table API CSV
1996fanrui commented on code in PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1391256838
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ConfigMapStore.java:
##
@@ -67,19 +67,14 @@ protected
[
https://issues.apache.org/jira/browse/FLINK-33536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prabhu Joseph updated FLINK-33536:
--
Summary: Flink Table API CSV streaming sink fails with "IOException: Stream
closed" (was:
[
https://issues.apache.org/jira/browse/FLINK-33536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prabhu Joseph updated FLINK-33536:
--
Description:
Flink Table API CSV streaming sink fails with "IOException: Stream closed".
[
https://issues.apache.org/jira/browse/FLINK-33402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise reassigned FLINK-33402:
Assignee: Varun Narayanan Chakravarthy
> Hybrid Source Concurrency Race Condition Fixes
Prabhu Joseph created FLINK-33536:
-
Summary: Flink Table API CSV streaming sink throws "IOException:
Stream closed"
Key: FLINK-33536
URL: https://issues.apache.org/jira/browse/FLINK-33536
Project:
1996fanrui commented on code in PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1391256838
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ConfigMapStore.java:
##
@@ -67,19 +67,14 @@ protected
1996fanrui commented on code in PR #710:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/710#discussion_r1391256838
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/ConfigMapStore.java:
##
@@ -67,19 +67,14 @@ protected
1 - 100 of 168 matches
Mail list logo
