[jira] [Commented] (FLINK-9936) Mesos resource manager unable to connect to master after failover

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567850#comment-16567850 ] ASF GitHub Bot commented on FLINK-9936: --- GJL commented on a change in pull request

[GitHub] GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-02 Thread GitBox
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207456451 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java ## @@ -894,17 +900,21 @@ p

[jira] [Assigned] (FLINK-10032) Flink SQL DATE_FORMAT Function throws Exception in SQL CLI

2018-08-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-10032: Assignee: Timo Walther > Flink SQL DATE_FORMAT Function throws Exception in SQL CLI > ---

[jira] [Updated] (FLINK-10032) Flink SQL DATE_FORMAT Function throws Exception in SQL CLI

2018-08-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10032: - Description: As Follows, but it works in sql program, and input string is expected result.   !

[jira] [Commented] (FLINK-10036) Flink's CSV output format is not consistent with the standard.

2018-08-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567839#comment-16567839 ] Timo Walther commented on FLINK-10036: -- [~wind_ljy] FLINK-9964 will only provide Se

[jira] [Commented] (FLINK-10039) FlinkKafkaProducer - Serializer Error

2018-08-02 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567834#comment-16567834 ] buptljy commented on FLINK-10039: - I think only ByteArrayDeserializer is supported accor

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

2018-08-02 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567824#comment-16567824 ] Zhenqiu Huang commented on FLINK-7243: -- [~najman] [~nssalian] Created a pull reques

[jira] [Commented] (FLINK-10020) Kinesis Consumer listShards should support more recoverable exceptions

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567823#comment-16567823 ] ASF GitHub Bot commented on FLINK-10020: tzulitai commented on a change in pull

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

2018-08-02 Thread GitBox
HuangZhenQiu commented on issue #6483: [Flink-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#issuecomment-410152524 @suez1224 Would you please have a look this PR? This is an aut

[GitHub] tzulitai commented on a change in pull request #6482: [FLINK-10020] [kinesis] Support recoverable exceptions in listShards.

2018-08-02 Thread GitBox
tzulitai commented on a change in pull request #6482: [FLINK-10020] [kinesis] Support recoverable exceptions in listShards. URL: https://github.com/apache/flink/pull/6482#discussion_r207447268 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/str

[jira] [Commented] (FLINK-9861) Add end-to-end test for reworked BucketingSink

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567814#comment-16567814 ] ASF GitHub Bot commented on FLINK-9861: --- tzulitai commented on a change in pull req

[GitHub] tzulitai commented on a change in pull request #6478: [FLINK-9861][tests] Add StreamingFileSink E2E test

2018-08-02 Thread GitBox
tzulitai commented on a change in pull request #6478: [FLINK-9861][tests] Add StreamingFileSink E2E test URL: https://github.com/apache/flink/pull/6478#discussion_r207438658 ## File path: flink-end-to-end-tests/flink-streaming-file-sink-test/src/main/java/StreamingFileSinkProgram.

[jira] [Commented] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567813#comment-16567813 ] Xingcan Cui commented on FLINK-9977: Hi [~twalthr] and [~fhueske], I've uploaded some

[jira] [Created] (FLINK-10039) FlinkKafkaProducer - Serializer Error

2018-08-02 Thread Akshay Nagpal (JIRA)
Akshay Nagpal created FLINK-10039: - Summary: FlinkKafkaProducer - Serializer Error Key: FLINK-10039 URL: https://issues.apache.org/jira/browse/FLINK-10039 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Attachment: Scala.jpg > Refine the docs for Table/SQL built-in functions > --

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Attachment: Java.jpg > Refine the docs for Table/SQL built-in functions > ---

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Attachment: SQL.jpg > Refine the docs for Table/SQL built-in functions >

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Attachment: (was: SQL.jpg) > Refine the docs for Table/SQL built-in functions > -

