wangzzu commented on PR #23243:
URL: https://github.com/apache/flink/pull/23243#issuecomment-1720782299
@FangYongs if you have time, help review it
--
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-33090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu reassigned FLINK-33090:
Assignee: Yi Zhang
> CheckpointsCleaner clean individual checkpoint states in parallel
>
Rui Fan created FLINK-33092:
---
Summary: Improve the resource-stabilization-timeout mechanism when
rescale a job for Adaptive Scheduler
Key: FLINK-33092
URL: https://issues.apache.org/jira/browse/FLINK-33092
[
https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33092:
Description:
!image-2023-09-15-14-43-35-104.png|width=1103,height=779!
h1. 1. Propose
The above is the st
[
https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-33092:
Description:
!image-2023-09-15-14-43-35-104.png|width=916,height=647!
h1. 1. Propose
The above is the sta
[
https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765483#comment-17765483
]
Rui Fan commented on FLINK-33092:
-
Hi [~chesnay] [~dmvk] , would you mind helping take
swuferhong opened a new pull request, #23423:
URL: https://github.com/apache/flink/pull/23423
## What is the purpose of the change
This pr is aims to skip redundant scan while partition table contains
none-existent partition. For this case, it means that there are no partitio
[
https://issues.apache.org/jira/browse/FLINK-25993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-25993:
---
Labels: pull-request-available (was: )
> Option to disable Kryo.setRegistrationRequired(fal
flinkbot commented on PR #23423:
URL: https://github.com/apache/flink/pull/23423#issuecomment-1720844251
## CI report:
* 89fbe5c54823b821d9ad8ed5ef5f95535d6d6b49 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-22128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765504#comment-17765504
]
Yunhong Zheng commented on FLINK-22128:
---
Hi, [~lzljs3620320] . Does this issue sti
pnowojski commented on PR #48:
URL:
https://github.com/apache/flink-connector-kafka/pull/48#issuecomment-1720912224
Yes, will do. @tzulitai , after merging this to v3.0, what Flink fix version
should I set for the ticket?
--
This is an automated message from the Apache Git Service.
pnowojski opened a new pull request, #49:
URL: https://github.com/apache/flink-connector-kafka/pull/49
this is a backport of https://github.com/apache/flink-connector-kafka/pull/48
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
gaborgsomogyi commented on PR #23417:
URL: https://github.com/apache/flink/pull/23417#issuecomment-1720942470
I've just analyzed through why `pemja 0.4.0` is not found and the reason is
that:
* `0.3.0` has pom inside:
https://repo.maven.apache.org/maven2/com/alibaba/pemja/0.3.0/
htt
gaborgsomogyi commented on PR #23417:
URL: https://github.com/apache/flink/pull/23417#issuecomment-1720944111
@HuangXingBo can the mentioned missing files added or new release is
required?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
Jiabao-Sun opened a new pull request, #23424:
URL: https://github.com/apache/flink/pull/23424
[FLINK-32445][runtime] Refactor BlobStoreService's closeAndCleanupAllData to
cleanupAllData
## What is the purpose of the change
We might want to refactor BlobStore.closeAndCle
[
https://issues.apache.org/jira/browse/FLINK-32445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32445:
---
Labels: auto-deprioritized-major pull-request-available starter (was:
auto-deprioritized-ma
flinkbot commented on PR #23424:
URL: https://github.com/apache/flink/pull/23424#issuecomment-1720951696
## CI report:
* 112c57c160f151365d46eef244629271ec7d1990 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765517#comment-17765517
]
Jiabao Sun commented on FLINK-32445:
Hi [~mapohl], I just submit a PR of this issue.
pnowojski merged PR #48:
URL: https://github.com/apache/flink-connector-kafka/pull/48
--
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: issues-unsubscr...
boring-cyborg[bot] commented on PR #48:
URL:
https://github.com/apache/flink-connector-kafka/pull/48#issuecomment-1720964183
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
pnowojski merged PR #49:
URL: https://github.com/apache/flink-connector-kafka/pull/49
--
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: issues-unsubscr...
[
https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-28758.
--
Resolution: Fixed
merged commit 27a5465 into main
merged commit 20c854c into v3.0
> FlinkKafk
gtk96 commented on code in PR #23424:
URL: https://github.com/apache/flink/pull/23424#discussion_r1327050879
##
flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobCacheRetriesTest.java:
##
@@ -148,7 +149,7 @@ void testBlobForJobFetchWithTooManyFailuresHa() throws
IOE
reswqa merged PR #23419:
URL: https://github.com/apache/flink/pull/23419
--
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: issues-unsubscr...@flink.apache
gtk96 commented on code in PR #23424:
URL: https://github.com/apache/flink/pull/23424#discussion_r1327054245
##
flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobCacheRetriesTest.java:
##
@@ -148,7 +149,7 @@ void testBlobForJobFetchWithTooManyFailuresHa() throws
IOE
reswqa merged PR #23418:
URL: https://github.com/apache/flink/pull/23418
--
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: issues-unsubscr...@flink.apache
[
https://issues.apache.org/jira/browse/FLINK-33088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765530#comment-17765530
]
Yuxin Tan commented on FLINK-33088:
---
master(1.19): 1774b84a74f5d348a94bf7dbd5694122150
[
https://issues.apache.org/jira/browse/FLINK-33088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan closed FLINK-33088.
-
Resolution: Fixed
> Fix NullPointerException in RemoteTierConsumerAgent of tiered storage
>
pnowojski merged PR #23391:
URL: https://github.com/apache/flink/pull/23391
--
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: issues-unsubscr...@flink.apa
[
https://issues.apache.org/jira/browse/FLINK-33071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-33071.
--
Fix Version/s: 1.19.0
Resolution: Fixed
merged commit ece5fad into apache:master
> Log
yigress opened a new pull request, #23425:
URL: https://github.com/apache/flink/pull/23425
## What is the purpose of the change
provide option to clean up checkpoints faster in CheckpointsCleaner
## Brief change log
adds a checkpointing config state.checkpoints.cleaner.fa
[
https://issues.apache.org/jira/browse/FLINK-33090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33090:
---
Labels: pull-request-available (was: )
> CheckpointsCleaner clean individual checkpoint sta
[
https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30400:
---
Labels: pull-request-available (was: )
> Stop bundling connector-base in externalized conne
reswqa merged PR #23397:
URL: https://github.com/apache/flink/pull/23397
--
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: issues-unsubscr...@flink.apache
[
https://issues.apache.org/jira/browse/FLINK-33090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765536#comment-17765536
]
Yi Zhang commented on FLINK-33090:
--
[~masteryhx] Can you help review? I am new to Flin
flinkbot commented on PR #23425:
URL: https://github.com/apache/flink/pull/23425#issuecomment-1720996447
## CI report:
* 0c17e787185059c7317f8a48b444358e5a2e1132 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
reswqa merged PR #23398:
URL: https://github.com/apache/flink/pull/23398
--
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: issues-unsubscr...@flink.apache
reswqa commented on PR #23398:
URL: https://github.com/apache/flink/pull/23398#issuecomment-1720998666
Has been approved for `master` branch.
--
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 s
ruanhang1993 opened a new pull request, #96:
URL: https://github.com/apache/flink-connector-aws/pull/96
## Purpose of the change
Stop bundling flink-connector-base.
## Verifying this change
This change is already covered by existing tests.
## Significant changes
JunRuiLee commented on PR #23420:
URL: https://github.com/apache/flink/pull/23420#issuecomment-1721052781
@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 comment.
curcur commented on code in PR #22890:
URL: https://github.com/apache/flink/pull/22890#discussion_r1327104203
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorFileMergingManager.java:
##
@@ -0,0 +1,146 @@
+/*
+ * Licensed to the Apache Software Foundatio
curcur commented on PR #22890:
URL: https://github.com/apache/flink/pull/22890#issuecomment-1721058066
Thanks @fredia for submitting this PR. It is a simple PR, LGTM, and approved
with a few minor comments, please take a look.
--
This is an automated message from the Apache Git Service.
T
flinkbot commented on PR #23426:
URL: https://github.com/apache/flink/pull/23426#issuecomment-1721088965
## CI report:
* cbcce97d39f0b4028320680d5c98969584ef09c4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dannycranmer commented on code in PR #94:
URL:
https://github.com/apache/flink-connector-aws/pull/94#discussion_r1327149189
##
flink-connector-aws-e2e-tests/flink-connector-aws-kinesis-streams-e2e-tests/src/test/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkITCase.java
[
https://issues.apache.org/jira/browse/FLINK-33071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-33071:
---
Fix Version/s: 1.18.1
> Log checkpoint statistics
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-33071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765533#comment-17765533
]
Piotr Nowojski edited comment on FLINK-33071 at 9/15/23 11:37 AM:
Jackson-xky opened a new pull request, #20:
URL: https://github.com/apache/flink-connector-hbase/pull/20
HBaseRowDataLookupFunction.lookup中返回的结果是Collections.singletonList(serde.convertToNewRow(result))，这里默认都是用convertToNewRow方法，内部是在复用同一个对象，当开启了lookup.cache的时候，会导致缓存的结果只都是同一个对象，从而导致结果错乱，由于这里目前不
boring-cyborg[bot] commented on PR #20:
URL:
https://github.com/apache/flink-connector-hbase/pull/20#issuecomment-1721135204
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is a
JunRuiLee commented on PR #23420:
URL: https://github.com/apache/flink/pull/23420#issuecomment-1721280205
@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 comment.
Dawid Wysakowicz created FLINK-33093:
Summary: SHOW FUNCTIONS throw exception with unset catalog
Key: FLINK-33093
URL: https://issues.apache.org/jira/browse/FLINK-33093
Project: Flink
Iss
JunRuiLee commented on PR #23420:
URL: https://github.com/apache/flink/pull/23420#issuecomment-1721374067
@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 comment.
dawidwys opened a new pull request, #23427:
URL: https://github.com/apache/flink/pull/23427
## What is the purpose of the change
Support listing functions with unset catalog
## Verifying this change
Added
`org.apache.flink.table.planner.catalog.UnknownCatalogTest#tes
[
https://issues.apache.org/jira/browse/FLINK-33093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33093:
---
Labels: pull-request-available (was: )
> SHOW FUNCTIONS throw exception with unset catalog
flinkbot commented on PR #23427:
URL: https://github.com/apache/flink/pull/23427#issuecomment-1721380936
## CI report:
* 9f43fbf15436effa7eb2d3dd587d20d3fda166d6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765669#comment-17765669
]
Ryan Skraba commented on FLINK-33058:
-
Hello! I can review this, but in my experien
JunRuiLee commented on PR #23420:
URL: https://github.com/apache/flink/pull/23420#issuecomment-1721396883
@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 comment.
twalthr commented on code in PR #23427:
URL: https://github.com/apache/flink/pull/23427#discussion_r1327410411
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/catalog/UnknownCatalogTest.java:
##
@@ -90,6 +94,19 @@ public void testSetCatalogWithSel
X-czh commented on PR #23301:
URL: https://github.com/apache/flink/pull/23301#issuecomment-1721439392
Squashed commits to clean up the commit history. @FangYongs Could you help
take a look when you have time?
--
This is an automated message from the Apache Git Service.
To respond to the m
[
https://issues.apache.org/jira/browse/FLINK-33094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lee SeungMin updated FLINK-33094:
-
Summary: kubernetes.decorator.kerberos-mount.enabled does not work (was:
KUBERNETES_KERBEROS_MO
Lee SeungMin created FLINK-33094:
Summary:
KUBERNETES_KERBEROS_MOUNT_DECORATOR_ENABLED(kubernetes.decorator.kerberos-mount.enabled)
not works
Key: FLINK-33094
URL: https://issues.apache.org/jira/browse/FLINK-3309
[
https://issues.apache.org/jira/browse/FLINK-33094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lee SeungMin updated FLINK-33094:
-
Description:
I deployed
_[basic-example|https://nightlies.apache.org/flink/flink-kubernetes-ope
[
https://issues.apache.org/jira/browse/FLINK-33094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lee SeungMin updated FLINK-33094:
-
Description:
I deployed
_[basic-example|https://nightlies.apache.org/flink/flink-kubernetes-ope
[
https://issues.apache.org/jira/browse/FLINK-33094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lee SeungMin updated FLINK-33094:
-
Description:
I deployed
_[basic-example|https://nightlies.apache.org/flink/flink-kubernetes-ope
[
https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-29050:
---
Labels: pull-request-available stale-assigned starter (was:
pull-request-available starter)
[
https://issues.apache.org/jira/browse/FLINK-28475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-28475:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-32605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32605:
---
Labels: stale-major test-stability (was: test-stability)
I am the [Flink Jira Bot|https://g
Jiabao-Sun commented on code in PR #23424:
URL: https://github.com/apache/flink/pull/23424#discussion_r1327890114
##
flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobCacheRetriesTest.java:
##
@@ -148,7 +149,7 @@ void testBlobForJobFetchWithTooManyFailuresHa() throws
[
https://issues.apache.org/jira/browse/FLINK-32769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765894#comment-17765894
]
Yanfei Lei commented on FLINK-32769:
Merged via 13469792821ee1e9d2171a28a071cc986626
[
https://issues.apache.org/jira/browse/FLINK-32769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-32769.
Fix Version/s: 1.19.0
Assignee: Feifan Wang
Resolution: Fixed
> PeriodicMaterializ
[
https://issues.apache.org/jira/browse/FLINK-32769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei closed FLINK-32769.
--
> PeriodicMaterializationManager pass descriptionFormat with invalid
> placeholder to MailboxExecutor#exe
JunRuiLee commented on PR #23420:
URL: https://github.com/apache/flink/pull/23420#issuecomment-172224
@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 comment.
gtk96 commented on PR #23424:
URL: https://github.com/apache/flink/pull/23424#issuecomment-1722115883
cc @ruanhang1993 @leonardBang
--
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 c
72 matches
Mail list logo
