[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

2019-09-25 Thread GitBox
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: *

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

2019-09-25 Thread GitBox
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

2019-09-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938298#comment-16938298 ] Jingsong Lee commented on FLINK-13740: -- It depends on implementation details... BinaryFormat only

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

2019-09-25 Thread GitBox
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

[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

2019-09-25 Thread GitBox
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: *

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

2019-09-25 Thread GitBox
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 :

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

2019-09-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938289#comment-16938289 ] Jark Wu commented on FLINK-13740: - If it is still lazy, then in my understanding, BinaryGeneric should

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

2019-09-25 Thread GitBox
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

2019-09-25 Thread GitBox
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

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

2019-09-25 Thread GitBox
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

[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

2019-09-25 Thread GitBox
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:

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

2019-09-25 Thread GitBox
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:

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

2019-09-25 Thread GitBox
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

[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

2019-09-25 Thread GitBox
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

[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

2019-09-25 Thread GitBox
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: *

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

2019-09-25 Thread GitBox
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 :

[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

2019-09-25 Thread GitBox
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

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

2019-09-25 Thread GitBox
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

[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

2019-09-25 Thread GitBox
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 :

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

2019-09-25 Thread GitBox
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

[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

2019-09-25 Thread GitBox
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: *

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

2019-09-25 Thread GitBox
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 :

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

2019-09-25 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938254#comment-16938254 ] Wei Zhong commented on FLINK-14019: --- Thanks for your reply [~sunjincheng121]! I have send the

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

2019-09-25 Thread GitBox
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

2019-09-25 Thread Zhu Zhu (Jira)
[ 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

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

2019-09-25 Thread Zhu Zhu (Jira)
[ 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

2019-09-25 Thread Zhu Zhu (Jira)
[ 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

2019-09-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938252#comment-16938252 ] Jingsong Lee commented on FLINK-13740: -- For #1, I mean BinaryGeneric still extends BinaryFormat and

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

2019-09-25 Thread GitBox
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:

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

2019-09-25 Thread GitBox
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:

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

2019-09-25 Thread GitBox
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:

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

2019-09-25 Thread GitBox
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:

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

2019-09-25 Thread GitBox
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:

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

2019-09-25 Thread GitBox
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:

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

2019-09-25 Thread GitBox
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:

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

2019-09-25 Thread GitBox
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

2019-09-25 Thread GitBox
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 ## @@

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

2019-09-25 Thread GitBox
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

2019-09-25 Thread GitBox
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

2019-09-25 Thread GitBox
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

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

2019-09-25 Thread GitBox
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

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

2019-09-25 Thread GitBox
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

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

2019-09-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938242#comment-16938242 ] Jark Wu commented on FLINK-13740: - I don't think #1 gets better performance, because it forces that we

[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

2019-09-25 Thread GitBox
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

2019-09-25 Thread GitBox
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 :

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

2019-09-25 Thread ASF GitHub Bot (Jira)
[ 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

[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

2019-09-25 Thread GitBox
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

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

2019-09-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938238#comment-16938238 ] Jingsong Lee commented on FLINK-13740: -- Let me clear the solutions: 1.Let BinaryGeneric not

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

2019-09-25 Thread GitBox
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

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

2019-09-25 Thread Jark Wu (Jira)
[ 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

2019-09-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938237#comment-16938237 ] Jingsong Lee commented on FLINK-14080: -- [~jark] Can you assign this ticket to [~docete] ? >

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

2019-09-25 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938235#comment-16938235 ] Yun Gao commented on FLINK-14186: - The reason of this issue is that -XX:+UseParNewGC [has been removed

[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

2019-09-25 Thread GitBox
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: *

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

2019-09-25 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938232#comment-16938232 ] Yingjie Cao commented on FLINK-12576: - [~alpinegizmo] I tried the instruction gave above, but the

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

2019-09-25 Thread GitBox
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 :

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

2019-09-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938231#comment-16938231 ] Jark Wu commented on FLINK-13740: - #1, It will be a great regression for generic types. (most users are

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

2019-09-25 Thread Yingjie Cao (Jira)
[ 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

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

2019-09-25 Thread Yingjie Cao (Jira)
[ 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

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

2019-09-25 Thread GitBox
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:

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

2019-09-25 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938225#comment-16938225 ] vinoyang commented on FLINK-12662: -- [~trohrmann] OK, I will wait until you are free. > Record failure

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

2019-09-25 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938224#comment-16938224 ] sunjincheng commented on FLINK-14019: - Thanks for the detail design doc [~zhongwei]! Could you

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

2019-09-25 Thread GitBox
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

[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

2019-09-25 Thread GitBox
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: *

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

2019-09-25 Thread GitBox
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

2019-09-25 Thread GitBox
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:

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

2019-09-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938206#comment-16938206 ] Jingsong Lee commented on FLINK-13740: -- 1.Let BinaryGeneric not extends LazyBinaryFormat 2.All

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

2019-09-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938203#comment-16938203 ] Jark Wu commented on FLINK-13740: - But LazyBinaryFormat BinaryGeneric need the javaObjectSer... >

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

2019-09-25 Thread GitBox
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

2019-09-25 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938201#comment-16938201 ] Jingsong Lee commented on FLINK-13740: -- Yes, A thorough solution is BinaryGeneric should never

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

2019-09-25 Thread GitBox
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

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

2019-09-25 Thread GitBox
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:

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

2019-09-25 Thread GitBox
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

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

2019-09-25 Thread GitBox
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:

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

2019-09-25 Thread GitBox
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_r328413950 ## File path:

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

2019-09-25 Thread GitBox
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_r328408371 ## File path:

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

2019-09-25 Thread GitBox
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_r328404835 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

2019-09-25 Thread GitBox
danny0405 commented on a change in pull request #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#discussion_r328414544 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

2019-09-25 Thread GitBox
danny0405 commented on a change in pull request #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#discussion_r328414311 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

2019-09-25 Thread GitBox
danny0405 commented on a change in pull request #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#discussion_r328414214 ## File path:

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

2019-09-25 Thread GitBox
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_r328414259 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

2019-09-25 Thread GitBox
danny0405 commented on a change in pull request #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#discussion_r328414087 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

2019-09-25 Thread GitBox
danny0405 commented on a change in pull request #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#discussion_r328413899 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

2019-09-25 Thread GitBox
danny0405 commented on a change in pull request #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#discussion_r328413261 ## File path:

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

2019-09-25 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-14080: - Description: Timestamp values have a precision in fractional seconds that range from 0 to 9.

[GitHub] [flink] wuchong commented on issue #9756: [backport to 1.9][FLINK-14145] Fix getLatestCheckpoint(true) returns wrong checkpoint

2019-09-25 Thread GitBox
wuchong commented on issue #9756: [backport to 1.9][FLINK-14145] Fix getLatestCheckpoint(true) returns wrong checkpoint URL: https://github.com/apache/flink/pull/9756#issuecomment-535303241 Thanks @gyfora for merging this.

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

2019-09-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938190#comment-16938190 ] Jark Wu commented on FLINK-13740: - Do you mean moving all the {{{materialize()}} logic to

[GitHub] [flink] AT-Fieldless edited a comment on issue #9718: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

2019-09-25 Thread GitBox
AT-Fieldless edited a comment on issue #9718: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9718#issuecomment-533946231 @klion26 Do you mean using `git -rebase` to clear the git history like this?

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

2019-09-25 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938180#comment-16938180 ] vinoyang commented on FLINK-13025: -- [~lilyevsky] Thanks for your verification and report your result.

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

2019-09-25 Thread GitBox
dianfu 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-535291026 @sunjincheng121 Thanks for your comments. Very

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

2019-09-25 Thread GitBox
dianfu commented 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-535291026 @sunjincheng121 Thanks for your comments. Very appreciated. The

[jira] [Updated] (FLINK-14208) Optimize Python UDFs with parameters of constant values

2019-09-25 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14208: Description: We need optimize Python UDFs with parameters of constant values. For example, the constant

[jira] [Created] (FLINK-14222) Optimize for Python UDFs with all parameters are constant values

2019-09-25 Thread Dian Fu (Jira)
Dian Fu created FLINK-14222: --- Summary: Optimize for Python UDFs with all parameters are constant values Key: FLINK-14222 URL: https://issues.apache.org/jira/browse/FLINK-14222 Project: Flink

[jira] [Updated] (FLINK-14208) Optimize Python UDFs with parameters of constant values

2019-09-25 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14208: Summary: Optimize Python UDFs with parameters of constant values (was: Support Python UDF with

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

2019-09-25 Thread Kyle Weaver (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938147#comment-16938147 ] Kyle Weaver commented on FLINK-10672: - [~zjwang] I have tested the pipeline on Flink 1.8.1 and Flink

[jira] [Updated] (FLINK-14217) introduce temp functions to FunctionCatalog

2019-09-25 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14217: - Summary: introduce temp functions to FunctionCatalog (was: introduce temp functions to replace

[jira] [Updated] (FLINK-14216) introduce temp system functions to FunctionCatalog

2019-09-25 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14216: - Summary: introduce temp system functions to FunctionCatalog (was: introduce temp system functions and

[jira] [Updated] (FLINK-14217) introduce temp functions to replace "userFunctions" in FunctionCatalog

2019-09-25 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14217: - Summary: introduce temp functions to replace "userFunctions" in FunctionCatalog (was: introduce temp

[jira] [Created] (FLINK-14221) support drop and alter temp system functions

2019-09-25 Thread Bowen Li (Jira)
Bowen Li created FLINK-14221: Summary: support drop and alter temp system functions Key: FLINK-14221 URL: https://issues.apache.org/jira/browse/FLINK-14221 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-14220) support drop and alter temp functions

2019-09-25 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-14220: - Fix Version/s: 1.10.0 > support drop and alter temp functions > - >

[jira] [Assigned] (FLINK-14220) support drop and alter temp functions

2019-09-25 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-14220: Assignee: Bowen Li > support drop and alter temp functions >

  1   2   3   4   5   6   >