[jira] [Commented] (FLINK-9875) Add concurrent creation of execution job vertex

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567803#comment-16567803 ] ASF GitHub Bot commented on FLINK-9875: --- TisonKun commented on issue #6353: [FLINK-

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Attachment: (was: Java.jpg) > Refine the docs for Table/SQL built-in functions >

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Attachment: (was: Scala.jpg) > Refine the docs for Table/SQL built-in functions > ---

[GitHub] TisonKun commented on issue #6353: [FLINK-9875][runtime] Add concurrent creation of execution job vertex

2018-08-02 Thread GitBox
TisonKun commented on issue #6353: [FLINK-9875][runtime] Add concurrent creation of execution job vertex URL: https://github.com/apache/flink/pull/6353#issuecomment-410149936 Further discussion about parallelizing the creation of InputSplit goes to [FLINK-10038](https://issues.apache.org/j

[jira] [Updated] (FLINK-9977) Refine the docs for Table/SQL built-in functions

2018-08-02 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-9977: --- Attachment: SQL.jpg Scala.jpg Java.jpg > Refine the docs for Table/SQ

[GitHub] HuangZhenQiu opened a new pull request #6483: Add parquet input format

2018-08-02 Thread GitBox
HuangZhenQiu opened a new pull request #6483: Add parquet input format URL: https://github.com/apache/flink/pull/6483 *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink. To help the community review your contribution in the best poss

[jira] [Updated] (FLINK-10038) Parallel the creation of InputSplit if necessary

2018-08-02 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-10038: Labels: improvement inputformat parallel perfomance (was: ) > Parallel the creation of InputSplit if necessary >

[jira] [Updated] (FLINK-10038) Parallel the creation of InputSplit if necessary

2018-08-02 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-10038: Component/s: (was: Build System) > Parallel the creation of InputSplit if necessary >

[jira] [Updated] (FLINK-10038) Parallel the creation of InputSplit if necessary

2018-08-02 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-10038: Component/s: Build System > Parallel the creation of InputSplit if necessary > ---

[jira] [Commented] (FLINK-10038) Parallel the creation of InputSplit if necessary

2018-08-02 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567780#comment-16567780 ] 陈梓立 commented on FLINK-10038: - After taking a look of InputSplit and InputFormat, I find it

[jira] [Created] (FLINK-10038) Parallel the creation of InputSplit if necessary

2018-08-02 Thread JIRA
陈梓立 created FLINK-10038: --- Summary: Parallel the creation of InputSplit if necessary Key: FLINK-10038 URL: https://issues.apache.org/jira/browse/FLINK-10038 Project: Flink Issue Type: Improvement Af

[jira] [Commented] (FLINK-9899) Add more metrics to the Kinesis source connector

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567778#comment-16567778 ] ASF GitHub Bot commented on FLINK-9899: --- glaksh100 edited a comment on issue #6409:

[GitHub] glaksh100 edited a comment on issue #6409: [FLINK-9899][Kinesis Connecotr] Add comprehensive per-shard metrics to ShardConsumer

2018-08-02 Thread GitBox
glaksh100 edited a comment on issue #6409: [FLINK-9899][Kinesis Connecotr] Add comprehensive per-shard metrics to ShardConsumer URL: https://github.com/apache/flink/pull/6409#issuecomment-410145433 @zentol @tzulitai Sorry for the delay. Rebased the branch with latest master and added docum

[jira] [Commented] (FLINK-9899) Add more metrics to the Kinesis source connector

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1656#comment-1656 ] ASF GitHub Bot commented on FLINK-9899: --- glaksh100 commented on issue #6409: [FLINK

[GitHub] glaksh100 commented on issue #6409: [FLINK-9899][Kinesis Connecotr] Add comprehensive per-shard metrics to ShardConsumer

2018-08-02 Thread GitBox
glaksh100 commented on issue #6409: [FLINK-9899][Kinesis Connecotr] Add comprehensive per-shard metrics to ShardConsumer URL: https://github.com/apache/flink/pull/6409#issuecomment-410145433 @tzulitai Sorry for the delay. Rebased the branch with latest master and added documentation for th

