[GitHub] [flink] flinkbot edited a comment on issue #11081: [FLINK-16033][table-api] Introduced Java Table API Expression DSL

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11081: [FLINK-16033][table-api] Introduced Java Table API Expression DSL URL: https://github.com/apache/flink/pull/11081#issuecomment-585639356 ## CI report: * 16d4e9e6fbeb230b8aa05976e4909299ebc929bf Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11073: [FLINK-15672][build] Migrate to log4j2

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11073: [FLINK-15672][build] Migrate to log4j2 URL: https://github.com/apache/flink/pull/11073#issuecomment-585286222 ## CI report: * 29034cb85769cd69b09b121c4b88f54b4483aafe Travis:

[jira] [Closed] (FLINK-14228) The runtime support for Bounded[One|Multi]Input#endInput does not properly implement their semantics

2020-02-21 Thread Haibo Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Sun closed FLINK-14228. - Resolution: Fixed > The runtime support for Bounded[One|Multi]Input#endInput does not properly >

[GitHub] [flink] sunhaibotb commented on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

2020-02-21 Thread GitBox
sunhaibotb commented on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#issuecomment-589614201 Thanks for reviewing and merging @pnowojski @rkhachatryan .

[jira] [Commented] (FLINK-16192) Remove "Legacy State" and Checkpoint Compatibility with Flink 1.2

2020-02-21 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041769#comment-17041769 ] Chesnay Schepler commented on FLINK-16192: -- Is legacy not usable in 1.3? > Remove "Legacy

[GitHub] [flink] flinkbot commented on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt

2020-02-21 Thread GitBox
flinkbot commented on issue #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt URL: https://github.com/apache/flink/pull/11173#issuecomment-589612980 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Comment Edited] (FLINK-15621) State TTL: Remove deprecated option and method to disable TTL compaction filter

2020-02-21 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040999#comment-17040999 ] Andrey Zagrebin edited comment on FLINK-15621 at 2/21/20 11:21 AM: ---

[jira] [Created] (FLINK-16198) FileUtilsTest fails on Mac OS

2020-02-21 Thread Andrey Zagrebin (Jira)
Andrey Zagrebin created FLINK-16198: --- Summary: FileUtilsTest fails on Mac OS Key: FLINK-16198 URL: https://issues.apache.org/jira/browse/FLINK-16198 Project: Flink Issue Type: Bug

[GitHub] [flink] zentol opened a new pull request #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt

2020-02-21 Thread GitBox
zentol opened a new pull request #11173: [FLINK-13417][build] Bundle Zookeeper 3.5 in opt URL: https://github.com/apache/flink/pull/11173 Based on #11143. With this we ship 2 versions of Zookeeper (3.4.10, 3.5.6, as defined by flink-shaded) in the distribution. ZK 3.4 is in

[jira] [Comment Edited] (FLINK-15621) State TTL: Remove deprecated option and method to disable TTL compaction filter

2020-02-21 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040999#comment-17040999 ] Andrey Zagrebin edited comment on FLINK-15621 at 2/21/20 11:15 AM: ---

[jira] [Closed] (FLINK-14231) Support the timers of the upstream operator with endInput properly

2020-02-21 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-14231. -- Fix Version/s: 1.11.0 Resolution: Fixed Merged to master as fa22ed2167..fd1ee495ad >

[GitHub] [flink] pnowojski merged pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

2020-02-21 Thread GitBox
pnowojski merged pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151 This is an automated

[jira] [Assigned] (FLINK-15813) Set default value of jobmanager.execution.failover-strategy to region

2020-02-21 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-15813: --- Assignee: Zhu Zhu > Set default value of jobmanager.execution.failover-strategy to region >

[jira] [Commented] (FLINK-13717) allow to set taskmanager.host and taskmanager.bind-host separately

2020-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041760#comment-17041760 ] Xintong Song commented on FLINK-13717: -- I'm closing this ticket because it can be resolved with the

[GitHub] [flink] flinkbot edited a comment on issue #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md URL: https://github.com/apache/flink/pull/11167#issuecomment-589539473 ## CI report: * e210c1aad1a84a8b2baabb019a895b677c358ebf Travis:

