[GitHub] [flink] flinkbot edited a comment on issue #10231: [FLINK-14711][table] add alter and show function ddl

flinkbot edited a comment on issue #10231: [FLINK-14711][table] add alter and show function ddl URL: https://github.com/apache/flink/pull/10231#issuecomment-554720304 ## CI report: * 3dc398a62bfd6c3da7561cba9f5e6c7f43947369 : PENDING [Build](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] zjuwangg commented on issue #10231: [FLINK-14711][table] add alter and show function ddl

zjuwangg commented on issue #10231: [FLINK-14711][table] add alter and show function ddl URL: https://github.com/apache/flink/pull/10231#issuecomment-554720311 Thanks @HuangZhenQiu for your work on this. I left some comments from my side. ---

[GitHub] [flink] flinkbot commented on issue #10231: [FLINK-14711][table] add alter and show function ddl

flinkbot commented on issue #10231: [FLINK-14711][table] add alter and show function ddl URL: https://github.com/apache/flink/pull/10231#issuecomment-554720304 ## CI report: * 3dc398a62bfd6c3da7561cba9f5e6c7f43947369 : UNKNOWN Bot commands The @flinkbot bot suppor

[GitHub] [flink] flinkbot edited a comment on issue #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics

flinkbot edited a comment on issue #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics URL: https://github.com/apache/flink/pull/10230#issuecomment-554717265 ## CI report: * 520a41fb6c3b0fdde8fdcea87a348d12918b2481 : CANCELED [Build](https://travis-ci.co

[GitHub] [flink] zjuwangg commented on a change in pull request #10231: [FLINK-14711][table] add alter and show function ddl

zjuwangg commented on a change in pull request #10231: [FLINK-14711][table] add alter and show function ddl URL: https://github.com/apache/flink/pull/10231#discussion_r347121198 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterDatabas

[GitHub] [flink] zjuwangg commented on a change in pull request #10231: [FLINK-14711][table] add alter and show function ddl

zjuwangg commented on a change in pull request #10231: [FLINK-14711][table] add alter and show function ddl URL: https://github.com/apache/flink/pull/10231#discussion_r347121153 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ## @@ -17

[GitHub] [flink] zjuwangg commented on a change in pull request #10231: [FLINK-14711][table] add alter and show function ddl

zjuwangg commented on a change in pull request #10231: [FLINK-14711][table] add alter and show function ddl URL: https://github.com/apache/flink/pull/10231#discussion_r347121104 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ## @@ -17

[GitHub] [flink] zjuwangg commented on a change in pull request #10231: [FLINK-14711][table] add alter and show function ddl

zjuwangg commented on a change in pull request #10231: [FLINK-14711][table] add alter and show function ddl URL: https://github.com/apache/flink/pull/10231#discussion_r347121223 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterFunctio

[jira] [Created] (FLINK-14832) Support kafka metrics reporter

ouyangwulin created FLINK-14832: --- Summary: Support kafka metrics reporter Key: FLINK-14832 URL: https://issues.apache.org/jira/browse/FLINK-14832 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-14831) When edit flink-metrics-influxdb, need add metrics.md by hand

