[
https://issues.apache.org/jira/browse/FLINK-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8602:
--
Description:
Right now, RocksDB backend supports {{fully checkpoint}} & {{incremental
checkpoint}}.
[
https://issues.apache.org/jira/browse/FLINK-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8602:
--
Description:
Right now, RocksDB backend supports {{fully checkpoint}} & {{incremental
checkpoint}}.
[
https://issues.apache.org/jira/browse/FLINK-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8602:
--
Summary: Improve recovery performance for rocksdb backend (was: Accelerate
recover from failover when
[
https://issues.apache.org/jira/browse/FLINK-8753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16374425#comment-16374425
]
Sihua Zhou commented on FLINK-8753:
---
[~gyfora] For your proposal, I think there is a problem that
[
https://issues.apache.org/jira/browse/FLINK-8753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16374414#comment-16374414
]
Sihua Zhou commented on FLINK-8753:
---
[~aljoscha] Thanks for your reply. I agree that if there is a rough
[
https://issues.apache.org/jira/browse/FLINK-7219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reassigned FLINK-7219:
-
Assignee: (was: Sihua Zhou)
> Current allocate strategy cann‘t achieve the optimal effect
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16373978#comment-16373978
]
Sihua Zhou commented on FLINK-8601:
---
[~aljoscha] Do you have any advice on this? How about I submit a PR
[
https://issues.apache.org/jira/browse/FLINK-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16373970#comment-16373970
]
Sihua Zhou commented on FLINK-8602:
---
[~stefanrichte...@gmail.com] Could you please have a look at this?
[
https://issues.apache.org/jira/browse/FLINK-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8602:
--
Description:
Currently, when enable incremental checkpoint, if user change the parallelism
then
[
https://issues.apache.org/jira/browse/FLINK-8753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16373962#comment-16373962
]
Sihua Zhou commented on FLINK-8753:
---
[~stefanrichte...@gmail.com] What do you think?
> Introduce
[
https://issues.apache.org/jira/browse/FLINK-8753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8753:
--
Description:
Right now, savepoint goes through the full checkpoint path, take a savepoint
could be
Sihua Zhou created FLINK-8753:
-
Summary: Introduce Incremental savepoint
Key: FLINK-8753
URL: https://issues.apache.org/jira/browse/FLINK-8753
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8602:
--
Affects Version/s: (was: 1.4.0)
1.5.0
> Accelerate recover from failover
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8601:
--
Affects Version/s: (was: 1.4.0)
1.5.0
> Introduce PartitionedBloomFilter for
[
https://issues.apache.org/jira/browse/FLINK-8699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou closed FLINK-8699.
-
Resolution: Fixed
Release Note: Richter has fixed this in his hotfix.
> Fix concurrency problem in
Sihua Zhou created FLINK-8699:
-
Summary: Fix concurrency problem in rocksdb full checkpoint
Key: FLINK-8699
URL: https://issues.apache.org/jira/browse/FLINK-8699
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8679:
--
Affects Version/s: 1.5.0
> RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8679:
--
Priority: Blocker (was: Critical)
> RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter
[
https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8679:
--
Priority: Critical (was: Major)
> RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter
Sihua Zhou created FLINK-8679:
-
Summary: RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't
filter data with namespace
Key: FLINK-8679
URL: https://issues.apache.org/jira/browse/FLINK-8679
Sihua Zhou created FLINK-8676:
-
Summary: Memory Leak in AbstractKeyedStateBackend.applyToAllKeys()
when backend is base on RocksDB
Key: FLINK-8676
URL: https://issues.apache.org/jira/browse/FLINK-8676
[
https://issues.apache.org/jira/browse/FLINK-6980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou closed FLINK-6980.
-
Resolution: Won't Fix
> TypeExtractor.getForObject can't get typeinfo correctly.
>
Sihua Zhou created FLINK-8657:
-
Summary: Fix incorrect description for external checkpoint vs
savepoint
Key: FLINK-8657
URL: https://issues.apache.org/jira/browse/FLINK-8657
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16364215#comment-16364215
]
Sihua Zhou commented on FLINK-8044:
---
Sorry [~till.rohrmann], finally I can't come up with a perfect
Sihua Zhou created FLINK-8639:
-
Summary: Fix always need to seek multiple times when iterator
RocksDBMapState
Key: FLINK-8639
URL: https://issues.apache.org/jira/browse/FLINK-8639
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8601:
--
Description:
h3. Backgroud
Bloom filter is useful in many situation, for example:
* 1. Approximate
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8601:
--
Summary: Introduce PartitionedBloomFilter for Approximate calculation and
other situations of
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16358051#comment-16358051
]
Sihua Zhou commented on FLINK-8601:
---
[~fhueske] I have update the document, could you please have a loot
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8601:
--
Component/s: (was: Core)
State Backends, Checkpointing
> Introduce
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8601:
--
Description:
h3. Backgroud
Bloom filter is useful in many situation, for example:
* 1. Approximate
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356796#comment-16356796
]
Sihua Zhou commented on FLINK-8601:
---
[~jark] When creating a BloomFilter user have to special the
[
https://issues.apache.org/jira/browse/FLINK-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8602:
--
Description:
Currently, when enable incremental checkpoint, if user change the parallelism
then
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356715#comment-16356715
]
Sihua Zhou commented on FLINK-3089:
---
[~phoenixjiangnan] Sorry for I did not reply for so long, because I
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8601:
--
Description:
h3. Backgroud
Bloom filter is useful in many situation, for example:
* 1. Approximate
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356703#comment-16356703
]
Sihua Zhou commented on FLINK-8601:
---
[~fhueske] Ok, I will modify the description and also add an
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16356663#comment-16356663
]
Sihua Zhou commented on FLINK-8601:
---
[~fhueske], thanks for you reply. I think this is not a new state
[
https://issues.apache.org/jira/browse/FLINK-8602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8602:
--
Description:
Currently, when enable incremental checkpoint, if user change the parallelism
then
Sihua Zhou created FLINK-8602:
-
Summary: Accelerate recover from failover when use incremental
checkpoint
Key: FLINK-8602
URL: https://issues.apache.org/jira/browse/FLINK-8602
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8601:
--
Description:
h3. Backgroud
Bloom filter is useful in many situation, for example:
* 1. Approximate
Sihua Zhou created FLINK-8601:
-
Summary: Introduce LinkedBloomFilterState for Approximate
calculation and other situations of performance optimization
Key: FLINK-8601
URL:
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317829#comment-16317829
]
Sihua Zhou commented on FLINK-3089:
---
[~phoenixjiangnan] Maybe we shouldn't enforce TtlDB delete all
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reopened FLINK-7873:
---
reopen for PR.
> Introduce CheckpointCacheManager for reading checkpoint data locally when
> performing
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16255081#comment-16255081
]
Sihua Zhou commented on FLINK-7873:
---
[~srichter] Happy to do that, will open a PR and attach the doc
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16255065#comment-16255065
]
Sihua Zhou commented on FLINK-7873:
---
closed.
> Introduce CheckpointCacheManager for reading checkpoint
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou closed FLINK-7873.
-
Resolution: Duplicate
Community plan to introduce this in Flink 1.5 and this issue seem to interfered
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16255055#comment-16255055
]
Sihua Zhou commented on FLINK-7873:
---
[~srichter] As you will introduce this feature in Flink 1.5
[
https://issues.apache.org/jira/browse/FLINK-8018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8018:
--
Fix Version/s: 1.5.0
> RMQ does not support disabling queueDeclare, when the user has no declaration
>
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16250747#comment-16250747
]
Sihua Zhou commented on FLINK-7873:
---
[~srichter] Thanks for your reply and the introduction of your
[
https://issues.apache.org/jira/browse/FLINK-4256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247272#comment-16247272
]
Sihua Zhou commented on FLINK-4256:
---
Partial recovery seem to more useful for Batch job, for stream job
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247268#comment-16247268
]
Sihua Zhou commented on FLINK-7873:
---
After a deeper thought, I found a way that can simply support all
[
https://issues.apache.org/jira/browse/FLINK-8044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247263#comment-16247263
]
Sihua Zhou commented on FLINK-8044:
---
Hi [~till.rohrmann] I have addressed
Sihua Zhou created FLINK-8044:
-
Summary: Introduce scheduling mechanism to satisfy both state
locality and input
Key: FLINK-8044
URL: https://issues.apache.org/jira/browse/FLINK-8044
Project: Flink
Sihua Zhou created FLINK-8018:
-
Summary: RMQ does not support disabling queueDeclare, when the
user has no declaration permissions, it cannot connect
Key: FLINK-8018
URL:
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16237111#comment-16237111
]
Sihua Zhou commented on FLINK-7866:
---
[~till.rohrmann] thanks and so happy for thinking of me when you
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reassigned FLINK-7866:
-
Assignee: Sihua Zhou
> Weigh list of preferred locations for scheduling
>
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16235215#comment-16235215
]
Sihua Zhou commented on FLINK-7866:
---
Hi [~till.rohrmann], i saw you have made a PR for
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16233643#comment-16233643
]
Sihua Zhou commented on FLINK-7873:
---
[~stefanrichte...@gmail.com] Thanks very much for your reply, you
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-7873:
--
Description:
Why i introduce this:
Current recover strategy will always read checkpoint data from
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-7873:
--
Summary: Introduce CheckpointCacheManager for reading checkpoint data
locally when performing failover
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-7873:
--
Description:
Current recover strategy will always read checkpoint data from remote
FileStream (HDFS).
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-7873:
--
Summary: Introduce HybridStreamHandle to optimize the recovery mechanism
and try to read the checkpoint
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-7873:
--
Description:
Current recover strategy will always read checkpoint data from remote
FileStream (HDFS).
[
https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-7873:
--
Description:
Current recover strategy will always read checkpoint data from remote
FileStream (HDFS).
Sihua Zhou created FLINK-7873:
-
Summary: Introduce HybridStreamStateHandle for quick recovery from
checkpoint.
Key: FLINK-7873
URL: https://issues.apache.org/jira/browse/FLINK-7873
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16210618#comment-16210618
]
Sihua Zhou commented on FLINK-7866:
---
[~till.rohrmann] have you already work on this? If not, can i take
[
https://issues.apache.org/jira/browse/FLINK-7218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou closed FLINK-7218.
-
Resolution: Duplicate
Release Note: Can be resolved in FLINK-7866, closing the PR for this too.
>
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16207212#comment-16207212
]
Sihua Zhou commented on FLINK-7153:
---
I prefer [2], it also fix FLINK-7218 and do a better job than the
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131864#comment-16131864
]
Sihua Zhou commented on FLINK-3089:
---
[~richtesn] I'm not sure if I understand the problem you said
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131845#comment-16131845
]
Sihua Zhou commented on FLINK-3089:
---
[~stefanrichte...@gmail.com] i think ttl is also fine for
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16129974#comment-16129974
]
Sihua Zhou commented on FLINK-3089:
---
[~ymost],all we have done it to modify the
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16129896#comment-16129896
]
Sihua Zhou commented on FLINK-3089:
---
We use TtlDB(provided by rocksdb that extends Rocksdbs) to support
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16096249#comment-16096249
]
Sihua Zhou commented on FLINK-7153:
---
[~aljoscha] I issues contains two subproblems, for the first one
[
https://issues.apache.org/jira/browse/FLINK-7219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16094193#comment-16094193
]
Sihua Zhou edited comment on FLINK-7219 at 7/20/17 5:25 AM:
Thanks for your
[
https://issues.apache.org/jira/browse/FLINK-7219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16094193#comment-16094193
]
Sihua Zhou commented on FLINK-7219:
---
Thanks for your reply. This question really needs to be further
[
https://issues.apache.org/jira/browse/FLINK-7218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16093373#comment-16093373
]
Sihua Zhou edited comment on FLINK-7218 at 7/19/17 4:32 PM:
I made a PR for
[
https://issues.apache.org/jira/browse/FLINK-7218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16093373#comment-16093373
]
Sihua Zhou edited comment on FLINK-7218 at 7/19/17 4:31 PM:
I made a PR for
[
https://issues.apache.org/jira/browse/FLINK-7218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16093373#comment-16093373
]
Sihua Zhou commented on FLINK-7218:
---
I made a PR for this issue, can anybody review for me?
[
https://issues.apache.org/jira/browse/FLINK-6980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16091689#comment-16091689
]
Sihua Zhou commented on FLINK-6980:
---
[~twalthr] Actually, we are building a stream sql framework base on
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-7153:
--
Comment: was deleted
(was: Current allocate strategy cann‘t achieve the optimal effect with input's
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16091579#comment-16091579
]
Sihua Zhou commented on FLINK-7153:
---
Current allocate strategy cann‘t achieve the optimal effect with
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-7153:
--
Comment: was deleted
(was: ExecutionVertex.getPreferredLocationsBasedOnInputs() will always return
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16091577#comment-16091577
]
Sihua Zhou commented on FLINK-7153:
---
ExecutionVertex.getPreferredLocationsBasedOnInputs() will always
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16091575#comment-16091575
]
Sihua Zhou commented on FLINK-7153:
---
After thinking about is, i found that this issue contains two
Sihua Zhou created FLINK-7219:
-
Summary: Current allocate strategy cann‘t achieve the optimal
effect with input's location
Key: FLINK-7219
URL: https://issues.apache.org/jira/browse/FLINK-7219
Project:
Sihua Zhou created FLINK-7218:
-
Summary: ExecutionVertex.getPreferredLocationsBasedOnInputs() will
always return empty
Key: FLINK-7218
URL: https://issues.apache.org/jira/browse/FLINK-7218
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16086915#comment-16086915
]
Sihua Zhou edited comment on FLINK-7153 at 7/16/17 3:37 PM:
Hi [~StephanEwen],
[
https://issues.apache.org/jira/browse/FLINK-7180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou closed FLINK-7180.
-
Resolution: Resolved
> CoGroupStream perform checkpoint failed
> ---
[
https://issues.apache.org/jira/browse/FLINK-7180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16087554#comment-16087554
]
Sihua Zhou commented on FLINK-7180:
---
Checked my pom.xml, i'm using Flink 1.3.0 After upgrading to
[
https://issues.apache.org/jira/browse/FLINK-7180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16087397#comment-16087397
]
Sihua Zhou edited comment on FLINK-7180 at 7/14/17 2:41 PM:
[~aljoscha] Sorry
[
https://issues.apache.org/jira/browse/FLINK-7180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16087397#comment-16087397
]
Sihua Zhou commented on FLINK-7180:
---
[~aljoscha] Sorry to reply late reply, i was on the train all the
Sihua Zhou created FLINK-7180:
-
Summary: CoGroupStream perform checkpoint failed
Key: FLINK-7180
URL: https://issues.apache.org/jira/browse/FLINK-7180
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-7180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-7180:
--
Description:
When using the CoGroup api and enable the checkpoint, Job will failed when
performing
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16086915#comment-16086915
]
Sihua Zhou edited comment on FLINK-7153 at 7/14/17 6:08 AM:
Hi [~StephanEwen],
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16086915#comment-16086915
]
Sihua Zhou commented on FLINK-7153:
---
Hi [~StephanEwen],
Here is my solution.
For problem 1, We need
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16085706#comment-16085706
]
Sihua Zhou commented on FLINK-7153:
---
[~StephanEwen] Thanks for you reply, can i contribute to this
[
https://issues.apache.org/jira/browse/FLINK-5747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1608#comment-1608
]
Sihua Zhou commented on FLINK-5747:
---
Hi，[~StephanEwen], there's some problems i found with Eager
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-7153:
--
Summary: Eager Scheduling can't allocate source for ExecutionGraph
correctly (was: JobManager can't
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16085038#comment-16085038
]
Sihua Zhou commented on FLINK-7153:
---
Hi, [~fhueske] can you help me to verify the problem i posted
[
https://issues.apache.org/jira/browse/FLINK-7160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou closed FLINK-7160.
-
Resolution: Duplicate
> Support hive like udtf
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-7160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16083796#comment-16083796
]
Sihua Zhou commented on FLINK-7160:
---
Hi, Fabian Hueske, you are right this is a duplicate issue.
>
301 - 400 of 408 matches
Mail list logo
