[
https://issues.apache.org/jira/browse/FLINK-31356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17702651#comment-17702651
]
John commented on FLINK-31356:
--
I know the reason through debugging.
My old pojo does not
[
https://issues.apache.org/jira/browse/FLINK-31356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697773#comment-17697773
]
John commented on FLINK-31356:
--
[~Yanfei Lei]
I have a mapState.
It turns out that pojo h
[
https://issues.apache.org/jira/browse/FLINK-31356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John updated FLINK-31356:
-
Description:
{panel:title=The last checkpoint of the program was successful}
2023-03-07 08:33:16,085 INFO
or
[
https://issues.apache.org/jira/browse/FLINK-31356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John updated FLINK-31356:
-
Description:
{panel:title=The last checkpoint of the program was successful}
2023-03-07 08:33:16,085 INFO
or
John created FLINK-31356:
Summary: Serialize garbled characters at checkpoint
Key: FLINK-31356
URL: https://issues.apache.org/jira/browse/FLINK-31356
Project: Flink
Issue Type: Bug
Componen
[
https://issues.apache.org/jira/browse/FLINK-27748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17580525#comment-17580525
]
john commented on FLINK-27748:
--
[~knaufk] Probably not, maxParallelism controls the total
john created FLINK-29004:
Summary: pyflink supports specifying index-url when installing
third-party dependencies
Key: FLINK-29004
URL: https://issues.apache.org/jira/browse/FLINK-29004
Project: Flink
john created FLINK-27748:
Summary: AdaptiveScheduler should support operator fixed
parallelism
Key: FLINK-27748
URL: https://issues.apache.org/jira/browse/FLINK-27748
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-25832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
john updated FLINK-25832:
-
Description:
I deployed a standalone flink cluster on k8s and enabled
scheduler-mode=reactive. When Taskmanager
john created FLINK-25832:
Summary: When the TaskManager is closed, its associated slot is
not set to the released state.
Key: FLINK-25832
URL: https://issues.apache.org/jira/browse/FLINK-25832
Project: Flink
john created FLINK-25642:
Summary: The standalone deployment mode should also support the
parameter pipeline.jars
Key: FLINK-25642
URL: https://issues.apache.org/jira/browse/FLINK-25642
Project: Flink
john created FLINK-25190:
Summary: The number of TaskManagers whose status is Pending should
be reported
Key: FLINK-25190
URL: https://issues.apache.org/jira/browse/FLINK-25190
Project: Flink
Issue
john created FLINK-25056:
Summary: Modify Flink dashboard task manager page, "Path, ID"
column，to support sorting by id.
Key: FLINK-25056
URL: https://issues.apache.org/jira/browse/FLINK-25056
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445657#comment-17445657
]
john commented on FLINK-24944:
--
[~wangyang0918] [~guoyangze] Thank you for your review.
>
[
https://issues.apache.org/jira/browse/FLINK-24944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17445585#comment-17445585
]
john commented on FLINK-24944:
--
[~guoyangze] if I want to specify the priority when submitt
john created FLINK-24944:
Summary: Flink job on k8s mode supports pod scheduling according
to priority
Key: FLINK-24944
URL: https://issues.apache.org/jira/browse/FLINK-24944
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443678#comment-17443678
]
john commented on FLINK-24897:
--
我们自己实现了 on yarn 模下的userlib功能。支持hdfs上的文件夹，都会一并加入到container的c
[
https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443678#comment-17443678
]
john edited comment on FLINK-24897 at 11/15/21, 9:33 AM:
-
我们自己实现
[
https://issues.apache.org/jira/browse/FLINK-24894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443658#comment-17443658
]
john commented on FLINK-24894:
--
[~guoyangze] But there is a problem with this mechanism: th
john created FLINK-24894:
Summary: Flink on k8s, open the HA mode based on
KubernetesHaServicesFactory ，When I deleted the job, the config map created
under the HA mechanism was not deleted.
Key: FLINK-24894
URL: https:/
john created FLINK-23508:
Summary: HA mode cannot coexist with history server
Key: FLINK-23508
URL: https://issues.apache.org/jira/browse/FLINK-23508
Project: Flink
Issue Type: Bug
Report
john created FLINK-23507:
Summary: The node IP obtained in NodePort mode is a VIP
Key: FLINK-23507
URL: https://issues.apache.org/jira/browse/FLINK-23507
Project: Flink
Issue Type: Bug
Comp
John created FLINK-12304:
Summary: AvroInputFormat should support schema evolution
Key: FLINK-12304
URL: https://issues.apache.org/jira/browse/FLINK-12304
Project: Flink
Issue Type: Bug
Com
John created FLINK-12106:
Summary: Jobmanager is killing FINISHED taskmanger containers,
causing exception in still running Taskmanagers an
Key: FLINK-12106
URL: https://issues.apache.org/jira/browse/FLINK-12106
24 matches
Mail list logo
