[
https://issues.apache.org/jira/browse/FLINK-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16196560#comment-16196560
]
Yun Tang commented on FLINK-5510:
-
According to [FLINK-725 (Remove Flink Futures or back them by
Yun Tang created FLINK-9328:
---
Summary: RocksDBStateBackend might use
PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not
register snapshots in some UTs
Key: FLINK-9328
URL:
[
https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16545318#comment-16545318
]
Yun Tang commented on FLINK-9598:
-
Hi [~premsantosh], the "Minimum Pause Between Checkpoints" is actually
[
https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-9598:
---
Assignee: Yun Tang
> [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when
[
https://issues.apache.org/jira/browse/FLINK-10267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-10267:
-
Description:
Currently, RocksDBMapIterator would load 128 entries into local cacheEntries
every time
Yun Tang created FLINK-10267:
Summary: [State] Fix arbitrary iterator access on
RocksDBMapIterator
Key: FLINK-10267
URL: https://issues.apache.org/jira/browse/FLINK-10267
Project: Flink
Issue
Yun Tang created FLINK-9758:
---
Summary: ContinuousFileProcessingTest failed due to not setting
runtimeContext
Key: FLINK-9758
URL: https://issues.apache.org/jira/browse/FLINK-9758
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538561#comment-16538561
]
Yun Tang commented on FLINK-4387:
-
[~NicoK] Has this issue already been fixed? I noticed you said this
[
https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-10712:
Assignee: Yun Tang
> RestartPipelinedRegionStrategy does not restore state
>
[
https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668964#comment-16668964
]
Yun Tang commented on FLINK-10712:
--
We have refactored _FailoverRegion.java_ to support fail-over with
[
https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668964#comment-16668964
]
Yun Tang edited comment on FLINK-10712 at 10/30/18 4:18 PM:
We have already
[
https://issues.apache.org/jira/browse/FLINK-10855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686065#comment-16686065
]
Yun Tang edited comment on FLINK-10855 at 11/14/18 3:54 AM:
[
https://issues.apache.org/jira/browse/FLINK-10855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686065#comment-16686065
]
Yun Tang commented on FLINK-10855:
--
[~till.rohrmann], as far as I know, the checkpoint directory is
[
https://issues.apache.org/jira/browse/FLINK-11363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-11363:
Assignee: Yun Tang
> Check and remove TaskManagerConfigurationTest
>
[
https://issues.apache.org/jira/browse/FLINK-11366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-11366:
Assignee: Yun Tang
> Check and port TaskManagerMetricsTest to new code base if necessary
>
[
https://issues.apache.org/jira/browse/FLINK-11368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-11368:
Assignee: Yun Tang
> Check and port TaskManagerStartupTest to new code base if necessary
>
[
https://issues.apache.org/jira/browse/FLINK-11333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-11333:
Assignee: Yun Tang
> First-class support for Protobuf types with evolvable schema
>
[
https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748419#comment-16748419
]
Yun Tang commented on FLINK-9920:
-
Another instance:
[
https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748350#comment-16748350
]
Yun Tang commented on FLINK-11380:
--
Another instance https://api.travis-ci.org/v3/job/481937341/log.txt
[
https://issues.apache.org/jira/browse/FLINK-10724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16715194#comment-16715194
]
Yun Tang commented on FLINK-10724:
--
[~yanghua] I think CheckpointSubsumed should not be counted as
[
https://issues.apache.org/jira/browse/FLINK-11138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16719713#comment-16719713
]
Yun Tang commented on FLINK-11138:
--
Yes, you are right. But we already disable the WAL of rocksDB. You
[
https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16728304#comment-16728304
]
Yun Tang commented on FLINK-10912:
--
[~thw] I would like to take this issue if you don't mind. We
[
https://issues.apache.org/jira/browse/FLINK-11212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16728299#comment-16728299
]
Yun Tang commented on FLINK-11212:
--
>From my point of view, the operator id is not so readable, which
[
https://issues.apache.org/jira/browse/FLINK-11171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722952#comment-16722952
]
Yun Tang commented on FLINK-11171:
--
[~sayatez] I think the 2nd problem should have no relationship with
[
https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16728133#comment-16728133
]
Yun Tang commented on FLINK-10930:
--
I plan to close this issue, and we should move to
[
https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang closed FLINK-10930.
Resolution: Won't Fix
> Refactor checkpoint directory layout
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-10912:
Assignee: Yun Tang
> Configurable RocksDBStateBackend options factory
>
[
https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708978#comment-16708978
]
Yun Tang commented on FLINK-10930:
--
Speaking of eager and proper discarding useless state, this is
[
https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-11107:
-
Description:
Currently, memory state-backend would create a folder named with random UUID
under HA
[
https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16714033#comment-16714033
]
Yun Tang commented on FLINK-11107:
--
@ [~StephanEwen] , as you commented in code below:
{noformat}
// to
[
https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704286#comment-16704286
]
Yun Tang commented on FLINK-10930:
--
[~StephanEwen] I think your opinion to refactor the mechanism of
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692610#comment-16692610
]
Yun Tang edited comment on FLINK-9043 at 11/20/18 3:55 AM:
---
I quite agree with
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692610#comment-16692610
]
Yun Tang commented on FLINK-9043:
-
I quite agreed with [~sihuazhou]'s idea, user just need to provide the
[
https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16698560#comment-16698560
]
Yun Tang commented on FLINK-10930:
--
[~StephanEwen] I know this suggested changes would impact your
[
https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701359#comment-16701359
]
Yun Tang commented on FLINK-10930:
--
[~StephanEwen] I try to answer your points of view:
* _The error
[
https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-10954:
Assignee: Yun Tang
> Hardlink from files of previous local stored state might cross devices
>
[
https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16693531#comment-16693531
]
Yun Tang commented on FLINK-10954:
--
First of all, I plan to handle the exception after calling
Yun Tang created FLINK-10954:
Summary: Hardlink from files of previous local stored state might
cross devices
Key: FLINK-10954
URL: https://issues.apache.org/jira/browse/FLINK-10954
Project: Flink
Yun Tang created FLINK-10930:
Summary: Refactor checkpoint directory layout
Key: FLINK-10930
URL: https://issues.apache.org/jira/browse/FLINK-10930
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-11292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-11292:
Assignee: Yun Tang
> Document how to use the new CompositeTypeSerializerSnapshot
>
Yun Tang created FLINK-11313:
Summary: [checkpoint] Introduce LZ4 compression for keyed state in
full checkpoints and savepoints
Key: FLINK-11313
URL: https://issues.apache.org/jira/browse/FLINK-11313
Yun Tang created FLINK-11107:
Summary: [state] Avoid memory stateBackend to create arbitrary
folders under HA path when no checkpoint path configured
Key: FLINK-11107
URL:
[
https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16713903#comment-16713903
]
Yun Tang commented on FLINK-10930:
--
[~StephanEwen] The ideas of cleaning up exclusive and shared state
[
https://issues.apache.org/jira/browse/FLINK-11437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16754159#comment-16754159
]
Yun Tang commented on FLINK-11437:
--
From the detailed message, I think this is because the task
[
https://issues.apache.org/jira/browse/FLINK-12080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16807443#comment-16807443
]
Yun Tang commented on FLINK-12080:
--
As discussed with Huang in user
[
https://issues.apache.org/jira/browse/FLINK-12096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16808647#comment-16808647
]
Yun Tang commented on FLINK-12096:
--
[~yogesh_n] Would you please provide more information such as
[
https://issues.apache.org/jira/browse/FLINK-11948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang closed FLINK-11948.
Resolution: Duplicate
> When kafka sink parallelism unbalance
>
[
https://issues.apache.org/jira/browse/FLINK-12058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16804581#comment-16804581
]
Yun Tang commented on FLINK-12058:
--
Hi [~till.rohrmann], is this a duplicate of FLINK-8871 ?
> Cancel
[
https://issues.apache.org/jira/browse/FLINK-12043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16804652#comment-16804652
]
Yun Tang commented on FLINK-12043:
--
hi [~quan], what's your purpose to report this Jira：
* Complain
[
https://issues.apache.org/jira/browse/FLINK-11789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782314#comment-16782314
]
Yun Tang commented on FLINK-11789:
--
[~shengjk1] When job fails, we should also consider the
[
https://issues.apache.org/jira/browse/FLINK-11700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773722#comment-16773722
]
Yun Tang commented on FLINK-11700:
--
Does the class {{org/apache/commons/lang3/SystemUtils}} existed in
[
https://issues.apache.org/jira/browse/FLINK-11691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-11691:
-
Description:
Currently, interface {{ConfigurableStateBackend}} has method definition below:
{code:java}
Yun Tang created FLINK-11691:
Summary: Introduce ClassLoader in the methods of
StateBackendFactory and ConfigurableStateBackend
Key: FLINK-11691
URL: https://issues.apache.org/jira/browse/FLINK-11691
[
https://issues.apache.org/jira/browse/FLINK-11691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-11691:
-
Description:
Currently, interface {{ConfigurableStateBackend}} has method definition below:
[
https://issues.apache.org/jira/browse/FLINK-11691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-11691:
Assignee: Yun Tang
> Introduce ClassLoader in the methods of StateBackendFactory and
>
[
https://issues.apache.org/jira/browse/FLINK-11691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-11691:
-
Description:
Currently, interface {{ConfigurableStateBackend}} has method definition below:
{code:java}
Yun Tang created FLINK-11696:
Summary: [checkpoint] Avoid to send mkdir requests to DFS from
task side
Key: FLINK-11696
URL: https://issues.apache.org/jira/browse/FLINK-11696
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-11695:
-
Description:
We meet this annoying problem many times when the {{sharedStateDir}} in
checkpoint path
Yun Tang created FLINK-11695:
Summary: [checkpoint] Make sharedStateDir could create
sub-directories to avoid MaxDirectoryItemsExceededException
Key: FLINK-11695
URL: https://issues.apache.org/jira/browse/FLINK-11695
Yun Tang created FLINK-11829:
Summary: [checkpoint] FsCheckpointStateOutputStream might store
state in files even state size below fileStateThreshold
Key: FLINK-11829
URL:
[
https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16792421#comment-16792421
]
Yun Tang commented on FLINK-11835:
--
Another instance
[
https://issues.apache.org/jira/browse/FLINK-11926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794769#comment-16794769
]
Yun Tang commented on FLINK-11926:
--
Yes, you could refer to the doc
[
https://issues.apache.org/jira/browse/FLINK-11948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794767#comment-16794767
]
Yun Tang commented on FLINK-11948:
--
I think this is what {{FlinkFixedPartitioner}} wants to achieve.
[
https://issues.apache.org/jira/browse/FLINK-11948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794767#comment-16794767
]
Yun Tang edited comment on FLINK-11948 at 3/18/19 6:43 AM:
---
I think this is
[
https://issues.apache.org/jira/browse/FLINK-11874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16790221#comment-16790221
]
Yun Tang commented on FLINK-11874:
--
[~yanghua] Thanks for your suggestion.
I thought I had given the
[
https://issues.apache.org/jira/browse/FLINK-11874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-11874:
-
Summary: Split CheckpointStorage interface to distinguish JM and TM side
(was: [checkpoint] Split
[
https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16791765#comment-16791765
]
Yun Tang commented on FLINK-11107:
--
User also meet this problem and report it in [chinese mail
[
https://issues.apache.org/jira/browse/FLINK-11868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-11868:
-
Description:
>From existed experience, we know {{listStatus}} is expensive for many
>distributed file
Yun Tang created FLINK-11868:
Summary: [filesystems] Introduce listStatusIterator API to file
system
Key: FLINK-11868
URL: https://issues.apache.org/jira/browse/FLINK-11868
Project: Flink
Issue
Yun Tang created FLINK-11869:
Summary: [checkpoint] Make buffer size in checkpoint stream
factory configurable
Key: FLINK-11869
URL: https://issues.apache.org/jira/browse/FLINK-11869
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795803#comment-16795803
]
Yun Tang commented on FLINK-11962:
--
[~GerogeRyd] The different checkpoint sizes reflect different
[
https://issues.apache.org/jira/browse/FLINK-11948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16794878#comment-16794878
]
Yun Tang commented on FLINK-11948:
--
[~bf30075] I think the name {{FlinkFixedPartitioner}} should
[
https://issues.apache.org/jira/browse/FLINK-11860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16787629#comment-16787629
]
Yun Tang commented on FLINK-11860:
--
This issue is inspired by user mail
Yun Tang created FLINK-11860:
Summary: Remove all the usage of deprecated unit-provided memory
options in docs and scripts
Key: FLINK-11860
URL: https://issues.apache.org/jira/browse/FLINK-11860
Project:
[
https://issues.apache.org/jira/browse/FLINK-11860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-11860:
Assignee: Yun Tang
> Remove all the usage of deprecated unit-provided memory options in docs and
[
https://issues.apache.org/jira/browse/FLINK-11926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793479#comment-16793479
]
Yun Tang commented on FLINK-11926:
--
[~chaiyq] lateness means {{time-of-event}} minus
[
https://issues.apache.org/jira/browse/FLINK-11926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang closed FLINK-11926.
Resolution: Not A Problem
> The Description of Assigners allowing a fixed amount of lateness is not
>
Yun Tang created FLINK-11874:
Summary: [checkpoint] Split CheckpointStorage interface to
distinguish JM and TM side
Key: FLINK-11874
URL: https://issues.apache.org/jira/browse/FLINK-11874
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789755#comment-16789755
]
Yun Tang commented on FLINK-8871:
-
We already introduce {{notifyCheckpointAbort}} which is like current
[
https://issues.apache.org/jira/browse/FLINK-11536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16761859#comment-16761859
]
Yun Tang commented on FLINK-11536:
--
hi [~hw271]
I think *user*@flink.apache.org (
[
https://issues.apache.org/jira/browse/FLINK-11641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16770397#comment-16770397
]
Yun Tang commented on FLINK-11641:
--
I think this is because your local mac does not know your machine's
Yun Tang created FLINK-11618:
Summary: [state] Refactor operator state repartition mechanism
Key: FLINK-11618
URL: https://issues.apache.org/jira/browse/FLINK-11618
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-11618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-11618:
-
Description:
Currently we have state assignment strategy of operator state below:
* When parallelism
[
https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772694#comment-16772694
]
Yun Tang commented on FLINK-11662:
--
[~framst] we already have some discussion about this problem that
[
https://issues.apache.org/jira/browse/FLINK-11333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16755185#comment-16755185
]
Yun Tang commented on FLINK-11333:
--
I planed to use avro-protobuf to extract Protobuf message's schema
[
https://issues.apache.org/jira/browse/FLINK-11427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16752126#comment-16752126
]
Yun Tang commented on FLINK-11427:
--
[~zjuguanghu] I just have a curious question which is a bit
[
https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16757409#comment-16757409
]
Yun Tang commented on FLINK-9920:
-
With more detailed messages, I believe this bug happened due to the
[
https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16815949#comment-16815949
]
Yun Tang edited comment on FLINK-11107 at 4/12/19 8:43 AM:
---
[~ykt836] This is
[
https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16815949#comment-16815949
]
Yun Tang commented on FLINK-11107:
--
[~ykt836] This is the issue which would created a lot of useless
[
https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang updated FLINK-11107:
-
Priority: Blocker (was: Major)
Fix Version/s: (was: 1.6.5)
(was:
[
https://issues.apache.org/jira/browse/FLINK-6984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-6984:
---
Assignee: Yun Tang
> Do not recover CompletedCheckpointStore on every restore
>
[
https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793662#comment-16793662
]
Yun Tang commented on FLINK-10912:
--
[~ZhenqiuHuang] If you really want to apply this feature to
[
https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793662#comment-16793662
]
Yun Tang edited comment on FLINK-10912 at 3/15/19 2:22 PM:
---
[~ZhenqiuHuang] If
[
https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848149#comment-16848149
]
Yun Tang commented on FLINK-8871:
-
Thanks for [~srichter]'s comment. I agree we should fix FLINK-11662
[
https://issues.apache.org/jira/browse/FLINK-12546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849904#comment-16849904
]
Yun Tang commented on FLINK-12546:
--
Thanks for [~till.rohrmann]'s explanation, I have another question
[
https://issues.apache.org/jira/browse/FLINK-12820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16862843#comment-16862843
]
Yun Tang commented on FLINK-12820:
--
Would you please help to clarify why current solution is impossible
[
https://issues.apache.org/jira/browse/FLINK-12820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16865105#comment-16865105
]
Yun Tang commented on FLINK-12820:
--
[~ozancicek] Sorry for late reply and thanks for your kind
[
https://issues.apache.org/jira/browse/FLINK-12859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16864791#comment-16864791
]
Yun Tang commented on FLINK-12859:
--
[~aitozi] I am afraid that the attached image has been broken to
[
https://issues.apache.org/jira/browse/FLINK-6931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-6931:
---
Assignee: Yun Tang
> Support custom compression formats for checkpoints (+Upgrade/Compatibility)
>
[
https://issues.apache.org/jira/browse/FLINK-6931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16860668#comment-16860668
]
Yun Tang commented on FLINK-6931:
-
I think https://github.com/apache/flink/pull/7819 should already cover
1 - 100 of 1896 matches
Mail list logo
