[GitHub] [flink] dawidwys edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

dawidwys edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-525634138 I get the problems with `BatchExecutor` I can't think of a better solution

[GitHub] [flink] dawidwys commented on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

dawidwys commented on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-525634138 I get the problems with `BatchExecutor` I can't think of a better solution for now

[GitHub] [flink] flinkbot edited a comment on issue #9543: [FLINK-12749][docs] Add Flink Operations Playground

flinkbot edited a comment on issue #9543: [FLINK-12749][docs] Add Flink Operations Playground URL: https://github.com/apache/flink/pull/9543#issuecomment-525285606 ## CI report: * 7a3937a6ea40998555003d7ee5bac8867c249af0 : UNKNOWN * 67b4837caf28fced548a5043c8c23a80c438d15b : U

[GitHub] [flink] flinkbot commented on issue #9549: [FLINK-13790][sql-client] Support -q option with a sql query statemen…

flinkbot commented on issue #9549: [FLINK-13790][sql-client] Support -q option with a sql query statemen… URL: https://github.com/apache/flink/pull/9549#issuecomment-525633421 ## CI report: * c074a0eeddf41241432007133491aaf39d639d63 : UNKNOWN

[GitHub] [flink] flinkbot commented on issue #9549: [FLINK-13790][sql-client] Support -q option with a sql query statemen…

flinkbot commented on issue #9549: [FLINK-13790][sql-client] Support -q option with a sql query statemen… URL: https://github.com/apache/flink/pull/9549#issuecomment-525631348 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[GitHub] [flink] flinkbot edited a comment on issue #9543: [FLINK-12749][docs] Add Flink Operations Playground

flinkbot edited a comment on issue #9543: [FLINK-12749][docs] Add Flink Operations Playground URL: https://github.com/apache/flink/pull/9543#issuecomment-525284477 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Commented] (FLINK-13661) Add a stream specific CREATE TABLE SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-13661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917523#comment-16917523 ] yelun commented on FLINK-13661: --- Hi ,all.  this is a big issue,maybe it can split into man

[jira] [Updated] (FLINK-13790) Support -q option with a sql query statement as input

[ https://issues.apache.org/jira/browse/FLINK-13790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13790: --- Labels: pull-request-available (was: ) > Support -q option with a sql query statement as in

[GitHub] [flink] docete opened a new pull request #9549: [FLINK-13790][sql-client] Support -q option with a sql query statemen…

docete opened a new pull request #9549: [FLINK-13790][sql-client] Support -q option with a sql query statemen… URL: https://github.com/apache/flink/pull/9549 …t as input ## What is the purpose of the change Support -q option to execute a SQL query statement without entering i

[jira] [Commented] (FLINK-13881) CEP within method should applied in every independent pattern

[ https://issues.apache.org/jira/browse/FLINK-13881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917520#comment-16917520 ] Dawid Wysakowicz commented on FLINK-13881: -- First of all to be clear, the curre

[GitHub] [flink] flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink

flinkbot edited a comment on issue #9484: [FLINK-13774][table] Expression DSL use should resolve Expressions in blink URL: https://github.com/apache/flink/pull/9484#issuecomment-522628616 ## CI report: * 9559898f9d03c5aad327febdcd6fcd6a2d3e99f2 : CANCELED [Build](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523767672 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[jira] [Created] (FLINK-13881) CEP within method should applied in every independent pattern

YufeiLiu created FLINK-13881: Summary: CEP within method should applied in every independent pattern Key: FLINK-13881 URL: https://issues.apache.org/jira/browse/FLINK-13881 Project: Flink Issue

[GitHub] [flink] carp84 commented on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-525626160 Thanks for the review @StephanEwen @tillrohrmann ! I've addressed most of the comments and left so

[jira] [Commented] (FLINK-10030) zookeeper jobgraphs job info cannot be removed when the job is cancelled with zk ha mode

[ https://issues.apache.org/jira/browse/FLINK-10030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917511#comment-16917511 ] Till Rohrmann commented on FLINK-10030: --- Thanks for reporting this issue [~thw]. F

[GitHub] [flink] flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-519129010 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkb

[jira] [Updated] (FLINK-10030) zookeeper jobgraphs job info cannot be removed when the job is cancelled with zk ha mode

[ https://issues.apache.org/jira/browse/FLINK-10030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10030: -- Affects Version/s: 1.8.1 > zookeeper jobgraphs job info cannot be removed when the job is canc

[jira] [Updated] (FLINK-10030) zookeeper jobgraphs job info cannot be removed when the job is cancelled with zk ha mode

[ https://issues.apache.org/jira/browse/FLINK-10030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10030: -- Priority: Critical (was: Major) > zookeeper jobgraphs job info cannot be removed when the job

[GitHub] [flink] AHeise commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

AHeise commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r318435616 ## File path: flink-streaming-java/src/test/java/org/apache/fl

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE [Build](htt

[GitHub] [flink] flinkbot edited a comment on issue #9548: [hotfix] [docs] Fix typo

flinkbot edited a comment on issue #9548: [hotfix] [docs] Fix typo URL: https://github.com/apache/flink/pull/9548#issuecomment-525621002 ## CI report: * 4db15eae32c52515a64a38d6e808cd40f5812c58 : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/124863301)

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE [Build](htt

[GitHub] [flink] flinkbot commented on issue #9548: [hotfix] [docs] Fix typo

flinkbot commented on issue #9548: [hotfix] [docs] Fix typo URL: https://github.com/apache/flink/pull/9548#issuecomment-525621002 ## CI report: * 4db15eae32c52515a64a38d6e808cd40f5812c58 : UNKNOWN This is an aut

[jira] [Closed] (FLINK-13870) within method should applied in every individual pattern

[ https://issues.apache.org/jira/browse/FLINK-13870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YufeiLiu closed FLINK-13870. Resolution: Staged > within method should applied in every individual pattern > --

[GitHub] [flink] flinkbot commented on issue #9548: [hotfix] [docs] Fix typo

flinkbot commented on issue #9548: [hotfix] [docs] Fix typo URL: https://github.com/apache/flink/pull/9548#issuecomment-525620568 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment

[GitHub] [flink] flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-519129010 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkb

[GitHub] [flink] YngwieWang opened a new pull request #9548: [hotfix] [docs] Fix typo

YngwieWang opened a new pull request #9548: [hotfix] [docs] Fix typo URL: https://github.com/apache/flink/pull/9548 [hotfix] [docs] Fix typo This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] pnowojski commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

pnowojski commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r318419679 ## File path: flink-streaming-java/src/main/java/org/apache

[GitHub] [flink] pnowojski commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

pnowojski commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r318420614 ## File path: flink-streaming-java/src/test/java/org/apache

[GitHub] [flink] pnowojski commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

pnowojski commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r318419434 ## File path: flink-streaming-java/src/main/java/org/apache

[GitHub] [flink] pnowojski commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

pnowojski commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r318428252 ## File path: flink-streaming-java/src/test/java/org/apache

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523767672 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[jira] [Commented] (FLINK-11937) Resolve small file problem in RocksDB incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-11937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16917498#comment-16917498 ] He Xiaoqiao commented on FLINK-11937: - [~klion26] Thanks for your proposal and contr

[GitHub] [flink] flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close

flinkbot edited a comment on issue #9467: [FLINK-9941][ScalaAPI] Flush in ScalaCsvOutputFormat before close URL: https://github.com/apache/flink/pull/9467#issuecomment-522053886 ## CI report: * 009da497d7c551ba854dc7ed8fa658f2acd6d6ce : SUCCESS [Build](https://travis-ci.com/flin

<    1   2   3   4   5