[ https://issues.apache.org/jira/browse/FLINK-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975933#comment-16975933 ] ouyangwulin commented on FLINK-14831: - can assign this for me > When edit flink-met

[jira] [Created] (FLINK-14831) When edit flink-metrics-influxdb, need add metrics.md by hand

ouyangwulin created FLINK-14831: --- Summary: When edit flink-metrics-influxdb, need add metrics.md by hand Key: FLINK-14831 URL: https://issues.apache.org/jira/browse/FLINK-14831 Project: Flink

[jira] [Commented] (FLINK-14711) Create Alter Function and Show Functions DDL

[ https://issues.apache.org/jira/browse/FLINK-14711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975932#comment-16975932 ] Zhenqiu Huang commented on FLINK-14711: --- [~Terry1897] [~phoenixjiangnan] [~xuefuz]

[GitHub] [flink] flinkbot commented on issue #10231: [FLINK-14711][table] add alter and show function ddl

flinkbot commented on issue #10231: [FLINK-14711][table] add alter and show function ddl URL: https://github.com/apache/flink/pull/10231#issuecomment-554718984 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull req

[GitHub] [flink] HuangZhenQiu commented on issue #10231: [FLINK-14711][table] add alter and show function ddl

HuangZhenQiu commented on issue #10231: [FLINK-14711][table] add alter and show function ddl URL: https://github.com/apache/flink/pull/10231#issuecomment-554718976 @zjuwangg @bowenli86 @xuefuz Please review this PR at your most convenient time. The PR only add new functions in Parser.

[jira] [Updated] (FLINK-14711) Create Alter Function and Show Functions DDL

[ https://issues.apache.org/jira/browse/FLINK-14711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14711: --- Labels: pull-request-available (was: ) > Create Alter Function and Show Functions DDL > ---

[GitHub] [flink] HuangZhenQiu opened a new pull request #10231: [FLINK-14711][table] add alter and show function ddl

HuangZhenQiu opened a new pull request #10231: [FLINK-14711][table] add alter and show function ddl URL: https://github.com/apache/flink/pull/10231 ## Brief change log - Add alter function and show functions ddl in SQL parser - Add unit test in FlinkSqlParserImplTest ##

[jira] [Updated] (FLINK-14803) Support Consistency Level for InfluxDB metrics

[ https://issues.apache.org/jira/browse/FLINK-14803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-14803: Summary: Support Consistency Level for InfluxDB metrics (was: -) > Support Consistency Level for

[GitHub] [flink] flinkbot edited a comment on issue #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics

flinkbot edited a comment on issue #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics URL: https://github.com/apache/flink/pull/10230#issuecomment-554717265 ## CI report: * 520a41fb6c3b0fdde8fdcea87a348d12918b2481 : PENDING [Build](https://travis-ci.com

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

[ https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975930#comment-16975930 ] Kurt Young commented on FLINK-14567: Even if the framework can't derive primary key

[GitHub] [flink] flinkbot commented on issue #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics

flinkbot commented on issue #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics URL: https://github.com/apache/flink/pull/10230#issuecomment-554717265 ## CI report: * 520a41fb6c3b0fdde8fdcea87a348d12918b2481 : UNKNOWN Bot commands The @fli

[GitHub] [flink] flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#issuecomment-553966392 ## CI report: * e4e45953ce0e5f3a20040e7bdf0016f90a0ea76e : SUCCESS [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #10179: [FLINK-14734][runtime] Add a ResourceSpec in SlotSharingGroup to describe its overall resources

flinkbot edited a comment on issue #10179: [FLINK-14734][runtime] Add a ResourceSpec in SlotSharingGroup to describe its overall resources URL: https://github.com/apache/flink/pull/10179#issuecomment-553511659 ## CI report: * a742132b798ff91bce1fb183f23f4461ade767b9 : SUCCESS [B

[GitHub] [flink] flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#issuecomment-549401980 ## CI report: * 5b7e9e832ed26f476d0149663b2f0dec9f1bc427 : SUCCES

[jira] [Resolved] (FLINK-14553) Respect non-blocking output in StreamTask#processInput

[ https://issues.apache.org/jira/browse/FLINK-14553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang resolved FLINK-14553. -- Resolution: Fixed Merged in master : 2c8b4ef572f05bf4740b7e204af1e5e709cd945c > Respect non-blocking

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] zhijiangW merged pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

zhijiangW merged pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029 This is an automated message from the Apache Git Service. T

[GitHub] [flink] flinkbot commented on issue #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics

flinkbot commented on issue #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics URL: https://github.com/apache/flink/pull/10230#issuecomment-554714697 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[jira] [Updated] (FLINK-14803) -

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

[GitHub] [flink] Mrart opened a new pull request #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics

Mrart opened a new pull request #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics URL: https://github.com/apache/flink/pull/10230 ## What is the purpose of the change *Support Consistency Level for InfluxDB metrics reporter. influxdb batch insert data defa

[jira] [Updated] (FLINK-14803) -

[ https://issues.apache.org/jira/browse/FLINK-14803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin updated FLINK-14803: Summary: - (was: Support Consistency Level for InfluxDB metrics reporter) > - > - > >

[GitHub] [flink] flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#issuecomment-553966392 ## CI report: * e4e45953ce0e5f3a20040e7bdf0016f90a0ea76e : SUCCESS [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[GitHub] [flink] flinkbot edited a comment on issue #10179: [FLINK-14734][runtime] Add a ResourceSpec in SlotSharingGroup to describe its overall resources

flinkbot edited a comment on issue #10179: [FLINK-14734][runtime] Add a ResourceSpec in SlotSharingGroup to describe its overall resources URL: https://github.com/apache/flink/pull/10179#issuecomment-553511659 ## CI report: * a742132b798ff91bce1fb183f23f4461ade767b9 : SUCCESS [B

[GitHub] [flink] flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#issuecomment-549401980 ## CI report: * 5b7e9e832ed26f476d0149663b2f0dec9f1bc427 : SUCCES

[GitHub] [flink] flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#issuecomment-553966392 ## CI report: * e4e45953ce0e5f3a20040e7bdf0016f90a0ea76e : SUCCESS [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[GitHub] [flink] flinkbot edited a comment on issue #10179: [FLINK-14734][runtime] Add a ResourceSpec in SlotSharingGroup to describe its overall resources

flinkbot edited a comment on issue #10179: [FLINK-14734][runtime] Add a ResourceSpec in SlotSharingGroup to describe its overall resources URL: https://github.com/apache/flink/pull/10179#issuecomment-553511659 ## CI report: * a742132b798ff91bce1fb183f23f4461ade767b9 : SUCCESS [B

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#issuecomment-549401980 ## CI report: * 5b7e9e832ed26f476d0149663b2f0dec9f1bc427 : SUCCES

[GitHub] [flink] flinkbot edited a comment on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

flinkbot edited a comment on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#issuecomment-547346386 ## CI report: * a41da903ca8bcf9fc325107d2b11f19b76c5508e : FAILURE [Build](https://tra

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r346897094 ## File path: flink-runtime/src/main/java/org/apache/fl

[GitHub] [flink] zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values

zhuzhurk commented on a change in pull request #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values URL: https://github.com/apache/flink/pull/10079#discussion_r346868195 ## File path: flink-runtime/src/main/java/org/apache/fl

[jira] [Commented] (FLINK-14830) Correct the link for chinese version stream_checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-14830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975908#comment-16975908 ] Jark Wu commented on FLINK-14830: - I assigned this issue to you [~klion26], feel free to

[jira] [Assigned] (FLINK-14830) Correct the link for chinese version stream_checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-14830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14830: --- Assignee: Congxian Qiu(klion26) > Correct the link for chinese version stream_checkpointing page >

[GitHub] [flink] flinkbot edited a comment on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

flinkbot edited a comment on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#issuecomment-547346386 ## CI report: * a41da903ca8bcf9fc325107d2b11f19b76c5508e : FAILURE [Build](https://tra

[jira] [Commented] (FLINK-14830) Correct the link for chinese version stream_checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-14830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975905#comment-16975905 ] Congxian Qiu(klion26) commented on FLINK-14830: --- [~jark], I agree that cha

[jira] [Commented] (FLINK-7151) Add a basic function SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975904#comment-16975904 ] Zhenqiu Huang commented on FLINK-7151: -- [~Terry1897] [~phoenixjiangnan] [~xuefuz] W

[jira] [Comment Edited] (FLINK-14830) Correct the link for chinese version stream_checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-14830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975903#comment-16975903 ] Jark Wu edited comment on FLINK-14830 at 11/17/19 3:34 AM: --- [~

[jira] [Commented] (FLINK-14830) Correct the link for chinese version stream_checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-14830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975903#comment-16975903 ] Jark Wu commented on FLINK-14830: - [~klion26], I agree with you this is bad for user exp

[jira] [Updated] (FLINK-14801) Improve the local variable name in SqlCreateTable#unparser()

[ https://issues.apache.org/jira/browse/FLINK-14801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14801: Summary: Improve the local variable name in SqlCreateTable#unparser() (was: flink sql parser unparser fun

[GitHub] [flink] wuchong closed pull request #10229: [FLINK-14801] flink sql parser unparser func partition frame local variable name mistake

wuchong closed pull request #10229: [FLINK-14801] flink sql parser unparser func partition frame local variable name mistake URL: https://github.com/apache/flink/pull/10229 This is an automated message from the Apache Git S

[jira] [Resolved] (FLINK-14801) flink sql parser unparser func partition frame local variable name mistake

[ https://issues.apache.org/jira/browse/FLINK-14801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14801. - Resolution: Fixed 1.10.0: e6fc1c6b98be89ded846f42f65a946330f40e54e > flink sql parser unparser func pa

[jira] [Commented] (FLINK-14830) Correct the link for chinese version stream_checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-14830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975901#comment-16975901 ] Congxian Qiu(klion26) commented on FLINK-14830: --- [~jark] I think this is a

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

flinkbot edited a comment on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#issuecomment-547346386 ## CI report: * a41da903ca8bcf9fc325107d2b11f19b76c5508e : FAILURE [Build](https://tra

[jira] [Commented] (FLINK-14830) Correct the link for chinese version stream_checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-14830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975900#comment-16975900 ] Jark Wu commented on FLINK-14830: - Hi [~klion26], I think this is not a problem, because

[jira] [Commented] (FLINK-14817) "Streaming Aggregation" document contains misleading code examples

[ https://issues.apache.org/jira/browse/FLINK-14817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975899#comment-16975899 ] Jark Wu commented on FLINK-14817: - Good catch! I would suggest to update the documentati

[jira] [Comment Edited] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

[ https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975898#comment-16975898 ] Jark Wu edited comment on FLINK-14567 at 11/17/19 3:07 AM: --- An

[jira] [Commented] (FLINK-14803) Support Consistency Level for InfluxDB metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-14803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975897#comment-16975897 ] ouyangwulin commented on FLINK-14803: - yes, I have test in our env. I will push to g

[jira] [Commented] (FLINK-14567) Aggregate query with more than two group fields can't be write into HBase sink

[ https://issues.apache.org/jira/browse/FLINK-14567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975898#comment-16975898 ] Jark Wu commented on FLINK-14567: - Another soution is letting sink concats keys. For exa

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[jira] [Commented] (FLINK-14808) ClientUtils set thread ClassLoader that is different from the user cl of PackagedProgram

[ https://issues.apache.org/jira/browse/FLINK-14808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975854#comment-16975854 ] Zili Chen commented on FLINK-14808: --- [~kkl0u] after looking into your fix I think I mi

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#issuecomment-553966392 ## CI report: * e4e45953ce0e5f3a20040e7bdf0016f90a0ea76e : SUCCESS [Build](http

[jira] [Commented] (FLINK-14830) Correct the link for chinese version stream_checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-14830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975685#comment-16975685 ] Congxian Qiu(klion26) commented on FLINK-14830: --- [~jark] what do you think

[jira] [Created] (FLINK-14830) Correct the link for chinese version stream_checkpointing page

Congxian Qiu(klion26) created FLINK-14830: - Summary: Correct the link for chinese version stream_checkpointing page Key: FLINK-14830 URL: https://issues.apache.org/jira/browse/FLINK-14830 Pro

[GitHub] [flink] flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#issuecomment-553966392 ## CI report: * e4e45953ce0e5f3a20040e7bdf0016f90a0ea76e : SUCCESS [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#issuecomment-553966392 ## CI report: * e4e45953ce0e5f3a20040e7bdf0016f90a0ea76e : SUCCESS [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#issuecomment-553966392 ## CI report: * e4e45953ce0e5f3a20040e7bdf0016f90a0ea76e : SUCCESS [Build](http

[GitHub] [flink] zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#discussion_r347086796 ## File path: flink-streaming-java/src/main/java/org/apache/flink/strea

[GitHub] [flink] zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#discussion_r347086338 ## File path: flink-streaming-java/src/main/java/org/apache/flink/strea

[GitHub] [flink] flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

flinkbot edited a comment on issue #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#issuecomment-553966392 ## CI report: * e4e45953ce0e5f3a20040e7bdf0016f90a0ea76e : SUCCESS [Build](http

[GitHub] [flink] zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#discussion_r347085720 ## File path: flink-streaming-java/src/test/java/org/apache/flink/strea

[GitHub] [flink] zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#discussion_r347085733 ## File path: flink-streaming-java/src/test/java/org/apache/flink/strea

[GitHub] [flink] zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#discussion_r347085730 ## File path: flink-streaming-java/src/main/java/org/apache/flink/strea

[GitHub] [flink] zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#discussion_r347085726 ## File path: flink-streaming-java/src/main/java/org/apache/flink/strea

[GitHub] [flink] zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#discussion_r347085735 ## File path: flink-streaming-java/src/main/java/org/apache/flink/strea

[GitHub] [flink] zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#discussion_r347085723 ## File path: flink-streaming-java/src/main/java/org/apache/flink/strea

[GitHub] [flink] zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#discussion_r347085720 ## File path: flink-streaming-java/src/test/java/org/apache/flink/strea

[GitHub] [flink] zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#discussion_r347083829 ## File path: flink-streaming-java/src/main/java/org/apache/flink/strea

[GitHub] [flink] zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#discussion_r347083742 ## File path: flink-streaming-java/src/main/java/org/apache/flink/strea

[GitHub] [flink] zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#discussion_r347083742 ## File path: flink-streaming-java/src/main/java/org/apache/flink/strea

[GitHub] [flink] zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#discussion_r347083742 ## File path: flink-streaming-java/src/main/java/org/apache/flink/strea

[GitHub] [flink] zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups

zhuzhurk commented on a change in pull request #10200: [FLINK-14062][runtime] Calculate managed memory fraction based on slot sharing groups URL: https://github.com/apache/flink/pull/10200#discussion_r347083742 ## File path: flink-streaming-java/src/main/java/org/apache/flink/strea

[GitHub] [flink] flinkbot edited a comment on issue #10229: [FLINK-14801] flink sql parser unparser func partition frame local variable name mistake

flinkbot edited a comment on issue #10229: [FLINK-14801] flink sql parser unparser func partition frame local variable name mistake URL: https://github.com/apache/flink/pull/10229#issuecomment-554614085 ## CI report: * 6a8c6e1dd8c26568e92eb6ae6f6f8de216f23b8d : SUCCESS [Build](

[jira] [Commented] (FLINK-14829) Add test that verifies that the CLI sets the correct classloader.

[ https://issues.apache.org/jira/browse/FLINK-14829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975637#comment-16975637 ] Kostas Kloudas commented on FLINK-14829: [~lzljs3620320]  FYI > Add test that v

[jira] [Commented] (FLINK-14808) ClientUtils set thread ClassLoader that is different from the user cl of PackagedProgram

[ https://issues.apache.org/jira/browse/FLINK-14808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975634#comment-16975634 ] Kostas Kloudas commented on FLINK-14808: [~tison] could you also point me to the

  1   2   >