[jira] [Commented] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962754#comment-16962754 ] Jark Wu commented on FLINK-14539: - [~KevinZwx], Yes, this is an very important use case

[GitHub] [flink] HuangXingBo commented on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner

HuangXingBo commented on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner URL: https://github.com/apache/flink/pull/10016#issuecomment-547763384 Thanks for @hequn8128 and @wuchong , I have replace the IT test with UT test. --

[jira] [Commented] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962753#comment-16962753 ] Kevin Zhang commented on FLINK-14539: - [~jark] thansk, greate catch, I omitted this

[jira] [Commented] (FLINK-13900) Add a built-in "console" sink to print results in console

[ https://issues.apache.org/jira/browse/FLINK-13900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962751#comment-16962751 ] Jark Wu commented on FLINK-13900: - Hi [~xiaodao], this is one of the approaches. However

[GitHub] [flink] zhuzhurk commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

zhuzhurk commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#discussion_r340451673 ## File path: flink-core/src/main/java/org/apache/fl

[GitHub] [flink] zhuzhurk commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

zhuzhurk commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#discussion_r340451673 ## File path: flink-core/src/main/java/org/apache/fl

[GitHub] [flink] wuchong commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

wuchong commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#discussion_r340449692 ## File path: flink-table/flink-table-planner-blink/src/mai

[GitHub] [flink] flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-546947394 ## CI report: * c851f9713cef338dd135c3e982f138d68bfbe33d

[jira] [Updated] (FLINK-13869) Hive functions can not work in blink planner stream mode

[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13869: Description: In flink, specifying the StreamTableEnvironment through the EnvironmentSetting using the bli

[jira] [Commented] (FLINK-13900) Add a built-in "console" sink to print results in console

[ https://issues.apache.org/jira/browse/FLINK-13900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962739#comment-16962739 ] xiaodao commented on FLINK-13900: - why not design console just like a sink table.we can

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340447130 ## File path: flink-runtime/src/main/java/org/apache/fl

[GitHub] [flink] JingsongLi commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

JingsongLi commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#discussion_r340446487 ## File path: flink-table/flink-table-planner-blink/src/

[jira] [Updated] (FLINK-13869) Hive functions can not work in blink planner stream mode

[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13869: - Description: In flink, specifying the StreamTableEnvironment through the EnvironmentSetting usi

[jira] [Commented] (FLINK-14560) The value of taskmanager.memory.size in flink-conf.yaml is set to zero will cause taskmanager not to work

[ https://issues.apache.org/jira/browse/FLINK-14560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962736#comment-16962736 ] Jark Wu commented on FLINK-14560: - [~faaronzheng], I see what's your problem. {{taskmana

[GitHub] [flink] zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

zhijiangW commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r340445716 ## File path: flink-runtime/src/main/java/org/apache/fl

[jira] [Updated] (FLINK-13869) Hive functions can not work in blink planner stream mode

[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13869: - Environment: (was: method call stack: !image-2019-08-27-15-37-11-230.png|width=595,height=12

[jira] [Issue Comment Deleted] (FLINK-11491) Support all TPC-DS queries

[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-11491: --- Comment: was deleted (was: Does this only include sql query validation testing? Have we considered

[jira] [Commented] (FLINK-11491) Support all TPC-DS queries

[ https://issues.apache.org/jira/browse/FLINK-11491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962730#comment-16962730 ] Jiayi Liao commented on FLINK-11491: Does this only include sql query validation tes

[GitHub] [flink] wuchong commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

wuchong commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#discussion_r340443213 ## File path: flink-table/flink-table-planner-blink/src/mai

[GitHub] [flink] WeiZhong94 commented on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

WeiZhong94 commented on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-547752070 @flinkbot run travis --

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d : FAILURE

[jira] [Resolved] (FLINK-14398) Further split input unboxing code into separate methods

[ https://issues.apache.org/jira/browse/FLINK-14398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14398. - Fix Version/s: 1.9.2 1.8.3 1.10.0 Resolution: Fixed 1.10.0:

[GitHub] [flink] lirui-apache commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

lirui-apache commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340441559 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink

[GitHub] [flink] JingsongLi commented on a change in pull request #10027: [FLINK-14549][Table SQL/Planner] Bring more detail by using logicalTy…

JingsongLi commented on a change in pull request #10027: [FLINK-14549][Table SQL/Planner] Bring more detail by using logicalTy… URL: https://github.com/apache/flink/pull/10027#discussion_r340437802 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d : FAILURE

[GitHub] [flink] wsry commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

wsry commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-547740869 Thanks @zhijiangW. I have updated the PR and all the concerns are addressed. --

[jira] [Created] (FLINK-14565) Shutdown SystemResourcesCounter on (JM|TM)MetricGroup closed

Zili Chen created FLINK-14565: - Summary: Shutdown SystemResourcesCounter on (JM|TM)MetricGroup closed Key: FLINK-14565 URL: https://issues.apache.org/jira/browse/FLINK-14565 Project: Flink Issue

[GitHub] [flink] wuchong commented on a change in pull request #10027: [FLINK-14549][Table SQL/Planner] Bring more detail by using logicalTy…

wuchong commented on a change in pull request #10027: [FLINK-14549][Table SQL/Planner] Bring more detail by using logicalTy… URL: https://github.com/apache/flink/pull/10027#discussion_r340429543 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/tab

[GitHub] [flink] buptljy commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

buptljy commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#discussion_r340403417 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/

[GitHub] [flink] JingsongLi commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

JingsongLi commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#discussion_r340428623 ## File path: flink-table/flink-table-planner-blink/src/

[GitHub] [flink] flinkbot edited a comment on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

flinkbot edited a comment on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment URL: https://github.com/apache/flink/pull/8194#issuecomment-545319242 ## CI report: * 29a887134fd9564f67c3698d187f36ea9148cf32 : SUCCESS [Buil

[GitHub] [flink] wuchong edited a comment on issue #10015: [FLINK-14539][Table SQL/Planner]Unique key metadata should be ketp wh…

wuchong edited a comment on issue #10015: [FLINK-14539][Table SQL/Planner]Unique key metadata should be ketp wh… URL: https://github.com/apache/flink/pull/10015#issuecomment-547735177 After rethinking this issue, I think we may can't support derivation primary key from concat/concat_ws. Fo

[jira] [Comment Edited] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962681#comment-16962681 ] Jark Wu edited comment on FLINK-14539 at 10/30/19 4:34 AM: --- Af

[jira] [Commented] (FLINK-14539) Unique key metadata should be ketp when using concat or concat_ws in some cases

[ https://issues.apache.org/jira/browse/FLINK-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962681#comment-16962681 ] Jark Wu commented on FLINK-14539: - After rethinking this issue, I think we may can't sup

[GitHub] [flink] wuchong commented on issue #10015: [FLINK-14539][Table SQL/Planner]Unique key metadata should be ketp wh…

wuchong commented on issue #10015: [FLINK-14539][Table SQL/Planner]Unique key metadata should be ketp wh… URL: https://github.com/apache/flink/pull/10015#issuecomment-547735177 After rethinking this issue, I think we may can't support drivation primary key from concat/concat_ws. For exampl

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340426797 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/t

[jira] [Assigned] (FLINK-12624) Make Flink case-insensitive to meta object names

[ https://issues.apache.org/jira/browse/FLINK-12624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-12624: Assignee: (was: Bowen Li) > Make Flink case-insensitive to meta object names > --

[GitHub] [flink] zhijiangW commented on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

zhijiangW commented on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#issuecomment-547733858 Thanks for the review and good suggestions @pnowojski ! Concerning of refactor of `getAvailableFu

[jira] [Commented] (FLINK-14560) The value of taskmanager.memory.size in flink-conf.yaml is set to zero will cause taskmanager not to work

[ https://issues.apache.org/jira/browse/FLINK-14560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962672#comment-16962672 ] fa zheng commented on FLINK-14560: -- [~jark], i think it's a little unreasonable.  zero

[GitHub] [flink] flinkbot edited a comment on issue #10038: [FLINK-14375][runtime] Refactor task state updating to only notify scheduler about state changes that really happened

flinkbot edited a comment on issue #10038: [FLINK-14375][runtime] Refactor task state updating to only notify scheduler about state changes that really happened URL: https://github.com/apache/flink/pull/10038#issuecomment-547556449 ## CI report: * 6f3d22fe8a4c9beb37e72f69d87f670d

[GitHub] [flink] lirui-apache commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

lirui-apache commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340424741 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d : FAILURE

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

zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r340423539 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/r

[GitHub] [flink] wuchong commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

wuchong commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#discussion_r340423132 ## File path: flink-table/flink-table-planner-blink/src/mai

[GitHub] [flink] wuchong commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

wuchong commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#discussion_r340423132 ## File path: flink-table/flink-table-planner-blink/src/mai

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

flinkbot edited a comment on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment URL: https://github.com/apache/flink/pull/8194#issuecomment-545319242 ## CI report: * 29a887134fd9564f67c3698d187f36ea9148cf32 : SUCCESS [Buil

[jira] [Commented] (FLINK-14560) The value of taskmanager.memory.size in flink-conf.yaml is set to zero will cause taskmanager not to work

[ https://issues.apache.org/jira/browse/FLINK-14560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962660#comment-16962660 ] Jark Wu commented on FLINK-14560: - Hi [~faaronzheng], I'm wondering it maybe not a bug.

[jira] [Assigned] (FLINK-14560) The value of taskmanager.memory.size in flink-conf.yaml is set to zero will cause taskmanager not to work

[ https://issues.apache.org/jira/browse/FLINK-14560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14560: --- Assignee: (was: fa zheng) > The value of taskmanager.memory.size in flink-conf.yaml is set to z

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

zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r340418087 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/r

[GitHub] [flink] TisonKun commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

TisonKun commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#discussion_r340416816 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnC

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

zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r340416659 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/r

[jira] [Updated] (FLINK-14375) Refactor task state updating to only notify scheduler about state changes that really happened

[ https://issues.apache.org/jira/browse/FLINK-14375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14375: Description: The DefaultScheduler triggers failover if a task is notified to be FAILED. However, in the c

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

zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r340416530 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/r

[jira] [Assigned] (FLINK-14560) The value of taskmanager.memory.size in flink-conf.yaml is set to zero will cause taskmanager not to work

[ https://issues.apache.org/jira/browse/FLINK-14560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14560: --- Assignee: fa zheng > The value of taskmanager.memory.size in flink-conf.yaml is set to zero will >

[GitHub] [flink] TisonKun commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

TisonKun commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#discussion_r340416055 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnC

[GitHub] [flink] flinkbot edited a comment on issue #10038: [FLINK-14375][runtime] Refactor task state updating to only notify scheduler about state changes that really happened

flinkbot edited a comment on issue #10038: [FLINK-14375][runtime] Refactor task state updating to only notify scheduler about state changes that really happened URL: https://github.com/apache/flink/pull/10038#issuecomment-547556449 ## CI report: * 6f3d22fe8a4c9beb37e72f69d87f670d

[jira] [Updated] (FLINK-14398) Further split input unboxing code into separate methods

[ https://issues.apache.org/jira/browse/FLINK-14398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14398: Summary: Further split input unboxing code into separate methods (was: Codegen produced larger-than-64kb

[GitHub] [flink] flinkbot edited a comment on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

flinkbot edited a comment on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment URL: https://github.com/apache/flink/pull/8194#issuecomment-545319242 ## CI report: * 29a887134fd9564f67c3698d187f36ea9148cf32 : SUCCESS [Buil

[GitHub] [flink] wuchong merged pull request #10000: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods

wuchong merged pull request #1: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods URL: https://github.com/apache/flink/pull/1 This is an automated message from the Apache Git Se

[GitHub] [flink] wuchong commented on a change in pull request #10000: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods

wuchong commented on a change in pull request #1: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods URL: https://github.com/apache/flink/pull/1#discussion_r340414436 ## File path: flink-table/flink-table-planner/src/test/scala/org/apac

[GitHub] [flink] JingsongLi commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode

JingsongLi commented on a change in pull request #10013: [FLINK-13869][table-planner-blink][hive] Hive functions can not work in blink planner stream mode URL: https://github.com/apache/flink/pull/10013#discussion_r340413622 ## File path: flink-table/flink-table-planner-blink/src/

[GitHub] [flink] liyafan82 commented on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment

liyafan82 commented on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input parameters in HybridMemorySegment URL: https://github.com/apache/flink/pull/8194#issuecomment-547718225 > @liyafan82 any thought? @azagrebin I agree with you. The loop in the else case is

[GitHub] [flink] yangjf2019 commented on issue #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese

yangjf2019 commented on issue #9764: [FLINK-12939][docs-zh] Translate "Apache Kafka Connector" page into Chinese URL: https://github.com/apache/flink/pull/9764#issuecomment-547718034 Hi, @wuchong Thanks for your review, and left some comment in your free time.I will check it as soon as my

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340411700 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/t

[GitHub] [flink] wangyang0918 commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

wangyang0918 commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#discussion_r340410753 ## File path: flink-core/src/main/java/org/apache/flink/configuration/ConfigCon

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340411700 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/t

[GitHub] [flink] wangyang0918 commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration

wangyang0918 commented on a change in pull request #10037: [FLINK-14561] Don't write FLINK_PLUGINS_DIR env variable to Configuration URL: https://github.com/apache/flink/pull/10037#discussion_r340411452 ## File path: flink-core/src/main/java/org/apache/flink/core/plugin/PluginConfi

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

zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r340411900 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340411434 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/t

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

zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r340411311 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/Availab

[GitHub] [flink] flinkbot edited a comment on issue #10038: [FLINK-14375][runtime] Refactor task state updating to only notify scheduler about state changes that really happened

flinkbot edited a comment on issue #10038: [FLINK-14375][runtime] Refactor task state updating to only notify scheduler about state changes that really happened URL: https://github.com/apache/flink/pull/10038#issuecomment-547556449 ## CI report: * 6f3d22fe8a4c9beb37e72f69d87f670d

[GitHub] [flink] wuchong commented on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner

wuchong commented on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner URL: https://github.com/apache/flink/pull/10016#issuecomment-547715692 Thanks for the fixing @HuangXingBo . I agree with @hequn8128 , a unit test for plan verifyi

[jira] [Assigned] (FLINK-14547) UDF cannot be in the join condition in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14547: --- Assignee: Huang Xingbo > UDF cannot be in the join condition in blink planner > ---

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

zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r340410253 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/Availab

[jira] [Closed] (FLINK-14559) flink sql connector for stream table stdout

[ https://issues.apache.org/jira/browse/FLINK-14559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-14559. --- Resolution: Duplicate I think this is a duplicate issue for FLINK-13900 > flink sql connector for stream ta

[GitHub] [flink] wuchong commented on a change in pull request #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT…

wuchong commented on a change in pull request #10001: [FLINK-14535][table-planner-blink] Fix distinct key type for DecimalT… URL: https://github.com/apache/flink/pull/10001#discussion_r340409154 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/tab

[jira] [Comment Edited] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16956735#comment-16956735 ] Zhu Zhu edited comment on FLINK-14164 at 10/30/19 2:35 AM: --- Ma

[jira] [Comment Edited] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16956735#comment-16956735 ] Zhu Zhu edited comment on FLINK-14164 at 10/30/19 2:33 AM: --- Ma

[GitHub] [flink] hequn8128 commented on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner

hequn8128 commented on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner URL: https://github.com/apache/flink/pull/10016#issuecomment-547712528 @HuangXingBo Thanks a lot for fixing the problem. The fix looks good. Besides, it would be

[GitHub] [flink] hequn8128 removed a comment on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner

hequn8128 removed a comment on issue #10016: [FLINK-14547][table-planner-blink] Fix UDF cannot be in the join condition in blink planner URL: https://github.com/apache/flink/pull/10016#issuecomment-547712528 @HuangXingBo Thanks a lot for fixing the problem. The fix looks good. Besides, it

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

zhijiangW commented on a change in pull request #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#discussion_r340406957 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340406393 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/t

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340406278 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/t

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340406101 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/t

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340405615 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/t

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340405352 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/t

[GitHub] [flink] JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

JingsongLi commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340405012 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/t

[jira] [Commented] (FLINK-14382) Incorrect handling of FLINK_PLUGINS_DIR on Yarn

[ https://issues.apache.org/jira/browse/FLINK-14382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962640#comment-16962640 ] Yang Wang commented on FLINK-14382: --- Hi [~trohrmann], I agree with you that we should

[GitHub] [flink] walterddr commented on a change in pull request #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT)

walterddr commented on a change in pull request #9082: [FLINK-13207][ml] Add the algorithm of Fast Fourier Transformation(FFT) URL: https://github.com/apache/flink/pull/9082#discussion_r340402381 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/ut

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340401995 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340401570 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table

[GitHub] [flink] haodang commented on a change in pull request #10000: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods

haodang commented on a change in pull request #1: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods URL: https://github.com/apache/flink/pull/1#discussion_r340094625 ## File path: flink-table/flink-table-planner/src/test/scala/org/apac

[GitHub] [flink] haodang commented on a change in pull request #10000: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods

haodang commented on a change in pull request #1: [FLINK-14398][SQL/Legacy Planner]Further split input unboxing code into separate methods URL: https://github.com/apache/flink/pull/1#discussion_r340094625 ## File path: flink-table/flink-table-planner/src/test/scala/org/apac

[GitHub] [flink] docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte…

docete commented on a change in pull request #10035: [FLINK-14080][table-planner-blink] Introduce PreciseTimestamp as inte… URL: https://github.com/apache/flink/pull/10035#discussion_r340401179 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table

[jira] [Assigned] (FLINK-14558) Fix the ClassNotFoundException issue for run python job in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-14558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-14558: --- Assignee: Dian Fu > Fix the ClassNotFoundException issue for run python job in standalone m

[jira] [Commented] (FLINK-14558) Fix the ClassNotFoundException issue for run python job in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-14558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962632#comment-16962632 ] sunjincheng commented on FLINK-14558: - Thanks for taking this Dian! > Fix the Class

[jira] [Commented] (FLINK-14557) Clean up the package of py4j

[ https://issues.apache.org/jira/browse/FLINK-14557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962631#comment-16962631 ] sunjincheng commented on FLINK-14557: - Thanks for taking this Dian! > Clean up the

[jira] [Assigned] (FLINK-14557) Clean up the package of py4j

[ https://issues.apache.org/jira/browse/FLINK-14557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-14557: --- Assignee: Dian Fu > Clean up the package of py4j > > >

[jira] [Commented] (FLINK-14556) Correct the package of cloud pickle

[ https://issues.apache.org/jira/browse/FLINK-14556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962630#comment-16962630 ] sunjincheng commented on FLINK-14556: - Thanks for taking this Dian! > Correct the p

  1   2   3   4   5   6   7   >