[
https://issues.apache.org/jira/browse/FLINK-33023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33023:
---
Labels: pull-request-available (was: )
> [JUnit5 Migration] Module: flink-table-planner
Jiabao-Sun commented on PR #23330:
URL: https://github.com/apache/flink/pull/23330#issuecomment-1722920078
@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
Jiabao-Sun commented on PR #23349:
URL: https://github.com/apache/flink/pull/23349#issuecomment-1722919065
@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-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762651#comment-17762651
]
Etienne Chauchot edited comment on FLINK-30314 at 9/18/23 8:21 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-32727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vetle Leinonen-Roeim updated FLINK-32727:
-
Attachment: (was: pubsub-attributes-0.patch)
> Adding capability of setting
[
https://issues.apache.org/jira/browse/FLINK-32727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vetle Leinonen-Roeim updated FLINK-32727:
-
Attachment: pubsub-attributes-0.patch
> Adding capability of setting Attributes
[
https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Etienne Chauchot updated FLINK-30314:
-
Summary: Unable to read all records from compressed delimited file input
format (was:
[
https://issues.apache.org/jira/browse/FLINK-25593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25593:
---
Labels: pull-request-available (was: )
> A redundant scan could be skipped if it is an
[
https://issues.apache.org/jira/browse/FLINK-33106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenwei updated FLINK-33106:
Attachment: flink_cmd.txt
> pyflink脚本通过python命令运行正常，但部署至Flink（单机）运行时报错
>
wangzzu opened a new pull request, #23437:
URL: https://github.com/apache/flink/pull/23437
## What is the purpose of the change
- `GlobalFailureHandler` and `LabeledGlobalFailureHandler` have overlapping
functionality. It is necessary to unify the two interfaces
reta opened a new pull request, #32:
URL: https://github.com/apache/flink-connector-opensearch/pull/32
Make the polling more aggressive but the flushing less aggressive (on busy
CI hosts, such timing doesn't play well)
--
This is an automated message from the Apache Git Service.
To
Roman Lupiichuk created FLINK-33110:
---
Summary: Array content gets replaced with last element duplicates
Key: FLINK-33110
URL: https://issues.apache.org/jira/browse/FLINK-33110
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Lupiichuk updated FLINK-33110:
Description:
After upgrade from Flink 1.14.0 to 1.15.4 a bunch of our tests started to
[
https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766401#comment-17766401
]
Rui Fan commented on FLINK-33109:
-
Hi [~YordanPavlov] , thanks for your report. I'm not sure whether
[
https://issues.apache.org/jira/browse/FLINK-33105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-33105:
-
Assignee: Gabor Somogyi
> Evaluate operator error log entry: Exception while fetching
[
https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762651#comment-17762651
]
Etienne Chauchot edited comment on FLINK-30314 at 9/18/23 8:22 AM:
---
X-czh commented on PR #23301:
URL: https://github.com/apache/flink/pull/23301#issuecomment-1722954878
@FangYongs Thanks for the careful review, I've corrected the two mistakes,
please review again when you have time~
--
This is an automated message from the Apache Git Service.
To respond
1996fanrui opened a new pull request, #677:
URL: https://github.com/apache/flink-kubernetes-operator/pull/677
## What is the purpose of the change
The first subtask of FLIP-334.
## Brief change log
[FLINK-33097][autoscaler] Initialize the generic autoscaler module and
[
https://issues.apache.org/jira/browse/FLINK-33106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenwei updated FLINK-33106:
Attachment: (was: flink_cmd.txt)
> pyflink脚本通过python命令运行正常，但部署至Flink（单机）运行时报错
>
Gabor Somogyi created FLINK-33108:
-
Summary: Error during error status handling
Key: FLINK-33108
URL: https://issues.apache.org/jira/browse/FLINK-33108
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-33108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766355#comment-17766355
]
Márton Balassi edited comment on FLINK-33108 at 9/18/23 12:19 PM:
--
That
[
https://issues.apache.org/jira/browse/FLINK-33108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766355#comment-17766355
]
Márton Balassi commented on FLINK-33108:
That value change represents when the taskmanager has
[
https://issues.apache.org/jira/browse/FLINK-33106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-33106.
--
Resolution: Invalid
[~palosky] Please translate this ticket to English, so it can be
echauchot commented on code in PR #22985:
URL: https://github.com/apache/flink/pull/22985#discussion_r1328774059
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java:
##
@@ -124,17 +154,33 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766401#comment-17766401
]
Rui Fan edited comment on FLINK-33109 at 9/18/23 2:19 PM:
--
Hi [~YordanPavlov] ,
[
https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766464#comment-17766464
]
Yordan Pavlov commented on FLINK-33109:
---
I'll give a try the 1.17.2 and 1.18.0 codebase and come
wangzzu commented on PR #23437:
URL: https://github.com/apache/flink/pull/23437#issuecomment-1723393465
@pgaref @huwh What do you think of this implementation?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
flinkbot commented on PR #23437:
URL: https://github.com/apache/flink/pull/23437#issuecomment-1723405610
## CI report:
* 116c658d7c01262f8e78095a7d789aa206affa90 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-31446.
--
Resolution: Cannot Reproduce
> KafkaSinkITCase$IntegrationTests.testMetrics failed because
[
https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Etienne Chauchot updated FLINK-30314:
-
Summary: Unable to read all records from compressed delimited file format
(was: Unable
[
https://issues.apache.org/jira/browse/FLINK-32727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vetle Leinonen-Roeim updated FLINK-32727:
-
Attachment: pubsub-attributes-0.patch
> Adding capability of setting Attributes
[
https://issues.apache.org/jira/browse/FLINK-32727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766261#comment-17766261
]
Vetle Leinonen-Roeim edited comment on FLINK-32727 at 9/18/23 8:20 AM:
[
https://issues.apache.org/jira/browse/FLINK-33108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766309#comment-17766309
]
Gabor Somogyi commented on FLINK-33108:
---
After some digging the following value changed from:
[
https://issues.apache.org/jira/browse/FLINK-33096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766335#comment-17766335
]
Weihua Hu commented on FLINK-33096:
---
[~wawa] I think it's because the job is failed after some TM pod
Jiabao-Sun opened a new pull request, #51:
URL: https://github.com/apache/flink-connector-kafka/pull/51
[FLINK-33104] Fix nightly run for Flink Kafka connector fails due to
architecture tests failing.
boring-cyborg[bot] commented on PR #51:
URL:
https://github.com/apache/flink-connector-kafka/pull/51#issuecomment-1723250842
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
mxm commented on code in PR #23406:
URL: https://github.com/apache/flink/pull/23406#discussion_r1328331551
##
flink-core/src/main/java/org/apache/flink/configuration/RestOptions.java:
##
@@ -80,6 +80,23 @@ public class RestOptions {
.withDescription(
dawidwys commented on code in PR #23427:
URL: https://github.com/apache/flink/pull/23427#discussion_r1328338429
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionCatalog.java:
##
@@ -306,17 +306,19 @@ public Set getUserDefinedFunctions(
lsyldliu commented on code in PR #23389:
URL: https://github.com/apache/flink/pull/23389#discussion_r1328339016
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -951,18 +957,28 @@ private Optional
[
https://issues.apache.org/jira/browse/FLINK-33105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-33105:
--
Summary: Evaluate operator error log entry: Exception while fetching
cluster info (was:
[
https://issues.apache.org/jira/browse/FLINK-33097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33097:
---
Labels: pull-request-available (was: )
> Initialize the generic autoscaler module and
chenwei created FLINK-33106:
---
Summary: pyflink脚本通过python命令运行正常，但部署至Flink（单机）运行时报错
Key: FLINK-33106
URL: https://issues.apache.org/jira/browse/FLINK-33106
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-25447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766313#comment-17766313
]
Sergey Nuyanzin commented on FLINK-25447:
-
[~fsk119], [~zhengyunhong97]
to double check, since
[
https://issues.apache.org/jira/browse/FLINK-32727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766261#comment-17766261
]
Vetle Leinonen-Roeim commented on FLINK-32727:
--
[~yinghai] can you attach a patch against
Gyula Fora created FLINK-33107:
--
Summary: Update stable-spec upgrade mode on reconciled-spec change
Key: FLINK-33107
URL: https://issues.apache.org/jira/browse/FLINK-33107
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-32055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan reassigned FLINK-32055:
-
Assignee: Yuxin Tan
> Migrate all subclasses of BatchAbstractTestBase to JUnit5
>
1996fanrui commented on PR #675:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/675#issuecomment-1722938653
> Could we include this in some other commit instead of having it separately?
Sure, I will do it in the subsequent commit. I will close this PR.
--
This is an
1996fanrui closed pull request #675: [hotfix] Removing the obsolete comment of
JobAutoScaler#scale
URL: https://github.com/apache/flink-kubernetes-operator/pull/675
--
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-32727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766259#comment-17766259
]
Vetle Leinonen-Roeim commented on FLINK-32727:
--
Came here to open a discussion about this,
gaborgsomogyi opened a new pull request, #676:
URL: https://github.com/apache/flink-kubernetes-operator/pull/676
## What is the purpose of the change
`ClusterInfo` fetch error can happen in normal situation which can show
temporary issues so I've lowered the log level from error to
gaborgsomogyi commented on PR #676:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/676#issuecomment-1722948256
cc @gyfora
--
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-33105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33105:
---
Labels: pull-request-available (was: )
> Evaluate operator error log entry: Exception
[
https://issues.apache.org/jira/browse/FLINK-31895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu resolved FLINK-31895.
---
Fix Version/s: 1.19.0
Resolution: Fixed
Resolved in master:
[
https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766321#comment-17766321
]
Jiabao Sun commented on FLINK-33104:
Hi [~martijnvisser].
Could you help assign this ticket to me?
[
https://issues.apache.org/jira/browse/FLINK-33108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766334#comment-17766334
]
Gabor Somogyi commented on FLINK-33108:
---
I'm not telling that this causes the issue but the
[
https://issues.apache.org/jira/browse/FLINK-32058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan closed FLINK-32058.
-
> Migrate subclasses of BatchAbstractTestBase in runtime.batch.sql to JUnit5
>
[
https://issues.apache.org/jira/browse/FLINK-32060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan closed FLINK-32060.
-
> Migrate subclasses of BatchAbstractTestBase in table and other modules to
> JUnit5
>
gyfora commented on PR #675:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/675#issuecomment-1722926872
Could we include this in some other commit instead of having it separately?
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-33105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-33105:
--
Component/s: Kubernetes Operator
> Evaluate operator error log entry: Exception while
[
https://issues.apache.org/jira/browse/FLINK-30311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi updated FLINK-30311:
--
Component/s: Kubernetes Operator
> CI error: Back-off pulling image "flink:1.14"
>
[
https://issues.apache.org/jira/browse/FLINK-26115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-26115.
--
Resolution: Resolved
> Multiple Kafka connector tests failed due to The topic metadata failed
huwh closed pull request #23405: [FLINK-31895] Add End-to-end integration tests
for failure labels
URL: https://github.com/apache/flink/pull/23405
--
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-33108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766311#comment-17766311
]
Gabor Somogyi commented on FLINK-33108:
---
The issue comes only occasionally and not consistent so
Martijn Visser created FLINK-33104:
--
Summary: Nightly run for Flink Kafka connector fails
Key: FLINK-33104
URL: https://issues.apache.org/jira/browse/FLINK-33104
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-33104:
---
Summary: Nightly run for Flink Kafka connector fails due to architecture
tests failing
[
https://issues.apache.org/jira/browse/FLINK-33017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766235#comment-17766235
]
Martijn Visser commented on FLINK-33017:
[~tzulitai][~Ge] Nightly builds are still failing,
Gabor Somogyi created FLINK-33105:
-
Summary: Evaluate operator log entry: Exception while fetching
cluster info
Key: FLINK-33105
URL: https://issues.apache.org/jira/browse/FLINK-33105
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762651#comment-17762651
]
Etienne Chauchot edited comment on FLINK-30314 at 9/18/23 8:12 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762651#comment-17762651
]
Etienne Chauchot edited comment on FLINK-30314 at 9/18/23 8:23 AM:
---
1996fanrui commented on code in PR #677:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/677#discussion_r1328450023
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/state/AutoScalerStateStore.java:
##
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache
fredia commented on code in PR #22890:
URL: https://github.com/apache/flink/pull/22890#discussion_r1328451234
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManager.java:
##
@@ -31,7 +32,7 @@
* FileMergingSnapshotManager
[
https://issues.apache.org/jira/browse/FLINK-33108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766355#comment-17766355
]
Márton Balassi edited comment on FLINK-33108 at 9/18/23 12:25 PM:
--
The
Yordan Pavlov created FLINK-33109:
-
Summary: Watermark alignment not applied after recovery from
checkpoint
Key: FLINK-33109
URL: https://issues.apache.org/jira/browse/FLINK-33109
Project: Flink
WencongLiu commented on code in PR #23000:
URL: https://github.com/apache/flink/pull/23000#discussion_r1321179253
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/OperatorAttributes.java:
##
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Software
KarmaGYZ commented on PR #23415:
URL: https://github.com/apache/flink/pull/23415#issuecomment-1724856050
@tisonkun Thanks for the review. I agree that is somehow a monkey patch.
Looking forward to a cleaner solution in curator or zookeeper side! Please let
me know when it ready and I'll
[
https://issues.apache.org/jira/browse/FLINK-32974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-32974:
---
Affects Version/s: 1.17.2
> RestClusterClient always leaks flink-rest-client-jobgraphs* directories
[
https://issues.apache.org/jira/browse/FLINK-32974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-32974:
---
Priority: Critical (was: Major)
> RestClusterClient always leaks flink-rest-client-jobgraphs*
[
https://issues.apache.org/jira/browse/FLINK-32114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766634#comment-17766634
]
Matt Wang commented on FLINK-32114:
---
[~pgaref] hi, If you haven't started doing this yet, I'd like to
KarmaGYZ merged PR #23415:
URL: https://github.com/apache/flink/pull/23415
--
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-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766646#comment-17766646
]
Yangze Guo commented on FLINK-33053:
master: d5e151f72336abcc13082fe4bb3e05fd5a785e86
> Watcher
[
https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo updated FLINK-33053:
---
Fix Version/s: 1.19.0
> Watcher leak in Zookeeper HA mode
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-33096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766652#comment-17766652
]
wawa commented on FLINK-33096:
--
[~huweihua] Restart-strategy has been set. Here are the details:
[
https://issues.apache.org/jira/browse/FLINK-32114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766650#comment-17766650
]
Panagiotis Garefalakis commented on FLINK-32114:
Sure [~wangm92] – please go ahead
>
Junfan Zhang created FLINK-33112:
Summary: Support placement constraint
Key: FLINK-33112
URL: https://issues.apache.org/jira/browse/FLINK-33112
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo closed FLINK-33053.
--
Resolution: Fixed
> Watcher leak in Zookeeper HA mode
> -
>
>
pgaref commented on PR #23405:
URL: https://github.com/apache/flink/pull/23405#issuecomment-1724874833
> @pgaref if you have time, Can you help me review this?
Late +1 from my side.
Pretty useful stuff @wangzzu! Thank you!
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-32512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32512:
---
Labels: auto-deprioritized-major pull-request-available (was:
pull-request-available
[
https://issues.apache.org/jira/browse/FLINK-32701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32701:
---
Labels: CEP auto-deprioritized-critical cep (was: CEP cep stale-critical)
Priority:
[
https://issues.apache.org/jira/browse/FLINK-33025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-33025:
---
Labels: stale-critical test-stability (was: test-stability)
I am the [Flink Jira
[
https://issues.apache.org/jira/browse/FLINK-32582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32582:
---
Labels: pull-request-available stale-major (was: pull-request-available)
I am the [Flink
venkata91 commented on PR #23313:
URL: https://github.com/apache/flink/pull/23313#issuecomment-1724620100
> @venkata91 Thanks for your contribution, please use git rebase instead of
git merge. I can't get your all commits correctly when pull your pr to local.
@lsyldliu Do you want me
[
https://issues.apache.org/jira/browse/FLINK-32718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766622#comment-17766622
]
Neha Aggarwal commented on FLINK-32718:
---
Hello Jane Chan,
I am attaching the Physical Plan. Let
venkata91 commented on PR #23313:
URL: https://github.com/apache/flink/pull/23313#issuecomment-1724625067
> > @venkata91 Thanks for your contribution, please use git rebase instead
of git merge. I can't get your all commits correctly when pull your pr to local.
>
> @lsyldliu Do you
venkata91 commented on PR #23313:
URL: https://github.com/apache/flink/pull/23313#issuecomment-1724629169
> > @venkata91 Thanks for your contribution, please use git rebase instead
of git merge. I can't get your all commits correctly when pull your pr to local.
>
> @lsyldliu Do you
[
https://issues.apache.org/jira/browse/FLINK-33111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Kania updated FLINK-33111:
Description:
In the documentation for the Flink Pulsar Connector,
Jason Kania created FLINK-33111:
---
Summary: Flink Pulsar Connector to Pulsar Client Version Mismatch
Key: FLINK-33111
URL: https://issues.apache.org/jira/browse/FLINK-33111
Project: Flink
Issue
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1161498735
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/tieredstore/upstream/TieredStoreMode.java:
##
@@ -0,0 +1,44 @@
+/*
+ * Licensed to
TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1164072696
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/upstream/common/TierWriter.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed
TanYuxin-tyx commented on code in PR #22352:
URL: https://github.com/apache/flink/pull/22352#discussion_r1193122840
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheFlushManager.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed
TanYuxin-tyx commented on code in PR #22352:
URL: https://github.com/apache/flink/pull/22352#discussion_r1193122339
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/CacheBufferFlushTrigger.java:
##
@@ -0,0 +1,26 @@
+/*
+ *
1 - 100 of 115 matches
Mail list logo