[jira] [Closed] (FLINK-13717) allow to set taskmanager.host and taskmanager.bind-host separately

2020-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-13717. Resolution: Duplicate > allow to set taskmanager.host and taskmanager.bind-host separately >

[GitHub] [flink] flinkbot edited a comment on issue #11170: [FLINK-16033][table-api] Expose catalog lookup function calls in Scala's expression dsl.

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11170: [FLINK-16033][table-api] Expose catalog lookup function calls in Scala's expression dsl. URL: https://github.com/apache/flink/pull/11170#issuecomment-589590759 ## CI report: * 2c85988d5f5074372ff5363164ebfe0244d0dc57 UNKNOWN *

[GitHub] [flink] flinkbot commented on issue #11171: [FLINK-15722] Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint

2020-02-21 Thread GitBox
flinkbot commented on issue #11171: [FLINK-15722] Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11171#issuecomment-589604347 ## CI report: * 29acf2322ddd57b6309ae87bfa9fc1747886449d UNKNOWN Bot

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #29: [FLINK-16063] Add simple backpressure

2020-02-21 Thread GitBox
tzulitai commented on a change in pull request #29: [FLINK-16063] Add simple backpressure URL: https://github.com/apache/flink-statefun/pull/29#discussion_r382518904 ## File path:

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #29: [FLINK-16063] Add simple backpressure

2020-02-21 Thread GitBox
tzulitai commented on a change in pull request #29: [FLINK-16063] Add simple backpressure URL: https://github.com/apache/flink-statefun/pull/29#discussion_r382516057 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11164: [hotfix][build system] Do not trigger dependent jobs if predecessor fails

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11164: [hotfix][build system] Do not trigger dependent jobs if predecessor fails URL: https://github.com/apache/flink/pull/11164#issuecomment-589179847 ## CI report: * 54afc31acb5e8b57a72442e39282c89252fb38fe Travis:

[GitHub] [flink] flinkbot commented on issue #11172: [FLINK-16067][table] Forward Calcite exception when parsing a sql query

2020-02-21 Thread GitBox
flinkbot commented on issue #11172: [FLINK-16067][table] Forward Calcite exception when parsing a sql query URL: https://github.com/apache/flink/pull/11172#issuecomment-589601620 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot edited a comment on issue #11081: [FLINK-16033][table-api] Introduced Java Table API Expression DSL

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11081: [FLINK-16033][table-api] Introduced Java Table API Expression DSL URL: https://github.com/apache/flink/pull/11081#issuecomment-585639356 ## CI report: * 16d4e9e6fbeb230b8aa05976e4909299ebc929bf Travis:

[GitHub] [flink-docker] patricklucas commented on issue #6: [FLINK-15978] Add GPG key and Dockerfiles for 1.10.0 release

2020-02-21 Thread GitBox
patricklucas commented on issue #6: [FLINK-15978] Add GPG key and Dockerfiles for 1.10.0 release URL: https://github.com/apache/flink-docker/pull/6#issuecomment-589601283 @carp84 the older images can still be downloaded, but will not be automatically rebuilt. I opened #8 to update

[GitHub] [flink-docker] patricklucas opened a new pull request #8: [hotfix] Update README.md

2020-02-21 Thread GitBox
patricklucas opened a new pull request #8: [hotfix] Update README.md URL: https://github.com/apache/flink-docker/pull/8 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-16067) Flink's CalciteParser swallows error position information

2020-02-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16067: --- Labels: pull-request-available (was: ) > Flink's CalciteParser swallows error position

[GitHub] [flink] dawidwys opened a new pull request #11172: [FLINK-16067][table] Forward Calcite exception when parsing a sql query

2020-02-21 Thread GitBox
dawidwys opened a new pull request #11172: [FLINK-16067][table] Forward Calcite exception when parsing a sql query URL: https://github.com/apache/flink/pull/11172 Minor change. Forwarding Calcite exception when parsing a sql query

[GitHub] [flink] dawidwys commented on issue #11172: [FLINK-16067][table] Forward Calcite exception when parsing a sql query

