[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644488#comment-16644488 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on a change in pull request #6483:

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644487#comment-16644487 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on a change in pull request #6483:

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-10-09 Thread GitBox
HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r223942389 ## File path:

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-10-09 Thread GitBox
HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r223942328 ## File path:

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-10-09 Thread GitBox
HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r223941595 ## File path:

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644486#comment-16644486 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on a change in pull request #6483:

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644483#comment-16644483 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on a change in pull request #6483:

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-10-09 Thread GitBox
HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r223941595 ## File path:

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644481#comment-16644481 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on a change in pull request #6483:

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644480#comment-16644480 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on a change in pull request #6483:

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-10-09 Thread GitBox
HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r223940956 ## File path:

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644479#comment-16644479 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on a change in pull request #6483:

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-10-09 Thread GitBox
HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r223940919 ## File path:

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-10-09 Thread GitBox
HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r223940936 ## File path:

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644476#comment-16644476 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on a change in pull request #6483:

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-10-09 Thread GitBox
HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r223940551 ## File path:

[jira] [Commented] (FLINK-9377) Remove writing serializers as part of the checkpoint meta information

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644465#comment-16644465 ] ASF GitHub Bot commented on FLINK-9377: --- tzulitai commented on issue #6711: [FLINK-9377] [core,

[GitHub] tzulitai commented on issue #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints

2018-10-09 Thread GitBox
tzulitai commented on issue #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints URL: https://github.com/apache/flink/pull/6711#issuecomment-428440460 Thanks @dawidwys. I'll address your last comments, rebase on master and after Travis gives green, proceed to

[jira] [Commented] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

2018-10-09 Thread huangjiatian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644460#comment-16644460 ] huangjiatian commented on FLINK-10464: -- [~twalthr] supplement to picture >

[jira] [Updated] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

2018-10-09 Thread huangjiatian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huangjiatian updated FLINK-10464: - Description: I met a strange question when i use Flink SQL API. I found two difference type

[jira] [Updated] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

2018-10-09 Thread huangjiatian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huangjiatian updated FLINK-10464: - Attachment: 3.png > TimeIndicatorRelDataType: digest can not describe a type completely. >

[jira] [Updated] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

2018-10-09 Thread huangjiatian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huangjiatian updated FLINK-10464: - Description: I met a strange question when i use Flink SQL API. I found two difference type

[jira] [Updated] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

2018-10-09 Thread huangjiatian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huangjiatian updated FLINK-10464: - Attachment: 2.png > TimeIndicatorRelDataType: digest can not describe a type completely. >

[jira] [Updated] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

2018-10-09 Thread huangjiatian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huangjiatian updated FLINK-10464: - Description: I met a strange question when i use Flink SQL API. I found two difference type

[jira] [Updated] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

2018-10-09 Thread huangjiatian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huangjiatian updated FLINK-10464: - Description: I met a strange question when i use Flink SQL API. I found two difference type

[jira] [Updated] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

2018-10-09 Thread huangjiatian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huangjiatian updated FLINK-10464: - Description: I met a strange question when i use Flink SQL API. I found two difference type

[jira] [Updated] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

2018-10-09 Thread huangjiatian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huangjiatian updated FLINK-10464: - Attachment: 1.png > TimeIndicatorRelDataType: digest can not describe a type completely. >

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644450#comment-16644450 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on a change in pull request #6483:

[jira] [Updated] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

2018-10-09 Thread huangjiatian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huangjiatian updated FLINK-10464: - Description: I met a strange question when i use Flink SQL API. I found two difference type

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-10-09 Thread GitBox
HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r223935440 ## File path:

[jira] [Updated] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

2018-10-09 Thread huangjiatian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huangjiatian updated FLINK-10464: - Description: I met a strange question when i use Flink SQL API. I found two difference type

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1663#comment-1663 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on a change in pull request #6483:

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-10-09 Thread GitBox
HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r223934091 ## File path:

[jira] [Commented] (FLINK-10491) Deadlock during spilling data in SpillableSubpartition

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644432#comment-16644432 ] ASF GitHub Bot commented on FLINK-10491: zhijiangW commented on issue #6809:

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644433#comment-16644433 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on a change in pull request #6483:

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-10-09 Thread GitBox
HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r223932565 ## File path:

[GitHub] zhijiangW commented on issue #6809: [FLINK-10491][network] Pass BufferPoolOwner in the constructor of LocalBufferPool

2018-10-09 Thread GitBox
zhijiangW commented on issue #6809: [FLINK-10491][network] Pass BufferPoolOwner in the constructor of LocalBufferPool URL: https://github.com/apache/flink/pull/6809#issuecomment-428432627 Thanks for efficient reviews! @NicoK @pnowojski I already updated the codes based on above

[jira] [Commented] (FLINK-10491) Deadlock during spilling data in SpillableSubpartition

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644425#comment-16644425 ] ASF GitHub Bot commented on FLINK-10491: zhijiangW commented on a change in pull request #6809:

[GitHub] zhijiangW commented on a change in pull request #6809: [FLINK-10491][network] Pass BufferPoolOwner in the constructor of LocalBufferPool

2018-10-09 Thread GitBox
zhijiangW commented on a change in pull request #6809: [FLINK-10491][network] Pass BufferPoolOwner in the constructor of LocalBufferPool URL: https://github.com/apache/flink/pull/6809#discussion_r223931343 ## File path:

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644421#comment-16644421 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on a change in pull request #6483:

[GitHub] HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-10-09 Thread GitBox
HuangZhenQiu commented on a change in pull request #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#discussion_r223930910 ## File path:

[jira] [Commented] (FLINK-10491) Deadlock during spilling data in SpillableSubpartition

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644407#comment-16644407 ] ASF GitHub Bot commented on FLINK-10491: zhijiangW commented on a change in pull request #6809:

[GitHub] zhijiangW commented on a change in pull request #6809: [FLINK-10491][network] Pass BufferPoolOwner in the constructor of LocalBufferPool

2018-10-09 Thread GitBox
zhijiangW commented on a change in pull request #6809: [FLINK-10491][network] Pass BufferPoolOwner in the constructor of LocalBufferPool URL: https://github.com/apache/flink/pull/6809#discussion_r223929542 ## File path:

[jira] [Commented] (FLINK-10134) UTF-16 support for TextInputFormat

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644406#comment-16644406 ] ASF GitHub Bot commented on FLINK-10134: XuQianJin-Stars commented on a change in pull request

[GitHub] XuQianJin-Stars commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed

2018-10-09 Thread GitBox
XuQianJin-Stars commented on a change in pull request #6710: [FLINK-10134] UTF-16 support for TextInputFormat bug fixed URL: https://github.com/apache/flink/pull/6710#discussion_r223929236 ## File path: flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java

[jira] [Commented] (FLINK-10491) Deadlock during spilling data in SpillableSubpartition

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644401#comment-16644401 ] ASF GitHub Bot commented on FLINK-10491: zhijiangW commented on a change in pull request #6809:

[jira] [Commented] (FLINK-10491) Deadlock during spilling data in SpillableSubpartition

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644403#comment-16644403 ] ASF GitHub Bot commented on FLINK-10491: zhijiangW commented on a change in pull request #6809:

[GitHub] zhijiangW commented on a change in pull request #6809: [FLINK-10491][network] Pass BufferPoolOwner in the constructor of LocalBufferPool

2018-10-09 Thread GitBox
zhijiangW commented on a change in pull request #6809: [FLINK-10491][network] Pass BufferPoolOwner in the constructor of LocalBufferPool URL: https://github.com/apache/flink/pull/6809#discussion_r223929096 ## File path:

[GitHub] zhijiangW commented on a change in pull request #6809: [FLINK-10491][network] Pass BufferPoolOwner in the constructor of LocalBufferPool

2018-10-09 Thread GitBox
zhijiangW commented on a change in pull request #6809: [FLINK-10491][network] Pass BufferPoolOwner in the constructor of LocalBufferPool URL: https://github.com/apache/flink/pull/6809#discussion_r223929018 ## File path:

[jira] [Commented] (FLINK-10474) Don't translate IN with Literals to JOIN with VALUES for streaming queries

2018-10-09 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644347#comment-16644347 ] Hequn Cheng commented on FLINK-10474: - Hi all, Thanks for your comments. I think there are two

[jira] [Commented] (FLINK-9990) Add regexp_extract supported in TableAPI and SQL

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644337#comment-16644337 ] ASF GitHub Bot commented on FLINK-9990: --- yanghua commented on issue #6448: [FLINK-9990] [table] Add

[GitHub] yanghua commented on issue #6448: [FLINK-9990] [table] Add regexp_extract supported in TableAPI and SQL

2018-10-09 Thread GitBox
yanghua commented on issue #6448: [FLINK-9990] [table] Add regexp_extract supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6448#issuecomment-428410089 @xccui Thank you very much for your time and effort. I also have a PR #6432 about `ASCII/CHR`. When you have time,

[jira] [Commented] (FLINK-10423) Forward RocksDB native metrics to Flink metrics reporter

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644320#comment-16644320 ] ASF GitHub Bot commented on FLINK-10423: sjwiesman commented on a change in pull request #6814:

[GitHub] sjwiesman commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor

2018-10-09 Thread GitBox
sjwiesman commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor URL: https://github.com/apache/flink/pull/6814#discussion_r223912317 ## File path:

[jira] [Created] (FLINK-10520) Job save points REST API fails unless parameters are specified

2018-10-09 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10520: -- Summary: Job save points REST API fails unless parameters are specified Key: FLINK-10520 URL: https://issues.apache.org/jira/browse/FLINK-10520 Project: Flink

[jira] [Commented] (FLINK-10516) YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup

2018-10-09 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644150#comment-16644150 ] Shuyi Chen commented on FLINK-10516: Hi [~till.rohrmann], how do you want to proceed? I can either

[jira] [Commented] (FLINK-10423) Forward RocksDB native metrics to Flink metrics reporter

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644138#comment-16644138 ] ASF GitHub Bot commented on FLINK-10423: zentol commented on a change in pull request #6814:

[jira] [Commented] (FLINK-10423) Forward RocksDB native metrics to Flink metrics reporter

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644136#comment-16644136 ] ASF GitHub Bot commented on FLINK-10423: zentol commented on a change in pull request #6814:

[jira] [Commented] (FLINK-10423) Forward RocksDB native metrics to Flink metrics reporter

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644137#comment-16644137 ] ASF GitHub Bot commented on FLINK-10423: zentol commented on a change in pull request #6814:

[jira] [Commented] (FLINK-10423) Forward RocksDB native metrics to Flink metrics reporter

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644139#comment-16644139 ] ASF GitHub Bot commented on FLINK-10423: zentol commented on a change in pull request #6814:

[GitHub] zentol commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor

2018-10-09 Thread GitBox
zentol commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor URL: https://github.com/apache/flink/pull/6814#discussion_r223873328 ## File path:

[GitHub] zentol commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor

2018-10-09 Thread GitBox
zentol commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor URL: https://github.com/apache/flink/pull/6814#discussion_r223872847 ## File path:

[GitHub] zentol commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor

2018-10-09 Thread GitBox
zentol commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor URL: https://github.com/apache/flink/pull/6814#discussion_r223873851 ## File path:

[GitHub] zentol commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor

2018-10-09 Thread GitBox
zentol commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor URL: https://github.com/apache/flink/pull/6814#discussion_r223872647 ## File path:

[jira] [Commented] (FLINK-9990) Add regexp_extract supported in TableAPI and SQL

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644127#comment-16644127 ] ASF GitHub Bot commented on FLINK-9990: --- asfgit closed pull request #6448: [FLINK-9990] [table] Add

[GitHub] asfgit closed pull request #6448: [FLINK-9990] [table] Add regexp_extract supported in TableAPI and SQL

2018-10-09 Thread GitBox
asfgit closed pull request #6448: [FLINK-9990] [table] Add regexp_extract supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6448 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Comment Edited] (FLINK-10465) Jepsen: runit supervised sshd is stopped on tear down

2018-10-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643266#comment-16643266 ] Gary Yao edited comment on FLINK-10465 at 10/9/18 7:46 PM: --- fixed via 1.6:

[jira] [Closed] (FLINK-10465) Jepsen: runit supervised sshd is stopped on tear down

2018-10-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-10465. Resolution: Fixed > Jepsen: runit supervised sshd is stopped on tear down >

[jira] [Closed] (FLINK-5542) YARN client incorrectly uses local YARN config to check vcore capacity

2018-10-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-5542. --- Resolution: Fixed fixed via 1.5: 5fb67abd51aca277d1140c274001e89f4bd7cf9a 1.6:

[jira] [Updated] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

2018-10-09 Thread Florian Schmidt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-10519: Description: The flink-parent:1.6.1 artifact can't be found on maven central:

[jira] [Updated] (FLINK-5542) YARN client incorrectly uses local YARN config to check vcore capacity

2018-10-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-5542: Fix Version/s: 1.5.5 1.6.2 > YARN client incorrectly uses local YARN config to check

[jira] [Commented] (FLINK-5542) YARN client incorrectly uses local YARN config to check vcore capacity

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643990#comment-16643990 ] ASF GitHub Bot commented on FLINK-5542: --- asfgit closed pull request #6775: [FLINK-5542] use

[GitHub] asfgit closed pull request #6775: [FLINK-5542] use YarnCluster vcores setting to do MaxVCore validation

2018-10-09 Thread GitBox
asfgit closed pull request #6775: [FLINK-5542] use YarnCluster vcores setting to do MaxVCore validation URL: https://github.com/apache/flink/pull/6775 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Comment Edited] (FLINK-10423) Forward RocksDB native metrics to Flink metrics reporter

2018-10-09 Thread Seth Wiesman (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629155#comment-16629155 ] Seth Wiesman edited comment on FLINK-10423 at 10/9/18 7:34 PM: --- -I have a

[jira] [Updated] (FLINK-10423) Forward RocksDB native metrics to Flink metrics reporter

2018-10-09 Thread Seth Wiesman (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-10423: - Summary: Forward RocksDB native metrics to Flink metrics reporter (was: Forward RocksDB

[jira] [Commented] (FLINK-10423) Forward RocksDB memory metrics to Flink metrics reporter

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643978#comment-16643978 ] ASF GitHub Bot commented on FLINK-10423: sjwiesman opened a new pull request #6814:

[jira] [Updated] (FLINK-10423) Forward RocksDB memory metrics to Flink metrics reporter

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10423: --- Labels: pull-request-available (was: ) > Forward RocksDB memory metrics to Flink metrics

[GitHub] sjwiesman opened a new pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor

2018-10-09 Thread GitBox
sjwiesman opened a new pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor URL: https://github.com/apache/flink/pull/6814 ## What is the purpose of the change Optionally expose RocksDB native metrics to Flink metrics reporter. All metrics are optionally

[jira] [Created] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central

2018-10-09 Thread Florian Schmidt (JIRA)
Florian Schmidt created FLINK-10519: --- Summary: flink-parent:1.6.1 artifact can't be found on maven central Key: FLINK-10519 URL: https://issues.apache.org/jira/browse/FLINK-10519 Project: Flink

[jira] [Commented] (FLINK-10440) Add a CassandraPojoOutputFormat to write Pojo in Cassandra from batch

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643912#comment-16643912 ] ASF GitHub Bot commented on FLINK-10440: bmeriaux edited a comment on issue #6813: [FLINK-10440]

[jira] [Commented] (FLINK-10440) Add a CassandraPojoOutputFormat to write Pojo in Cassandra from batch

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643911#comment-16643911 ] ASF GitHub Bot commented on FLINK-10440: bmeriaux commented on issue #6813: [FLINK-10440] Add a

[GitHub] bmeriaux edited a comment on issue #6813: [FLINK-10440] Add a new CassandraPojoOutputFormat

2018-10-09 Thread GitBox
bmeriaux edited a comment on issue #6813: [FLINK-10440] Add a new CassandraPojoOutputFormat URL: https://github.com/apache/flink/pull/6813#issuecomment-428299042 Hi, I need you advice on the inheritance with `CassandraOutputFormatBase`, because `CassandraOutputFormatBase` constructor

[GitHub] bmeriaux commented on issue #6813: [FLINK-10440] Add a new CassandraPojoOutputFormat

2018-10-09 Thread GitBox
bmeriaux commented on issue #6813: [FLINK-10440] Add a new CassandraPojoOutputFormat URL: https://github.com/apache/flink/pull/6813#issuecomment-428299042 Hi, I need you advice on the inheritance with `CassandraOutputFormatBase`, because `CassandraOutputFormatBase` constructor need an

[jira] [Updated] (FLINK-10440) Add a CassandraPojoOutputFormat to write Pojo in Cassandra from batch

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10440: --- Labels: pull-request-available (was: ) > Add a CassandraPojoOutputFormat to write Pojo in

[jira] [Commented] (FLINK-10440) Add a CassandraPojoOutputFormat to write Pojo in Cassandra from batch

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643872#comment-16643872 ] ASF GitHub Bot commented on FLINK-10440: bmeriaux opened a new pull request #6813: [FLINK-10440]

[GitHub] bmeriaux opened a new pull request #6813: [FLINK-10440] Add a new CassandraPojoOutputFormat

2018-10-09 Thread GitBox
bmeriaux opened a new pull request #6813: [FLINK-10440] Add a new CassandraPojoOutputFormat URL: https://github.com/apache/flink/pull/6813 ## What is the purpose of the change *Create a new CassandraPojoOutputFormat to write Pojo in Cassandra in Batch* ## Brief change log

[jira] [Commented] (FLINK-10440) Add a CassandraPojoOutputFormat to write Pojo in Cassandra from batch

2018-10-09 Thread Benoit MERIAUX (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643840#comment-16643840 ] Benoit MERIAUX commented on FLINK-10440: Hi, could you assign this to me ? I have code ready

[jira] [Updated] (FLINK-10440) Add a CassandraPojoOutputFormat to write Pojo in Cassandra from batch

2018-10-09 Thread Benoit MERIAUX (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoit MERIAUX updated FLINK-10440: --- Fix Version/s: 1.7.0 > Add a CassandraPojoOutputFormat to write Pojo in Cassandra from

[jira] [Commented] (FLINK-9953) Active Kubernetes integration

2018-10-09 Thread JIN SUN (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643757#comment-16643757 ] JIN SUN commented on FLINK-9953: Thanks Till. > Active Kubernetes integration >

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643752#comment-16643752 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on issue #6483:

[GitHub] HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format

2018-10-09 Thread GitBox
HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#issuecomment-428274826 @fhueske Thanks for reviewing this PR. I can't agree more on offering a similar experience for both input formats (Parquet

[jira] [Commented] (FLINK-9697) Provide connector for Kafka 2.0.0

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643744#comment-16643744 ] ASF GitHub Bot commented on FLINK-9697: --- eliaslevy commented on a change in pull request #6703:

[jira] [Commented] (FLINK-9697) Provide connector for Kafka 2.0.0

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643745#comment-16643745 ] ASF GitHub Bot commented on FLINK-9697: --- eliaslevy commented on a change in pull request #6703:

[GitHub] eliaslevy commented on a change in pull request #6703: [FLINK-9697] Provide connector for Kafka 2.0.0

2018-10-09 Thread GitBox
eliaslevy commented on a change in pull request #6703: [FLINK-9697] Provide connector for Kafka 2.0.0 URL: https://github.com/apache/flink/pull/6703#discussion_r223779984 ## File path: flink-connectors/flink-connector-kafka-2.0/pom.xml ## @@ -0,0 +1,312 @@ + +

[GitHub] eliaslevy commented on a change in pull request #6703: [FLINK-9697] Provide connector for Kafka 2.0.0

2018-10-09 Thread GitBox
eliaslevy commented on a change in pull request #6703: [FLINK-9697] Provide connector for Kafka 2.0.0 URL: https://github.com/apache/flink/pull/6703#discussion_r223781101 ## File path:

[jira] [Resolved] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-09 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10469. - Resolution: Fixed Fixed via: - master: 1e0a77959d27031048c1c4079a504274c82cc173 - release-1.6:

[jira] [Commented] (FLINK-10469) FileChannel may not write the whole buffer in a single call to FileChannel.write(Buffer buffer)

2018-10-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643685#comment-16643685 ] ASF GitHub Bot commented on FLINK-10469: NicoK closed pull request #6788: [FLINK-10469][core]

[GitHub] NicoK closed pull request #6788: [FLINK-10469][core] make sure to always write the whole buffer to FileChannel

2018-10-09 Thread GitBox
NicoK closed pull request #6788: [FLINK-10469][core] make sure to always write the whole buffer to FileChannel URL: https://github.com/apache/flink/pull/6788 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Commented] (FLINK-10367) Avoid recursion stack overflow during releasing SingleInputGate

2018-10-09 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643673#comment-16643673 ] Nico Kruber commented on FLINK-10367: - As a rough sketch for option 3 (maybe this can be optimised):

[jira] [Commented] (FLINK-10441) Don't log warning when creating upload directory

2018-10-09 Thread Guibo Pan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16643667#comment-16643667 ] Guibo Pan commented on FLINK-10441: --- In RestServerEndpoint#createUploadDir, it seems that the

  1   2   3   4   5   >