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
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.
[
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
[
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:comment-tabpanel&focusedCommentId=17765894#comment-17765894
]
Yanfei Lei commented on FLINK-32769:
Merged via 13469792821ee1e9d2171a28a071cc986626
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-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
[
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-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-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
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:
-
Summary: kubernetes.decorator.kerberos-mount.enabled does not work (was:
KUBERNETES_KERBEROS_MO
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
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
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.
[
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
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-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
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
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.
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-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.
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
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的时候，会导致缓存的结果只都是同一个对象，从而导致结果错乱，由于这里目前不
[
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:
[
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
> --
>
>
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
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`
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
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
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.
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
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
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
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`
[
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
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-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
[
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
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-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
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-33088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan closed FLINK-33088.
-
Resolution: Fixed
> Fix NullPointerException in RemoteTierConsumerAgent of tiered storage
>
[
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
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
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 #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_r1327050879
##
flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobCacheRetriesTest.java:
##
@@ -148,7 +149,7 @@ void testBlobForJobFetchWithTooManyFailuresHa() throws
IOE
[
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
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...
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 #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...
[
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.
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:all-tabpanel
]
ASF GitHub Bot updated FLINK-32445:
---
Labels: auto-deprioritized-major pull-request-available starter (was:
auto-deprioritized-ma
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
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
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
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
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.
[
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
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-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
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-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
[
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: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
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-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
>
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
72 matches
Mail list logo
