lsyldliu commented on PR #17654:
URL: https://github.com/apache/flink/pull/17654#issuecomment-1159608614
Due to @meetjunsu had not respond for a long time, I will take over it.
Thanks for @meetjunsu contribution.
--
This is an automated message from the Apache Git Service.
To respond to
xinbinhuang commented on PR #17873:
URL: https://github.com/apache/flink/pull/17873#issuecomment-1159608446
@twalthr Thank you so much for providing the context. I agree that change
fields or remove fields (i.e. change the name) should be extra careful. How
about adding a new field? I
[
https://issues.apache.org/jira/browse/FLINK-28021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17556023#comment-17556023
]
Shubham Bansal commented on FLINK-28021:
[~jingge] I looked at the code and understood what is
gyfora commented on code in PR #269:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/269#discussion_r900951149
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/listener/ListenerUtils.java:
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to
1996fanrui commented on PR #19993:
URL: https://github.com/apache/flink/pull/19993#issuecomment-1159477055
@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-28117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-28117:
Affects Version/s: 1.16.0
> More metrics for FileSource
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-28117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jing Ge updated FLINK-28117:
Component/s: Connectors / FileSystem
Runtime / Metrics
> More metrics for FileSource
>
Jing Ge created FLINK-28117:
---
Summary: More metrics for FileSource
Key: FLINK-28117
URL: https://issues.apache.org/jira/browse/FLINK-28117
Project: Flink
Issue Type: Improvement
tweise commented on code in PR #269:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/269#discussion_r900884753
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/listener/ListenerUtils.java:
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to
tweise commented on code in PR #269:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/269#discussion_r900884502
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/listener/ListenerUtils.java:
##
@@ -0,0 +1,127 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-28101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555906#comment-17555906
]
Jing Ge commented on FLINK-28101:
-
closed because of duplication, please refer to FLINK-27667 for more
[
https://issues.apache.org/jira/browse/FLINK-28107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555905#comment-17555905
]
Jing Ge commented on FLINK-28107:
-
[~ana4] please find the external ES connector repo:
[
https://issues.apache.org/jira/browse/FLINK-28116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555903#comment-17555903
]
Jing Ge commented on FLINK-28116:
-
Thanks for reporting this. Flink need a more generic way to handle
lsyldliu commented on PR #20003:
URL: https://github.com/apache/flink/pull/20003#issuecomment-1159453217
> You can just take whatever classloader you have (e.g., the Flink CL), and
create a new FlinkUserCodeClassLoader with that CL as a parent and specify the
jar via the urls parameter.
[
https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555896#comment-17555896
]
Martijn Visser commented on FLINK-28060:
Fixed in master:
MartijnVisser merged PR #19994:
URL: https://github.com/apache/flink/pull/19994
--
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-28110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555878#comment-17555878
]
xingyuan cheng edited comment on FLINK-28110 at 6/18/22 10:39 AM:
--
1996fanrui commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r900807989
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -98,6 +98,9 @@ static ChannelStateWriteRequest
1996fanrui commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r900803080
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -109,6 +112,9 @@ static ChannelStateWriteRequest
[
https://issues.apache.org/jira/browse/FLINK-28110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555881#comment-17555881
]
xingyuan cheng commented on FLINK-28110:
I will try to perfect this feature
> Table Store Hive
[
https://issues.apache.org/jira/browse/FLINK-28110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555878#comment-17555878
]
xingyuan cheng edited comment on FLINK-28110 at 6/18/22 10:13 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-28110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555878#comment-17555878
]
xingyuan cheng edited comment on FLINK-28110 at 6/18/22 10:12 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-28110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555878#comment-17555878
]
xingyuan cheng commented on FLINK-28110:
Maybe we need to use
flinkbot commented on PR #20016:
URL: https://github.com/apache/flink/pull/20016#issuecomment-1159410389
## CI report:
* 83ee6c72efbdbc39f12e2847b43a4565b70f877d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27857:
---
Labels: pull-request-available (was: )
> Hive source support filter push down for orc
luoyuxia opened a new pull request, #20016:
URL: https://github.com/apache/flink/pull/20016
## What is the purpose of the change
Make hive source support filter push down for orc format
## Brief change log
- Make HiveTableSource implement `SupportsFilterPushDown`
1996fanrui commented on code in PR #19993:
URL: https://github.com/apache/flink/pull/19993#discussion_r900755285
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java:
##
@@ -98,6 +98,9 @@ static ChannelStateWriteRequest
[
https://issues.apache.org/jira/browse/FLINK-27792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555864#comment-17555864
]
fanrui commented on FLINK-27792:
Hi [~chesnay] [~pnowojski] . Sorry for introducing this issue, I'm
[
https://issues.apache.org/jira/browse/FLINK-27792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fanrui updated FLINK-27792:
---
Attachment: image-2022-06-18-16-42-13-669.png
> InterruptedException thrown by ChannelStateWriterImpl
>
[
https://issues.apache.org/jira/browse/FLINK-27792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fanrui updated FLINK-27792:
---
Attachment: image-2022-06-18-16-42-46-283.png
> InterruptedException thrown by ChannelStateWriterImpl
>
flinkbot commented on PR #20015:
URL: https://github.com/apache/flink/pull/20015#issuecomment-1159398835
## CI report:
* 7d52086ccc9b658988e1908d34f1d175035c27d4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fanrui updated FLINK-27792:
---
Attachment: image-2022-06-18-16-39-54-402.png
> InterruptedException thrown by ChannelStateWriterImpl
>
[
https://issues.apache.org/jira/browse/FLINK-28011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-28011:
---
Labels: pull-request-available (was: )
> Optimize getAllPartitions in HiveSource
>
luoyuxia opened a new pull request, #20015:
URL: https://github.com/apache/flink/pull/20015
## What is the purpose of the change
Make HiveSouce get partitions in batch instead of getting one by one, which
is time consuming.
## Brief change log
- First get all
[
https://issues.apache.org/jira/browse/FLINK-27708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27708:
---
Labels: pull-request-available (was: )
> Add background compaction task for append-only
complone opened a new pull request, #164:
URL: https://github.com/apache/flink-table-store/pull/164
Related to FLINK-27708
Add background compaction task for append-only table when ingesting.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-28021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555861#comment-17555861
]
Shubham Bansal edited comment on FLINK-28021 at 6/18/22 8:26 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-28021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555861#comment-17555861
]
Shubham Bansal commented on FLINK-28021:
Thanks. Taking a look.
> Add FLIP-33 metrics to
flinkbot commented on PR #20014:
URL: https://github.com/apache/flink/pull/20014#issuecomment-1159393589
## CI report:
* 413ff339da9dbcad6329da5134c27fbbf7bc05bb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-26979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26979:
---
Labels: pull-request-available test-stability (was: test-stability)
>
shba24 opened a new pull request, #20014:
URL: https://github.com/apache/flink/pull/20014
## What is the purpose of the change
Fix the race condition on node id of transformation when test execution
happens in parallel
## Brief change log
- *Correct the race condition
Aitozi commented on code in PR #19840:
URL: https://github.com/apache/flink/pull/19840#discussion_r900711478
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java:
##
@@ -504,8 +522,11 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-27708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555851#comment-17555851
]
xingyuan cheng commented on FLINK-27708:
I want to try to do this work. There are some studies
Aitozi commented on code in PR #19840:
URL: https://github.com/apache/flink/pull/19840#discussion_r900707375
##
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/AbstractFineGrainedSlotManagerITCase.java:
##
@@ -752,4 +753,76 @@ public void
Aitozi commented on code in PR #19840:
URL: https://github.com/apache/flink/pull/19840#discussion_r900706727
##
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java:
##
@@ -504,8 +522,11 @@ private void
[
https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1732#comment-1732
]
Biao Geng edited comment on FLINK-27667 at 6/18/22 6:36 AM:
hi
[
https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1732#comment-1732
]
Biao Geng edited comment on FLINK-27667 at 6/18/22 6:34 AM:
hi
[
https://issues.apache.org/jira/browse/FLINK-28103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555843#comment-17555843
]
David commented on FLINK-28103:
---
[~chesnay] PATCH is supported neither in Java (HttpURLConnection) nor in
[
https://issues.apache.org/jira/browse/FLINK-28103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17555842#comment-17555842
]
David commented on FLINK-28103:
---
[~martijnvisser] I'll try that next week
> Job cancelling api returns
MartijnVisser commented on PR #19994:
URL: https://github.com/apache/flink/pull/19994#issuecomment-1159371183
@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
50 matches
Mail list logo