[
https://issues.apache.org/jira/browse/FLINK-34043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878995#comment-17878995
]
Peter Vary edited comment on FLINK-34043 at 9/3/24 7:23 PM:
[
https://issues.apache.org/jira/browse/FLINK-34043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878995#comment-17878995
]
Peter Vary commented on FLINK-34043:
[~guoweijie]: It would be nice if you could rem
[
https://issues.apache.org/jira/browse/FLINK-34840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849623#comment-17849623
]
Peter Vary commented on FLINK-34840:
If you need help with Iceberg reviews, feel fre
[
https://issues.apache.org/jira/browse/FLINK-35051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835142#comment-17835142
]
Peter Vary commented on FLINK-35051:
FLINK-34704 is one of the ways this issue mater
[
https://issues.apache.org/jira/browse/FLINK-34042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814739#comment-17814739
]
Peter Vary commented on FLINK-34042:
Currently there is no existing documentation fo
[
https://issues.apache.org/jira/browse/FLINK-33328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary closed FLINK-33328.
--
Resolution: Duplicate
Solved as part of FLINK-33972
> Allow TwoPhaseCommittingSink WithPreCommitTopol
[
https://issues.apache.org/jira/browse/FLINK-34307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary closed FLINK-34307.
--
Resolution: Won't Fix
[~lincoln.86xy]: Thanks for managing the release.
For now, the unit tests are su
[
https://issues.apache.org/jira/browse/FLINK-34306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary resolved FLINK-34306.
Resolution: Won't Fix
> Release Testing Instructions: Verify FLINK-25857 Add committer metrics to
[
https://issues.apache.org/jira/browse/FLINK-34306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814733#comment-17814733
]
Peter Vary commented on FLINK-34306:
[~lincoln.86xy]: Thanks for managing the releas
[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary updated FLINK-25857:
---
Release Note:
The TwoPhaseCommittingSink.createCommitter method parametrization has been
changed, a
[
https://issues.apache.org/jira/browse/FLINK-33973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary updated FLINK-33973:
---
Release Note:
According to FILP-372
(https://cwiki.apache.org/confluence/display/FLINK/FLIP-372%3A+
Peter Vary created FLINK-34228:
--
Summary: Add long UTF serializer/deserializer
Key: FLINK-34228
URL: https://issues.apache.org/jira/browse/FLINK-34228
Project: Flink
Issue Type: Improvement
Peter Vary created FLINK-34209:
--
Summary: Migrate FileSink to the new SinkV2 API
Key: FLINK-34209
URL: https://issues.apache.org/jira/browse/FLINK-34209
Project: Flink
Issue Type: Sub-task
Peter Vary created FLINK-34208:
--
Summary: Migrate SinkV1Adapter to the new SinkV2 API
Key: FLINK-34208
URL: https://issues.apache.org/jira/browse/FLINK-34208
Project: Flink
Issue Type: Sub-task
Peter Vary created FLINK-34043:
--
Summary: Remove deprecated Sink V2 interfaces
Key: FLINK-34043
URL: https://issues.apache.org/jira/browse/FLINK-34043
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-34042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary updated FLINK-34042:
---
Description: Check the documentation and update the Sink V2 API usages
whenever it is needed
> Upda
Peter Vary created FLINK-34042:
--
Summary: Update the documentation
Key: FLINK-34042
URL: https://issues.apache.org/jira/browse/FLINK-34042
Project: Flink
Issue Type: Sub-task
Report
[
https://issues.apache.org/jira/browse/FLINK-34042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary updated FLINK-34042:
---
Summary: Update the documentation for Sink V2 (was: Update the
documentation )
> Update the docume
Peter Vary created FLINK-33975:
--
Summary: Tests for the new Sink V2 transformations
Key: FLINK-33975
URL: https://issues.apache.org/jira/browse/FLINK-33975
Project: Flink
Issue Type: Sub-task
Peter Vary created FLINK-33974:
--
Summary: Implement the Sink transformation depending on the new
SinkV2 interfaces
Key: FLINK-33974
URL: https://issues.apache.org/jira/browse/FLINK-33974
Project: Flink
Peter Vary created FLINK-33973:
--
Summary: Add new interfaces for SinkV2 to synchronize the API with
the SourceV2 API
Key: FLINK-33973
URL: https://issues.apache.org/jira/browse/FLINK-33973
Project: Flink
Peter Vary created FLINK-33972:
--
Summary: Enhance and synchronize Sink API to match the Source API
Key: FLINK-33972
URL: https://issues.apache.org/jira/browse/FLINK-33972
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17799320#comment-17799320
]
Peter Vary commented on FLINK-33528:
[~Sergey Nuyanzin]: FLINK-33762 is needed, so t
[
https://issues.apache.org/jira/browse/FLINK-33523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794128#comment-17794128
]
Peter Vary commented on FLINK-33523:
Created a thread about this topic on the mailin
Peter Vary created FLINK-33762:
--
Summary: Versioned release of flink-connector-shared-utils python
scripts
Key: FLINK-33762
URL: https://issues.apache.org/jira/browse/FLINK-33762
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789963#comment-17789963
]
Peter Vary commented on FLINK-25857:
If you check the discussion [1] the diamond inh
[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789335#comment-17789335
]
Peter Vary commented on FLINK-25857:
For the Iceberg connector we release separate v
[
https://issues.apache.org/jira/browse/FLINK-33568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786947#comment-17786947
]
Peter Vary commented on FLINK-33568:
With the patch it looks like this:
!Screenshot
[
https://issues.apache.org/jira/browse/FLINK-33568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary updated FLINK-33568:
---
Attachment: Screenshot 2023-11-16 at 22.30.51.png
> SinkV2MetricsITCase.testCommitterMetrics fails w
[
https://issues.apache.org/jira/browse/FLINK-33568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786814#comment-17786814
]
Peter Vary commented on FLINK-33568:
Checking
> SinkV2MetricsITCase.testCommitterMe
[
https://issues.apache.org/jira/browse/FLINK-33295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784689#comment-17784689
]
Peter Vary edited comment on FLINK-33295 at 11/10/23 6:23 AM:
[
https://issues.apache.org/jira/browse/FLINK-33295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784689#comment-17784689
]
Peter Vary commented on FLINK-33295:
`InternalSinkWriterMetricGroup` is an initial c
Peter Vary created FLINK-33328:
--
Summary: Allow TwoPhaseCommittingSink WithPreCommitTopology to
alter the type of the Committable
Key: FLINK-33328
URL: https://issues.apache.org/jira/browse/FLINK-33328
P
Peter Vary created FLINK-33295:
--
Summary: Separate SinkV2 and SinkV1Adapter tests
Key: FLINK-33295
URL: https://issues.apache.org/jira/browse/FLINK-33295
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-32046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary updated FLINK-32046:
---
Description:
If the checkpointing is turned off then the
{{SplitAssignmentTracker.uncheckpointedAss
Peter Vary created FLINK-32046:
--
Summary: OOM caused by
SplitAssignmentTracker.uncheckpointedAssignments
Key: FLINK-32046
URL: https://issues.apache.org/jira/browse/FLINK-32046
Project: Flink
I
Peter Vary created FLINK-31868:
--
Summary: Fix DefaultInputSplitAssigner javadoc for class
Key: FLINK-31868
URL: https://issues.apache.org/jira/browse/FLINK-31868
Project: Flink
Issue Type: Impro
[
https://issues.apache.org/jira/browse/FLINK-31246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary updated FLINK-31246:
---
Summary: Beautify the SpecChange message (was: Remove PodTemplate
description from the SpecChange m
[
https://issues.apache.org/jira/browse/FLINK-31246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694443#comment-17694443
]
Peter Vary edited comment on FLINK-31246 at 2/28/23 8:57 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-31246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694443#comment-17694443
]
Peter Vary commented on FLINK-31246:
Talked with [~gyfora] about this, and he is con
Peter Vary created FLINK-31246:
--
Summary: Remove PodTemplate description from the SpecChange message
Key: FLINK-31246
URL: https://issues.apache.org/jira/browse/FLINK-31246
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-30543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary updated FLINK-30543:
---
Component/s: Kubernetes Operator
> Adding more examples for setting up jobs via operator.
>
[
https://issues.apache.org/jira/browse/FLINK-30367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17646136#comment-17646136
]
Peter Vary commented on FLINK-30367:
The depth of the stack trace could be set by th
[
https://issues.apache.org/jira/browse/FLINK-30315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary updated FLINK-30315:
---
Description:
When there is an image pull error, this is what we see in the operator log:
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-30315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643909#comment-17643909
]
Peter Vary commented on FLINK-30315:
The {{ContainerStateWaiting}} contains the mess
Peter Vary created FLINK-30315:
--
Summary: Add more information about image pull failures to the
operator log
Key: FLINK-30315
URL: https://issues.apache.org/jira/browse/FLINK-30315
Project: Flink
Peter Vary created FLINK-30311:
--
Summary: CI error: Back-off pulling image "flink:1.14"
Key: FLINK-30311
URL: https://issues.apache.org/jira/browse/FLINK-30311
Project: Flink
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/FLINK-30150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643305#comment-17643305
]
Peter Vary commented on FLINK-30150:
This is the exception in the logs:
{code:java}
Peter Vary created FLINK-30199:
--
Summary: Add a script to run Kubernetes Operator e2e tests manually
Key: FLINK-30199
URL: https://issues.apache.org/jira/browse/FLINK-30199
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629824#comment-17629824
]
Peter Vary commented on FLINK-29629:
Most probably I will not have time to work on t
[
https://issues.apache.org/jira/browse/FLINK-29754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623882#comment-17623882
]
Peter Vary commented on FLINK-29754:
[This|https://github.com/apache/flink/blob/0e61
[
https://issues.apache.org/jira/browse/FLINK-29754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623704#comment-17623704
]
Peter Vary commented on FLINK-29754:
I create a configuration file like this:
{code:
Peter Vary created FLINK-29754:
--
Summary: HadoopConfigLoader should consider Hadoop configuration
files
Key: FLINK-29754
URL: https://issues.apache.org/jira/browse/FLINK-29754
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623647#comment-17623647
]
Peter Vary commented on FLINK-29629:
Thanks [~zhuzh]!
Thanks for the info, I checke
[
https://issues.apache.org/jira/browse/FLINK-29713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17622561#comment-17622561
]
Peter Vary commented on FLINK-29713:
The main goal is to have a possibility to add a
Peter Vary created FLINK-29713:
--
Summary: Kubernetes operator should restart failed jobs
Key: FLINK-29713
URL: https://issues.apache.org/jira/browse/FLINK-29713
Project: Flink
Issue Type: Improv
[
https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619053#comment-17619053
]
Peter Vary commented on FLINK-29629:
[~chesnay]: Does that mean that some of the cod
Peter Vary created FLINK-29629:
--
Summary: FlameGraph is empty for Legacy Source Threads
Key: FLINK-29629
URL: https://issues.apache.org/jira/browse/FLINK-29629
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-29123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary updated FLINK-29123:
---
Summary: Dynamic paramters are not pushed to working with kubernetes (was:
Dynamic paramters are no
Peter Vary created FLINK-29123:
--
Summary: Dynamic paramters are not pushed to working with
kubertenes
Key: FLINK-29123
URL: https://issues.apache.org/jira/browse/FLINK-29123
Project: Flink
Issu
60 matches
Mail list logo