[
https://issues.apache.org/jira/browse/FLINK-33798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825913#comment-17825913
]
Ming Li commented on FLINK-33798:
-
[~fanrui], good idea, I will back port to 1.17 , 1.18 and 1.19.
>
[
https://issues.apache.org/jira/browse/FLINK-32181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796044#comment-17796044
]
Ming Li commented on FLINK-32181:
-
I also encountered the same problem. Is it necessary to forcefully
Ming Li created FLINK-33798:
---
Summary: Automatically clean up rocksdb logs when the task
failover.
Key: FLINK-33798
URL: https://issues.apache.org/jira/browse/FLINK-33798
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-32698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747789#comment-17747789
]
Ming Li commented on FLINK-32698:
-
[~zjureel] [~zhuzh] [~fanrui] Thanks for your suggestions, I will
[
https://issues.apache.org/jira/browse/FLINK-32698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ming Li updated FLINK-32698:
Description:
Currently only {{checkpointID}} and {{checkpointTimestamp}} information are
provided in
Ming Li created FLINK-32698:
---
Summary: Add getCheckpointOptions interface in
ManagedSnapshotContext
Key: FLINK-32698
URL: https://issues.apache.org/jira/browse/FLINK-32698
Project: Flink
Issue
Ming Li created FLINK-32655:
---
Summary: RecreateOnResetOperatorCoordinator did not forward
notifyCheckpointAborted to the real OperatorCoordinator
Key: FLINK-32655
URL: https://issues.apache.org/jira/browse/FLINK-32655
Ming Li created FLINK-32001:
---
Summary: SupportsRowLevelUpdate does not support returning only a
part of the columns.
Key: FLINK-32001
URL: https://issues.apache.org/jira/browse/FLINK-32001
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-26465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701531#comment-17701531
]
Ming Li commented on FLINK-26465:
-
Hi, [~lzljs3620320] . Is this issue still going on? If there is no
Ming Li created FLINK-31474:
---
Summary: [Flink] Add failure information for out-of-order
checkpoints
Key: FLINK-31474
URL: https://issues.apache.org/jira/browse/FLINK-31474
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-31462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700658#comment-17700658
]
Ming Li commented on FLINK-31462:
-
Hi, [~lzljs3620320] ,
For example, I consume two tables A and B. The
Ming Li created FLINK-31465:
---
Summary: [Flink] Fix shortcode errors in docs
Key: FLINK-31465
URL: https://issues.apache.org/jira/browse/FLINK-31465
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-31462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ming Li updated FLINK-31462:
Description: Currently, the table store provides a startup mode for
incremental consumption from a
[
https://issues.apache.org/jira/browse/FLINK-31462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ming Li updated FLINK-31462:
Summary: [Flink] Supports full calculation from specified snapshots in
streaming mode (was: [Flink]
Ming Li created FLINK-31462:
---
Summary: [Flink] Supports full calculation from the specified
snapshot
Key: FLINK-31462
URL: https://issues.apache.org/jira/browse/FLINK-31462
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-31364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ming Li closed FLINK-31364.
---
Resolution: Duplicate
> [Flink] add metrics for TableStore
> --
>
>
Ming Li created FLINK-31364:
---
Summary: [Flink] add metrics for TableStore
Key: FLINK-31364
URL: https://issues.apache.org/jira/browse/FLINK-31364
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-31294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695457#comment-17695457
]
Ming Li commented on FLINK-31294:
-
[~lzljs3620320], hi, please help take a look at this issue if you
ming li created FLINK-31294:
---
Summary: CommitterOperator forgot to close Committer when closing.
Key: FLINK-31294
URL: https://issues.apache.org/jira/browse/FLINK-31294
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694909#comment-17694909
]
ming li commented on FLINK-31266:
-
hi, [~Weijie Guo], [~Zhanghao Chen] It is indeed confusing for new
[
https://issues.apache.org/jira/browse/FLINK-30985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687053#comment-17687053
]
ming li commented on FLINK-30985:
-
[~lzljs3620320] The {{RequestSplit}} event may not have occurred when
[
https://issues.apache.org/jira/browse/FLINK-31008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687046#comment-17687046
]
ming li commented on FLINK-31008:
-
[~lzljs3620320] I have created a pull request, please review it if
[
https://issues.apache.org/jira/browse/FLINK-30985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17687041#comment-17687041
]
ming li commented on FLINK-30985:
-
[~lzljs3620320] Consider extreme cases, for example, I only have one
[
https://issues.apache.org/jira/browse/FLINK-30985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686991#comment-17686991
]
ming li commented on FLINK-30985:
-
[~lzljs3620320] This is somewhat different from
[
https://issues.apache.org/jira/browse/FLINK-31008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686921#comment-17686921
]
ming li commented on FLINK-31008:
-
[~lzljs3620320] Yes, thanks a lot, I've been doing some related work
[
https://issues.apache.org/jira/browse/FLINK-31008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686912#comment-17686912
]
ming li commented on FLINK-31008:
-
hi, [~lzljs3620320], if you have time, please help to take a look at
ming li created FLINK-31008:
---
Summary: [Flink][Table Store] The Split allocation of the same
bucket in ContinuousFileSplitEnumerator may be out of order
Key: FLINK-31008
URL:
[
https://issues.apache.org/jira/browse/FLINK-30985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-30985:
Summary: [Flink][Table Store] Change the Splits allocation algorithm of
ContinuousFileSplitEnumerator in
ming li created FLINK-30985:
---
Summary: [Flink][table-store] Change the Splits allocation
algorithm of ContinuousFileSplitEnumerator in TableStore to a fair algorithm.
Key: FLINK-30985
URL:
[
https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645200#comment-17645200
]
ming li commented on FLINK-30251:
-
[~gaoyunhaii] thanks for your reply.
We have tried setting timeout
[
https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643730#comment-17643730
]
ming li commented on FLINK-30251:
-
hi, [~Yanfei Lei]. I re-read FLINK-28984, it seems that it is a
[
https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641685#comment-17641685
]
ming li commented on FLINK-30251:
-
hi, [~Yanfei Lei] , I made a simple implementation, can you help to
[
https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641648#comment-17641648
]
ming li commented on FLINK-27681:
-
[~Yanfei Lei] thank you for your reply.
In our production, the
[
https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-30251:
Description:
Currently when the {{checkpoint}} fails, we process the abort message in the
Task's
[
https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-30251:
Description:
Currently when the {{checkpoint}} fails, we process the abort message in the
Task's
[
https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-30251:
Description:
Currently when the {{checkpoint}} fails, we process the abort message in the
Task's
ming li created FLINK-30251:
---
Summary: Move the IO with DFS during abort checkpoint to an
asynchronous thread.
Key: FLINK-30251
URL: https://issues.apache.org/jira/browse/FLINK-30251
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17570607#comment-17570607
]
ming li commented on FLINK-28390:
-
[~yunta] ok thanks, I got it.
This commit has fixed the problem that
[
https://issues.apache.org/jira/browse/FLINK-28390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17569799#comment-17569799
]
ming li commented on FLINK-28390:
-
[~yunta] sorry, maybe I didn't describe clearly.
In Flink we only
[
https://issues.apache.org/jira/browse/FLINK-28390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17565029#comment-17565029
]
ming li commented on FLINK-28390:
-
[~yunta] the {{RocksDB}} version used by Flink already contains the
[
https://issues.apache.org/jira/browse/FLINK-28390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564959#comment-17564959
]
ming li commented on FLINK-28390:
-
[~martijnvisser] we generally set the TTL for the state, assuming
[
https://issues.apache.org/jira/browse/FLINK-28010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564905#comment-17564905
]
ming li commented on FLINK-28010:
-
[~yunta], can you assign this to me and help review the code?
> Use
[
https://issues.apache.org/jira/browse/FLINK-28473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564903#comment-17564903
]
ming li edited comment on FLINK-28473 at 7/11/22 9:51 AM:
--
[~chesnay], at
[
https://issues.apache.org/jira/browse/FLINK-28473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564903#comment-17564903
]
ming li edited comment on FLINK-28473 at 7/11/22 9:50 AM:
--
[~chesnay], at
[
https://issues.apache.org/jira/browse/FLINK-28473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564903#comment-17564903
]
ming li commented on FLINK-28473:
-
[~chesnay], at present, after JM failover, all tasks must be
[
https://issues.apache.org/jira/browse/FLINK-28390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564890#comment-17564890
]
ming li commented on FLINK-28390:
-
Hi, [~masteryhx], [~Zhanghao Chen]
Yes, although we currently have
[
https://issues.apache.org/jira/browse/FLINK-28473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564875#comment-17564875
]
ming li commented on FLINK-28473:
-
Hi，[~lkokhreidze] I think after JM failover, it may be difficult for
[
https://issues.apache.org/jira/browse/FLINK-28010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17563041#comment-17563041
]
ming li commented on FLINK-28010:
-
[~yunta], maybe we just need to add 1 to the prefix bytes?
> Use
ming li created FLINK-28390:
---
Summary: Allows RocksDB to configure FIFO Compaction to reduce CPU
overhead.
Key: FLINK-28390
URL: https://issues.apache.org/jira/browse/FLINK-28390
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-28010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562403#comment-17562403
]
ming li commented on FLINK-28010:
-
hi, [~yunta], do you think this optimization is feasible?
> Use
[
https://issues.apache.org/jira/browse/FLINK-28010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561322#comment-17561322
]
ming li commented on FLINK-28010:
-
[~Yanfei Lei] thank you for your reply, I think this can save us a
ming li created FLINK-28010:
---
Summary: Use deleteRange to optimize the clear operation of
RocksDBMapState.
Key: FLINK-28010
URL: https://issues.apache.org/jira/browse/FLINK-28010
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-20681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542901#comment-17542901
]
ming li commented on FLINK-20681:
-
hi, [~RocMarshal], what is the current progress of this issue? We
ming li created FLINK-27681:
---
Summary: Improve the availability of Flink when the RocksDB file
is corrupted.
Key: FLINK-27681
URL: https://issues.apache.org/jira/browse/FLINK-27681
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444925#comment-17444925
]
ming li edited comment on FLINK-24815 at 11/17/21, 3:43 AM:
[~pnowojski],
[
https://issues.apache.org/jira/browse/FLINK-24815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444925#comment-17444925
]
ming li commented on FLINK-24815:
-
[~pnowojski], um. . . you are right. Although the size of the
[
https://issues.apache.org/jira/browse/FLINK-24815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443533#comment-17443533
]
ming li edited comment on FLINK-24815 at 11/15/21, 3:54 AM:
Hi, [~pnowojski]
[
https://issues.apache.org/jira/browse/FLINK-24815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443533#comment-17443533
]
ming li commented on FLINK-24815:
-
Hi, [~pnowojski] , In{{{} TaskStateAssignment#getSubtaskState{}}}, we
ming li created FLINK-24815:
---
Summary: Reduce the cpu cost of calculating stateSize during state
allocation
Key: FLINK-24815
URL: https://issues.apache.org/jira/browse/FLINK-24815
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-21543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437186#comment-17437186
]
ming li commented on FLINK-21543:
-
Hi, [~yunta], can you describe in detail the problem of data loss
[
https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415847#comment-17415847
]
ming li commented on FLINK-24086:
-
Hi, [~dwysakowicz], I am sorry for not being able to update in time,
[
https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17413232#comment-17413232
]
ming li commented on FLINK-24086:
-
Hi, [~dwysakowicz], Here I have a question:
{quote}it reuses old
[
https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410902#comment-17410902
]
ming li commented on FLINK-24086:
-
[~pnowojski], thanks for your reply, I will try to make changes on
[
https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408273#comment-17408273
]
ming li edited comment on FLINK-24086 at 9/1/21, 4:49 PM:
--
{quote}We
[
https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408273#comment-17408273
]
ming li edited comment on FLINK-24086 at 9/1/21, 4:48 PM:
--
{quote}We
[
https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408273#comment-17408273
]
ming li edited comment on FLINK-24086 at 9/1/21, 4:48 PM:
--
{quote}We
[
https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408273#comment-17408273
]
ming li commented on FLINK-24086:
-
??We implemented a new failover strategy (by discarding some data to
[
https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408138#comment-17408138
]
ming li commented on FLINK-24086:
-
Hi, [~pnowojski], We implemented a new failover strategy (by
[
https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408017#comment-17408017
]
ming li commented on FLINK-24086:
-
Hi, [~pnowojski], Can you help to take a look at this ticket ? :)
>
[
https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-24086:
Description:
At present, we only recover the {{CompletedCheckpointStore}} when the
{{JobManager}}
ming li created FLINK-24086:
---
Summary: Do not re-register SharedStateRegistry to reduce the
recovery time of the job
Key: FLINK-24086
URL: https://issues.apache.org/jira/browse/FLINK-24086
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407365#comment-17407365
]
ming li commented on FLINK-22483:
-
Hi, [~trohrmann]. Thanks for your reply, I will create a separate
[
https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407055#comment-17407055
]
ming li edited comment on FLINK-22483 at 8/31/21, 3:46 AM:
---
Hi, [~trohrmann],
[
https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407055#comment-17407055
]
ming li commented on FLINK-22483:
-
Hi, [~trohrmann], thanks for your reply. It seems that more of the
[
https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17406647#comment-17406647
]
ming li edited comment on FLINK-22483 at 8/30/21, 9:25 AM:
---
Hi, [~dmvk],
[
https://issues.apache.org/jira/browse/FLINK-22483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17406647#comment-17406647
]
ming li commented on FLINK-22483:
-
Hi, [~dmvk], [~edu05]. Could you please help answer one of my
[
https://issues.apache.org/jira/browse/FLINK-21990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-21990:
Affects Version/s: 1.12.0
> SourceStreamTask will always hang if the CheckpointedFunction#snapshotState
[
https://issues.apache.org/jira/browse/FLINK-21990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-21990:
Description:
If the source in {{SourceStreamTask}} implements {{CheckpointedFunction}} and
an exception
[
https://issues.apache.org/jira/browse/FLINK-21990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-21990:
Description:
If the source in {{SourceStreamTask}} implements {{CheckpointedFunction}} and
an exception
[
https://issues.apache.org/jira/browse/FLINK-21990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-21990:
Description:
If the source in SourceStreamTask implements {{CheckpointedFunction}} and an
exception is
[
https://issues.apache.org/jira/browse/FLINK-21990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-21990:
Summary: SourceStreamTask will always hang if the
CheckpointedFunction#snapshotState throws an exception.
[
https://issues.apache.org/jira/browse/FLINK-21990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-21990:
Description:
We need to double check Task status when making Checkpoint. Otherwise, after a
Task failed,
ming li created FLINK-21990:
---
Summary: Double check Task status when perform checkpoint.
Key: FLINK-21990
URL: https://issues.apache.org/jira/browse/FLINK-21990
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17281761#comment-17281761
]
ming li commented on FLINK-8790:
Hi, [~legojoey17], Great Job! We are also exploring how to optimize the
[
https://issues.apache.org/jira/browse/FLINK-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255484#comment-17255484
]
ming li commented on FLINK-8790:
Hi, [~sihuazhou]. At present, we use the incremental state of rocksdb to
[
https://issues.apache.org/jira/browse/FLINK-20554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247000#comment-17247000
]
ming li commented on FLINK-20554:
-
Hi, [~yunta], What do you think?
> The Checkpointed Data Size of the
[
https://issues.apache.org/jira/browse/FLINK-20554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-20554:
Description:
The {{Checkpointed Data Size}} of the {{Latest Completed Checkpoint}} always
shows '-' in
ming li created FLINK-20554:
---
Summary: The Checkpointed Data Size of the Latest Completed
Checkpoint is incorrectly displayed on the Overview page of the UI
Key: FLINK-20554
URL:
[
https://issues.apache.org/jira/browse/FLINK-19006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185184#comment-17185184
]
ming li commented on FLINK-19006:
-
Hi,[~ting.lt]. I am not sure who is responsible for this module,
[
https://issues.apache.org/jira/browse/FLINK-19006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185184#comment-17185184
]
ming li edited comment on FLINK-19006 at 8/26/20, 1:22 PM:
---
Hi,[~ting.lt]. I
ming li created FLINK-19006:
---
Summary: project transformation does not support conversion to
Tuple25 type
Key: FLINK-19006
URL: https://issues.apache.org/jira/browse/FLINK-19006
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177788#comment-17177788
]
ming li commented on FLINK-18808:
-
Okay, I will fix it as soon as possible. Thank you for your reply.
>
[
https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1712#comment-1712
]
ming li commented on FLINK-18808:
-
{quote}{{And as an optimisation in {{AbstractStreamOperator}}, we
[
https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177743#comment-17177743
]
ming li edited comment on FLINK-18808 at 8/14/20, 12:38 PM:
{quote}I would
[
https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177743#comment-17177743
]
ming li commented on FLINK-18808:
-
{quote}I would be afraid of this check adding too much computation
[
https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177624#comment-17177624
]
ming li edited comment on FLINK-18808 at 8/14/20, 9:14 AM:
---
My proposal is to
[
https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177624#comment-17177624
]
ming li commented on FLINK-18808:
-
My proposal is to group {{Output}} according to {{OutputTag}} in
[
https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177475#comment-17177475
]
ming li commented on FLINK-18808:
-
Hi, [~pnowojski]. Sorry, I'm still a little confused. In fact, in
[
https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176948#comment-17176948
]
ming li commented on FLINK-18808:
-
I understand what you mean. You may think that a record will only be
[
https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ming li updated FLINK-18808:
Attachment: image-2020-08-13-18-36-13-282.png
> Task-level numRecordsOut metric may be underestimated
>
1 - 100 of 137 matches
Mail list logo