2020-02-21 Thread GitBox
dawidwys commented on issue #11172: [FLINK-16067][table] Forward Calcite exception when parsing a sql query URL: https://github.com/apache/flink/pull/11172#issuecomment-589600587 cc @fhueske This is an automated message

[jira] [Commented] (FLINK-15154) Change Flink binding addresses in local mode

2020-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041754#comment-17041754 ] Xintong Song commented on FLINK-15154: -- I'm closing this ticket because it can be resolved with the

[jira] [Closed] (FLINK-15154) Change Flink binding addresses in local mode

2020-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-15154. Resolution: Duplicate > Change Flink binding addresses in local mode >

[jira] [Updated] (FLINK-16067) Flink's CalciteParser swallows error position information

2020-02-21 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-16067: - Fix Version/s: 1.11.0 1.10.1 > Flink's CalciteParser swallows error

[GitHub] [flink] aljoscha closed pull request #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader

2020-02-21 Thread GitBox
aljoscha closed pull request #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader URL: https://github.com/apache/flink/pull/10836 This is an automated message from the Apache Git

[GitHub] [flink] aljoscha commented on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader

2020-02-21 Thread GitBox
aljoscha commented on issue #10836: [FLINK-11589][Security] Support security module and context discovery via ServiceLoader URL: https://github.com/apache/flink/pull/10836#issuecomment-589599397 Thanks a lot for your work @walterddr! I merged this. 

[jira] [Closed] (FLINK-11589) Introduce service provider pattern for user to dynamically load SecurityFactory classes

