[GitHub] flink pull request #3925: [FLINK-6600] Add key serializer config snapshot to...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/3925#discussion_r116977261 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@

[jira] [Commented] (FLINK-6600) Add key serializer's config snapshot to KeyedBackendSerializationProxy

[ https://issues.apache.org/jira/browse/FLINK-6600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013883#comment-16013883 ] ASF GitHub Bot commented on FLINK-6600: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #3925: [FLINK-6600] Add key serializer config snapshot to...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/3925#discussion_r116977075 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@

[jira] [Updated] (FLINK-6611) When TaskManager or JobManager restart after crash the PID file contain also the old PID

[ https://issues.apache.org/jira/browse/FLINK-6611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mauro Cortellazzi updated FLINK-6611: - Issue Type: Task (was: Bug) > When TaskManager or JobManager restart after crash the PID

[jira] [Created] (FLINK-6613) OOM during reading big messages from Kafka

Andrey created FLINK-6613: - Summary: OOM during reading big messages from Kafka Key: FLINK-6613 URL: https://issues.apache.org/jira/browse/FLINK-6613 Project: Flink Issue Type: Bug Affects

[GitHub] flink issue #3929: [FLINK-6543] [table] Deprecate toDataStream

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3929 I forgot to update the documentation. Will do this later. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[GitHub] flink issue #3923: [FLINK-6587] [table] Simplification and bug fixing of the...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3923 Thanks @fhueske. I will merge this and update the documentation. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Resolved] (FLINK-6601) Use time indicators in DataStreamLogicalWindowAggregateRule

[ https://issues.apache.org/jira/browse/FLINK-6601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-6601. - Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 Fixed in 1.4:

[GitHub] flink issue #3924: [FLINK-6601] [table] Use time indicators in DataStreamLog...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3924 Merging... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (FLINK-6601) Use time indicators in DataStreamLogicalWindowAggregateRule

[ https://issues.apache.org/jira/browse/FLINK-6601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013807#comment-16013807 ] ASF GitHub Bot commented on FLINK-6601: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3924: [FLINK-6601] [table] Use time indicators in DataSt...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3924 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Assigned] (FLINK-6611) When TaskManager or JobManager restart after crash the PID file contain also the old PID

[ https://issues.apache.org/jira/browse/FLINK-6611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mauro Cortellazzi reassigned FLINK-6611: Assignee: Mauro Cortellazzi > When TaskManager or JobManager restart after crash

[jira] [Commented] (FLINK-6570) QueryableStateClient constructor in documentation doesn't match actual signature

[ https://issues.apache.org/jira/browse/FLINK-6570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013804#comment-16013804 ] ASF GitHub Bot commented on FLINK-6570: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #3926: [FLINK-6570] QueryableStateClient docs with matching cons...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3926 Sadly, our tests are a little bit unstable. The issue is not related to your change. @tillrohrmann could you talk a quick look here? --- If your project is set up for it, you can reply to

[jira] [Comment Edited] (FLINK-6611) When TaskManager or JobManager restart after crash the PID file contain also the old PID

[ https://issues.apache.org/jira/browse/FLINK-6611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013802#comment-16013802 ] Mauro Cortellazzi edited comment on FLINK-6611 at 5/17/17 9:45 AM: --- In

[jira] [Commented] (FLINK-6570) QueryableStateClient constructor in documentation doesn't match actual signature

[ https://issues.apache.org/jira/browse/FLINK-6570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013801#comment-16013801 ] ASF GitHub Bot commented on FLINK-6570: --- Github user gosubpl commented on the issue:

[jira] [Commented] (FLINK-6611) When TaskManager or JobManager restart after crash the PID file contain also the old PID

[ https://issues.apache.org/jira/browse/FLINK-6611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013802#comment-16013802 ] Mauro Cortellazzi commented on FLINK-6611: -- In `flink-daemon.sh` the is the following piece of

[GitHub] flink issue #3926: [FLINK-6570] QueryableStateClient docs with matching cons...

Github user gosubpl commented on the issue: https://github.com/apache/flink/pull/3926 Please note that the only change in this PR is a documentation change. Not sure why this should result in test failing. How can another test run be requested (a _flaky test_ perhaps)? --- If your

[GitHub] flink issue #3502: [FLINK-4565] Support for SQL IN operator

Github user DmytroShkvyra commented on the issue: https://github.com/apache/flink/pull/3502 Hi @fhueske could you review this PR. It also related to support of SQL standarts --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-6543) Deprecate toDataStream

[ https://issues.apache.org/jira/browse/FLINK-6543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013800#comment-16013800 ] ASF GitHub Bot commented on FLINK-6543: --- GitHub user twalthr opened a pull request:

[GitHub] flink pull request #3929: [FLINK-6543] [table] Deprecate toDataStream

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/3929 [FLINK-6543] [table] Deprecate toDataStream This deprecates toDataStream in Scala and Java Table API. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Assigned] (FLINK-6611) When TaskManager or JobManager restart after crash the PID file contain also the old PID

[ https://issues.apache.org/jira/browse/FLINK-6611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mauro Cortellazzi reassigned FLINK-6611: Assignee: (was: Mauro Cortellazzi) > When TaskManager or JobManager restart

[jira] [Commented] (FLINK-5476) Fail fast if trying to submit a job to a non-existing Flink cluster

[ https://issues.apache.org/jira/browse/FLINK-5476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013790#comment-16013790 ] ASF GitHub Bot commented on FLINK-5476: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #3753: [FLINK-5476] Fail fast if trying to submit a job to a non...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3753 Sorry for not coming back to you earlier. I will try to give it another round of review in the next days. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Created] (FLINK-6612) ZooKeeperStateHandleStore does not guard against concurrent delete operations

Till Rohrmann created FLINK-6612: Summary: ZooKeeperStateHandleStore does not guard against concurrent delete operations Key: FLINK-6612 URL: https://issues.apache.org/jira/browse/FLINK-6612 Project:

[jira] [Assigned] (FLINK-6611) When TaskManager or JobManager restart after crash the PID file contain also the old PID

[ https://issues.apache.org/jira/browse/FLINK-6611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mauro Cortellazzi reassigned FLINK-6611: Assignee: Mauro Cortellazzi > When TaskManager or JobManager restart after crash

[jira] [Commented] (FLINK-5476) Fail fast if trying to submit a job to a non-existing Flink cluster

[ https://issues.apache.org/jira/browse/FLINK-5476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013788#comment-16013788 ] ASF GitHub Bot commented on FLINK-5476: --- Github user DmytroShkvyra commented on the issue:

[GitHub] flink issue #3753: [FLINK-5476] Fail fast if trying to submit a job to a non...

Github user DmytroShkvyra commented on the issue: https://github.com/apache/flink/pull/3753 Hi @tillrohrmann could you review this PR --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Updated] (FLINK-6611) When TaskManager or JobManager restart after crash the PID file contain also the old PID

[ https://issues.apache.org/jira/browse/FLINK-6611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mauro Cortellazzi updated FLINK-6611: - Description: When TaskManager or JobManager restart after crash the PID file contain also

[jira] [Created] (FLINK-6611) When TaskManager or JobManager crash

Mauro Cortellazzi created FLINK-6611: Summary: When TaskManager or JobManager crash Key: FLINK-6611 URL: https://issues.apache.org/jira/browse/FLINK-6611 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-6611) When TaskManager or JobManager restart after crash the PID file contain also the old PID

[ https://issues.apache.org/jira/browse/FLINK-6611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mauro Cortellazzi updated FLINK-6611: - Summary: When TaskManager or JobManager restart after crash the PID file contain also the

[jira] [Assigned] (FLINK-6031) Add parameter for per job yarn clusters to control whether the user code jar is included into the system classloader.

[ https://issues.apache.org/jira/browse/FLINK-6031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6031: --- Assignee: Chesnay Schepler > Add parameter for per job yarn clusters to control

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013773#comment-16013773 ] ASF GitHub Bot commented on FLINK-2055: --- Github user nragon commented on the issue:

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

Github user nragon commented on the issue: https://github.com/apache/flink/pull/2332 Currently trying to fix some throttling issues, reported here https://github.com/OpenTSDB/asynchbase/issues/162 --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-6589) ListSerializer should deserialize as ArrayList with size + 1

[ https://issues.apache.org/jira/browse/FLINK-6589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013765#comment-16013765 ] ASF GitHub Bot commented on FLINK-6589: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3912: [FLINK-6589] [core] Deserialize ArrayList with capacity o...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3912 Thank you, I'll merge this then. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Commented] (FLINK-6031) Add parameter for per job yarn clusters to control whether the user code jar is included into the system classloader.

[ https://issues.apache.org/jira/browse/FLINK-6031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013762#comment-16013762 ] Robert Metzger commented on FLINK-6031: --- I responded on the BEAM issue. Back to this one: >From the

[jira] [Commented] (FLINK-6589) ListSerializer should deserialize as ArrayList with size + 1

[ https://issues.apache.org/jira/browse/FLINK-6589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013760#comment-16013760 ] ASF GitHub Bot commented on FLINK-6589: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #3912: [FLINK-6589] [core] Deserialize ArrayList with capacity o...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3912 Yes, there is a tradeoff, and probably the nicest way would be to restore the internal array size as it was when we serialized the original. However, I guess that is too much effort for the

[GitHub] flink issue #3912: [FLINK-6589] [core] Deserialize ArrayList with capacity o...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3912 If the only case we currently know of right now is in the Table API with 1 additional element to be added, then I think this is good for now. I think the improvement should be bounded to

[jira] [Commented] (FLINK-6589) ListSerializer should deserialize as ArrayList with size + 1

[ https://issues.apache.org/jira/browse/FLINK-6589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013756#comment-16013756 ] ASF GitHub Bot commented on FLINK-6589: --- Github user tzulitai commented on the issue:

[jira] [Commented] (FLINK-6589) ListSerializer should deserialize as ArrayList with size + 1

[ https://issues.apache.org/jira/browse/FLINK-6589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013722#comment-16013722 ] ASF GitHub Bot commented on FLINK-6589: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3912: [FLINK-6589] [core] Deserialize ArrayList with capacity o...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3912 At least in the Table API / SQL operators, we use a ProcessFunction add elements in the `processElement()` method. So, in the case that I want to improve just adds a single element. My

[GitHub] flink issue #3912: [FLINK-6589] [core] Deserialize ArrayList with capacity o...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3912 Share the same question as Stefan. Otherwise LGTM. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-6589) ListSerializer should deserialize as ArrayList with size + 1

[ https://issues.apache.org/jira/browse/FLINK-6589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013717#comment-16013717 ] ASF GitHub Bot commented on FLINK-6589: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #3912: [FLINK-6589] [core] Deserialize ArrayList with capacity o...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3912 No concern, just curious if there is any reason for the 1 additional. The problem also still exists now for a second element. So is it, in general, unlikely that new elements are added? Or

[jira] [Commented] (FLINK-6589) ListSerializer should deserialize as ArrayList with size + 1

[ https://issues.apache.org/jira/browse/FLINK-6589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013716#comment-16013716 ] ASF GitHub Bot commented on FLINK-6589: --- Github user StefanRRichter commented on the issue:

[jira] [Commented] (FLINK-6589) ListSerializer should deserialize as ArrayList with size + 1

[ https://issues.apache.org/jira/browse/FLINK-6589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013714#comment-16013714 ] ASF GitHub Bot commented on FLINK-6589: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3912: [FLINK-6589] [core] Deserialize ArrayList with capacity o...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3912 Any concerns regarding this change @tzulitai @StephanEwen @StefanRRichter ? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your

[jira] [Commented] (FLINK-6598) Remove useless param rowRelDataType of DataStreamGroupAggregate.

[ https://issues.apache.org/jira/browse/FLINK-6598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013710#comment-16013710 ] ASF GitHub Bot commented on FLINK-6598: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3922: [FLINK-6598][table]Remove useless param rowRelDataType of...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3922 +1 to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Commented] (FLINK-6583) Enable QueryConfig in count base GroupWindow

[ https://issues.apache.org/jira/browse/FLINK-6583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013705#comment-16013705 ] ASF GitHub Bot commented on FLINK-6583: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #3919: [FLINK-6583][talbe]Enable QueryConfig in count bas...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3919#discussion_r116932844 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/triggers/StateCleaningCountTrigger.scala --- @@ -19,44 +19,46 @@

[jira] [Commented] (FLINK-6608) Relax Kerberos login contexts parsing by trimming whitespaces in contexts list

[ https://issues.apache.org/jira/browse/FLINK-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013703#comment-16013703 ] ASF GitHub Bot commented on FLINK-6608: --- GitHub user tzulitai opened a pull request:

[GitHub] flink pull request #3928: [FLINK-6608] [security, config] Relax Kerberos log...

GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/3928 [FLINK-6608] [security, config] Relax Kerberos login contexts parsing This PR allows whitespaces in the list of configured Kerberos login contexts. It generally covers some over scenarios as

[jira] [Commented] (FLINK-6609) Wrong version assignment when multiple TAKEs transitions

[ https://issues.apache.org/jira/browse/FLINK-6609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013697#comment-16013697 ] ASF GitHub Bot commented on FLINK-6609: --- GitHub user dawidwys opened a pull request:

[GitHub] flink pull request #3927: [FLINK-6609] Wrong version assignment when multipl...

GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/3927 [FLINK-6609] Wrong version assignment when multiple TAKEs transitions Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Created] (FLINK-6610) WebServer could not be created,when set the "jobmanager.web.submit.enable" to false

zhihao chen created FLINK-6610: -- Summary: WebServer could not be created,when set the "jobmanager.web.submit.enable" to false Key: FLINK-6610 URL: https://issues.apache.org/jira/browse/FLINK-6610

[jira] [Commented] (FLINK-6608) Relax Kerberos login contexts parsing by trimming whitespaces in contexts list

[ https://issues.apache.org/jira/browse/FLINK-6608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013672#comment-16013672 ] Eron Wright commented on FLINK-6608: - Sorry about this, thanks for fixing. > Relax Kerberos login

[jira] [Updated] (FLINK-6606) Create checkpoint hook with user classloader

[ https://issues.apache.org/jira/browse/FLINK-6606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-6606: Fix Version/s: 1.3.0 > Create checkpoint hook with user classloader >

[jira] [Commented] (FLINK-6606) Create checkpoint hook with user classloader

[ https://issues.apache.org/jira/browse/FLINK-6606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013670#comment-16013670 ] Eron Wright commented on FLINK-6606: - I have a fix ready and will open a PR soon. The fix wraps all

[jira] [Created] (FLINK-6609) Wrong version assignment when multiple TAKEs transitions

Dawid Wysakowicz created FLINK-6609: --- Summary: Wrong version assignment when multiple TAKEs transitions Key: FLINK-6609 URL: https://issues.apache.org/jira/browse/FLINK-6609 Project: Flink

[jira] [Created] (FLINK-6608) Relax Kerberos login contexts parsing by trimming whitespaces in contexts list

Tzu-Li (Gordon) Tai created FLINK-6608: -- Summary: Relax Kerberos login contexts parsing by trimming whitespaces in contexts list Key: FLINK-6608 URL: https://issues.apache.org/jira/browse/FLINK-6608

[GitHub] flink pull request #3913: [FLINK-6574] Support nested catalogs in ExternalCa...

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3913#discussion_r116919339 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/exceptions.scala --- @@ -128,7 +128,7 @@ case class

[jira] [Commented] (FLINK-6574) Support nested catalogs in ExternalCatalog

[ https://issues.apache.org/jira/browse/FLINK-6574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013613#comment-16013613 ] ASF GitHub Bot commented on FLINK-6574: --- Github user KurtYoung commented on a diff in the pull

[jira] [Commented] (FLINK-6574) Support nested catalogs in ExternalCatalog

[ https://issues.apache.org/jira/browse/FLINK-6574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013614#comment-16013614 ] ASF GitHub Bot commented on FLINK-6574: --- Github user KurtYoung commented on a diff in the pull

[GitHub] flink pull request #3913: [FLINK-6574] Support nested catalogs in ExternalCa...

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3913#discussion_r116919313 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/exceptions.scala --- @@ -114,7 +114,7 @@ case class

[jira] [Commented] (FLINK-6574) Support nested catalogs in ExternalCatalog

[ https://issues.apache.org/jira/browse/FLINK-6574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013608#comment-16013608 ] ASF GitHub Bot commented on FLINK-6574: --- Github user KurtYoung commented on a diff in the pull

[GitHub] flink pull request #3913: [FLINK-6574] Support nested catalogs in ExternalCa...

Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3913#discussion_r116919169 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalogTable.scala --- @@ -37,25 +36,10 @@ import

[jira] [Closed] (FLINK-6555) Generalize ConjunctFuture

[ https://issues.apache.org/jira/browse/FLINK-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-6555. Resolution: Fixed Fix Version/s: 1.3.0 1.4.0: c081201fd6c3c97a932c09d971f24bf42102650f

[jira] [Assigned] (FLINK-6284) Incorrect sorting of completed checkpoints in ZooKeeperCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-6284: Assignee: Till Rohrmann > Incorrect sorting of completed checkpoints in >

[jira] [Closed] (FLINK-6519) Integrate BlobStore in HighAvailabilityServices lifecycle management

[ https://issues.apache.org/jira/browse/FLINK-6519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-6519. Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 1.4.0:

[jira] [Resolved] (FLINK-6284) Incorrect sorting of completed checkpoints in ZooKeeperCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-6284. -- Resolution: Fixed Fix Version/s: 1.4.0 1.4.0: ebc13688c9441adf61075707f40b361ee02597f3

[jira] [Resolved] (FLINK-6020) Blob Server cannot handle multiple job submits (with same content) parallelly

[ https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-6020. -- Resolution: Fixed Fix Version/s: 1.4.0 1.3.0 1.4.0

[GitHub] flink pull request #3884: [FLINK-6284] Correct sorting of completed checkpoi...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3884 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6020) Blob Server cannot handle multiple job submits (with same content) parallelly

[ https://issues.apache.org/jira/browse/FLINK-6020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013597#comment-16013597 ] ASF GitHub Bot commented on FLINK-6020: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3864: [FLINK-6519] Integrate BlobStore in lifecycle mana...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3864 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6284) Incorrect sorting of completed checkpoints in ZooKeeperCompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013596#comment-16013596 ] ASF GitHub Bot commented on FLINK-6284: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3873: [FLINK-6555] [futures] Generalize ConjunctFuture t...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3873 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3888: [FLINK-6020] Introduce BlobServer#readWriteLock to...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3888 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6555) Generalize ConjunctFuture

[ https://issues.apache.org/jira/browse/FLINK-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013594#comment-16013594 ] ASF GitHub Bot commented on FLINK-6555: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6519) Integrate BlobStore in HighAvailabilityServices lifecycle management

[ https://issues.apache.org/jira/browse/FLINK-6519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16013595#comment-16013595 ] ASF GitHub Bot commented on FLINK-6519: --- Github user asfgit closed the pull request at:

<    1   2   3