[jira] [Commented] (FLINK-14206) Let fullRestart metric count fine grained restarts as well

[ https://issues.apache.org/jira/browse/FLINK-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938334#comment-16938334 ] Till Rohrmann commented on FLINK-14206: --- I agree with Zhu Zhu. With fine grained r

[jira] [Assigned] (FLINK-14206) Let fullRestart metric count fine grained restarts as well

[ https://issues.apache.org/jira/browse/FLINK-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14206: - Assignee: Zhu Zhu > Let fullRestart metric count fine grained restarts as well > --

[GitHub] [flink] flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#issuecomment-534879961 ## CI report: * 8fffbbc4bc605ccedad7412ac2292

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r328459063 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics

flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#issuecomment-534565595 ## CI report: * 6bc9773c54eed0b1646ec67413cb3855c1057d87 : FAILURE [Build](https://travis-ci.com/flink-ci/fl

[GitHub] [flink] TisonKun commented on issue #9776: [HOTFIX] remove the invalid parameter in handleCheckpointSuccess method

TisonKun commented on issue #9776: [HOTFIX] remove the invalid parameter in handleCheckpointSuccess method URL: https://github.com/apache/flink/pull/9776#issuecomment-535367265 @flinkbot attention @yanghua please take a look why we don't use this parameter.

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

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r328460576 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src

[jira] [Closed] (FLINK-14016) Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec which are containers for Python PythonScalarFunctions

[ https://issues.apache.org/jira/browse/FLINK-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14016. --- Resolution: Resolved > Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and > DataStreamPyth

[jira] [Commented] (FLINK-14016) Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec which are containers for Python PythonScalarFunctions

[ https://issues.apache.org/jira/browse/FLINK-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938324#comment-16938324 ] Hequn Cheng commented on FLINK-14016: - Resolved in 1.10.0 via 2b608e3169ee416c922a83

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

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r328460043 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src

[jira] [Commented] (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=16938323#comment-16938323 ] Till Rohrmann commented on FLINK-14164: --- Can't we deprecate the {{fullRestarts}} m

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r328459063 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] hequn8128 closed pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

hequn8128 closed pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748 This is an automated message from th

[jira] [Commented] (FLINK-14186) Nightly e2e-misc-jdk11 fails complaining unrecognized VM option

[ https://issues.apache.org/jira/browse/FLINK-14186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938319#comment-16938319 ] Yun Gao commented on FLINK-14186: - I have tested the elastic search e2e test cases local

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[jira] [Commented] (FLINK-11374) See more failover and can filter by time range

[ https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938317#comment-16938317 ] Till Rohrmann commented on FLINK-11374: --- Yes this sounds like a good idea [~lining

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

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r328456850 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src

[jira] [Comment Edited] (FLINK-14206) Let fullRestart metric count fine grained restarts as well

[ https://issues.apache.org/jira/browse/FLINK-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937665#comment-16937665 ] Zhu Zhu edited comment on FLINK-14206 at 9/26/19 6:42 AM: -- [~gj

[GitHub] [flink] flinkbot commented on issue #9776: [HOTFIX] remove the invalid parameter in handleCheckpointSuccess method

flinkbot commented on issue #9776: [HOTFIX] remove the invalid parameter in handleCheckpointSuccess method URL: https://github.com/apache/flink/pull/9776#issuecomment-535362270 ## CI report: * 8789586cf29e98502633d9db81eb551e3892067a : UNKNOWN ---

[GitHub] [flink] flinkbot edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi…

flinkbot edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi… URL: https://github.com/apache/flink/pull/9773#issuecomment-535013943 ## CI report: * a7a643c54c912e9a42b1dbf887f14eba2ac80f82 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#issuecomment-534879961 ## CI report: * 8fffbbc4bc605ccedad7412ac2292

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

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r328452591 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[GitHub] [flink] flinkbot commented on issue #9776: [HOTFIX] remove the invalid parameter in handleCheckpointSuccess method

flinkbot commented on issue #9776: [HOTFIX] remove the invalid parameter in handleCheckpointSuccess method URL: https://github.com/apache/flink/pull/9776#issuecomment-535357550 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to rev

[GitHub] [flink] lamber-ken opened a new pull request #9776: [HOTFIX] remove the invalid parameter in handleCheckpointSuccess method

lamber-ken opened a new pull request #9776: [HOTFIX] remove the invalid parameter in handleCheckpointSuccess method URL: https://github.com/apache/flink/pull/9776 ## What is the purpose of the change remove the invalid parameter in handleCheckpointSuccess method ## Bri

[GitHub] [flink] TisonKun commented on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh

TisonKun commented on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh URL: https://github.com/apache/flink/pull/9774#issuecomment-535352518 travis fails on >03:36:34.014 [INFO] Results: 03:36:34.014 [INFO] 03:36:34.014 [ERROR] Failures: 03:36:34.01

[GitHub] [flink] flinkbot edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi…

flinkbot edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi… URL: https://github.com/apache/flink/pull/9773#issuecomment-535013943 ## CI report: * a7a643c54c912e9a42b1dbf887f14eba2ac80f82 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#issuecomment-534879961 ## CI report: * 8fffbbc4bc605ccedad7412ac2292

[GitHub] [flink] ashangit commented on issue #8760: [FLINK-12869] Add yarn acls capability to flink containers

ashangit commented on issue #8760: [FLINK-12869] Add yarn acls capability to flink containers URL: https://github.com/apache/flink/pull/8760#issuecomment-535350073 @GJL will look at how I can add some test this week or the next --

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938298#comment-16938298 ] Jingsong Lee commented on FLINK-13740: -- It depends on implementation details... Bin

[GitHub] [flink] flinkbot edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi…

flinkbot edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi… URL: https://github.com/apache/flink/pull/9773#issuecomment-535013943 ## CI report: * a7a643c54c912e9a42b1dbf887f14eba2ac80f82 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#issuecomment-534879961 ## CI report: * 8fffbbc4bc605ccedad7412ac2292

[GitHub] [flink] flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-534087366 ## CI report: * dd50b7a2af07a87280b2e358d31d0ad9345ad8c4 : SUCC

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938289#comment-16938289 ] Jark Wu commented on FLINK-13740: - If it is still lazy, then in my understanding, Binary

[GitHub] [flink] Mrart edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

Mrart edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-534871400 @zentol Could you help review again，I have add A config option。I am sorry for delay。 --

[GitHub] [flink] flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy

flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/9688#issuecomment-531737820 ## CI report: * 23278b65f27154ae066841334f0d0b06885e713a : FAILURE [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi…

flinkbot edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi… URL: https://github.com/apache/flink/pull/9773#issuecomment-535013943 ## CI report: * a7a643c54c912e9a42b1dbf887f14eba2ac80f82 : FAILURE [Build](https://travis-ci.com

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

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r328435002 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src

[GitHub] [flink] xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328434865 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/MLEnvironment.j

[GitHub] [flink] carp84 commented on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState

carp84 commented on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState URL: https://github.com/apache/flink/pull/9255#issuecomment-535334308 > What's more, since this adds a method in `MapState` interface which is `PublicEvolving`, we will need a release note. And don'

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[GitHub] [flink] flinkbot edited a comment on issue #9775: [FLINK-14186][e2e] Let JVM ignores unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11

flinkbot edited a comment on issue #9775: [FLINK-14186][e2e] Let JVM ignores unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11 URL: https://github.com/apache/flink/pull/9775#issuecomment-535327571 ## CI report: * 7ca40f4410862da362c16e5a9410ca692854451f

[GitHub] [flink] flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-534087366 ## CI report: * dd50b7a2af07a87280b2e358d31d0ad9345ad8c4 : SUCC

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE [B

[GitHub] [flink] flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy

flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/9688#issuecomment-531737820 ## CI report: * 23278b65f27154ae066841334f0d0b06885e713a : FAILURE [Build](https://travis-ci.com/fl

[GitHub] [flink] flinkbot commented on issue #9775: [FLINK-14186][e2e] Let JVM ignores unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11

flinkbot commented on issue #9775: [FLINK-14186][e2e] Let JVM ignores unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11 URL: https://github.com/apache/flink/pull/9775#issuecomment-535327571 ## CI report: * 7ca40f4410862da362c16e5a9410ca692854451f : UNKN

[GitHub] [flink] flinkbot edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi…

flinkbot edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi… URL: https://github.com/apache/flink/pull/9773#issuecomment-535013943 ## CI report: * a7a643c54c912e9a42b1dbf887f14eba2ac80f82 : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#issuecomment-534879961 ## CI report: * 8fffbbc4bc605ccedad7412ac2292

[GitHub] [flink] flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-534087366 ## CI report: * dd50b7a2af07a87280b2e358d31d0ad9345ad8c4 : SUCC

[jira] [Commented] (FLINK-14019) Python environment and dependency management

[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938254#comment-16938254 ] Wei Zhong commented on FLINK-14019: --- Thanks for your reply [~sunjincheng121]! I have s

[GitHub] [flink] dianfu commented on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

dianfu commented on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-535325224 @hequn8128 Thanks for the latest comments. Updated. ---

[jira] [Updated] (FLINK-14059) Introduce option allSourcesInSamePipelinedRegion in ExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-14059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14059: Component/s: Table SQL / Runtime Runtime / Coordination > Introduce option allSourcesInSa

[jira] [Updated] (FLINK-14059) Introduce option allSourcesInSamePipelinedRegion in ExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-14059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14059: Fix Version/s: 1.10.0 > Introduce option allSourcesInSamePipelinedRegion in ExecutionConfig >

[jira] [Updated] (FLINK-14059) Introduce option allSourcesInSamePipelinedRegion in ExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-14059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14059: Affects Version/s: 1.10.0 > Introduce option allSourcesInSamePipelinedRegion in ExecutionConfig >

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938252#comment-16938252 ] Jingsong Lee commented on FLINK-13740: -- For #1, I mean BinaryGeneric still extends 

[GitHub] [flink] hequn8128 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

hequn8128 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#discussion_r328422873 ## File path: flink-table/flink-table-planner/src/mai

[GitHub] [flink] hequn8128 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

hequn8128 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#discussion_r328426233 ## File path: flink-table/flink-table-planner/src/tes

[GitHub] [flink] hequn8128 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

hequn8128 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#discussion_r328424222 ## File path: flink-table/flink-table-planner/src/mai

[GitHub] [flink] hequn8128 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

hequn8128 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#discussion_r328425098 ## File path: flink-table/flink-table-planner/src/mai

[GitHub] [flink] hequn8128 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

hequn8128 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#discussion_r328425659 ## File path: flink-table/flink-table-common/src/main

[GitHub] [flink] hequn8128 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

hequn8128 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#discussion_r328422557 ## File path: flink-table/flink-table-planner/src/mai

[GitHub] [flink] hequn8128 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

hequn8128 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#discussion_r328425219 ## File path: flink-table/flink-table-planner/src/mai

[GitHub] [flink] xintongsong commented on a change in pull request #9747: [FLINK-13985] Use unsafe memory for managed memory

xintongsong commented on a change in pull request #9747: [FLINK-13985] Use unsafe memory for managed memory URL: https://github.com/apache/flink/pull/9747#discussion_r328422193 ## File path: flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentFactory.java ##

[GitHub] [flink] xintongsong commented on a change in pull request #9747: [FLINK-13985] Use unsafe memory for managed memory

xintongsong commented on a change in pull request #9747: [FLINK-13985] Use unsafe memory for managed memory URL: https://github.com/apache/flink/pull/9747#discussion_r328425366 ## File path: flink-core/src/main/java/org/apache/flink/core/memory/MemoryUtils.java ## @@ -57,

[GitHub] [flink] xintongsong commented on a change in pull request #9747: [FLINK-13985] Use unsafe memory for managed memory

xintongsong commented on a change in pull request #9747: [FLINK-13985] Use unsafe memory for managed memory URL: https://github.com/apache/flink/pull/9747#discussion_r328413824 ## File path: flink-core/src/test/java/org/apache/flink/core/memory/CrossSegmentTypeTest.java ##

[GitHub] [flink] xintongsong commented on a change in pull request #9747: [FLINK-13985] Use unsafe memory for managed memory

xintongsong commented on a change in pull request #9747: [FLINK-13985] Use unsafe memory for managed memory URL: https://github.com/apache/flink/pull/9747#discussion_r328422844 ## File path: flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentFactory.java ##

[GitHub] [flink] zhuzhurk commented on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy

zhuzhurk commented on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/9688#issuecomment-535323407 @flinkbot run travis This is an automated message fr

[GitHub] [flink] flinkbot edited a comment on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh

flinkbot edited a comment on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh URL: https://github.com/apache/flink/pull/9774#issuecomment-535311583 ## CI report: * b863a8fcbbf97650009e0947b10f283e6954ace3 : FAILURE [Build](https://travis-ci.com/flink-ci/f

[GitHub] [flink] flinkbot edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi…

flinkbot edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi… URL: https://github.com/apache/flink/pull/9773#issuecomment-535013943 ## CI report: * a7a643c54c912e9a42b1dbf887f14eba2ac80f82 : FAILURE [Build](https://travis-ci.com

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938242#comment-16938242 ] Jark Wu commented on FLINK-13740: - I don't think #1 gets better performance, because it

[GitHub] [flink] flinkbot commented on issue #9775: [FLINK-14186][e2e] Let JVM ignores unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11

flinkbot commented on issue #9775: [FLINK-14186][e2e] Let JVM ignores unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11 URL: https://github.com/apache/flink/pull/9775#issuecomment-535322691 Thanks a lot for your contribution to the Apache Flink project. I'm the @

[GitHub] [flink] flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-534087366 ## CI report: * dd50b7a2af07a87280b2e358d31d0ad9345ad8c4 : SUCC

[jira] [Updated] (FLINK-14186) Nightly e2e-misc-jdk11 fails complaining unrecognized VM option

[ https://issues.apache.org/jira/browse/FLINK-14186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14186: --- Labels: pull-request-available test-stability (was: test-stability) > Nightly e2e-misc-jdk1

[GitHub] [flink] gaoyunhaii opened a new pull request #9775: [FLINK-14186][e2e] Let JVM ignores unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11

gaoyunhaii opened a new pull request #9775: [FLINK-14186][e2e] Let JVM ignores unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11 URL: https://github.com/apache/flink/pull/9775 ## What is the purpose of the change This PR fixes the end-to-end tes

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938238#comment-16938238 ] Jingsong Lee commented on FLINK-13740: -- Let me clear the solutions: 1.Let BinaryGe

[GitHub] [flink] Mrart commented on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi…

Mrart commented on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi… URL: https://github.com/apache/flink/pull/9773#issuecomment-535320428 @1u0 ths for review This is an automated message fro

[jira] [Assigned] (FLINK-14080) Support precision of TimestampType

[ https://issues.apache.org/jira/browse/FLINK-14080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14080: --- Assignee: Zhenghua Gao > Support precision of TimestampType > -- >

[jira] [Commented] (FLINK-14080) Support precision of TimestampType

[ https://issues.apache.org/jira/browse/FLINK-14080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938237#comment-16938237 ] Jingsong Lee commented on FLINK-14080: -- [~jark] Can you assign this ticket to [~doc

[jira] [Commented] (FLINK-14186) Nightly e2e-misc-jdk11 fails complaining unrecognized VM option

[ https://issues.apache.org/jira/browse/FLINK-14186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938235#comment-16938235 ] Yun Gao commented on FLINK-14186: - The reason of this issue is that -XX:+UseParNewGC [ha

[GitHub] [flink] flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#issuecomment-534879961 ## CI report: * 8fffbbc4bc605ccedad7412ac2292

[jira] [Commented] (FLINK-12576) inputQueueLength metric does not work for LocalInputChannels

[ https://issues.apache.org/jira/browse/FLINK-12576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938232#comment-16938232 ] Yingjie Cao commented on FLINK-12576: - [~alpinegizmo] I tried the instruction gave a

[GitHub] [flink] flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

flinkbot edited a comment on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-534087366 ## CI report: * dd50b7a2af07a87280b2e358d31d0ad9345ad8c4 : SUCC

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938231#comment-16938231 ] Jark Wu commented on FLINK-13740: - #1, It will be a great regression for generic types.

[jira] [Updated] (FLINK-12576) inputQueueLength metric does not work for LocalInputChannels

[ https://issues.apache.org/jira/browse/FLINK-12576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-12576: Attachment: image-2019-09-26-11-36-06-027.png > inputQueueLength metric does not work for LocalInp

[jira] [Updated] (FLINK-12576) inputQueueLength metric does not work for LocalInputChannels

[ https://issues.apache.org/jira/browse/FLINK-12576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-12576: Attachment: image-2019-09-26-11-34-24-878.png > inputQueueLength metric does not work for LocalInp

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r328422187 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[jira] [Commented] (FLINK-12662) Record failure and restart information for ExecutionGraph to keep history information

[ https://issues.apache.org/jira/browse/FLINK-12662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938225#comment-16938225 ] vinoyang commented on FLINK-12662: -- [~trohrmann] OK, I will wait until you are free. >

[jira] [Commented] (FLINK-14019) Python environment and dependency management

[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938224#comment-16938224 ] sunjincheng commented on FLINK-14019: - Thanks for the detail design doc [~zhongwei]!

[GitHub] [flink] flinkbot edited a comment on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh

flinkbot edited a comment on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh URL: https://github.com/apache/flink/pull/9774#issuecomment-535311583 ## CI report: * b863a8fcbbf97650009e0947b10f283e6954ace3 : PENDING [Build](https://travis-ci.com/flink-ci/f

[GitHub] [flink] flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#issuecomment-534879961 ## CI report: * 8fffbbc4bc605ccedad7412ac2292

[GitHub] [flink] dianfu commented on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

dianfu commented on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-535315320 @hequn8128 Thanks for your review. Updated. ---

[GitHub] [flink] dianfu commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

dianfu commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#discussion_r328420024 ## File path: flink-table/flink-table-planner/src/main/s

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938206#comment-16938206 ] Jingsong Lee commented on FLINK-13740: -- 1.Let BinaryGeneric not extends LazyBinaryF

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938203#comment-16938203 ] Jark Wu commented on FLINK-13740: - But LazyBinaryFormat BinaryGeneric need the javaObjec

[GitHub] [flink] flinkbot commented on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh

flinkbot commented on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh URL: https://github.com/apache/flink/pull/9774#issuecomment-535311583 ## CI report: * b863a8fcbbf97650009e0947b10f283e6954ace3 : UNKNOWN ---

[jira] [Commented] (FLINK-13740) TableAggregateITCase.testNonkeyedFlatAggregate failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16938201#comment-16938201 ] Jingsong Lee commented on FLINK-13740: -- Yes, A thorough solution is BinaryGeneric

[GitHub] [flink] flinkbot commented on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh

flinkbot commented on issue #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh URL: https://github.com/apache/flink/pull/9774#issuecomment-535310464 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pul

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r328416725 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/task

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r328416725 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/task

[GitHub] [flink] TisonKun opened a new pull request #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh

TisonKun opened a new pull request #9774: [hotfix][tools] Update comments in verify_scala_suffixes.sh URL: https://github.com/apache/flink/pull/9774 ## What is the purpose of the change flink-storm has been dropped. Correspondingly update comments. ## Verifying this change

  1   2   3   4   5   6   >