[jira] [Commented] (FLINK-10037) Document details event time behavior in a single location

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567769#comment-16567769 ] ASF GitHub Bot commented on FLINK-10037: TisonKun commented on issue #6481: [FLI

[GitHub] TisonKun commented on issue #6481: [FLINK-10037] [Documentation] Add Event Time Details documentation page

2018-08-02 Thread GitBox
TisonKun commented on issue #6481: [FLINK-10037] [Documentation] Add Event Time Details documentation page URL: https://github.com/apache/flink/pull/6481#issuecomment-410143882 cc @zentol This is an automated message from th

[jira] [Updated] (FLINK-10037) Document details event time behavior in a single location

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10037: --- Labels: pull-request-available (was: ) > Document details event time behavior in a single l

[jira] [Commented] (FLINK-10037) Document details event time behavior in a single location

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567726#comment-16567726 ] ASF GitHub Bot commented on FLINK-10037: eliaslevy commented on issue #6481: [FL

[GitHub] eliaslevy commented on issue #6481: [FLINK-10037] [Documentation] Add Event Time Details documentation page

2018-08-02 Thread GitBox
eliaslevy commented on issue #6481: [FLINK-10037] [Documentation] Add Event Time Details documentation page URL: https://github.com/apache/flink/pull/6481#issuecomment-410135944 Done. This is an automated message from the Apa

[jira] [Comment Edited] (FLINK-10036) Flink's CSV output format is not consistent with the standard.

2018-08-02 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567721#comment-16567721 ] buptljy edited comment on FLINK-10036 at 8/3/18 3:39 AM: - This i

[jira] [Created] (FLINK-10037) Document details event time behavior in a single location

2018-08-02 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10037: -- Summary: Document details event time behavior in a single location Key: FLINK-10037 URL: https://issues.apache.org/jira/browse/FLINK-10037 Project: Flink Issue T

[jira] [Commented] (FLINK-10036) Flink's CSV output format is not consistent with the standard.

2018-08-02 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567721#comment-16567721 ] buptljy commented on FLINK-10036: - This is very similar to this [JIRA](https://issues.a

[jira] [Updated] (FLINK-10036) Flink's CSV output format is not consistent with the standard.

2018-08-02 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-10036: Description: h2. What's the problem Flink's CSV output format is not consistent with the standard

[GitHub] TisonKun commented on issue #6481: Add Event Time Details documentation page

2018-08-02 Thread GitBox
TisonKun commented on issue #6481: Add Event Time Details documentation page URL: https://github.com/apache/flink/pull/6481#issuecomment-410131208 FYI, the travis-ci failure is irrelevant about this PR. This is an automated me

[GitHub] TisonKun commented on issue #6481: Add Event Time Details documentation page

2018-08-02 Thread GitBox
TisonKun commented on issue #6481: Add Event Time Details documentation page URL: https://github.com/apache/flink/pull/6481#issuecomment-410131107 Hi @eliaslevy , thanks for you PR! It looks this PR is far more than a trivial work. Please take a look at the PULL_REQUEST_TEMPLATE as your

[jira] [Commented] (FLINK-9969) Unreasonable memory requirements to complete examples/batch/WordCount

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567700#comment-16567700 ] ASF GitHub Bot commented on FLINK-9969: --- TisonKun commented on a change in pull req

[GitHub] TisonKun commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger

2018-08-02 Thread GitBox
TisonKun commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger URL: https://github.com/apache/flink/pull/6479#discussion_r207428623 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/so

[jira] [Commented] (FLINK-9969) Unreasonable memory requirements to complete examples/batch/WordCount

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567692#comment-16567692 ] ASF GitHub Bot commented on FLINK-9969: --- TisonKun commented on a change in pull req

[GitHub] TisonKun commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger

2018-08-02 Thread GitBox
TisonKun commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger URL: https://github.com/apache/flink/pull/6479#discussion_r207425876 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/operators/so

