[jira] [Created] (FLINK-10104) Job super slow to start

2018-08-08 Thread Florian (JIRA)
Florian created FLINK-10104: --- Summary: Job super slow to start Key: FLINK-10104 URL: https://issues.apache.org/jira/browse/FLINK-10104 Project: Flink Issue Type: Bug Affects Versions: 1.5.2

[jira] [Commented] (FLINK-10059) Add LTRIM supported in Table API and SQL

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

[GitHub] hequn8128 commented on a change in pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL

2018-08-08 Thread GitBox
hequn8128 commented on a change in pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6494#discussion_r208779211 ## File path:

[jira] [Commented] (FLINK-7829) Remove (or at least deprecate) DataStream.writeToFile/Csv

2018-08-08 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574080#comment-16574080 ] zhangminglei commented on FLINK-7829: - [~aljoscha] We should replace make the use of

[jira] [Updated] (FLINK-9675) Avoid FileInputStream/FileOutputStream

2018-08-08 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei updated FLINK-9675: Affects Version/s: 1.4.1 1.4.2 1.5.1 > Avoid

[jira] [Updated] (FLINK-9675) Avoid FileInputStream/FileOutputStream

2018-08-08 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei updated FLINK-9675: Fix Version/s: 1.7.0 > Avoid FileInputStream/FileOutputStream >

[jira] [Commented] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

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

[GitHub] medcv commented on issue #6259: [FLINK-9679] Implement AvroSerializationSchema

2018-08-08 Thread GitBox
medcv commented on issue #6259: [FLINK-9679] Implement AvroSerializationSchema URL: https://github.com/apache/flink/pull/6259#issuecomment-411629081 @dawidwys Thanks for the review. I will do my best to address your comments on next commit and will add tests when the implementations got

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

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574213#comment-16574213 ] ASF GitHub Bot commented on FLINK-10020: tweise commented on issue #6482: [FLINK-10020]

[GitHub] tweise commented on issue #6482: [FLINK-10020] [kinesis] Support recoverable exceptions in listShards.

2018-08-08 Thread GitBox
tweise commented on issue #6482: [FLINK-10020] [kinesis] Support recoverable exceptions in listShards. URL: https://github.com/apache/flink/pull/6482#issuecomment-411622174 @tzulitai PTAL This is an automated message from

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

2018-08-08 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

[GitHub] maqingxiang commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8

2018-08-08 Thread GitBox
maqingxiang commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8 URL: https://github.com/apache/flink/pull/5304#discussion_r208790526 ## File path:

[jira] [Updated] (FLINK-9849) Create hbase connector for hbase version to 2.0.1

2018-08-08 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9849: -- Description: Currently hbase 1.4.3 is used for hbase connector. We should create connector for hbase 2.0.1

[jira] [Created] (FLINK-10105) Test failure because of jobmanager.execution.failover-strategy is outdated

2018-08-08 Thread vinoyang (JIRA)
vinoyang created FLINK-10105: Summary: Test failure because of jobmanager.execution.failover-strategy is outdated Key: FLINK-10105 URL: https://issues.apache.org/jira/browse/FLINK-10105 Project: Flink

[jira] [Commented] (FLINK-10056) Add testRequestNextInputSplit

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574243#comment-16574243 ] ASF GitHub Bot commented on FLINK-10056: TisonKun commented on issue #6490: [FLINK-10056] [test]

[GitHub] TisonKun commented on issue #6490: [FLINK-10056] [test] Add JobMasterTest#testRequestNextInputSplit

2018-08-08 Thread GitBox
TisonKun commented on issue #6490: [FLINK-10056] [test] Add JobMasterTest#testRequestNextInputSplit URL: https://github.com/apache/flink/pull/6490#issuecomment-411627844 cc @aljoscha @zentol This is an automated message

[GitHub] TisonKun commented on issue #6345: [FLINK-9869][runtime] Send PartitionInfo in batch to Improve perfornance

