[jira] [Commented] (FLINK-3875) Add a TableSink for Elasticsearch

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

[GitHub] asfgit closed pull request #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch

2018-10-01 Thread GitBox
asfgit closed pull request #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch URL: https://github.com/apache/flink/pull/6611 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-10447) Create Bucketing Table Sink.

2018-10-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633751#comment-16633751 ] ASF GitHub Bot commented on FLINK-10447: dawidwys commented on issue #6769: [FLINK-10447][HDFS

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

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

2018-10-01 Thread Yun Gao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-10469: --- Assignee: Yun Gao > FileChannel may not write the whole buffer in a single call to >

[GitHub] dawidwys commented on issue #6769: [FLINK-10447][HDFS Connector] Create Bucketing Table Sink

2018-10-01 Thread GitBox
dawidwys commented on issue #6769: [FLINK-10447][HDFS Connector] Create Bucketing Table Sink URL: https://github.com/apache/flink/pull/6769#issuecomment-425840104 Hi @SuXingLee, thank you very much for your contribution. I think having a table sink for file system would be a great

[GitHub] pnowojski commented on a change in pull request #6741: [FLINK-9712][table, docs] Document processing time Temporal Table Joins

2018-10-01 Thread GitBox
pnowojski commented on a change in pull request #6741: [FLINK-9712][table,docs] Document processing time Temporal Table Joins URL: https://github.com/apache/flink/pull/6741#discussion_r221540451 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -0,0 +1,263

[jira] [Commented] (FLINK-10466) flink-yarn-tests should depend flink-dist

2018-10-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633748#comment-16633748 ] Chesnay Schepler commented on FLINK-10466: -- if flink-yarn-tests does indeed rely on flink-dist

[jira] [Commented] (FLINK-9715) Support versioned joins with event time

2018-10-01 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633747#comment-16633747 ] Piotr Nowojski commented on FLINK-9715: --- [~hequn8128] probably something like that would be

[jira] [Commented] (FLINK-10340) Add Cosh math function supported in Table API and SQL

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

[GitHub] pnowojski commented on a change in pull request #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL

2018-10-01 Thread GitBox
pnowojski commented on a change in pull request #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6700#discussion_r221537661 ## File path: docs/dev/table/functions.md ## @@ -1274,6 +1274,17 @@

[jira] [Commented] (FLINK-3875) Add a TableSink for Elasticsearch

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

[GitHub] twalthr commented on issue #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch

2018-10-01 Thread GitBox
twalthr commented on issue #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch URL: https://github.com/apache/flink/pull/6611#issuecomment-425835514 Thank you @dawidwys. Travis gave green light. I will merge this...

[jira] [Commented] (FLINK-10447) Create Bucketing Table Sink.

2018-10-01 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633722#comment-16633722 ] Fabian Hueske commented on FLINK-10447: --- Hi [~Suxing Lee], you should be aware that this is a

[jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers

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

[jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers

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

[jira] [Updated] (FLINK-2435) Add support for custom CSV field parsers

2018-10-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-2435: -- Labels: pull-request-available (was: ) > Add support for custom CSV field parsers >

[jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers

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

[jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers

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

[jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers

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

[GitHub] ex00 commented on a change in pull request #5862: [FLINK-2435] User-defined types in CsvReader

2018-10-01 Thread GitBox
ex00 commented on a change in pull request #5862: [FLINK-2435] User-defined types in CsvReader URL: https://github.com/apache/flink/pull/5862#discussion_r221526823 ## File path: flink-java/src/main/java/org/apache/flink/api/java/io/CsvReader.java ## @@ -20,22 +20,53 @@

[GitHub] ex00 commented on a change in pull request #5862: [FLINK-2435] User-defined types in CsvReader

2018-10-01 Thread GitBox
ex00 commented on a change in pull request #5862: [FLINK-2435] User-defined types in CsvReader URL: https://github.com/apache/flink/pull/5862#discussion_r221243381 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java ## @@ -129,7

[GitHub] ex00 commented on a change in pull request #5862: [FLINK-2435] User-defined types in CsvReader

2018-10-01 Thread GitBox
ex00 commented on a change in pull request #5862: [FLINK-2435] User-defined types in CsvReader URL: https://github.com/apache/flink/pull/5862#discussion_r221242052 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/TupleTypeInfo.java ## @@ -238,6

[GitHub] ex00 commented on a change in pull request #5862: [FLINK-2435] User-defined types in CsvReader

2018-10-01 Thread GitBox
ex00 commented on a change in pull request #5862: [FLINK-2435] User-defined types in CsvReader URL: https://github.com/apache/flink/pull/5862#discussion_r221248122 ## File path: flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java ## @@ -262,54

[GitHub] ex00 commented on a change in pull request #5862: [FLINK-2435] User-defined types in CsvReader

2018-10-01 Thread GitBox
ex00 commented on a change in pull request #5862: [FLINK-2435] User-defined types in CsvReader URL: https://github.com/apache/flink/pull/5862#discussion_r221250089 ## File path: flink-java/src/test/java/org/apache/flink/api/java/tuple/TupleGenerator.java ## @@ -473,7

[jira] [Updated] (FLINK-10470) Add method to check if pattern can produce empty matches

2018-10-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10470: --- Labels: pull-request-available (was: ) > Add method to check if pattern can produce empty

[GitHub] dawidwys opened a new pull request #6781: [FLINK-10470] Add method to check if pattern can produce empty matches

2018-10-01 Thread GitBox
dawidwys opened a new pull request #6781: [FLINK-10470] Add method to check if pattern can produce empty matches URL: https://github.com/apache/flink/pull/6781 ## What is the purpose of the change This change introduces a method that allows checking if a Pattern can produce empty

[jira] [Commented] (FLINK-10470) Add method to check if pattern can produce empty matches

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

[jira] [Updated] (FLINK-10470) Add method to check if pattern can produce empty matches

2018-10-01 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-10470: - Description: There is couple of inconsistencies how CEP library handles greedy and

[jira] [Created] (FLINK-10470) Add method to check if pattern can produce empty matches

2018-10-01 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-10470: Summary: Add method to check if pattern can produce empty matches Key: FLINK-10470 URL: https://issues.apache.org/jira/browse/FLINK-10470 Project: Flink

[jira] [Resolved] (FLINK-10417) Add option to throw exception on pattern variable miss with SKIP_TO_FIRST/LAST

2018-10-01 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-10417. -- Resolution: Done > Add option to throw exception on pattern variable miss with

[jira] [Commented] (FLINK-10417) Add option to throw exception on pattern variable miss with SKIP_TO_FIRST/LAST

2018-10-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633679#comment-16633679 ] ASF GitHub Bot commented on FLINK-10417: dawidwys closed pull request #6758: [FLINK-10417][cep]

[GitHub] dawidwys closed pull request #6758: [FLINK-10417][cep] Added option to throw exception on pattern variable mis…

2018-10-01 Thread GitBox
dawidwys closed pull request #6758: [FLINK-10417][cep] Added option to throw exception on pattern variable mis… URL: https://github.com/apache/flink/pull/6758 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-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

2018-10-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633676#comment-16633676 ] Timo Walther commented on FLINK-10464: -- [~huangjiatian] could you add a more complete example of

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[GitHub] twalthr commented on a change in pull request #6741: [FLINK-9712][table, docs] Document processing time Temporal Table Joins

2018-10-01 Thread GitBox
twalthr commented on a change in pull request #6741: [FLINK-9712][table,docs] Document processing time Temporal Table Joins URL: https://github.com/apache/flink/pull/6741#discussion_r221515643 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -0,0 +1,263 @@

[jira] [Commented] (FLINK-3875) Add a TableSink for Elasticsearch

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

[GitHub] twalthr commented on a change in pull request #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch

2018-10-01 Thread GitBox
twalthr commented on a change in pull request #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch URL: https://github.com/apache/flink/pull/6611#discussion_r221513851 ## File path:

[jira] [Commented] (FLINK-3875) Add a TableSink for Elasticsearch

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

[GitHub] twalthr commented on a change in pull request #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch

2018-10-01 Thread GitBox
twalthr commented on a change in pull request #6611: [FLINK-3875] [connectors] Add an upsert table sink factory for Elasticsearch URL: https://github.com/apache/flink/pull/6611#discussion_r221513851 ## File path:

[jira] [Commented] (FLINK-6966) Add maxParallelism and UIDs to all operators generated by the Table API / SQL

2018-10-01 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633656#comment-16633656 ] Hequn Cheng commented on FLINK-6966: [~fanweiwen] Hi, it's better to ask user related questions on

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

2018-10-01 Thread tison (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16633639#comment-16633639 ] tison commented on FLINK-10469: --- Sounds reasonable. Maybe [~zjwang] and [~NicoK] could provide more

<    1   2   3