[GitHub] TisonKun commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger

2018-08-02 Thread GitBox
TisonKun commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger URL: https://github.com/apache/flink/pull/6479#discussion_r207425876 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/operators/so

[jira] [Commented] (FLINK-9969) Unreasonable memory requirements to complete examples/batch/WordCount

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567691#comment-16567691 ] ASF GitHub Bot commented on FLINK-9969: --- TisonKun commented on a change in pull req

[jira] [Commented] (FLINK-10033) Let Task release reference to Invokable on shutdown

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567687#comment-16567687 ] ASF GitHub Bot commented on FLINK-10033: TisonKun commented on issue #6480: [FLI

[GitHub] TisonKun commented on issue #6480: [FLINK-10033] [runtime] Task releases reference to AbstractInvokable

2018-08-02 Thread GitBox
TisonKun commented on issue #6480: [FLINK-10033] [runtime] Task releases reference to AbstractInvokable URL: https://github.com/apache/flink/pull/6480#issuecomment-410124471 nice catch! memory leaks is one of the most terrible issues, this is helpful. +1 for merge

[jira] [Updated] (FLINK-10036) Flink's CSV output format is not consistent with the standard.

2018-08-02 Thread Caizhi Weng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-10036: Description: h2. What's the problem Flink's CSV output format is not consistent with the standard

[jira] [Created] (FLINK-10036) Flink's CSV output format is not consistent with the standard.

2018-08-02 Thread Caizhi Weng (JIRA)
Caizhi Weng created FLINK-10036: --- Summary: Flink's CSV output format is not consistent with the standard. Key: FLINK-10036 URL: https://issues.apache.org/jira/browse/FLINK-10036 Project: Flink

[jira] [Comment Edited] (FLINK-5315) Support distinct aggregations in table api

2018-08-02 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567666#comment-16567666 ] Rong Rong edited comment on FLINK-5315 at 8/3/18 1:25 AM: -- [~heq

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

2018-08-02 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567666#comment-16567666 ] Rong Rong commented on FLINK-5315: -- [~hequn8128], [~fhueske] I am actually close to fini

[GitHub] tweise opened a new pull request #6482: [FLINK-10020] [kinesis] Support recoverable exceptions in listShards.

2018-08-02 Thread GitBox
tweise opened a new pull request #6482: [FLINK-10020] [kinesis] Support recoverable exceptions in listShards. URL: https://github.com/apache/flink/pull/6482 This change fixes the retry behavior of listShards to match what getRecords already supports. Importantly this will prevent the subta

[jira] [Commented] (FLINK-10020) Kinesis Consumer listShards should support more recoverable exceptions

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567647#comment-16567647 ] ASF GitHub Bot commented on FLINK-10020: tweise opened a new pull request #6482:

[jira] [Updated] (FLINK-10020) Kinesis Consumer listShards should support more recoverable exceptions

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10020: --- Labels: pull-request-available (was: ) > Kinesis Consumer listShards should support more re

[GitHub] eliaslevy opened a new pull request #6481: Add Event Time Details documentation page

2018-08-02 Thread GitBox
eliaslevy opened a new pull request #6481: Add Event Time Details documentation page URL: https://github.com/apache/flink/pull/6481 *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink. To help the community review your contribution i

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

2018-08-02 Thread Zhenqiu Huang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567546#comment-16567546 ] Zhenqiu Huang commented on FLINK-7243: -- [~najman] [~nssalian] I created a diff for

[jira] [Comment Edited] (FLINK-7642) Upgrade maven surefire plugin to 2.21.0

2018-08-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16433258#comment-16433258 ] Ted Yu edited comment on FLINK-7642 at 8/2/18 8:28 PM: --- SUREFIRE-14

[jira] [Updated] (FLINK-9924) Upgrade zookeeper to 3.4.13

2018-08-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9924: -- Description: zookeeper 3.4.13 is being released. ZOOKEEPER-2959 fixes data loss when observer is used ZOOKEEP