2018-08-08 Thread GitBox
TisonKun commented on issue #6345: [FLINK-9869][runtime] Send PartitionInfo in batch to Improve perfornance URL: https://github.com/apache/flink/pull/6345#issuecomment-411627672 cc @GJL @twalthr This is an automated message

[jira] [Commented] (FLINK-9869) Send PartitionInfo in batch to Improve perfornance

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574240#comment-16574240 ] ASF GitHub Bot commented on FLINK-9869: --- TisonKun commented on issue #6345: [FLINK-9869][runtime]

[jira] [Commented] (FLINK-9679) Implement AvroSerializationSchema

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574250#comment-16574250 ] ASF GitHub Bot commented on FLINK-9679: --- medcv commented on issue #6259: [FLINK-9679] Implement

[jira] [Commented] (FLINK-9964) Add a CSV table format factory

2018-08-08 Thread buptljy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16574323#comment-16574323 ] buptljy commented on FLINK-9964: [~twalthr] Should we support json schema for csv format? If json schema

[GitHub] asfgit closed pull request #6506: [FLINK-10073] [sql-client] Allow setting a restart strategy in SQL Client

2018-08-08 Thread GitBox
asfgit closed pull request #6506: [FLINK-10073] [sql-client] Allow setting a restart strategy in SQL Client URL: https://github.com/apache/flink/pull/6506 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-10073) Allow setting a restart strategy in SQL Client

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572727#comment-16572727 ] ASF GitHub Bot commented on FLINK-10073: asfgit closed pull request #6506: [FLINK-10073]

[jira] [Resolved] (FLINK-10073) Allow setting a restart strategy in SQL Client

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

[jira] [Commented] (FLINK-10063) Jepsen: Automatically restart Mesos Processes

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

[GitHub] GJL commented on a change in pull request #6496: [FLINK-10063][tests] Use runit to supervise mesos processes.

2018-08-08 Thread GitBox
GJL commented on a change in pull request #6496: [FLINK-10063][tests] Use runit to supervise mesos processes. URL: https://github.com/apache/flink/pull/6496#discussion_r208471471 ## File path: flink-jepsen/src/jepsen/flink/mesos.clj ## @@ -24,11 +24,35 @@

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

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

[jira] [Commented] (FLINK-10073) Allow setting a restart strategy in SQL Client

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572724#comment-16572724 ] ASF GitHub Bot commented on FLINK-10073: twalthr commented on issue #6506: [FLINK-10073]

[GitHub] twalthr commented on issue #6506: [FLINK-10073] [sql-client] Allow setting a restart strategy in SQL Client

2018-08-08 Thread GitBox
twalthr commented on issue #6506: [FLINK-10073] [sql-client] Allow setting a restart strategy in SQL Client URL: https://github.com/apache/flink/pull/6506#issuecomment-411297539 @dawidwys Thanks, merging... This is an

[jira] [Commented] (FLINK-7205) Add UUID supported in TableAPI/SQL

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572732#comment-16572732 ] ASF GitHub Bot commented on FLINK-7205: --- buptljy commented on issue #6381: [FLINK-7205] [table] Add

[GitHub] buptljy commented on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi

2018-08-08 Thread GitBox
buptljy commented on issue #6381: [FLINK-7205] [table] Add UUID supported in SQL and TableApi URL: https://github.com/apache/flink/pull/6381#issuecomment-411299151 @hequn8128 ok.it's done. This is an automated message from

[jira] [Resolved] (FLINK-9438) Add documentation for (Registry)AvroDeserializationSchema

2018-08-08 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-9438. - Resolution: Fixed > Add documentation for (Registry)AvroDeserializationSchema >

[jira] [Commented] (FLINK-9438) Add documentation for (Registry)AvroDeserializationSchema

2018-08-08 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572805#comment-16572805 ] Dawid Wysakowicz commented on FLINK-9438: - Fixed in master via:

[jira] [Commented] (FLINK-9933) Simplify taskmanager memory default values

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572909#comment-16572909 ] ASF GitHub Bot commented on FLINK-9933: --- yanghua commented on issue #6444: [FLINK-9933] Simplify

[jira] [Created] (FLINK-10100) Optimizer pushes partitioning past Null-Filter

2018-08-08 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-10100: - Summary: Optimizer pushes partitioning past Null-Filter Key: FLINK-10100 URL: https://issues.apache.org/jira/browse/FLINK-10100 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-8483) Implement and expose outer joins

2018-08-08 Thread Florian Schmidt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-8483: -- Assignee: Florian Schmidt > Implement and expose outer joins >

[jira] [Commented] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

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

[GitHub] NicoK commented on issue #6431: [FLINK-9972][flip6] Handle debug memory logging in flip6

2018-08-08 Thread GitBox
NicoK commented on issue #6431: [FLINK-9972][flip6] Handle debug memory logging in flip6 URL: https://github.com/apache/flink/pull/6431#issuecomment-411352576 merging to `release-1.5` and `release-1.6` ... This is an

[GitHub] yanghua commented on issue #6444: [FLINK-9933] Simplify taskmanager memory default values

2018-08-08 Thread GitBox
yanghua commented on issue #6444: [FLINK-9933] Simplify taskmanager memory default values URL: https://github.com/apache/flink/pull/6444#issuecomment-411340236 @dawidwys can you review this PR? This is an automated message

[GitHub] yanghua commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

2018-08-08 Thread GitBox
yanghua commented on issue #6475: [FLINK-10012] Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API URL: https://github.com/apache/flink/pull/6475#issuecomment-411340866 @StefanRRichter can you review this PR?

[jira] [Commented] (FLINK-10012) Add setStreamTimeCharacteristic/getStreamTimeCharacteristic for Python API

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572911#comment-16572911 ] ASF GitHub Bot commented on FLINK-10012: yanghua commented on issue #6475: [FLINK-10012] Add

[jira] [Updated] (FLINK-8482) Implement and expose option to use min / max / left / right timestamp for joined streamrecords

2018-08-08 Thread Florian Schmidt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-8482: --- Fix Version/s: 1.7.0 > Implement and expose option to use min / max / left / right timestamp

[jira] [Updated] (FLINK-8483) Implement and expose outer joins

