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

2018-10-02 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635685#comment-16635685 ] Fabian Hueske commented on FLINK-10474: --- It might be possible to generate code tha

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-10-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635693#comment-16635693 ] Nico Kruber commented on FLINK-10419: - One more note on my original issue: there sh

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Description: Hey Guys, Just testing the new bugfix release of 1.5.4 (edit: also h

[GitHub] pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

2018-10-02 Thread GitBox
pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r221626059 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/Tempora

[GitHub] pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

2018-10-02 Thread GitBox
pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r221622010 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/Tempora

[GitHub] pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

2018-10-02 Thread GitBox
pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r221643699 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/Tempora

[GitHub] pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

2018-10-02 Thread GitBox
pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r222000146 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/Tempora

[GitHub] pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

2018-10-02 Thread GitBox
pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r221627515 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/Tempora

[GitHub] pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

2018-10-02 Thread GitBox
pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r221638717 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/Tempora

[GitHub] pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

2018-10-02 Thread GitBox
pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r221642460 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/Tempora

[GitHub] pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

2018-10-02 Thread GitBox
pnowojski commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r221988168 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/Temp

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[GitHub] hequn8128 opened a new pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

2018-10-02 Thread GitBox
hequn8128 opened a new pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787 ## What is the purpose of the change Currently, only append stream can be ingested as a stream table. This pull

[jira] [Commented] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

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

[jira] [Updated] (FLINK-8577) Implement proctime DataStream to Table upsert conversion.

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8577: -- Labels: pull-request-available (was: ) > Implement proctime DataStream to Table upsert convers

[GitHub] tweise commented on issue #6761: [FLINK-10279] [documentation] Make jython limitations more obvious in documentation.

2018-10-02 Thread GitBox
tweise commented on issue #6761: [FLINK-10279] [documentation] Make jython limitations more obvious in documentation. URL: https://github.com/apache/flink/pull/6761#issuecomment-426335956 @zentol @mxm thanks, I incorporated your suggestions. PTAL ---

[jira] [Commented] (FLINK-10279) Make jython limitations more obvious in documentation

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635774#comment-16635774 ] ASF GitHub Bot commented on FLINK-10279: tweise commented on issue #6761: [FLINK

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

2018-10-02 Thread GitBox
fhueske 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_r222046660 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -0,0 +1,286 @@ +

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

2018-10-02 Thread GitBox
fhueske 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_r221990880 ## File path: docs/dev/table/streaming/joins.md ## @@ -0,0 +1,104 @@ +--- +title

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

2018-10-02 Thread GitBox
fhueske 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_r221993667 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -0,0 +1,286 @@ +

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

2018-10-02 Thread GitBox
fhueske 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_r222045023 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -0,0 +1,286 @@ +

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

2018-10-02 Thread GitBox
fhueske 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_r221988938 ## File path: docs/dev/table/streaming/joins.md ## @@ -0,0 +1,93 @@ +--- +title:

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

2018-10-02 Thread GitBox
fhueske 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_r221993366 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -0,0 +1,286 @@ +

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

2018-10-02 Thread GitBox
fhueske 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_r221983956 ## File path: docs/dev/table/streaming/joins.md ## @@ -0,0 +1,104 @@ +--- +title

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

2018-10-02 Thread GitBox
fhueske 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_r221982954 ## File path: docs/dev/table/streaming/joins.md ## @@ -0,0 +1,104 @@ +--- +title

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

2018-10-02 Thread GitBox
fhueske 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_r221983566 ## File path: docs/dev/table/streaming/joins.md ## @@ -0,0 +1,104 @@ +--- +title

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

2018-10-02 Thread GitBox
fhueske 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_r222045580 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -0,0 +1,286 @@ +

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

2018-10-02 Thread GitBox
fhueske 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_r221982232 ## File path: docs/dev/table/streaming/joins.md ## @@ -0,0 +1,104 @@ +--- +title

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

2018-10-02 Thread GitBox
fhueske 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_r221989545 ## File path: docs/dev/table/streaming/joins.md ## @@ -0,0 +1,104 @@ +--- +title

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

2018-10-02 Thread GitBox
fhueske 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_r221981230 ## File path: docs/dev/table/streaming/joins.md ## @@ -0,0 +1,104 @@ +--- +title

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

2018-10-02 Thread GitBox
fhueske 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_r221992003 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -0,0 +1,286 @@ +

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

2018-10-02 Thread GitBox
fhueske 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_r222011035 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -0,0 +1,286 @@ +

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

2018-10-02 Thread GitBox
fhueske 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_r222004085 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -0,0 +1,286 @@ +

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

2018-10-02 Thread GitBox
fhueske 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_r221994819 ## File path: docs/dev/table/streaming/temporal_tables.md ## @@ -0,0 +1,286 @@ +

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[jira] [Created] (FLINK-10482) java.lang.IllegalArgumentException: Negative number of in progress checkpoints

2018-10-02 Thread Julio Biason (JIRA)
Julio Biason created FLINK-10482: Summary: java.lang.IllegalArgumentException: Negative number of in progress checkpoints Key: FLINK-10482 URL: https://issues.apache.org/jira/browse/FLINK-10482 Projec

[jira] [Commented] (FLINK-10168) support filtering files by modified/created time in StreamExecutionEnvironment.readFile()

2018-10-02 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16635923#comment-16635923 ] Bowen Li commented on FLINK-10168: -- [~kkl0u] what do you think about this task? I bel

[jira] [Commented] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16636033#comment-16636033 ] Thomas Wozniakowski commented on FLINK-10475: - Aha - so it appears to be the

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader (ZK 3.5.3-beta only)

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Priority: Minor (was: Blocker) > Standalone HA - Leader election is not triggered

[jira] [Updated] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader (ZK 3.5.3-beta only)

2018-10-02 Thread Thomas Wozniakowski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-10475: Summary: Standalone HA - Leader election is not triggered on loss of leader (ZK 3.

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

2018-10-02 Thread GitBox
NicoK opened a new pull request #6788: [FLINK-10469][core] make sure to always write the whole buffer to FileChannel URL: https://github.com/apache/flink/pull/6788 ## What is the purpose of the change Currently all the calls to one of the `FileChannel.write()` methods assume that th

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

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

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

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10469: --- Labels: pull-request-available (was: ) > FileChannel may not write the whole buffer in a si

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

2018-10-02 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16636087#comment-16636087 ] Nico Kruber commented on FLINK-10469: - [~gaoyunhaii] I hacked something together - o

[GitHub] xccui commented on a change in pull request #6448: [FLINK-9990] [table] Add regexp_extract supported in TableAPI and SQL

2018-10-02 Thread GitBox
xccui commented on a change in pull request #6448: [FLINK-9990] [table] Add regexp_extract supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6448#discussion_r221666556 ## File path: docs/dev/table/functions.md ## @@ -2963,6 +2989,19 @@ STRING1.replace

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

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

[GitHub] xccui commented on a change in pull request #6448: [FLINK-9990] [table] Add regexp_extract supported in TableAPI and SQL

2018-10-02 Thread GitBox
xccui commented on a change in pull request #6448: [FLINK-9990] [table] Add regexp_extract supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6448#discussion_r221666999 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/scala/ex

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

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

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

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

[GitHub] xccui commented on a change in pull request #6448: [FLINK-9990] [table] Add regexp_extract supported in TableAPI and SQL

2018-10-02 Thread GitBox
xccui commented on a change in pull request #6448: [FLINK-9990] [table] Add regexp_extract supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6448#discussion_r221665820 ## File path: docs/dev/table/functions.md ## @@ -2460,6 +2460,19 @@ REPLACE(string1

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

2018-10-02 Thread GitBox
xccui 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_r222125558 ## File path: docs/dev/table/functions.md ## @@ -1274,6 +1274,17 @@ ATAN2(nume

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

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

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

2018-10-02 Thread GitBox
xccui 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_r222127427 ## File path: docs/dev/table/functions.md ## @@ -1274,6 +1274,17 @@ ATAN2(nume

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

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

[jira] [Created] (FLINK-10483) Can't restore from a savepoint even with Allow Non Restored State enabled

2018-10-02 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10483: -- Summary: Can't restore from a savepoint even with Allow Non Restored State enabled Key: FLINK-10483 URL: https://issues.apache.org/jira/browse/FLINK-10483 Project: Flink

[jira] [Created] (FLINK-10484) New latency tracking metrics format causes metrics cardinality explosion

2018-10-02 Thread Jamie Grier (JIRA)
Jamie Grier created FLINK-10484: --- Summary: New latency tracking metrics format causes metrics cardinality explosion Key: FLINK-10484 URL: https://issues.apache.org/jira/browse/FLINK-10484 Project: Flink

[jira] [Created] (FLINK-10485) Gremlin Support from Flink for Graph Processing

2018-10-02 Thread Wei Ding (JIRA)
Wei Ding created FLINK-10485: Summary: Gremlin Support from Flink for Graph Processing Key: FLINK-10485 URL: https://issues.apache.org/jira/browse/FLINK-10485 Project: Flink Issue Type: New Featu

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

2018-10-02 Thread JIN SUN (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JIN SUN reassigned FLINK-9953: -- Assignee: JIN SUN > Active Kubernetes integration > - > >

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

2018-10-02 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_r222166893 ## File path: flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java

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

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

[jira] [Commented] (FLINK-10481) Wordcount end-to-end test in docker env unstable

2018-10-02 Thread JIN SUN (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16636387#comment-16636387 ] JIN SUN commented on FLINK-10481: - seems like a intermittent issue, might be docker repo

[jira] [Updated] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

2018-10-02 Thread JIN SUN (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JIN SUN updated FLINK-10205: Fix Version/s: 1.7.0 > Batch Job: InputSplit Fault tolerant for DataSourceTask > -

[jira] [Updated] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

2018-10-02 Thread JIN SUN (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JIN SUN updated FLINK-10205: Affects Version/s: 1.7.0 > Batch Job: InputSplit Fault tolerant for DataSourceTask > -

[GitHub] isunjin commented on issue #5617: [FLINK-8799][YARN] Make AbstractYarnClusterDescriptor immutable

2018-10-02 Thread GitBox
isunjin commented on issue #5617: [FLINK-8799][YARN] Make AbstractYarnClusterDescriptor immutable URL: https://github.com/apache/flink/pull/5617#issuecomment-426505899 @yanghua, please also close the JIRA: https://issues.apache.org/jira/browse/FLINK-8799 --

[jira] [Commented] (FLINK-8799) Make AbstractYarnClusterDescriptor immutable

2018-10-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16636400#comment-16636400 ] ASF GitHub Bot commented on FLINK-8799: --- isunjin commented on issue #5617: [FLINK-8

[jira] [Comment Edited] (FLINK-10467) Upgrade commons-compress to 1.18

2018-10-02 Thread Guibo Pan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16636427#comment-16636427 ] Guibo Pan edited comment on FLINK-10467 at 10/3/18 5:01 AM:

[jira] [Commented] (FLINK-10467) Upgrade commons-compress to 1.18

2018-10-02 Thread Guibo Pan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16636427#comment-16636427 ] Guibo Pan commented on FLINK-10467: --- [~yuzhih...@gmail.com] I wonder could you attach

<    1   2   3