[jira] [Commented] (FLINK-10035) ConcurrentModificationException with flink-metrics-slf4j

2018-08-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567424#comment-16567424 ] Chesnay Schepler commented on FLINK-10035: -- This isn't really an issue, and app

[jira] [Created] (FLINK-10035) ConcurrentModificationException with flink-metrics-slf4j

2018-08-02 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10035: --- Summary: ConcurrentModificationException with flink-metrics-slf4j Key: FLINK-10035 URL: https://issues.apache.org/jira/browse/FLINK-10035 Project: Flink Issue

[jira] [Closed] (FLINK-9950) Handle migration to Gitbox

2018-08-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9950. --- Resolution: Fixed > Handle migration to Gitbox > -- > >

[jira] [Closed] (FLINK-10034) Update website pages

2018-08-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10034. Resolution: Fixed cc2041d3bf80c2fb91cedb6ec0b29ea10a9b4e77 > Update website pages > -

[jira] [Updated] (FLINK-10034) Update website pages

2018-08-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10034: - Description: Several pages of the project website still refer to the old repositories.

[jira] [Updated] (FLINK-10034) Update website pages

2018-08-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10034: - Summary: Update website pages (was: Update community page) > Update website pages > ---

[jira] [Created] (FLINK-10034) Update community page

2018-08-02 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10034: Summary: Update community page Key: FLINK-10034 URL: https://issues.apache.org/jira/browse/FLINK-10034 Project: Flink Issue Type: Sub-task

[jira] [Reopened] (FLINK-9950) Handle migration to Gitbox

2018-08-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-9950: - > Handle migration to Gitbox > -- > > Key: FLINK-9950

[jira] [Commented] (FLINK-10033) Let Task release reference to Invokable on shutdown

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567385#comment-16567385 ] ASF GitHub Bot commented on FLINK-10033: StephanEwen opened a new pull request #

[jira] [Updated] (FLINK-10033) Let Task release reference to Invokable on shutdown

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10033: --- Labels: pull-request-available (was: ) > Let Task release reference to Invokable on shutdow

[GitHub] StephanEwen opened a new pull request #6480: [FLINK-10033] [runtime] Task releases reference to AbstractInvokable

2018-08-02 Thread GitBox
StephanEwen opened a new pull request #6480: [FLINK-10033] [runtime] Task releases reference to AbstractInvokable URL: https://github.com/apache/flink/pull/6480 ## What is the purpose of the change References to Task objects may under some conditions linger longer than for the lifet

[jira] [Created] (FLINK-10033) Let Task release reference to Invokable on shutdown

2018-08-02 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-10033: Summary: Let Task release reference to Invokable on shutdown Key: FLINK-10033 URL: https://issues.apache.org/jira/browse/FLINK-10033 Project: Flink Issue Typ

[jira] [Commented] (FLINK-9969) Unreasonable memory requirements to complete examples/batch/WordCount

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567291#comment-16567291 ] ASF GitHub Bot commented on FLINK-9969: --- zentol commented on a change in pull reque

[jira] [Commented] (FLINK-9969) Unreasonable memory requirements to complete examples/batch/WordCount

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567292#comment-16567292 ] ASF GitHub Bot commented on FLINK-9969: --- zentol commented on a change in pull reque

[GitHub] zentol commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger

2018-08-02 Thread GitBox
zentol commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger URL: https://github.com/apache/flink/pull/6479#discussion_r207319672 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort

[GitHub] zentol commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger

2018-08-02 Thread GitBox
zentol commented on a change in pull request #6479: [FLINK-9969][batch] Dispose InMemorySorters created by the UnilateralSortMerger URL: https://github.com/apache/flink/pull/6479#discussion_r207319425 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort

[jira] [Resolved] (FLINK-9947) Document unified table sources/sinks/formats

2018-08-02 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-9947. - Resolution: Fixed Fix Version/s: 1.6.0 Fixed in 1.7.0: dacc16b4fa6db6abfdbf73b99f26a5fd36b