2020-02-21 Thread Aljoscha Krettek (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-11589. Fix Version/s: 1.11.0 Resolution: Fixed master:

[jira] [Commented] (FLINK-15911) Flink does not work over NAT

2020-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041749#comment-17041749 ] Xintong Song commented on FLINK-15911: -- I've spent some time looking into this issue, together with

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382511423 ## File path:

[jira] [Assigned] (FLINK-16067) Flink's CalciteParser swallows error position information

2020-02-21 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-16067: Assignee: Dawid Wysakowicz > Flink's CalciteParser swallows error position

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382510922 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382510241 ## File path:

[jira] [Comment Edited] (FLINK-10231) Add a view SQL DDL

2020-02-21 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041698#comment-17041698 ] Zili Chen edited comment on FLINK-10231 at 2/21/20 10:22 AM: - Hi here, is

[GitHub] [flink] flinkbot commented on issue #11170: [FLINK-16033][table-api] Expose catalog lookup function calls in Scala's expression dsl.

2020-02-21 Thread GitBox
flinkbot commented on issue #11170: [FLINK-16033][table-api] Expose catalog lookup function calls in Scala's expression dsl. URL: https://github.com/apache/flink/pull/11170#issuecomment-589590759 ## CI report: * 2c85988d5f5074372ff5363164ebfe0244d0dc57 UNKNOWN Bot

[GitHub] [flink] flinkbot edited a comment on issue #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md URL: https://github.com/apache/flink/pull/11167#issuecomment-589539473 ## CI report: * e210c1aad1a84a8b2baabb019a895b677c358ebf Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11169: [FLINK-16196][hive] FlinkStandaloneHiveRunner leaks HMS process

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11169: [FLINK-16196][hive] FlinkStandaloneHiveRunner leaks HMS process URL: https://github.com/apache/flink/pull/11169#issuecomment-589576991 ## CI report: * 6187e51e301c2c81d6e2fb9446747a2e5265e99a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11168: [FLINK-16140] [docs-zh] Translate Event Processing (CEP) page into Chinese

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11168: [FLINK-16140] [docs-zh] Translate Event Processing (CEP) page into Chinese URL: https://github.com/apache/flink/pull/11168#issuecomment-589576910 ## CI report: * 8e08bdefc8f3a02ffdba8591620b4fea59889cc2 Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382500680 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese URL: https://github.com/apache/flink/pull/11129#issuecomment-588061442 ## CI report: * d85ac6aa7166a24fff2bd1def31023877a95daeb Travis:

[jira] [Commented] (FLINK-15992) Incorrect classloader when finding TableFactory

2020-02-21 Thread Victor Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041731#comment-17041731 ] Victor Wong commented on FLINK-15992: - [~jark] ok, sorry for the inconvenience caused by this PR:(

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382497972 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11081: [FLINK-16033][table-api] Introduced Java Table API Expression DSL

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11081: [FLINK-16033][table-api] Introduced Java Table API Expression DSL URL: https://github.com/apache/flink/pull/11081#issuecomment-585639356 ## CI report: * 16d4e9e6fbeb230b8aa05976e4909299ebc929bf Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382498174 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382497972 ## File path:

[GitHub] [flink] rmetzger commented on issue #11164: [hotfix][build system] Do not trigger dependent jobs if predecessor fails

2020-02-21 Thread GitBox
rmetzger commented on issue #11164: [hotfix][build system] Do not trigger dependent jobs if predecessor fails URL: https://github.com/apache/flink/pull/11164#issuecomment-589586092 Good idea! I updated the PR. This is an

[GitHub] [flink] flinkbot commented on issue #11171: [FLINK-15722] Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint

2020-02-21 Thread GitBox
flinkbot commented on issue #11171: [FLINK-15722] Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11171#issuecomment-589585710 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[jira] [Updated] (FLINK-15722) Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint

2020-02-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15722: --- Labels: pull-request-available (was: ) > Update TypeSerializerSnapshotMigrationITCase to

[GitHub] [flink] yanghua opened a new pull request #11171: [FLINK-15722] Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint

2020-02-21 Thread GitBox
yanghua opened a new pull request #11171: [FLINK-15722] Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint URL: https://github.com/apache/flink/pull/11171 ## What is the purpose of the change *This pull request updates

[GitHub] [flink-statefun] tzulitai commented on issue #27: [FLINK-16149][core] Set configurations using StreamExecutionEnvironment#getConfiguration

2020-02-21 Thread GitBox
tzulitai commented on issue #27: [FLINK-16149][core] Set configurations using StreamExecutionEnvironment#getConfiguration URL: https://github.com/apache/flink-statefun/pull/27#issuecomment-589583732 Thanks for the work and reviews @sjwiesman @igalshilman. Just a quick update from my

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382488831 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382486306 ## File path:

[GitHub] [flink] dawidwys commented on issue #11081: [FLINK-16033][table-api] Introduced Java Table API Expression DSL

2020-02-21 Thread GitBox
dawidwys commented on issue #11081: [FLINK-16033][table-api] Introduced Java Table API Expression DSL URL: https://github.com/apache/flink/pull/11081#issuecomment-589577543 In the end I had to rebase this on top of #11156 and #11170. The reason is I had to first solve looking up functions

[jira] [Commented] (FLINK-15722) Update TypeSerializerSnapshotMigrationITCase to restore from 1.10 savepoint

2020-02-21 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041712#comment-17041712 ] vinoyang commented on FLINK-15722: -- [~aljoscha] There is a class named

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382484642 ## File path:

[GitHub] [flink] flinkbot commented on issue #11168: [FLINK-16140] [docs-zh] Translate Event Processing (CEP) page into Chinese

2020-02-21 Thread GitBox
flinkbot commented on issue #11168: [FLINK-16140] [docs-zh] Translate Event Processing (CEP) page into Chinese URL: https://github.com/apache/flink/pull/11168#issuecomment-589576910 ## CI report: * 8e08bdefc8f3a02ffdba8591620b4fea59889cc2 UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on issue #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md URL: https://github.com/apache/flink/pull/11167#issuecomment-589539473 ## CI report: * e210c1aad1a84a8b2baabb019a895b677c358ebf Travis:

[GitHub] [flink] flinkbot commented on issue #11169: [FLINK-16196][hive] FlinkStandaloneHiveRunner leaks HMS process

2020-02-21 Thread GitBox
flinkbot commented on issue #11169: [FLINK-16196][hive] FlinkStandaloneHiveRunner leaks HMS process URL: https://github.com/apache/flink/pull/11169#issuecomment-589576991 ## CI report: * 6187e51e301c2c81d6e2fb9446747a2e5265e99a UNKNOWN Bot commands The @flinkbot

[GitHub] [flink] flinkbot edited a comment on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#issuecomment-588965557 ## CI report: * fee93cecf80cb73fcdf082f47fe0b9bd727a3002 Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382482736 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese URL: https://github.com/apache/flink/pull/11129#issuecomment-588061442 ## CI report: * d85ac6aa7166a24fff2bd1def31023877a95daeb Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382480419 ## File path:

[GitHub] [flink] flinkbot commented on issue #11170: [FLINK-16033][table-api] Expose catalog lookup function calls in Scala's expression dsl.

2020-02-21 Thread GitBox
flinkbot commented on issue #11170: [FLINK-16033][table-api] Expose catalog lookup function calls in Scala's expression dsl. URL: https://github.com/apache/flink/pull/11170#issuecomment-589572782 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] rkhachatryan edited a comment on issue #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting

2020-02-21 Thread GitBox
rkhachatryan edited a comment on issue #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting URL: https://github.com/apache/flink/pull/11071#issuecomment-589571827 BTW, I was thinking about another approach:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382478245 ## File path:

[GitHub] [flink] rkhachatryan commented on issue #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting

2020-02-21 Thread GitBox
rkhachatryan commented on issue #11071: [FLINK-16019][runtime] fix ContinuousFileReaderOperator error reporting URL: https://github.com/apache/flink/pull/11071#issuecomment-589571827 BTW, I was thinking about another approach:

[GitHub] [flink] dawidwys opened a new pull request #11170: [FLINK-16033][table-api] Expose catalog lookup function calls in Scala's expression dsl.

2020-02-21 Thread GitBox
dawidwys opened a new pull request #11170: [FLINK-16033][table-api] Expose catalog lookup function calls in Scala's expression dsl. URL: https://github.com/apache/flink/pull/11170 ## What is the purpose of the change First of all it fixes the fact that we were loosing function

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382476766 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382476367 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382476367 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382475991 ## File path:

[jira] [Updated] (FLINK-16197) Failed to query partitioned table when partition folder is removed

2020-02-21 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-16197: --- Description: If a partition exists in HMS but not in HDFS, the query fails with {noformat} Caused by:

[jira] [Commented] (FLINK-10231) Add a view SQL DDL

2020-02-21 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041698#comment-17041698 ] Zili Chen commented on FLINK-10231: --- Hi here, is this issue belongs to FLIP-71? > Add a view SQL DDL

[jira] [Created] (FLINK-16197) Failed to query partitioned table when partition folder is removed

2020-02-21 Thread Rui Li (Jira)
Rui Li created FLINK-16197: -- Summary: Failed to query partitioned table when partition folder is removed Key: FLINK-16197 URL: https://issues.apache.org/jira/browse/FLINK-16197 Project: Flink

[GitHub] [flink] zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-21 Thread GitBox
zhijiangW commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r382472385 ## File path:

[GitHub] [flink] lirui-apache commented on issue #11169: [FLINK-16196][hive] FlinkStandaloneHiveRunner leaks HMS process

2020-02-21 Thread GitBox
lirui-apache commented on issue #11169: [FLINK-16196][hive] FlinkStandaloneHiveRunner leaks HMS process URL: https://github.com/apache/flink/pull/11169#issuecomment-589565667 cc @bowenli86 @JingsongLi This is an automated

[GitHub] [flink] flinkbot commented on issue #11169: [FLINK-16196][hive] FlinkStandaloneHiveRunner leaks HMS process

2020-02-21 Thread GitBox
flinkbot commented on issue #11169: [FLINK-16196][hive] FlinkStandaloneHiveRunner leaks HMS process URL: https://github.com/apache/flink/pull/11169#issuecomment-589564795 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-16196) FlinkStandaloneHiveRunner leaks HMS process

2020-02-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16196: --- Labels: pull-request-available (was: ) > FlinkStandaloneHiveRunner leaks HMS process >

[GitHub] [flink] lirui-apache opened a new pull request #11169: [FLINK-16196][hive] FlinkStandaloneHiveRunner leaks HMS process

2020-02-21 Thread GitBox
lirui-apache opened a new pull request #11169: [FLINK-16196][hive] FlinkStandaloneHiveRunner leaks HMS process URL: https://github.com/apache/flink/pull/11169 ## What is the purpose of the change Make sure to kill HMS process if timed out waiting for it to start.

[GitHub] [flink] flinkbot commented on issue #11168: [FLINK-16140] [docs-zh] Translate Event Processing (CEP) page into Chinese

2020-02-21 Thread GitBox
flinkbot commented on issue #11168: [FLINK-16140] [docs-zh] Translate Event Processing (CEP) page into Chinese URL: https://github.com/apache/flink/pull/11168#issuecomment-589562914 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot edited a comment on issue #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11167: [FLINK-16129] [docs] Translate /ops/filesystems/index.zh.md URL: https://github.com/apache/flink/pull/11167#issuecomment-589539473 ## CI report: * e210c1aad1a84a8b2baabb019a895b677c358ebf Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#issuecomment-588965557 ## CI report: * fee93cecf80cb73fcdf082f47fe0b9bd727a3002 Travis:

[GitHub] [flink] shuai-xu opened a new pull request #11168: [FLINK-16140] [docs-zh] Translate Event Processing (CEP) page into Chinese

2020-02-21 Thread GitBox
shuai-xu opened a new pull request #11168: [FLINK-16140] [docs-zh] Translate Event Processing (CEP) page into Chinese URL: https://github.com/apache/flink/pull/11168 ## What is the purpose of the change *This pull request translates the CEP page into Chinese.* ##

[jira] [Updated] (FLINK-16140) Translate "Event Processing (CEP)" page into Chinese

2020-02-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16140: --- Labels: pull-request-available (was: ) > Translate "Event Processing (CEP)" page into

[GitHub] [flink] flinkbot edited a comment on issue #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese

2020-02-21 Thread GitBox
flinkbot edited a comment on issue #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese URL: https://github.com/apache/flink/pull/11129#issuecomment-588061442 ## CI report: * d85ac6aa7166a24fff2bd1def31023877a95daeb Travis:

[jira] [Commented] (FLINK-16142) Memory Leak causes Metaspace OOM error on repeated job submission

2020-02-21 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17041683#comment-17041683 ] Thomas Wozniakowski commented on FLINK-16142: - Hi [~sewen], here is the first chunk of the

[GitHub] [flink] twalthr commented on a change in pull request #11153: [FLINK-15958][table-common] Introduce unresolved data types in API

2020-02-21 Thread GitBox
twalthr commented on a change in pull request #11153: [FLINK-15958][table-common] Introduce unresolved data types in API URL: https://github.com/apache/flink/pull/11153#discussion_r382457836 ## File path:

[GitHub] [flink] twalthr commented on a change in pull request #11153: [FLINK-15958][table-common] Introduce unresolved data types in API

2020-02-21 Thread GitBox
twalthr commented on a change in pull request #11153: [FLINK-15958][table-common] Introduce unresolved data types in API URL: https://github.com/apache/flink/pull/11153#discussion_r382457836 ## File path:

[jira] [Updated] (FLINK-16196) FlinkStandaloneHiveRunner leaks HMS process

2020-02-21 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-16196: --- Description: When we time out waiting for HMS to start, we failed to cancel the HMS process via the watcher

[jira] [Created] (FLINK-16196) FlinkStandaloneHiveRunner leaks HMS process

2020-02-21 Thread Rui Li (Jira)
Rui Li created FLINK-16196: -- Summary: FlinkStandaloneHiveRunner leaks HMS process Key: FLINK-16196 URL: https://issues.apache.org/jira/browse/FLINK-16196 Project: Flink Issue Type: Test

[GitHub] [flink] pnowojski commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-21 Thread GitBox
pnowojski commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382441933 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-21 Thread GitBox
pnowojski commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382441933 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-21 Thread GitBox
pnowojski commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r382445336 ## File path:

[jira] [Closed] (FLINK-16002) Add stateful functions test utilities

2020-02-21 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16002. --- Fix Version/s: statefun-1.1 Resolution: Fixed > Add stateful functions test

<    1   2   3   4   5   6   >