[jira] [Commented] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

2017-04-10 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963873#comment-15963873 ] mingleizhang commented on FLINK-6275: - Let me inside it what happened. > Unprotected

[jira] [Commented] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

2017-04-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963759#comment-15963759 ] ASF GitHub Bot commented on FLINK-5756: --- Github user hsaputra commented on the issue

[GitHub] flink issue #3704: [FLINK-5756] Replace RocksDB dependency with FRocksDB

2017-04-10 Thread hsaputra
Github user hsaputra commented on the issue: https://github.com/apache/flink/pull/3704 I hope there is a plan to contribute back to rocksdb and we could come back to bring back dependencies on the fixed version. Relying on modified lib never good practice --- If your project is set

[jira] [Commented] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

2017-04-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963694#comment-15963694 ] ASF GitHub Bot commented on FLINK-5756: --- Github user asfgit closed the pull request

[GitHub] flink pull request #3704: [FLINK-5756] Replace RocksDB dependency with FRock...

2017-04-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3704 --- 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 enab

[jira] [Commented] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

2017-04-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963693#comment-15963693 ] Robert Metzger commented on FLINK-5756: --- Merged frocksdb to 1.3-SNAPSHOT in http://

[jira] [Commented] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

2017-04-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963661#comment-15963661 ] Robert Metzger commented on FLINK-5756: --- Merged change from rocksdb to frocksdb for

[jira] [Commented] (FLINK-5756) When there are many values under the same key in ListState, RocksDBStateBackend performances poor

2017-04-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963656#comment-15963656 ] ASF GitHub Bot commented on FLINK-5756: --- Github user rmetzger commented on the issue

[GitHub] flink issue #3704: [FLINK-5756] Replace RocksDB dependency with FRocksDB

2017-04-10 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3704 I'll merge the change now --- 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 wishe

[jira] [Commented] (FLINK-6283) Enable to clear a given file cache path

2017-04-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963481#comment-15963481 ] Aljoscha Krettek commented on FLINK-6283: - What FileCache feature is this referenc

[jira] [Closed] (FLINK-6289) ExecutionEnvironment.readTextFile() can read gzip files & directories but not both

2017-04-10 Thread Arnaud Linz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz closed FLINK-6289. -- Resolution: Invalid Fix Version/s: 1.1.3 Actually, it works... It seems I was to quick to report

[jira] [Commented] (FLINK-6290) SharedBuffer is improperly released when multiple edges between entries

2017-04-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15962996#comment-15962996 ] ASF GitHub Bot commented on FLINK-6290: --- GitHub user dawidwys opened a pull request:

[GitHub] flink pull request #3706: [FLINK-6290] SharedBuffer is improperly released w...

2017-04-10 Thread dawidwys
GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/3706 [FLINK-6290] SharedBuffer is improperly released when multiple edges … …between entries Thanks for contributing to Apache Flink. Before you open your pull request, please take the foll

[jira] [Assigned] (FLINK-6290) SharedBuffer is improperly released when multiple edges between entries

2017-04-10 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-6290: --- Assignee: Dawid Wysakowicz > SharedBuffer is improperly released when multiple edges

[jira] [Updated] (FLINK-6290) SharedBuffer is improperly released when multiple edges between entries

2017-04-10 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-6290: Description: Below test right now fails: {code} @Test public void testCleari

[jira] [Updated] (FLINK-6287) Flakey JobManagerRegistrationTest

2017-04-10 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-6287: --- Component/s: Tests > Flakey JobManagerRegistrationTest > - > >

[jira] [Updated] (FLINK-6290) SharedBuffer is improperly released when multiple edges between entries

2017-04-10 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-6290: Description: Below test right now fails: {code} @Test public void testCleari

[jira] [Created] (FLINK-6290) SharedBuffer is improperly released when multiple edges between entries

2017-04-10 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-6290: --- Summary: SharedBuffer is improperly released when multiple edges between entries Key: FLINK-6290 URL: https://issues.apache.org/jira/browse/FLINK-6290 Project:

[jira] [Created] (FLINK-6289) ExecutionEnvironment.readTextFile() can read gzip files & directories but not both

2017-04-10 Thread Arnaud Linz (JIRA)
Arnaud Linz created FLINK-6289: -- Summary: ExecutionEnvironment.readTextFile() can read gzip files & directories but not both Key: FLINK-6289 URL: https://issues.apache.org/jira/browse/FLINK-6289 Project:

[jira] [Created] (FLINK-6288) FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic

2017-04-10 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6288: -- Summary: FlinkKafkaProducer's custom Partitioner is always invoked with number of partitions of default topic Key: FLINK-6288 URL: https://issues.apache.org/jira/brows

[jira] [Created] (FLINK-6287) Flakey JobManagerRegistrationTest

2017-04-10 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-6287: -- Summary: Flakey JobManagerRegistrationTest Key: FLINK-6287 URL: https://issues.apache.org/jira/browse/FLINK-6287 Project: Flink Issue Type: Bug Compone

[jira] [Updated] (FLINK-6286) hbase command not found error

2017-04-10 Thread Jinjiang Ling (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jinjiang Ling updated FLINK-6286: - Description: As I'm using flink with the HBASE_CONF_DIR env variable and don't install hbase, the

[jira] [Commented] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

2017-04-10 Thread hongyuhong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15962727#comment-15962727 ] hongyuhong commented on FLINK-6232: --- Hi [~fhueske], I have made a preliminary implementa

[GitHub] flink pull request #3705: [FLINK-6286] Fix the hbase command not found error

2017-04-10 Thread lingjinjiang
GitHub user lingjinjiang opened a pull request: https://github.com/apache/flink/pull/3705 [FLINK-6286] Fix the hbase command not found error Fix the hbase command not found error. https://issues.apache.org/jira/browse/FLINK-6286 You can merge this pull request into a Git reposit

[jira] [Commented] (FLINK-6286) hbase command not found error

2017-04-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15962697#comment-15962697 ] ASF GitHub Bot commented on FLINK-6286: --- GitHub user lingjinjiang opened a pull requ

[jira] [Updated] (FLINK-6286) hbase command not found error

2017-04-10 Thread Jinjiang Ling (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jinjiang Ling updated FLINK-6286: - Attachment: FLINK-6286-0.patch > hbase command not found error > - > >

[jira] [Created] (FLINK-6286) hbase command not found error

2017-04-10 Thread Jinjiang Ling (JIRA)
Jinjiang Ling created FLINK-6286: Summary: hbase command not found error Key: FLINK-6286 URL: https://issues.apache.org/jira/browse/FLINK-6286 Project: Flink Issue Type: Bug Repor

[jira] [Commented] (FLINK-5544) Implement Internal Timer Service in RocksDB

2017-04-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15962659#comment-15962659 ] ASF GitHub Bot commented on FLINK-5544: --- Github user vpernin commented on the issue:

[GitHub] flink issue #3359: [FLINK-5544][streaming] Add InternalTimerService implemen...

2017-04-10 Thread vpernin
Github user vpernin commented on the issue: https://github.com/apache/flink/pull/3359 Is this PR in a testable/working state based on 1.3-SNAPHOT ? I could help test with a quite large number of window timers (between 2M and 6M). --- If your project is set up for it, you can repl

[jira] [Updated] (FLINK-6285) resolve hadoop-compatibility confusion

2017-04-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-6285: -- Component/s: Build System > resolve hadoop-compatibility confusion > ---