[jira] [Commented] (FLINK-9947) Document unified table sources/sinks/formats

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567119#comment-16567119 ] ASF GitHub Bot commented on FLINK-9947: --- asfgit closed pull request #6456: [FLINK-9

[GitHub] asfgit closed pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats

2018-08-02 Thread GitBox
asfgit closed pull request #6456: [FLINK-9947] [docs] Document unified table sources/sinks/formats URL: https://github.com/apache/flink/pull/6456 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 provenance: As

[jira] [Commented] (FLINK-9936) Mesos resource manager unable to connect to master after failover

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567113#comment-16567113 ] ASF GitHub Bot commented on FLINK-9936: --- tillrohrmann commented on a change in pull

[GitHub] tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-02 Thread GitBox
tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207306976 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java ## @@

[jira] [Updated] (FLINK-9363) Bump up the Jackson version

2018-08-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9363: -- Description: CVE's for Jackson: CVE-2017-17485 CVE-2018-5968 CVE-2018-7489 We can upgrade to 2.9.5 was: C

[jira] [Commented] (FLINK-9936) Mesos resource manager unable to connect to master after failover

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567088#comment-16567088 ] ASF GitHub Bot commented on FLINK-9936: --- tillrohrmann commented on a change in pull

[jira] [Assigned] (FLINK-9861) Add end-to-end test for reworked BucketingSink

2018-08-02 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-9861: - Assignee: Kostas Kloudas > Add end-to-end test for reworked BucketingSink >

[jira] [Commented] (FLINK-9936) Mesos resource manager unable to connect to master after failover

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567084#comment-16567084 ] ASF GitHub Bot commented on FLINK-9936: --- tillrohrmann commented on a change in pull

[jira] [Assigned] (FLINK-9861) Add end-to-end test for reworked BucketingSink

2018-08-02 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-9861: - Assignee: Chesnay Schepler (was: Kostas Kloudas) > Add end-to-end test for reworked Buc

[jira] [Commented] (FLINK-9936) Mesos resource manager unable to connect to master after failover

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567082#comment-16567082 ] ASF GitHub Bot commented on FLINK-9936: --- tillrohrmann commented on a change in pull

[jira] [Commented] (FLINK-9936) Mesos resource manager unable to connect to master after failover

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567085#comment-16567085 ] ASF GitHub Bot commented on FLINK-9936: --- tillrohrmann commented on a change in pull

[jira] [Commented] (FLINK-9936) Mesos resource manager unable to connect to master after failover

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567083#comment-16567083 ] ASF GitHub Bot commented on FLINK-9936: --- tillrohrmann commented on a change in pull

[jira] [Commented] (FLINK-9936) Mesos resource manager unable to connect to master after failover

2018-08-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16567081#comment-16567081 ] ASF GitHub Bot commented on FLINK-9936: --- tillrohrmann commented on a change in pull

[GitHub] tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-02 Thread GitBox
tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207295725 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java ## @@

[GitHub] tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-02 Thread GitBox
tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207302752 ## File path: flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerTest.java ##

[GitHub] tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-02 Thread GitBox
tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207302992 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java ## @@ -894,17 +9

[GitHub] tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-02 Thread GitBox
tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207294014 ## File path: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java ## @@

[GitHub] tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-02 Thread GitBox
tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207294205 ## File path: flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerTest.java ##

[GitHub] tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP

2018-08-02 Thread GitBox
tillrohrmann commented on a change in pull request #6464: [FLINK-9936][mesos] WIP URL: https://github.com/apache/flink/pull/6464#discussion_r207293251 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java ## @@ -894,17 +9

[jira] [Closed] (FLINK-10029) Refactor the code for better separation of concerns.

2018-08-02 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-10029. -- Resolution: Fixed Merged on master with 1b0baa162bd87efd69040eb787de8d6624f14c85 and on releas

  1   2   3   4   >