2018-08-08 Thread Florian Schmidt (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt updated FLINK-8483: --- Fix Version/s: 1.7.0 > Implement and expose outer joins > >

[GitHub] azagrebin commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8

2018-08-08 Thread GitBox
azagrebin commented on a change in pull request #5304: [FLINK-8290]Modify clientId to groupId in flink-connector-kafka-0.8 URL: https://github.com/apache/flink/pull/5304#discussion_r208522780 ## File path:

[jira] [Commented] (FLINK-9972) Debug memory logging not working

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572965#comment-16572965 ] ASF GitHub Bot commented on FLINK-9972: --- NicoK commented on issue #6431: [FLINK-9972][flip6] Handle

[GitHub] TisonKun commented on issue #6339: [FLINK-9859] [runtime] More Akka config

2018-08-08 Thread GitBox
TisonKun commented on issue #6339: [FLINK-9859] [runtime] More Akka config URL: https://github.com/apache/flink/pull/6339#issuecomment-411299625 @tillrohrmann thanks for your patient review and guide. The PR goes a bit away from its original purpose so I modify the JIRA message to

[GitHub] dawidwys commented on issue #6078: [FLINK-9438] Add documentation for AvroDeserializationSchema

2018-08-08 Thread GitBox
dawidwys commented on issue #6078: [FLINK-9438] Add documentation for AvroDeserializationSchema URL: https://github.com/apache/flink/pull/6078#issuecomment-411312346 thanks @tzulitai, merging This is an automated message

[GitHub] dawidwys closed pull request #6078: [FLINK-9438] Add documentation for AvroDeserializationSchema

2018-08-08 Thread GitBox
dawidwys closed pull request #6078: [FLINK-9438] Add documentation for AvroDeserializationSchema URL: https://github.com/apache/flink/pull/6078 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-10094) Always backup default config for end-to-end tests

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572856#comment-16572856 ] ASF GitHub Bot commented on FLINK-10094: zentol closed pull request #6518: [FLINK-10094][tests]

[jira] [Closed] (FLINK-10094) Always backup default config for end-to-end tests

2018-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10094. Resolution: Fixed master: f2bf1f5d4cc12a04e36d165ec34e5b8dd716dfda 1.6:

[GitHub] zentol closed pull request #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4

2018-08-08 Thread GitBox
zentol closed pull request #6517: [FLINK-9446][docs] Update savepoint compatibility table for 1.4 URL: https://github.com/apache/flink/pull/6517 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-9859) More Akka config

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572737#comment-16572737 ] ASF GitHub Bot commented on FLINK-9859: --- TisonKun commented on issue #6339: [FLINK-9859] [runtime]

[jira] [Commented] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572784#comment-16572784 ] ASF GitHub Bot commented on FLINK-9559: --- yanghua commented on issue #6519: [FLINK-9559] [table] The

[GitHub] yanghua commented on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR

2018-08-08 Thread GitBox
yanghua commented on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR URL: https://github.com/apache/flink/pull/6519#issuecomment-411309954 +1 This is an automated

[jira] [Commented] (FLINK-9438) Add documentation for (Registry)AvroDeserializationSchema

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572795#comment-16572795 ] ASF GitHub Bot commented on FLINK-9438: --- dawidwys closed pull request #6078: [FLINK-9438] Add

[jira] [Commented] (FLINK-9438) Add documentation for (Registry)AvroDeserializationSchema

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572794#comment-16572794 ] ASF GitHub Bot commented on FLINK-9438: --- dawidwys commented on issue #6078: [FLINK-9438] Add

[jira] [Commented] (FLINK-9446) Compatibility table not up-to-date

2018-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572865#comment-16572865 ] Chesnay Schepler commented on FLINK-9446: - 1.4 entry added in: * master:

[jira] [Updated] (FLINK-9918) Outsource fastutil dependency to flink-shading.

2018-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9918: Fix Version/s: (was: 1.6.0) > Outsource fastutil dependency to flink-shading. >

[jira] [Closed] (FLINK-9918) Outsource fastutil dependency to flink-shading.

2018-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9918. --- Resolution: Workaround > Outsource fastutil dependency to flink-shading. >

[jira] [Reopened] (FLINK-9918) Outsource fastutil dependency to flink-shading.

2018-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-9918: - Removing fixVersion. > Outsource fastutil dependency to flink-shading. >

[jira] [Updated] (FLINK-9859) More Akka config

2018-08-08 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-9859: --- Summary: More Akka config (was: Distinguish TM akka config with JM config) > More Akka config > >

[jira] [Updated] (FLINK-9859) More Akka config

2018-08-08 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-9859: --- Description: Add more akka config options. (was: ... increase the number of akka threads on JM, to improve its

[GitHub] zentol closed pull request #6518: [FLINK-10094][tests] Always backup config before running test

2018-08-08 Thread GitBox
zentol closed pull request #6518: [FLINK-10094][tests] Always backup config before running test URL: https://github.com/apache/flink/pull/6518 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-9739) Regression in supported filesystems for RocksDB

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572755#comment-16572755 ] ASF GitHub Bot commented on FLINK-9739: --- sampathBhat commented on issue #6452: [FLINK-9739]

[GitHub] sampathBhat commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB

2018-08-08 Thread GitBox
sampathBhat commented on issue #6452: [FLINK-9739] Regression in supported filesystems for RocksDB URL: https://github.com/apache/flink/pull/6452#issuecomment-411303375 Any Update on this PR? This is an automated message

[GitHub] yanghua commented on a change in pull request #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream

2018-08-08 Thread GitBox
yanghua commented on a change in pull request #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream URL: https://github.com/apache/flink/pull/6521#discussion_r208473676 ## File path:

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

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

[GitHub] yanghua commented on a change in pull request #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream

2018-08-08 Thread GitBox
yanghua commented on a change in pull request #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream URL: https://github.com/apache/flink/pull/6521#discussion_r208473640 ## File path:

[jira] [Commented] (FLINK-9446) Compatibility table not up-to-date

2018-08-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16572862#comment-16572862 ] ASF GitHub Bot commented on FLINK-9446: --- zentol closed pull request #6517: [FLINK-9446][docs]

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

2018-08-08 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-9969. - Confirmed on EMR cluster that problem is gone > Unreasonable memory requirements to complete

[jira] [Updated] (FLINK-9976) Odd signatures for streaming file sink format builders

2018-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9976: Issue Type: Improvement (was: Bug) > Odd signatures for streaming file sink format

[jira] [Reopened] (FLINK-9976) Odd signatures for streaming file sink format builders

2018-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-9976: - > Odd signatures for streaming file sink format builders >

[jira] [Reopened] (FLINK-9792) Cannot add html tags in options description

2018-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-9792: - > Cannot add html tags in options description > ---

[jira] [Closed] (FLINK-9792) Cannot add html tags in options description

2018-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9792. --- Resolution: Fixed > Cannot add html tags in options description >

[jira] [Updated] (FLINK-9792) Cannot add html tags in options description

2018-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9792: Issue Type: Improvement (was: Bug) > Cannot add html tags in options description >

[jira] [Closed] (FLINK-9976) Odd signatures for streaming file sink format builders

2018-08-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9976. --- Resolution: Fixed > Odd signatures for streaming file sink format builders >

[GitHub] hequn8128 commented on a change in pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL

2018-08-08 Thread GitBox
hequn8128 commented on a change in pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6494#discussion_r208608871 ## File path:

[GitHub] hequn8128 commented on a change in pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL

2018-08-08 Thread GitBox
hequn8128 commented on a change in pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6494#discussion_r208608782 ## File path: docs/dev/table/tableApi.md ## @@ -2510,6 +2510,19 @@ STRING.toBase64()

[GitHub] hequn8128 commented on a change in pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL

2018-08-08 Thread GitBox
hequn8128 commented on a change in pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6494#discussion_r208608751 ## File path: docs/dev/table/sql.md ## @@ -1873,6 +1873,18 @@ TO_BASE64(string)

[GitHub] hequn8128 commented on a change in pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL

2018-08-08 Thread GitBox
hequn8128 commented on a change in pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6494#discussion_r208608850 ## File path:

[GitHub] hequn8128 commented on a change in pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL

2018-08-08 Thread GitBox
hequn8128 commented on a change in pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6494#discussion_r208608793 ## File path: docs/dev/table/tableApi.md ## @@ -4062,6 +4075,19 @@ STRING.toBase64()

[GitHub] hequn8128 commented on a change in pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL

2018-08-08 Thread GitBox
hequn8128 commented on a change in pull request #6494: [FLINK-10059] [table] Add LTRIM supported in Table API and SQL URL: https://github.com/apache/flink/pull/6494#discussion_r208608819 ## File path:

[jira] [Commented] (FLINK-10059) Add LTRIM supported in Table API and SQL

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

[jira] [Created] (FLINK-10103) Refine built-in-functions docs for SQL

2018-08-08 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-10103: --- Summary: Refine built-in-functions docs for SQL Key: FLINK-10103 URL: https://issues.apache.org/jira/browse/FLINK-10103 Project: Flink Issue Type: Improvement

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

2018-08-08 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: --- Description: There exist some syntax errors or inconsistencies in documents and Scala docs of the

[jira] [Commented] (FLINK-9867) Extend release notes for Flink 1.6

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

[GitHub] tillrohrmann opened a new pull request #6526: [FLINK-9867] Extend release notes for Flink 1.6 and empty file for 1.7

2018-08-08 Thread GitBox
tillrohrmann opened a new pull request #6526: [FLINK-9867] Extend release notes for Flink 1.6 and empty file for 1.7 URL: https://github.com/apache/flink/pull/6526 Extend the release notes for Flink 1.6 which can be found in /docs/release-notes/flink-1.6.md. Add an empty release

[jira] [Commented] (FLINK-9664) FlinkML Quickstart Loading Data section example doesn't work as described

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

[GitHub] walterddr commented on a change in pull request #6425: [FLINK-9664][Doc] fixing documentation in ML quick start

2018-08-08 Thread GitBox
walterddr commented on a change in pull request #6425: [FLINK-9664][Doc] fixing documentation in ML quick start URL: https://github.com/apache/flink/pull/6425#discussion_r208629086 ## File path: docs/dev/libs/ml/quickstart.md ## @@ -129,6 +129,10 @@ and the [test set

[jira] [Commented] (FLINK-4542) Add MULTISET operations

2018-08-08 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16573387#comment-16573387 ] Timo Walther commented on FLINK-4542: - [~Sergey Nuyanzin] No problem. Just wanted to give you an

[jira] [Commented] (FLINK-9853) add hex support in table api and sql

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

[jira] [Commented] (FLINK-10063) Jepsen: Automatically restart Mesos Processes

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

[jira] [Commented] (FLINK-6895) Add STR_TO_DATE supported in SQL

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

[GitHub] twalthr commented on a change in pull request #6359: [FLINK-6895][table]Add STR_TO_DATE supported in SQL

2018-08-08 Thread GitBox
twalthr commented on a change in pull request #6359: [FLINK-6895][table]Add STR_TO_DATE supported in SQL URL: https://github.com/apache/flink/pull/6359#discussion_r208613255 ## File path:

[jira] [Commented] (FLINK-10103) Refine built-in-functions docs for SQL

2018-08-08 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16573350#comment-16573350 ] Xingcan Cui commented on FLINK-10103: - Yes, you are right. Thanks for reminding me of that,

[jira] [Closed] (FLINK-10103) Refine built-in-functions docs for SQL

2018-08-08 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui closed FLINK-10103. --- Resolution: Duplicate > Refine built-in-functions docs for SQL >

[GitHub] hequn8128 commented on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR

2018-08-08 Thread GitBox
hequn8128 commented on issue #6519: [FLINK-9559] [table] The type of a union of CHAR columns of different lengths should be VARCHAR URL: https://github.com/apache/flink/pull/6519#issuecomment-411444753 @twalthr Thanks a lot for your review. You are right. This change will break

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

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

[GitHub] walterddr commented on a change in pull request #6337: [FLINK-9853] [table] Add HEX support

2018-08-08 Thread GitBox
walterddr commented on a change in pull request #6337: [FLINK-9853] [table] Add HEX support URL: https://github.com/apache/flink/pull/6337#discussion_r208630486 ## File path: docs/dev/table/sql.md ## @@ -1664,6 +1664,17 @@ BIN(numeric) + + +{%

[GitHub] GJL commented on a change in pull request #6496: [FLINK-10063][tests] Use runit to supervise mesos processes.

2018-08-08 Thread GitBox
GJL commented on a change in pull request #6496: [FLINK-10063][tests] Use runit to supervise mesos processes. URL: https://github.com/apache/flink/pull/6496#discussion_r208608118 ## File path: flink-jepsen/docker/Dockerfile-db ## @@ -35,5 +35,12 @@ RUN mkdir -p

[jira] [Commented] (FLINK-10063) Jepsen: Automatically restart Mesos Processes

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

  1   2   3   >