[jira] [Updated] (FLINK-14637) Introduce framework off heap memory config

[ https://issues.apache.org/jira/browse/FLINK-14637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-14637: Description: At the moment after 

[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-554897033 @zjuwangg @xuefuz Thanks for your comments. I updated the PR accordingly. Please review again at your most convenient

[GitHub] [flink] klion26 commented on issue #10233: [FLINK-14830][docs] Correct the external link for Chinese version stream_checkpointing page

klion26 commented on issue #10233: [FLINK-14830][docs] Correct the external link for Chinese version stream_checkpointing page URL: https://github.com/apache/flink/pull/10233#issuecomment-554895971 @wuchong thanks for the reviewing and merging.

[GitHub] [flink] azagrebin commented on issue #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle)

azagrebin commented on issue #10180: [FLINK-14631] Account for netty direct allocations in direct memory limit (Netty Shuffle) URL: https://github.com/apache/flink/pull/10180#issuecomment-554891572 @zhijiangW Really thanks for the good insight. We were thinking about a

[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 #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics

flinkbot edited a comment on issue #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics URL: https://github.com/apache/flink/pull/10174#issuecomment-553372516 ## CI report: * 0877da16f10eef830aafb9d6b3328df1c1b461a0

[GitHub] [flink] TisonKun commented on a change in pull request #10194: [FLINK-14758] Add Executor-related interfaces and executor discovery.

TisonKun commented on a change in pull request #10194: [FLINK-14758] Add Executor-related interfaces and executor discovery. URL: https://github.com/apache/flink/pull/10194#discussion_r347228778 ## File path:

[GitHub] [flink] lamber-ken commented on issue #10228: [FLINK-14816] Add thread dump feature for taskmanager

lamber-ken commented on issue #10228: [FLINK-14816] Add thread dump feature for taskmanager URL: https://github.com/apache/flink/pull/10228#issuecomment-554885271 > I'm not sure whether or not it is a desirable feature to implement. Could you share the user case a bit? @lamber-ken

[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] TisonKun commented on issue #10228: [FLINK-14816] Add thread dump feature for taskmanager

TisonKun commented on issue #10228: [FLINK-14816] Add thread dump feature for taskmanager URL: https://github.com/apache/flink/pull/10228#issuecomment-554881322 I'm not sure whether or not it is a desirable feature to implement. Could you share the user case a bit? @lamber-ken

[jira] [Assigned] (FLINK-14816) Add thread dump feature for taskmanager

[ https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-14816: - Assignee: lamber-ken > Add thread dump feature for taskmanager >

[GitHub] [flink] TisonKun commented on a change in pull request #10205: [FLINK-14797][tests] Remove power mockito from RemoteStreamExecutionEnvironmentTest

TisonKun commented on a change in pull request #10205: [FLINK-14797][tests] Remove power mockito from RemoteStreamExecutionEnvironmentTest URL: https://github.com/apache/flink/pull/10205#discussion_r347222364 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347191720 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347207728 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347184596 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347188287 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347192732 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347190503 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347189167 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347186023 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347190983 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347184396 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347184961 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules

danny0405 commented on a change in pull request #10224: [FLINK-14716][table-planner-blink] Cooperate computed column with push down rules URL: https://github.com/apache/flink/pull/10224#discussion_r347185578 ## File path:

[jira] [Comment Edited] (FLINK-14735) Improve batch schedule check input consumable performance

[ https://issues.apache.org/jira/browse/FLINK-14735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976312#comment-16976312 ] Zhu Zhu edited comment on FLINK-14735 at 11/18/19 6:35 AM: --- Yes. The

[jira] [Comment Edited] (FLINK-14735) Improve batch schedule check input consumable performance

[ https://issues.apache.org/jira/browse/FLINK-14735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976312#comment-16976312 ] Zhu Zhu edited comment on FLINK-14735 at 11/18/19 6:34 AM: --- Yes. The

[jira] [Commented] (FLINK-14735) Improve batch schedule check input consumable performance

[ https://issues.apache.org/jira/browse/FLINK-14735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976312#comment-16976312 ] Zhu Zhu commented on FLINK-14735: - Yes. The {{InputDependencyConstraint}} check was introduced in 1.8 by

[GitHub] [flink] TisonKun edited a comment on issue #10185: [FLINK-14762][client] Implement ClusterClientJobClientAdapter

TisonKun edited a comment on issue #10185: [FLINK-14762][client] Implement ClusterClientJobClientAdapter URL: https://github.com/apache/flink/pull/10185#issuecomment-554872452 @aljoscha it sounds a bit weird to me. If we move `JobClient` interface to `flink-core` and remains the

[GitHub] [flink] TisonKun commented on issue #10185: [FLINK-14762][client] Implement ClusterClientJobClientAdapter

TisonKun commented on issue #10185: [FLINK-14762][client] Implement ClusterClientJobClientAdapter URL: https://github.com/apache/flink/pull/10185#issuecomment-554872452 @aljoscha it sounds a bit weird to me. If we move `JobClient` interface to `flink-core` and remains the implementation

[jira] [Comment Edited] (FLINK-12362) Remove legacy container number config option for Flink on yarn

[ https://issues.apache.org/jira/browse/FLINK-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976310#comment-16976310 ] Jeff Zhang edited comment on FLINK-12362 at 11/18/19 6:28 AM: -- [~yanghua] 

[jira] [Commented] (FLINK-12362) Remove legacy container number config option for Flink on yarn

[ https://issues.apache.org/jira/browse/FLINK-12362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976310#comment-16976310 ] Jeff Zhang commented on FLINK-12362: [~yanghua] How can do that via start-scala-shell ?  > Remove

[GitHub] [flink] TisonKun commented on issue #10207: [FLINK-14766] Remove volatile variable in ExecutionVertex

TisonKun commented on issue #10207: [FLINK-14766] Remove volatile variable in ExecutionVertex URL: https://github.com/apache/flink/pull/10207#issuecomment-554866884 @buptljy if these variable are guarded by locks so that we don't need to marking them as `volatile`, I think it is necessary

[GitHub] [flink] flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group

flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group URL: https://github.com/apache/flink/pull/10232#issuecomment-554775330 ## CI report: * b62006e7cf875fa318b3ce57afb14b0b2679bcb5

[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=16976296#comment-16976296 ] Kurt Young edited comment on FLINK-14567 at 11/18/19 5:42 AM: -- It depends

[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=16976296#comment-16976296 ] Kurt Young commented on FLINK-14567: It depends on how we see this problem. IMO if we want to emit

[GitHub] [flink] flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group

flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group URL: https://github.com/apache/flink/pull/10232#issuecomment-554775330 ## CI report: * b62006e7cf875fa318b3ce57afb14b0b2679bcb5

[GitHub] [flink] flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group

flinkbot edited a comment on issue #10232: [FLINK-14314][runtime] Allocate shared slot resources respecting the resources of all vertices in the group URL: https://github.com/apache/flink/pull/10232#issuecomment-554775330 ## CI report: * b62006e7cf875fa318b3ce57afb14b0b2679bcb5

[GitHub] [flink] flinkbot edited a comment on issue #10206: [FLINK-14781] [docs-zh] clarify that a RocksDB dependency in pom.xml may not be needed

flinkbot edited a comment on issue #10206: [FLINK-14781] [docs-zh] clarify that a RocksDB dependency in pom.xml may not be needed URL: https://github.com/apache/flink/pull/10206#issuecomment-554207625 ## CI report: * 6c2fb0094be219ab90a28b525a5d0c8504f2d45d : SUCCESS

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

xuefuz 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_r347198556 ## File path: flink-table/flink-sql-parser/src/main/codegen/data/Parser.tdd ## @@ -342,7 +346,6

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

xuefuz 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_r347199015 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ## @@

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

xuefuz 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_r347198622 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ## @@

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

xuefuz 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_r347198724 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10206: [FLINK-14781] [docs-zh] clarify that a RocksDB dependency in pom.xml may not be needed

flinkbot edited a comment on issue #10206: [FLINK-14781] [docs-zh] clarify that a RocksDB dependency in pom.xml may not be needed URL: https://github.com/apache/flink/pull/10206#issuecomment-554207625 ## CI report: * 6c2fb0094be219ab90a28b525a5d0c8504f2d45d : SUCCESS

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

xuefuz 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_r347198098 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ## @@

[GitHub] [flink] flinkbot edited a comment on issue #10144: [FLINK-14613][table-planner-blink] Fix temporal table join when containing multiple keyfields with UDF

flinkbot edited a comment on issue #10144: [FLINK-14613][table-planner-blink] Fix temporal table join when containing multiple keyfields with UDF URL: https://github.com/apache/flink/pull/10144#issuecomment-552178404 ## CI report: * c0059cd9abc4281fbc962aba9d2a2a9d7965f745 :

[GitHub] [flink] flinkbot edited a comment on issue #10206: [FLINK-14781] [docs-zh] clarify that a RocksDB dependency in pom.xml may not be needed

flinkbot edited a comment on issue #10206: [FLINK-14781] [docs-zh] clarify that a RocksDB dependency in pom.xml may not be needed URL: https://github.com/apache/flink/pull/10206#issuecomment-554207625 ## CI report: * 6c2fb0094be219ab90a28b525a5d0c8504f2d45d : SUCCESS

[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

[GitHub] [flink] docete commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte…

docete commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte… URL: https://github.com/apache/flink/pull/10212#discussion_r347193267 ## File path:

[GitHub] [flink] catkint commented on issue #10206: [FLINK-14781] [docs-zh] clarify that a RocksDB dependency in pom.xml may not be needed

catkint commented on issue #10206: [FLINK-14781] [docs-zh] clarify that a RocksDB dependency in pom.xml may not be needed URL: https://github.com/apache/flink/pull/10206#issuecomment-554837578 Hi, It seems that friend finished this issue before me. And without using jira. I modify some

[GitHub] [flink] flinkbot edited a comment on issue #10144: [FLINK-14613][table-planner-blink] Fix temporal table join when containing multiple keyfields with UDF

flinkbot edited a comment on issue #10144: [FLINK-14613][table-planner-blink] Fix temporal table join when containing multiple keyfields with UDF URL: https://github.com/apache/flink/pull/10144#issuecomment-552178404 ## CI report: * c0059cd9abc4281fbc962aba9d2a2a9d7965f745 :

[GitHub] [flink] wuchong commented on a change in pull request #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

wuchong commented on a change in pull request #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#discussion_r347188400 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

wuchong commented on a change in pull request #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#discussion_r347185790 ## File path:

[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=16976257#comment-16976257 ] Victor Wong commented on FLINK-14817: - [~jark], thanks for your quick reply. Please assign this

[GitHub] [flink] flinkbot commented on issue #10233: [FLINK-14830][docs] Correct the external link for Chinese version stream_checkpointing page

flinkbot commented on issue #10233: [FLINK-14830][docs] Correct the external link for Chinese version stream_checkpointing page URL: https://github.com/apache/flink/pull/10233#issuecomment-554831758 ## CI report: * 2d02cfa2499aeaad880829876eaeaa807a0a34ca : UNKNOWN

[jira] [Updated] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

[ https://issues.apache.org/jira/browse/FLINK-14835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-14835: Description: *Goal:* To make the following code examples work in production, which is very handy

[GitHub] [flink] Mrart commented on a change in pull request #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics

Mrart commented on a change in pull request #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics URL: https://github.com/apache/flink/pull/10230#discussion_r347180972 ## File path:

[jira] [Updated] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

[ https://issues.apache.org/jira/browse/FLINK-14835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-14835: Description: To make the following code examples work in production, which is very handy for

[GitHub] [flink] TisonKun commented on issue #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

TisonKun commented on issue #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#issuecomment-554830820 @wangyang0918 after a consideration my opinion is that the second part of this pull request doesn't

[jira] [Updated] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

[ https://issues.apache.org/jira/browse/FLINK-14835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-14835: External issue URL: (was: https://issues.apache.org/jira/browse/FLINK-14817) > Make

[jira] [Created] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

Victor Wong created FLINK-14835: --- Summary: Make `org.apache.flink.configuration.Configuration` support method chaining Key: FLINK-14835 URL: https://issues.apache.org/jira/browse/FLINK-14835 Project:

[GitHub] [flink] flinkbot edited a comment on issue #10144: [FLINK-14613][table-planner-blink] Fix temporal table join when containing multiple keyfields with UDF

flinkbot edited a comment on issue #10144: [FLINK-14613][table-planner-blink] Fix temporal table join when containing multiple keyfields with UDF URL: https://github.com/apache/flink/pull/10144#issuecomment-552178404 ## CI report: * c0059cd9abc4281fbc962aba9d2a2a9d7965f745 :

[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

[GitHub] [flink] klion26 edited a comment on issue #10206: [FLINK-14781] [docs-zh] clarify that a RocksDB dependency in pom.xml may not be needed

klion26 edited a comment on issue #10206: [FLINK-14781] [docs-zh] clarify that a RocksDB dependency in pom.xml may not be needed URL: https://github.com/apache/flink/pull/10206#issuecomment-554829710 Hi, @catkint seems there still some conflict there, could you please rebase the new

[jira] [Comment Edited] (FLINK-14814) Show the vertex that produces the backpressure source in the job

[ https://issues.apache.org/jira/browse/FLINK-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976238#comment-16976238 ] lining edited comment on FLINK-14814 at 11/18/19 2:57 AM: -- Now we may just show

[jira] [Comment Edited] (FLINK-14814) Show the vertex that produces the backpressure source in the job

[ https://issues.apache.org/jira/browse/FLINK-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976238#comment-16976238 ] lining edited comment on FLINK-14814 at 11/18/19 2:57 AM: -- Now we may just show

[GitHub] [flink] klion26 commented on issue #10206: [FLINK-14781] [docs-zh] clarify that a RocksDB dependency in pom.xml may not be needed

klion26 commented on issue #10206: [FLINK-14781] [docs-zh] clarify that a RocksDB dependency in pom.xml may not be needed URL: https://github.com/apache/flink/pull/10206#issuecomment-554829710 Hi @catkint could you please rebase the new master branch to fix the conflict first?

[GitHub] [flink] TsReaper commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics

TsReaper commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics URL: https://github.com/apache/flink/pull/10174#discussion_r347183638 ## File path:

[jira] [Resolved] (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 resolved FLINK-14830. - Resolution: Fixed 1.10.0: f6e39aa60d1ce3c020fcb49955912e559d5202e7 > Correct the link for chinese

[GitHub] [flink] wuchong merged pull request #10233: [FLINK-14830][docs] Correct the external link for Chinese version stream_checkpointing page

wuchong merged pull request #10233: [FLINK-14830][docs] Correct the external link for Chinese version stream_checkpointing page URL: https://github.com/apache/flink/pull/10233 This is an automated message from the Apache

[GitHub] [flink] JingsongLi commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte…

JingsongLi commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte… URL: https://github.com/apache/flink/pull/10212#discussion_r347182205 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte…

JingsongLi commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte… URL: https://github.com/apache/flink/pull/10212#discussion_r347182280 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte…

JingsongLi commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte… URL: https://github.com/apache/flink/pull/10212#discussion_r347182468 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte…

JingsongLi commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte… URL: https://github.com/apache/flink/pull/10212#discussion_r347184123 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte…

JingsongLi commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte… URL: https://github.com/apache/flink/pull/10212#discussion_r347183975 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte…

JingsongLi commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte… URL: https://github.com/apache/flink/pull/10212#discussion_r347182594 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte…

JingsongLi commented on a change in pull request #10212: [FLINK-14806][table-planner-blink] Add setTimestamp/getTimestamp inte… URL: https://github.com/apache/flink/pull/10212#discussion_r347182810 ## File path:

[GitHub] [flink] flinkbot commented on issue #10233: [FLINK-14830][docs] Correct the external link for Chinese version stream_checkpointing page

flinkbot commented on issue #10233: [FLINK-14830][docs] Correct the external link for Chinese version stream_checkpointing page URL: https://github.com/apache/flink/pull/10233#issuecomment-554827004 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[jira] [Updated] (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 ] ASF GitHub Bot updated FLINK-14830: --- Labels: pull-request-available (was: ) > Correct the link for chinese version

[GitHub] [flink] TsReaper commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics

TsReaper commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics URL: https://github.com/apache/flink/pull/10174#discussion_r347183638 ## File path:

[GitHub] [flink] klion26 opened a new pull request #10233: [FLINK-14830][docs] Correct the external link for Chinese version stream_checkpointing page

klion26 opened a new pull request #10233: [FLINK-14830][docs] Correct the external link for Chinese version stream_checkpointing page URL: https://github.com/apache/flink/pull/10233 ## What is the purpose of the change Correct the external link for Chinese version in

[GitHub] [flink] klion26 commented on issue #10233: [FLINK-14830][docs] Correct the external link for Chinese version stream_checkpointing page

klion26 commented on issue #10233: [FLINK-14830][docs] Correct the external link for Chinese version stream_checkpointing page URL: https://github.com/apache/flink/pull/10233#issuecomment-554826355 cc @wuchong This is an

[jira] [Updated] (FLINK-14814) Show the vertex that produces the backpressure source in the job

[ https://issues.apache.org/jira/browse/FLINK-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14814: --- Attachment: 2B0E910D-6D95-401F-B450-1F6B1AFB9BEA.png > Show the vertex that produces the backpressure

[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=16976242#comment-16976242 ] Jark Wu commented on FLINK-14567: - But adding an operator to convert into upsert stream is an

[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] lamber-ken removed a comment on issue #10228: [FLINK-14816] Add thread dump feature for taskmanager

lamber-ken removed a comment on issue #10228: [FLINK-14816] Add thread dump feature for taskmanager URL: https://github.com/apache/flink/pull/10228#issuecomment-554759306 @flinkbot run travis This is an automated message

[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

[jira] [Updated] (FLINK-14815) Expose network pool usage in IOMetricsInfo

[ https://issues.apache.org/jira/browse/FLINK-14815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14815: --- Description: * If sub task is not back pressured, but it is causing a back pressure (full input, empty

[jira] [Commented] (FLINK-14814) Show the vertex that produces the backpressure source in the job

[ https://issues.apache.org/jira/browse/FLINK-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16976238#comment-16976238 ] lining commented on FLINK-14814: Now we may just show this information in the Web Frontend. > Show the

[GitHub] [flink] zhijiangW merged pull request #10218: [hotfix][network] Reduce the synchronisation overhead in CreditBasedSequenceNumberingViewReader

zhijiangW merged pull request #10218: [hotfix][network] Reduce the synchronisation overhead in CreditBasedSequenceNumberingViewReader URL: https://github.com/apache/flink/pull/10218 This is an automated message from the

[GitHub] [flink] Mrart commented on a change in pull request #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics

Mrart commented on a change in pull request #10230: [FLINK-14803][metrics]Support Consistency Level for InfluxDB metrics URL: https://github.com/apache/flink/pull/10230#discussion_r347180972 ## File path:

[GitHub] [flink] lamber-ken commented on issue #10228: [FLINK-14816] Add thread dump feature for taskmanager

lamber-ken commented on issue #10228: [FLINK-14816] Add thread dump feature for taskmanager URL: https://github.com/apache/flink/pull/10228#issuecomment-554820006 hi, @TisonKun please cc, thanks. This is an automated

[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)

[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=16976226#comment-16976226 ] Jingsong Lee commented on FLINK-14808: -- [~kkl0u] Yes, please assign to me. > ClientUtils set

[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

[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

[GitHub] [flink] openinx closed pull request #9981: [FLINK-13195][sql-client] Add create table support for SqlClient

openinx closed pull request #9981: [FLINK-13195][sql-client] Add create table support for SqlClient URL: https://github.com/apache/flink/pull/9981 This is an automated message from the Apache Git Service. To respond to the

[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

[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

[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

  1   2   >