Qingsheng Ren created FLINK-29153:
-
Summary: KafkaConsumerThread should catch WakeupException when
committing offsets
Key: FLINK-29153
URL: https://issues.apache.org/jira/browse/FLINK-29153
Project: F
JingsongLi commented on code in PR #280:
URL: https://github.com/apache/flink-table-store/pull/280#discussion_r959226860
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/MergeTreeReader.java:
##
@@ -62,6 +62,12 @@ public MergeTreeReader(
pvary commented on PR #20716:
URL: https://github.com/apache/flink/pull/20716#issuecomment-1232543422
@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.
To
[
https://issues.apache.org/jira/browse/FLINK-29018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598212#comment-17598212
]
Qingsheng Ren commented on FLINK-29018:
---
Thanks for sharing the info [~hxb]! This
JingsongLi commented on code in PR #280:
URL: https://github.com/apache/flink-table-store/pull/280#discussion_r959229043
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/KeyValueFileStoreRead.java:
##
@@ -50,13 +60,18 @@
*/
public class KeyV
JingsongLi commented on code in PR #280:
URL: https://github.com/apache/flink-table-store/pull/280#discussion_r959229043
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/KeyValueFileStoreRead.java:
##
@@ -50,13 +60,18 @@
*/
public class KeyV
JingsongLi commented on code in PR #280:
URL: https://github.com/apache/flink-table-store/pull/280#discussion_r959231586
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/KeyValueFileStoreRead.java:
##
@@ -87,34 +108,78 @@ public KeyValueFileSto
Jingsong Lee created FLINK-29154:
Summary: Support LookupTableSource for table store
Key: FLINK-29154
URL: https://issues.apache.org/jira/browse/FLINK-29154
Project: Flink
Issue Type: New Fea
MartijnVisser closed pull request #20712: add a comment
URL: https://github.com/apache/flink/pull/20712
--
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:
MartijnVisser commented on PR #20712:
URL: https://github.com/apache/flink/pull/20712#issuecomment-1232570604
Closing due to invalid PR
--
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 specifi
Xingbo Huang created FLINK-29155:
Summary: Improve default config of grpcServer in Process Mode
Key: FLINK-29155
URL: https://issues.apache.org/jira/browse/FLINK-29155
Project: Flink
Issue Ty
morhidi commented on PR #357:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/357#issuecomment-1232574252
Hi Folks,
It would be really great to see what `faster` recovery means here, through
an example. In general this sounds a fair benefit but before choosing a more
c
MartijnVisser commented on PR #20718:
URL: https://github.com/apache/flink/pull/20718#issuecomment-1232577553
Closing due to invalid PR
--
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 specifi
MartijnVisser closed pull request #20718: git clone unable to connect to
github.com
URL: https://github.com/apache/flink/pull/20718
--
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 comme
gyfora commented on PR #357:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/357#issuecomment-1232587067
@morhidi I think this would have no impact on reactive scaling. I think the
actual benefit is the possibility to configure PVCs for TMs which could help
with checkpointing
bzhaoopenstack opened a new pull request, #20720:
URL: https://github.com/apache/flink/pull/20720
This is a hotfix for pyflink shell mode.
The output sample has several problems:
1. Need to import the necessary py pkg for avoiding NotDefinitaion
error.
2. Use the current fu
flinkbot commented on PR #20720:
URL: https://github.com/apache/flink/pull/20720#issuecomment-1232610721
## CI report:
* 14881a00df354b518055fb13212940a015e97ec2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JingsongLi opened a new pull request, #281:
URL: https://github.com/apache/flink-table-store/pull/281
At present, the bottom layer of Table Store is LSM structure, and it has
full and incremental reading, which can have certain lookup capability. We can
unlock Table Store to implement Looku
[
https://issues.apache.org/jira/browse/FLINK-29154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29154:
---
Labels: pull-request-available (was: )
> Support LookupTableSource for table store
> --
MartijnVisser merged PR #20620:
URL: https://github.com/apache/flink/pull/20620
--
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
[
https://issues.apache.org/jira/browse/FLINK-29019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-29019.
--
Resolution: Fixed
Fixed in master: 279856570807ba3818c8a5302cc7e3401256c64d
> Updating parque
[
https://issues.apache.org/jira/browse/FLINK-28907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598239#comment-17598239
]
Martijn Visser commented on FLINK-28907:
I do think Go reports back on errors, b
MartijnVisser commented on PR #18118:
URL: https://github.com/apache/flink/pull/18118#issuecomment-1232616069
@gyfora Is this a PR that you could review? I recall that this was mentioned
in the Flink Slack channel?
--
This is an automated message from the Apache Git Service.
To respond t
gyfora commented on PR #18118:
URL: https://github.com/apache/flink/pull/18118#issuecomment-1232621389
Thanks, I or someone from my team will review this ASAP .
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
[
https://issues.apache.org/jira/browse/FLINK-28852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyuzhi updated FLINK-28852:
--
Affects Version/s: 1.14.0
Environment: Flink 1.11.3/1.14.0 (was: Flink 1.11.3)
> Closed met
[
https://issues.apache.org/jira/browse/FLINK-28852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17590109#comment-17590109
]
chenyuzhi edited comment on FLINK-28852 at 8/31/22 8:23 AM:
[
https://issues.apache.org/jira/browse/FLINK-29132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598245#comment-17598245
]
Chesnay Schepler commented on FLINK-29132:
--
True, the attempts will continue to
[
https://issues.apache.org/jira/browse/FLINK-28907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598246#comment-17598246
]
Zhu Zhu commented on FLINK-28907:
-
Got it! Thanks for the explanation.
> Flink docs do
[
https://issues.apache.org/jira/browse/FLINK-29132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29132:
-
Priority: Blocker (was: Major)
> SubtaskMetricStore causes memory leak.
> -
[
https://issues.apache.org/jira/browse/FLINK-28907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-28907.
---
Resolution: Won't Fix
> Flink docs do not compile locally
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-28907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-28907:
Fix Version/s: (was: 1.16.0)
> Flink docs do not compile locally
> -
>
Myasuka commented on PR #20708:
URL: https://github.com/apache/flink/pull/20708#issuecomment-1232627217
My local CI passed
https://myasuka.visualstudio.com/flink/_build/results?buildId=434&view=results
--
This is an automated message from the Apache Git Service.
To respond to the message
Myasuka merged PR #20708:
URL: https://github.com/apache/flink/pull/20708
--
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.apach
[
https://issues.apache.org/jira/browse/FLINK-28078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598256#comment-17598256
]
Matthias Pohl commented on FLINK-28078:
---
Ok, I tried to reproduce the issue in [bu
[
https://issues.apache.org/jira/browse/FLINK-28078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598256#comment-17598256
]
Matthias Pohl edited comment on FLINK-28078 at 8/31/22 8:32 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-28078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-28078:
--
Attachment: FLINK-28078-build-40525-20220830.14.tar.gz
> ZooKeeperMultipleComponentLeaderElect
XComp commented on PR #20709:
URL: https://github.com/apache/flink/pull/20709#issuecomment-1232638165
I couldn't reproduce the issue. I listed the findings in FLINK-28078's
comment section. I'm gonna proceed with providing the fix in this PR.
--
This is an automated message from the Apach
yuzelin commented on PR #20714:
URL: https://github.com/apache/flink/pull/20714#issuecomment-1232642349
@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.
zhangjingcun created FLINK-29156:
Summary: Support LISTAGG in the Table API
Key: FLINK-29156
URL: https://issues.apache.org/jira/browse/FLINK-29156
Project: Flink
Issue Type: New Feature
gyfora commented on PR #357:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/357#issuecomment-1232646931
@Grypse this seems like a fairly large architecture decision that we
underestimated at first. We would like to kindly ask you to prepare your
proposal in a FLIP format and
ZanderXu commented on code in PR #16927:
URL: https://github.com/apache/flink/pull/16927#discussion_r959323071
##
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java:
##
@@ -360,4 +391,37 @@ private static boo
[
https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598261#comment-17598261
]
Gyula Fora commented on FLINK-29110:
[@Grypse|https://github.com/Grypse] this seems
gyfora commented on PR #20716:
URL: https://github.com/apache/flink/pull/20716#issuecomment-1232648336
@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.
T
gyfora commented on PR #18118:
URL: https://github.com/apache/flink/pull/18118#issuecomment-1232648808
@gaborgsomogyi will help reviewing this feature.
--
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 g
[
https://issues.apache.org/jira/browse/FLINK-28852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-28852.
Resolution: Won't Fix
This fundamentally conflicts with FLINK-28588.
Unless you are creat
[
https://issues.apache.org/jira/browse/FLINK-29132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598245#comment-17598245
]
Chesnay Schepler edited comment on FLINK-29132 at 8/31/22 8:55 AM:
---
zentol merged PR #18133:
URL: https://github.com/apache/flink/pull/18133
--
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-24718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-24718.
Fix Version/s: 1.16.0
Resolution: Fixed
master: c0f080762e7a1c1763942fed2e34420164a
[
https://issues.apache.org/jira/browse/FLINK-24718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-24718:
-
Issue Type: Improvement (was: Technical Debt)
> Update AVRO dependency to 1.11.1
>
leozhangsr commented on PR #20701:
URL: https://github.com/apache/flink/pull/20701#issuecomment-1232669403
I had just refresh the review request, and
[PatrickRen](https://github.com/PatrickRen) is removed accidently, please add
him back.
--
This is an automated message from the Apache Gi
JingsongLi closed pull request #282: [hotfix] Seperate flink connector in ci
URL: https://github.com/apache/flink-table-store/pull/282
--
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 com
yuzelin commented on PR #20714:
URL: https://github.com/apache/flink/pull/20714#issuecomment-1232677322
@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-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-28719.
Resolution: Information Provided
> Mapping a data source before window aggregation causes
[
https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598272#comment-17598272
]
Chesnay Schepler commented on FLINK-28653:
--
Did you create a new savepoint afte
zentol merged PR #130:
URL: https://github.com/apache/flink-docker/pull/130
--
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
zentol merged PR #131:
URL: https://github.com/apache/flink-docker/pull/131
--
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
zentol merged PR #132:
URL: https://github.com/apache/flink-docker/pull/132
--
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-29137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29137:
---
Labels: pull-request-available (was: )
> Switch docker images to eclipse temurin base
> ---
[
https://issues.apache.org/jira/browse/FLINK-29137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29137.
Resolution: Fixed
dev-master: 47747fa25eeccbbea31c11b6a8bfe957c490a91c
dev-1.15: ff76f1e2d
[
https://issues.apache.org/jira/browse/FLINK-29146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuiqiang Chen updated FLINK-29146:
---
Description:
Currently, when building an ExecutionGraph, it requires to set the job specific
[
https://issues.apache.org/jira/browse/FLINK-29155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang reassigned FLINK-29155:
Assignee: Xingbo Huang
> Improve default config of grpcServer in Process Mode
> -
roncohen opened a new pull request, #20721:
URL: https://github.com/apache/flink/pull/20721
## What is the purpose of the change
FileSystem is also a source, but the overview list only notes it as a sink.
## Brief change log
Update overview.md to indicate that Fi
flinkbot commented on PR #20721:
URL: https://github.com/apache/flink/pull/20721#issuecomment-1232699308
## CI report:
* 65b6213a935d095421ca18a5cfc506081729 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-28408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matyas Orhidi updated FLINK-28408:
--
Description:
Based on our recent interactions with the users we should gather some
frequently
[
https://issues.apache.org/jira/browse/FLINK-28408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598284#comment-17598284
]
Matyas Orhidi commented on FLINK-28408:
---
[~pvary] can you take this?
> FAQ / best
[
https://issues.apache.org/jira/browse/FLINK-28975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598286#comment-17598286
]
Qingsheng Ren commented on FLINK-28975:
---
[~pnowojski] There are two outputs in the
[
https://issues.apache.org/jira/browse/FLINK-29130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-29130.
--
Resolution: Fixed
merged
master(1.16.0): 581e1fe3682e95e0935e0cd1cf4565529af49f84
release-1.15: ad3
zentol merged PR #20721:
URL: https://github.com/apache/flink/pull/20721
--
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
SmirAlex commented on PR #20676:
URL: https://github.com/apache/flink/pull/20676#issuecomment-1232723263
Hi @PatrickRen, thanks for the review! I rebased and CI was successful. Link
- https://dev.azure.com/asmirnov1/Flink/_build/results?buildId=31&view=results
--
This is an automated mess
gyfora commented on code in PR #356:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/356#discussion_r959399419
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java:
##
@@ -98,12 +99,39 @@
zentol merged PR #20691:
URL: https://github.com/apache/flink/pull/20691
--
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-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598298#comment-17598298
]
Gyula Fora commented on FLINK-29144:
[~tashoyan] would you like to work on this impr
MartijnVisser commented on PR #20554:
URL: https://github.com/apache/flink/pull/20554#issuecomment-1232757558
@liuyongvs Please make sure that you use and fill in the PR template. Now it
requires scanning through the code, to see if tests are added etc.
--
This is an automated message fr
[
https://issues.apache.org/jira/browse/FLINK-16775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-16775.
--
Fix Version/s: (was: 1.17.0)
Resolution: Won't Fix
Since FlinkKafkaConsumer / Flink
[
https://issues.apache.org/jira/browse/FLINK-18231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-18231.
--
Fix Version/s: (was: 1.17.0)
Resolution: Done
This has been resolved since we've mo
[
https://issues.apache.org/jira/browse/FLINK-18213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-18213.
--
Fix Version/s: (was: 1.17.0)
Resolution: Done
Resolved due to Flink now having only
[
https://issues.apache.org/jira/browse/FLINK-29132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598314#comment-17598314
]
Gen Luo commented on FLINK-29132:
-
[~nagist]
Thanks a lot for reporting the issue!
And
rkhachatryan opened a new pull request, #20722:
URL: https://github.com/apache/flink/pull/20722
## What is the purpose of the change
Improve logging in `SharedStateRegistry`
and make the conditional logic more clear.
## Verifying this change
This change is a trivial re
[
https://issues.apache.org/jira/browse/FLINK-29095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29095:
---
Labels: pull-request-available (was: )
> logging state file deletion
>
rkhachatryan commented on PR #20722:
URL: https://github.com/apache/flink/pull/20722#issuecomment-1232777846
@fredia could you take a look please?
--
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-29095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-29095:
--
Summary: Improve logging in SharedStateRegistry (was: logging state file
deletion)
[
https://issues.apache.org/jira/browse/FLINK-26603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598327#comment-17598327
]
Martijn Visser commented on FLINK-26603:
[~luoyuxia] Any update from your end on
flinkbot commented on PR #20722:
URL: https://github.com/apache/flink/pull/20722#issuecomment-1232780274
## CI report:
* 9e78c6256faaaee3e0b9aad36cf2a2e0317455b3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Roman Khachatryan created FLINK-29157:
-
Summary: Clarify the contract between CompletedCheckpointStore and
SharedStateRegistry
Key: FLINK-29157
URL: https://issues.apache.org/jira/browse/FLINK-29157
[
https://issues.apache.org/jira/browse/FLINK-23035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-23035:
-
Assignee: Xinbin Huang
> Add explicit method to StateChangelogWriter to write m
[
https://issues.apache.org/jira/browse/FLINK-23035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598335#comment-17598335
]
Roman Khachatryan commented on FLINK-23035:
---
[~binh] I've assigned the ticket
Roman Khachatryan created FLINK-29158:
-
Summary: Fix logging in DefaultCompletedCheckpointStore
Key: FLINK-29158
URL: https://issues.apache.org/jira/browse/FLINK-29158
Project: Flink
Issu
rkhachatryan commented on code in PR #16582:
URL: https://github.com/apache/flink/pull/16582#discussion_r959468204
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/DefaultCompletedCheckpointStore.java:
##
@@ -133,17 +134,23 @@ public void addCheckpoint(
fsk119 merged PR #20665:
URL: https://github.com/apache/flink/pull/20665
--
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-28938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598337#comment-17598337
]
Shengkai Fang commented on FLINK-28938:
---
Merged into master:
549d4327cf4ae9646f74
[
https://issues.apache.org/jira/browse/FLINK-28938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-28938.
-
Resolution: Fixed
> Fix HiveServer2 Endpoint can not set variable correctly
> --
rkhachatryan opened a new pull request, #20723:
URL: https://github.com/apache/flink/pull/20723
## What is the purpose of the change
Fix swapped log messages on checkpoint subsumption.
## Verifying this change
This change is a trivial rework without any test coverage.
[
https://issues.apache.org/jira/browse/FLINK-29158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29158:
---
Labels: pull-request-available (was: )
> Fix logging in DefaultCompletedCheckpointStore
> -
flinkbot commented on PR #20723:
URL: https://github.com/apache/flink/pull/20723#issuecomment-1232818506
## CI report:
* b6cea0e9b8f7b3564e4c20e4132bce60e3a31f72 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
HannanKan commented on PR #270:
URL:
https://github.com/apache/flink-table-store/pull/270#issuecomment-1232820628
> Hi @HannanKan , can you add more unit tests to functions? Now there is
only itcase.
Good idea! I will do it later.
--
This is an automated message from the Apache Gi
XComp commented on PR #20709:
URL: https://github.com/apache/flink/pull/20709#issuecomment-1232823084
force push was necessary because spotless wasn't applied
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
MartijnVisser commented on PR #28:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/28#issuecomment-1232830105
@nielsbasjes Will you update the PR? I'll have a look then
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/FLINK-28975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598346#comment-17598346
]
Piotr Nowojski commented on FLINK-28975:
{quote}WatermarksWithIdleness (which is
[
https://issues.apache.org/jira/browse/FLINK-28975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598346#comment-17598346
]
Piotr Nowojski edited comment on FLINK-28975 at 8/31/22 12:05 PM:
[
https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598347#comment-17598347
]
Martijn Visser commented on FLINK-25421:
[~eskabetxe] Do you think
https://cwik
1 - 100 of 206 matches
Mail list logo
