TanYuxin-tyx commented on code in PR #22330:
URL: https://github.com/apache/flink/pull/22330#discussion_r1187052528
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionID.java:
##
@@ -23,6 +23,9 @@
import
pgaref commented on code in PR #22520:
URL: https://github.com/apache/flink/pull/22520#discussion_r1187021736
##
flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java:
##
@@ -243,13 +243,22 @@ public class PipelineOptions {
[
https://issues.apache.org/jira/browse/FLINK-32019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32019:
---
Labels: pull-request-available (was: )
> EARLIEST offset strategy for partitions
[
https://issues.apache.org/jira/browse/FLINK-32021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32021:
---
Labels: pull-request-available (was: )
> Improvement the Javadoc for
loserwang1024 opened a new pull request, #29:
URL: https://github.com/apache/flink-connector-kafka/pull/29
### What is the purpose of the change
As described in
loserwang1024 closed pull request #28: EARLIEST offset strategy for partitions
discoveried later based on FLIP-288
URL: https://github.com/apache/flink-connector-kafka/pull/28
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
loserwang1024 opened a new pull request, #28:
URL: https://github.com/apache/flink-connector-kafka/pull/28
### What is the purpose of the change
As described in
tisonkun merged PR #44:
URL: https://github.com/apache/flink-connector-pulsar/pull/44
--
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:
zhuzhurk commented on code in PR #22506:
URL: https://github.com/apache/flink/pull/22506#discussion_r1186678825
##
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java:
##
@@ -473,26 +500,50 @@ public CompletableFuture cancel(Time
timeout) {
[
https://issues.apache.org/jira/browse/FLINK-32027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720378#comment-17720378
]
Yun Tang commented on FLINK-32027:
--
[~Weijie Guo] [~zhuzh] Please take a look at this issue.
> Batch
Yun Tang created FLINK-32027:
Summary: Batch jobs could hang at shuffle phase when max
parallelism is really large
Key: FLINK-32027
URL: https://issues.apache.org/jira/browse/FLINK-32027
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-32023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720377#comment-17720377
]
Rui Fan commented on FLINK-32023:
-
Thanks [~wanglijie] 's feedback.
Sorry, after my double check, I see
[
https://issues.apache.org/jira/browse/FLINK-32023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-32023:
Affects Version/s: 1.16.1
1.17.0
1.18.0
Issue
[
https://issues.apache.org/jira/browse/FLINK-32023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720375#comment-17720375
]
Rui Fan commented on FLINK-32023:
-
Hi [~Jiangang] , thanks for your report. It's really a bug. Would you
[
https://issues.apache.org/jira/browse/FLINK-32026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xueyongyang updated FLINK-32026:
Issue Type: Bug (was: Improvement)
> jdbc-3.1.0-1.16 left join conversion error
>
xueyongyang created FLINK-32026:
---
Summary: jdbc-3.1.0-1.16 left join conversion error
Key: FLINK-32026
URL: https://issues.apache.org/jira/browse/FLINK-32026
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-32023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720374#comment-17720374
]
Lijie Wang commented on FLINK-32023:
[~Jiangang] Thanks for reporting this. Would you like to
TanYuxin-tyx commented on PR #22427:
URL: https://github.com/apache/flink/pull/22427#issuecomment-1537644742
@godfreyhe @JunRuiLee Thanks for helping review the change.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
X-czh commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1186953244
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -87,28 +88,28
X-czh commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1186950803
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,16
X-czh commented on code in PR #586:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/586#discussion_r1186950803
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/config/AutoScalerOptions.java:
##
@@ -68,15 +68,16
[
https://issues.apache.org/jira/browse/FLINK-31997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720364#comment-17720364
]
Thomas Weise commented on FLINK-31997:
--
[~gyfora] would it be possible to also shade the fabric8
[
https://issues.apache.org/jira/browse/FLINK-32025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-32025.
Resolution: Duplicate
> Make job cancellation button on UI configurable
>
[
https://issues.apache.org/jira/browse/FLINK-32025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720362#comment-17720362
]
Echo Lee commented on FLINK-32025:
--
It is already possible to hide the 'cancel job' button by setting
Ted Yu created FLINK-32025:
--
Summary: Make job cancellation button on UI configurable
Key: FLINK-32025
URL: https://issues.apache.org/jira/browse/FLINK-32025
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-29847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720328#comment-17720328
]
xiaochen zhou commented on FLINK-29847:
---
hi, I would like to give a try on this, can I take this
[
https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720303#comment-17720303
]
padavan commented on FLINK-31967:
-
[~martijnvisser] [~jark] [~lincoln.86xy]
If you need anything else,
reswqa merged PR #47:
URL: https://github.com/apache/flink-connector-pulsar/pull/47
--
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 merged PR #46:
URL: https://github.com/apache/flink-connector-pulsar/pull/46
--
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:
tisonkun merged PR #45:
URL: https://github.com/apache/flink-connector-pulsar/pull/45
--
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 code in PR #45:
URL:
https://github.com/apache/flink-connector-pulsar/pull/45#discussion_r1186793455
##
flink-connector-pulsar/archunit-violations/f4d91193-72ba-4ce4-ad83-98f780dce581:
##
@@ -10,3 +10,15 @@
reswqa commented on code in PR #45:
URL:
https://github.com/apache/flink-connector-pulsar/pull/45#discussion_r1186793455
##
flink-connector-pulsar/archunit-violations/f4d91193-72ba-4ce4-ad83-98f780dce581:
##
@@ -10,3 +10,15 @@
[
https://issues.apache.org/jira/browse/FLINK-32024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-32024:
---
Summary: Short code related to externalized connector retrieve version from
its own data yaml
[
https://issues.apache.org/jira/browse/FLINK-32024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-32024:
---
Description:
Currently, we have some shortcodes specifically designed for externalized
connector,
[
https://issues.apache.org/jira/browse/FLINK-32024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-32024:
---
Description:
Currently, we have some shortcodes specifically designed for externalized
connector,
Weijie Guo created FLINK-32024:
--
Summary: Short code related to external connector retrieve version
from its own data yaml
Key: FLINK-32024
URL: https://issues.apache.org/jira/browse/FLINK-32024
tisonkun commented on code in PR #45:
URL:
https://github.com/apache/flink-connector-pulsar/pull/45#discussion_r1186792428
##
flink-connector-pulsar/archunit-violations/f4d91193-72ba-4ce4-ad83-98f780dce581:
##
@@ -10,3 +10,15 @@
reswqa opened a new pull request, #72:
URL: https://github.com/apache/flink-connector-aws/pull/72
(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
reswqa opened a new pull request, #71:
URL: https://github.com/apache/flink-connector-aws/pull/71
(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
reswqa commented on code in PR #45:
URL:
https://github.com/apache/flink-connector-pulsar/pull/45#discussion_r1186787932
##
flink-connector-pulsar/archunit-violations/f4d91193-72ba-4ce4-ad83-98f780dce581:
##
@@ -10,3 +10,15 @@
reswqa commented on code in PR #45:
URL:
https://github.com/apache/flink-connector-pulsar/pull/45#discussion_r1186787932
##
flink-connector-pulsar/archunit-violations/f4d91193-72ba-4ce4-ad83-98f780dce581:
##
@@ -10,3 +10,15 @@
reswqa commented on code in PR #45:
URL:
https://github.com/apache/flink-connector-pulsar/pull/45#discussion_r1186787331
##
flink-connector-pulsar/archunit-violations/f4d91193-72ba-4ce4-ad83-98f780dce581:
##
@@ -10,3 +10,15 @@
reswqa commented on code in PR #45:
URL:
https://github.com/apache/flink-connector-pulsar/pull/45#discussion_r1186787932
##
flink-connector-pulsar/archunit-violations/f4d91193-72ba-4ce4-ad83-98f780dce581:
##
@@ -10,3 +10,15 @@
43 matches
Mail list logo