[jira] [Commented] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

[ https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601803#comment-16601803 ] xueyu commented on FLINK-10261: --- In addition, `DataStreamSortRule` seems require the first

[jira] [Commented] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

[ https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601802#comment-16601802 ] ASF GitHub Bot commented on FLINK-10261: xueyumusic opened a new pull request #6

[jira] [Updated] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

[ https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10261: --- Labels: pull-request-available (was: ) > INSERT INTO does not work with ORDER BY clause > -

[GitHub] xueyumusic opened a new pull request #6648: [FLINK-10261][table] fix insert into with order by

xueyumusic opened a new pull request #6648: [FLINK-10261][table] fix insert into with order by URL: https://github.com/apache/flink/pull/6648 ## What is the purpose of the change This PR tried to fix insert into with order by. It was caused by calcite validate rewrite and change Sql

[jira] [Commented] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

[ https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601797#comment-16601797 ] xueyu commented on FLINK-10261: --- It was caused by calcite validate rewrite and change SqlN

[GitHub] lamber-ken commented on issue #6647: [hotfix][docs] Fix error html tag in batch index documentatition

lamber-ken commented on issue #6647: [hotfix][docs] Fix error html tag in batch index documentatition URL: https://github.com/apache/flink/pull/6647#issuecomment-418009418 @dawidwys hi, cc This is an automated message from th

[GitHub] lamber-ken commented on issue #6647: [hotfix][docs] Fix error html tag in batch index documentatition

lamber-ken commented on issue #6647: [hotfix][docs] Fix error html tag in batch index documentatition URL: https://github.com/apache/flink/pull/6647#issuecomment-418008209 Old `DataSet Transformations documents` has some error html tag. [flink-1.4-dataset-transformations-scala](http

[GitHub] lamber-ken opened a new pull request #6647: [hotfix][docs] Fix error html tag in batch index documentatition

lamber-ken opened a new pull request #6647: [hotfix][docs] Fix error html tag in batch index documentatition URL: https://github.com/apache/flink/pull/6647 ## What is the purpose of the change Fix error html tag in batch index documentatition ## Brief change log -

[jira] [Updated] (FLINK-10245) Add DataStream HBase Sink

[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang updated FLINK-10245: Description: Design documentation:  [https://docs.google.com/document/d/1of0cYd73CtKGPt-UL3WVFTTBsV

[jira] [Created] (FLINK-10277) Add AppendStreamTableSink and UpsertStreamTableSink

Shimin Yang created FLINK-10277: --- Summary: Add AppendStreamTableSink and UpsertStreamTableSink Key: FLINK-10277 URL: https://issues.apache.org/jira/browse/FLINK-10277 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10245) Add DataStream HBase Sink

[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601755#comment-16601755 ] ASF GitHub Bot commented on FLINK-10245: Clark commented on issue #6628: [FL

[GitHub] Clarkkkkk commented on issue #6628: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink for HBase

Clark commented on issue #6628: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink for HBase URL: https://github.com/apache/flink/pull/6628#issuecomment-417989650 Hi @twalthr @hequn8128 , I have added the link of design document in the PR.

[GitHub] maqingxiang commented on a change in pull request #6645: [hotfix] Update deprecated parameters in WebOptions

maqingxiang commented on a change in pull request #6645: [hotfix] Update deprecated parameters in WebOptions URL: https://github.com/apache/flink/pull/6645#discussion_r214565332 ## File path: flink-jepsen/src/jepsen/flink/db.clj ## @@ -51,7 +51,7 @@ :high-availability

[GitHub] maqingxiang commented on a change in pull request #6645: [hotfix] Update deprecated parameters in WebOptions

maqingxiang commented on a change in pull request #6645: [hotfix] Update deprecated parameters in WebOptions URL: https://github.com/apache/flink/pull/6645#discussion_r214565291 ## File path: flink-core/src/test/java/org/apache/flink/configuration/RestOptionsTest.java ##

[jira] [Comment Edited] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601690#comment-16601690 ] Rong Rong edited comment on FLINK-9172 at 9/2/18 10:41 PM: --- Hi

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601690#comment-16601690 ] Rong Rong commented on FLINK-9172: -- Hi folks. Sorry for not taking this task for so long

[GitHub] zentol commented on a change in pull request #6645: [hotfix] Update deprecated parameters in WebOptions

zentol commented on a change in pull request #6645: [hotfix] Update deprecated parameters in WebOptions URL: https://github.com/apache/flink/pull/6645#discussion_r214549713 ## File path: flink-jepsen/src/jepsen/flink/db.clj ## @@ -51,7 +51,7 @@ :high-availability.zook

[GitHub] zentol commented on a change in pull request #6645: [hotfix] Update deprecated parameters in WebOptions

zentol commented on a change in pull request #6645: [hotfix] Update deprecated parameters in WebOptions URL: https://github.com/apache/flink/pull/6645#discussion_r214549705 ## File path: flink-core/src/test/java/org/apache/flink/configuration/RestOptionsTest.java ## @@ -

[jira] [Comment Edited] (FLINK-10206) Add hbase sink connector

[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601241#comment-16601241 ] Hequn Cheng edited comment on FLINK-10206 at 9/2/18 3:39 PM: -

[jira] [Commented] (FLINK-10206) Add hbase sink connector

[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601241#comment-16601241 ] Hequn Cheng commented on FLINK-10206: - [~dangdangdang] Cool~ You can start from the

[jira] [Commented] (FLINK-10259) Key validation for GroupWindowAggregate is broken

[ https://issues.apache.org/jira/browse/FLINK-10259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601236#comment-16601236 ] ASF GitHub Bot commented on FLINK-10259: hequn8128 commented on a change in pull

[jira] [Commented] (FLINK-10259) Key validation for GroupWindowAggregate is broken

[ https://issues.apache.org/jira/browse/FLINK-10259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601237#comment-16601237 ] ASF GitHub Bot commented on FLINK-10259: hequn8128 commented on a change in pull

[jira] [Commented] (FLINK-10259) Key validation for GroupWindowAggregate is broken

[ https://issues.apache.org/jira/browse/FLINK-10259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601238#comment-16601238 ] ASF GitHub Bot commented on FLINK-10259: hequn8128 commented on a change in pull

[jira] [Commented] (FLINK-10259) Key validation for GroupWindowAggregate is broken

[ https://issues.apache.org/jira/browse/FLINK-10259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601235#comment-16601235 ] ASF GitHub Bot commented on FLINK-10259: hequn8128 commented on a change in pull

[GitHub] hequn8128 commented on a change in pull request #6641: [FLINK-10259] Fix key extraction for GroupWindows.

hequn8128 commented on a change in pull request #6641: [FLINK-10259] Fix key extraction for GroupWindows. URL: https://github.com/apache/flink/pull/6641#discussion_r214543996 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/InsertIn

[GitHub] hequn8128 commented on a change in pull request #6641: [FLINK-10259] Fix key extraction for GroupWindows.

hequn8128 commented on a change in pull request #6641: [FLINK-10259] Fix key extraction for GroupWindows. URL: https://github.com/apache/flink/pull/6641#discussion_r214543970 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/InsertIn

[GitHub] hequn8128 commented on a change in pull request #6641: [FLINK-10259] Fix key extraction for GroupWindows.

hequn8128 commented on a change in pull request #6641: [FLINK-10259] Fix key extraction for GroupWindows. URL: https://github.com/apache/flink/pull/6641#discussion_r214544003 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/InsertIn

[GitHub] hequn8128 commented on a change in pull request #6641: [FLINK-10259] Fix key extraction for GroupWindows.

hequn8128 commented on a change in pull request #6641: [FLINK-10259] Fix key extraction for GroupWindows. URL: https://github.com/apache/flink/pull/6641#discussion_r214543996 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/InsertIn

[GitHub] TisonKun commented on issue #6644: [hotfix] check correct parameter

TisonKun commented on issue #6644: [hotfix] check correct parameter URL: https://github.com/apache/flink/pull/6644#issuecomment-417934845 cc @zentol This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-8660) Enable the user to provide custom HAServices implementation

[ https://issues.apache.org/jira/browse/FLINK-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601212#comment-16601212 ] ASF GitHub Bot commented on FLINK-8660: --- Xeli commented on issue #5530: [FLINK-8660

[jira] [Updated] (FLINK-8660) Enable the user to provide custom HAServices implementation

[ https://issues.apache.org/jira/browse/FLINK-8660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8660: -- Labels: pull-request-available (was: ) > Enable the user to provide custom HAServices implemen

[GitHub] Xeli commented on issue #5530: [FLINK-8660] Enable the user to provide custom HAServices implementation

Xeli commented on issue #5530: [FLINK-8660] Enable the user to provide custom HAServices implementation URL: https://github.com/apache/flink/pull/5530#issuecomment-417931651 I am in the process of building a HAService for our kubernetes set up without having to use zookeeper (https://stack

[jira] [Comment Edited] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601172#comment-16601172 ] eugen yushin edited comment on FLINK-10050 at 9/2/18 10:28 AM: ---

[jira] [Commented] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601172#comment-16601172 ] eugen yushin commented on FLINK-10050: -- [~aljoscha], [~till.rohrmann] Guys, please

[jira] [Commented] (FLINK-10229) Support listing of views

[ https://issues.apache.org/jira/browse/FLINK-10229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601170#comment-16601170 ] ASF GitHub Bot commented on FLINK-10229: hequn8128 commented on a change in pull

[jira] [Commented] (FLINK-10229) Support listing of views

[ https://issues.apache.org/jira/browse/FLINK-10229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601167#comment-16601167 ] ASF GitHub Bot commented on FLINK-10229: hequn8128 commented on a change in pull

[jira] [Commented] (FLINK-10229) Support listing of views

[ https://issues.apache.org/jira/browse/FLINK-10229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601169#comment-16601169 ] ASF GitHub Bot commented on FLINK-10229: hequn8128 commented on a change in pull

[jira] [Commented] (FLINK-10229) Support listing of views

[ https://issues.apache.org/jira/browse/FLINK-10229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601168#comment-16601168 ] ASF GitHub Bot commented on FLINK-10229: hequn8128 commented on a change in pull

[GitHub] hequn8128 commented on a change in pull request #6631: [FLINK-10229] [sql-client] Support listing of views

hequn8128 commented on a change in pull request #6631: [FLINK-10229] [sql-client] Support listing of views URL: https://github.com/apache/flink/pull/6631#discussion_r214535531 ## File path: flink-libraries/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/L

[GitHub] hequn8128 commented on a change in pull request #6631: [FLINK-10229] [sql-client] Support listing of views

hequn8128 commented on a change in pull request #6631: [FLINK-10229] [sql-client] Support listing of views URL: https://github.com/apache/flink/pull/6631#discussion_r214535527 ## File path: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.j

[jira] [Updated] (FLINK-10274) The stop-cluster.sh cannot stop cluster properly when there are multiple clusters running

[ https://issues.apache.org/jira/browse/FLINK-10274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YuFeng Shen updated FLINK-10274: Description: When you are preparing to do a Flink framework version upgrading by using the strate

[GitHub] hequn8128 commented on a change in pull request #6631: [FLINK-10229] [sql-client] Support listing of views

hequn8128 commented on a change in pull request #6631: [FLINK-10229] [sql-client] Support listing of views URL: https://github.com/apache/flink/pull/6631#discussion_r214535526 ## File path: docs/dev/table/sqlClient.md ## @@ -503,6 +503,12 @@ Views created within a CLI sess

[GitHub] hequn8128 commented on a change in pull request #6631: [FLINK-10229] [sql-client] Support listing of views

hequn8128 commented on a change in pull request #6631: [FLINK-10229] [sql-client] Support listing of views URL: https://github.com/apache/flink/pull/6631#discussion_r214535530 ## File path: flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.j

[jira] [Commented] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601166#comment-16601166 ] ASF GitHub Bot commented on FLINK-10050: EugeneYushin opened a new pull request

[jira] [Updated] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10050: --- Labels: pull-request-available ready-to-commit windows (was: ready-to-commit windows) > Su

[GitHub] EugeneYushin opened a new pull request #6646: [FLINK-10050] Support allowedLateness in CoGroupedStreams

EugeneYushin opened a new pull request #6646: [FLINK-10050] Support allowedLateness in CoGroupedStreams URL: https://github.com/apache/flink/pull/6646 ## What is the purpose of the change [https://issues.apache.org/jira/browse/FLINK-10050](https://issues.apache.org/jira/browse/FLINK-100

[jira] [Commented] (FLINK-10212) REST API for listing all the available save points

[ https://issues.apache.org/jira/browse/FLINK-10212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601131#comment-16601131 ] Marc Rooding commented on FLINK-10212: -- Hi Chesnay,  You understand correctly. I d