Chesnay Schepler created FLINK-9602:
---
Summary: Extend CommonOption section
Key: FLINK-9602
URL: https://issues.apache.org/jira/browse/FLINK-9602
Project: Flink
Issue Type: Improvement
Sihua Zhou created FLINK-9601:
-
Summary: Snapshot of CopyOnWriteStateTable will failed, when the
amount of record is more than MAXIMUM_CAPACITY
Key: FLINK-9601
URL: https://issues.apache.org/jira/browse/FLINK-9601
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6159
@StefanRRichter Sorry that I didn't take a look again yesterday, I was a
bit too busy at that time. I had a look at the fix for the
`CopyOnWriteStateTable`, I afraid it's still a partial fix, I
[
https://issues.apache.org/jira/browse/FLINK-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514743#comment-16514743
]
ASF GitHub Bot commented on FLINK-9487:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6174
CC @StefanRRichter
---
GitHub user sihuazhou opened a pull request:
https://github.com/apache/flink/pull/6174
[FLINNK-9601][state]Try to reuse the snapshotData array as the partitioned
destination onâ¦
## What is the purpose of the change
In `CopyOnWriteStateTableSnapshot`, we only reuse the
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514727#comment-16514727
]
swy edited comment on FLINK-9597 at 6/16/18 9:27 AM:
-
Hi [~fhueske] Do you mind to
[
https://issues.apache.org/jira/browse/FLINK-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514787#comment-16514787
]
ASF GitHub Bot commented on FLINK-9571:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514789#comment-16514789
]
ASF GitHub Bot commented on FLINK-9571:
---
Github user sihuazhou commented on a diff in the pull
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6173#discussion_r195903979
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/StateBinder.java ---
@@ -23,7 +23,10 @@
/**
* The {@code StateBinder} is
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6173#discussion_r195903433
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
---
@@ -203,91 +216,16 @@ private boolean
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6173#discussion_r195903383
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
---
@@ -110,7 +123,7 @@
/**
* Map
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6173#discussion_r195903191
--- Diff:
flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java
---
@@
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6173#discussion_r195903638
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6173#discussion_r195903619
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514790#comment-16514790
]
ASF GitHub Bot commented on FLINK-9571:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514788#comment-16514788
]
ASF GitHub Bot commented on FLINK-9571:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514791#comment-16514791
]
ASF GitHub Bot commented on FLINK-9571:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514786#comment-16514786
]
ASF GitHub Bot commented on FLINK-9571:
---
Github user sihuazhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
swy closed FLINK-9597.
--
Resolution: Later
> Flink application does not scale as expected
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514698#comment-16514698
]
Till Rohrmann commented on FLINK-9552:
--
You could add the checkpoint lock around the {{collect}}
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514727#comment-16514727
]
swy commented on FLINK-9597:
Hi [~fhueske] Do you mind to share your experience any other reason the
[
https://issues.apache.org/jira/browse/FLINK-9597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514734#comment-16514734
]
Fabian Hueske commented on FLINK-9597:
--
Thanks für starting the thread on the mailing list!
Would
Rinat Sharipov created FLINK-9603:
-
Summary: Incorrect indexing of part files, when part suffix is
specified (FileAlreadyExistsException)
Key: FLINK-9603
URL: https://issues.apache.org/jira/browse/FLINK-9603
[
https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rinat Sharipov updated FLINK-9603:
--
Description:
Hi mates, since 1.5 release, BucketingSink has ability to configure suffix of
[
https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9603:
---
Assignee: vinoyang
> Incorrect indexing of part files, when part suffix is specified
>
[
https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514885#comment-16514885
]
ASF GitHub Bot commented on FLINK-9563:
---
Github user deepaks4077 commented on the issue:
Github user deepaks4077 commented on the issue:
https://github.com/apache/flink/pull/6170
@zentol, I've updated the tests and all tests pass now. Please take a look
when you get the chance.
---
[
https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9598:
---
Assignee: vinoyang
> [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when
[
https://issues.apache.org/jira/browse/FLINK-9601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514841#comment-16514841
]
ASF GitHub Bot commented on FLINK-9601:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/6174
Thanks for the contribution. I think the general idea is good, but I think
the implementation can be improved. How about changing
`CopyOnWriteStateTable::snapshotTableArrays()` in such ways
[
https://issues.apache.org/jira/browse/FLINK-9380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514884#comment-16514884
]
Deepak Sharma commented on FLINK-9380:
--
Hi [~till.rohrmann], are we saying that we want the failed
[
https://issues.apache.org/jira/browse/FLINK-9602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9602:
---
Assignee: vinoyang
> Extend CommonOption section
> ---
>
>
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6174
@StefanRRichter Thanks for the review, I think that makes a lot of sense,
will change it according to your suggestion.
---
[
https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514975#comment-16514975
]
Ted Yu commented on FLINK-4534:
---
lgtm
> Lack of synchronization in BucketingSink#restoreState()
>
[
https://issues.apache.org/jira/browse/FLINK-6359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6359:
--
Labels: perfomance (was: )
> Utilize Hierarchical Timing Wheels for performant timer
>
[
https://issues.apache.org/jira/browse/FLINK-9601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514945#comment-16514945
]
ASF GitHub Bot commented on FLINK-9601:
---
Github user sihuazhou commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9601:
--
Summary: Snapshot of CopyOnWriteStateTable will failed when the amount of
record is more than
[
https://issues.apache.org/jira/browse/FLINK-9585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514806#comment-16514806
]
ASF GitHub Bot commented on FLINK-9585:
---
GitHub user yanghua opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514807#comment-16514807
]
ASF GitHub Bot commented on FLINK-9585:
---
Github user yanghua commented on the issue:
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/6175
[FLINK-9585] Logger in ZooKeeperStateHandleStore is public and non-final
## What is the purpose of the change
*This pull request mark Logger in ZooKeeperStateHandleStore as private and
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6175
cc @zentol
---
[
https://issues.apache.org/jira/browse/FLINK-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rinat Sharipov updated FLINK-9603:
--
Description:
Hi mates, since 1.5 release, BucketingSink has ability to configure suffix of
43 matches
Mail list logo
