[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

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

2019-09-23 Thread GitBox
KarmaGYZ 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_r327430872 ## File path: flink-core/src/test/java/org/apache/flink/core/memory/MemorySegmentChecksTest.java ##

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

2019-09-23 Thread GitBox
KarmaGYZ 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_r327431101 ## File path: flink-core/src/test/java/org/apache/flink/core/memory/MemorySegmentChecksTest.java ##

[jira] [Commented] (FLINK-14173) ANSI-style JOIN with Temporal Table Function fails

2019-09-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936463#comment-16936463 ] Jark Wu commented on FLINK-14173: - Hi [~BenoitParis], AFAIK, we don't support {{JOIN UDT

[GitHub] [flink] flinkbot commented on issue #9752: [FLINK-14179]Correct description of 'SHOW FUNCTIONS'

2019-09-23 Thread GitBox
flinkbot commented on issue #9752: [FLINK-14179]Correct description of 'SHOW FUNCTIONS' URL: https://github.com/apache/flink/pull/9752#issuecomment-534417125 ## CI report: * 8ef80718287aa84b664560c8c0caa2b0201e218a : UNKNOWN --

[GitHub] [flink] gaofeilong198810 commented on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

2019-09-23 Thread GitBox
gaofeilong198810 commented on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534416836 I found that flinkbot marked my PR as 'FAILURE Build', is there anything incorrect in my PR? ---

[jira] [Closed] (FLINK-14181) TableEnvironment explain maybe causes StreamGraph to be inconsistent

2019-09-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-14181. --- Resolution: Duplicate > TableEnvironment explain maybe causes StreamGraph to be inconsistent > -

[jira] [Commented] (FLINK-14181) TableEnvironment explain maybe causes StreamGraph to be inconsistent

2019-09-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936455#comment-16936455 ] Jark Wu commented on FLINK-14181: - Thanks for reporting this [~jianlong miao]. I think t

[jira] [Updated] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

2019-09-23 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14163: Description: Currently {{Execution#producedPartitions}} is assigned after the partitions have completed t

[jira] [Assigned] (FLINK-14098) Support multiple statements for TableEnvironment

2019-09-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14098: --- Assignee: Canbin Zheng > Support multiple statements for TableEnvironment > ---

[jira] [Commented] (FLINK-14098) Support multiple statements for TableEnvironment

2019-09-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936452#comment-16936452 ] Jark Wu commented on FLINK-14098: - I assigned to you [~felixzheng] > Support multiple s

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

2019-09-23 Thread GitBox
zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327446705 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[GitHub] [flink] flinkbot commented on issue #9752: [FLINK-14179]Correct description of 'SHOW FUNCTIONS'

2019-09-23 Thread GitBox
flinkbot commented on issue #9752: [FLINK-14179]Correct description of 'SHOW FUNCTIONS' URL: https://github.com/apache/flink/pull/9752#issuecomment-534411559 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull reque

[jira] [Updated] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

2019-09-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14179: --- Labels: pull-request-available (was: ) > Wrong description of SqlCommand.SHOW_FUNCTIONS > -

[GitHub] [flink] zhengcanbin opened a new pull request #9752: [FLINK-14179]Correct description of 'SHOW FUNCTIONS'

2019-09-23 Thread GitBox
zhengcanbin opened a new pull request #9752: [FLINK-14179]Correct description of 'SHOW FUNCTIONS' URL: https://github.com/apache/flink/pull/9752 This is an automated message from the Apache Git Service. To respond to the mes

[jira] [Commented] (FLINK-12501) AvroTypeSerializer does not work with types generated by avrohugger

2019-09-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936446#comment-16936446 ] Jark Wu commented on FLINK-12501: - I'm fine to cherry-pick it to 1.9 as this is a minor

[jira] [Updated] (FLINK-14181) TableEnvironment explain maybe causes StreamGraph to be inconsistent

2019-09-23 Thread jianlong miao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jianlong miao updated FLINK-14181: -- Description: Now TableEnviroment.explain will use StreamEnv to generateStreamGraph. That will

[GitHub] [flink] sunjincheng121 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctio

2019-09-23 Thread GitBox
sunjincheng121 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python function execution URL: https://github.com/apache/flink/pull/9748#discussion_r327443321 ##

[jira] [Created] (FLINK-14181) TableEnvironment explain maybe causes StreamGraph to be inconsistent

2019-09-23 Thread jianlong miao (Jira)
jianlong miao created FLINK-14181: - Summary: TableEnvironment explain maybe causes StreamGraph to be inconsistent Key: FLINK-14181 URL: https://issues.apache.org/jira/browse/FLINK-14181 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED [Build](https://t

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

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

[jira] [Created] (FLINK-14180) Enable config of maximum capacity of FileArchivedExecutionGraphStore.

2019-09-23 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-14180: --- Summary: Enable config of maximum capacity of FileArchivedExecutionGraphStore. Key: FLINK-14180 URL: https://issues.apache.org/jira/browse/FLINK-14180 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-534387866 ## CI report: * 5b73b3d6319447fd2d81b48183d9f22012133a6b : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/

[GitHub] [flink] flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-534387866 ## CI report: * 5b73b3d6319447fd2d81b48183d9f22012133a6b : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly URL: https://github.com/apache/flink/pull/9719#issuecomment-533096961 ## CI report: * c4a475ad50edd91fb1189f57651734f3a3df3508 : SUCCESS [Build](http

[GitHub] [flink] flinkbot commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

2019-09-23 Thread GitBox
flinkbot commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-534387866 ## CI report: * 5b73b3d6319447fd2d81b48183d9f22012133a6b : UNKNOWN ---

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED [Build](https://t

[GitHub] [flink] flinkbot commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

2019-09-23 Thread GitBox
flinkbot commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-534386397 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. W

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

2019-09-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14177: --- Labels: pull-request-available (was: ) > Bump Curator From 2.12.0 to 4.2.0 > --

[GitHub] [flink] lamber-ken opened a new pull request #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

2019-09-23 Thread GitBox
lamber-ken opened a new pull request #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751 ## What is the purpose of the change According to `FLINK-10052` and `FLINK-13417`, we needs to upgrade the version of CuratorFramework f

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

2019-09-23 Thread lamber-ken (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Description: According to FLINK-10052 and FLINK-13417, we needs to upgrade the version of CuratorFr

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

2019-09-23 Thread lamber-ken (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Description: According to FLINK-10052 and FLINK-14117, we needs to upgrade the version of CuratorFr

[GitHub] [flink] flinkbot edited a comment on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server.

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server. URL: https://github.com/apache/flink/pull/9750#issuecomment-534370339 ## CI report: * 9ea7a2157e67850fe26c893969108694d2525284 : SUCCESS [Build](https://travis-ci.com/f

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

2019-09-23 Thread GitBox
zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327421441 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.ja

[GitHub] [flink] flinkbot edited a comment on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly URL: https://github.com/apache/flink/pull/9719#issuecomment-533096961 ## CI report: * c4a475ad50edd91fb1189f57651734f3a3df3508 : SUCCESS [Build](http

[GitHub] [flink] zhijiangW commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

2019-09-23 Thread GitBox
zhijiangW commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r327416156 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

2019-09-23 Thread GitBox
zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327418704 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[GitHub] [flink] zhijiangW commented on issue #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

2019-09-23 Thread GitBox
zhijiangW commented on issue #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#issuecomment-534376369 Thanks for the review @AHeise and I would consider fixing the `optional` issue as you sugges

[GitHub] [flink] zhijiangW commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

2019-09-23 Thread GitBox
zhijiangW commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r327416302 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime

[GitHub] [flink] zhijiangW commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

2019-09-23 Thread GitBox
zhijiangW commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r327416156 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] zhijiangW commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

2019-09-23 Thread GitBox
zhijiangW commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r327416156 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] flinkbot edited a comment on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly URL: https://github.com/apache/flink/pull/9719#issuecomment-533096961 ## CI report: * c4a475ad50edd91fb1189f57651734f3a3df3508 : SUCCESS [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[GitHub] [flink] zhijiangW commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

2019-09-23 Thread GitBox
zhijiangW commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r327415850 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] zhijiangW commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

2019-09-23 Thread GitBox
zhijiangW commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r327415096 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] zhijiangW commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

2019-09-23 Thread GitBox
zhijiangW commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r327414997 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime

[GitHub] [flink] flinkbot edited a comment on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server.

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server. URL: https://github.com/apache/flink/pull/9750#issuecomment-534370339 ## CI report: * 9ea7a2157e67850fe26c893969108694d2525284 : PENDING [Build](https://travis-ci.com/f

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

2019-09-23 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936348#comment-16936348 ] zhijiang commented on FLINK-12576: -- Thanks for reporting this [~alpinegizmo] I want to

[GitHub] [flink] flinkbot edited a comment on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly URL: https://github.com/apache/flink/pull/9719#issuecomment-533096961 ## CI report: * c4a475ad50edd91fb1189f57651734f3a3df3508 : SUCCESS [Build](http

[GitHub] [flink] flinkbot commented on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server.

2019-09-23 Thread GitBox
flinkbot commented on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server. URL: https://github.com/apache/flink/pull/9750#issuecomment-534370339 ## CI report: * 9ea7a2157e67850fe26c893969108694d2525284 : UNKNOWN --

[GitHub] [flink] TisonKun commented on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly

2019-09-23 Thread GitBox
TisonKun commented on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly URL: https://github.com/apache/flink/pull/9719#issuecomment-534370206 Hi @tillrohrmann Thanks for your review. I add a `DispatcherResourceManagerComponentTest` a

[GitHub] [flink] TisonKun edited a comment on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly

2019-09-23 Thread GitBox
TisonKun edited a comment on issue #9719: [FLINK-14010][coordination] Shutdown cluster if ResourceManager terminated unexpectedly URL: https://github.com/apache/flink/pull/9719#issuecomment-534370206 Hi @tillrohrmann Thanks for your review. I add a `DispatcherResourceManagerComponent

[jira] [Created] (FLINK-14179) Wrong description of SqlCommand.SHOW_FUNCTIONS

2019-09-23 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-14179: Summary: Wrong description of SqlCommand.SHOW_FUNCTIONS Key: FLINK-14179 URL: https://issues.apache.org/jira/browse/FLINK-14179 Project: Flink Issue Type: Bu

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

2019-09-23 Thread GitBox
zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327410288 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[GitHub] [flink] flinkbot commented on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server.

2019-09-23 Thread GitBox
flinkbot commented on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server. URL: https://github.com/apache/flink/pull/9750#issuecomment-534366740 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-14139) Fix potential memory leak of rest server when using session/standalone cluster

2019-09-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14139: --- Labels: pull-request-available (was: ) > Fix potential memory leak of rest server when usin

[GitHub] [flink] wsry opened a new pull request #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server.

2019-09-23 Thread GitBox
wsry opened a new pull request #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server. URL: https://github.com/apache/flink/pull/9750 ## What is the purpose of the change The purpose of this pr is to fix the potential memory leak problem of rest server when using

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

2019-09-23 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936323#comment-16936323 ] Zhu Zhu commented on FLINK-14164: - Maybe a Meter/MeterView is a better choice as it dire

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

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

2019-09-23 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936318#comment-16936318 ] vinoyang commented on FLINK-13025: -- [~lilyevsky] From [~victorvilladev]'s description,

[jira] [Created] (FLINK-14178) maven-shade-plugin 3.2.1 doesn't work on ARM for Flink

2019-09-23 Thread wangxiyuan (Jira)
wangxiyuan created FLINK-14178: -- Summary: maven-shade-plugin 3.2.1 doesn't work on ARM for Flink Key: FLINK-14178 URL: https://issues.apache.org/jira/browse/FLINK-14178 Project: Flink Issue Type

[jira] [Assigned] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

2019-09-23 Thread tison (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tison reassigned FLINK-14177: - Assignee: lamber-ken > Bump Curator From 2.12.0 to 4.2.0 > - > >

[GitHub] [flink] zjuwangg commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

2019-09-23 Thread GitBox
zjuwangg commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r327400979 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ## @@ -155,6 +155,24 @@ Sq

[GitHub] [flink] zjuwangg commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

2019-09-23 Thread GitBox
zjuwangg commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r327400280 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ## @@ -155,6 +155,24 @@ Sq

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

2019-09-23 Thread lamber-ken (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Description: According to FLINK-10052 and FLINK-14177, we needs to upgrade the version of CuratorFr

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

2019-09-23 Thread lamber-ken (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Description: According to FLINK-10052 and FLINK-14177, we needs to upgrade the version of CuratorFr

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

2019-09-23 Thread lamber-ken (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Description: **According to FLINK-10052 and FLINK-14177 > Bump Curator From 2.12.0 to 4.2.0 > --

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

2019-09-23 Thread lamber-ken (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Component/s: Runtime / Checkpointing Connectors / Hadoop Compatibility > Bump Curat

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

2019-09-23 Thread lamber-ken (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Fix Version/s: 1.9.1 > Bump Curator From 2.12.0 to 4.2.0 > - > >

[jira] [Created] (FLINK-14177) Bump Curator to 3.5.5

2019-09-23 Thread lamber-ken (Jira)
lamber-ken created FLINK-14177: -- Summary: Bump Curator to 3.5.5 Key: FLINK-14177 URL: https://issues.apache.org/jira/browse/FLINK-14177 Project: Flink Issue Type: Improvement Reporte

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

2019-09-23 Thread lamber-ken (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Affects Version/s: 1.8.1 1.9.0 > Bump Curator From 2.12.0 to 4.2.0 >

[jira] [Updated] (FLINK-14177) Bump Curator From 2.12.0 to 4.2.0

2019-09-23 Thread lamber-ken (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lamber-ken updated FLINK-14177: --- Summary: Bump Curator From 2.12.0 to 4.2.0 (was: Bump Curator to 3.5.5) > Bump Curator From 2.12.0

[jira] [Created] (FLINK-14176) add taskmanager link in vertex‘s page of taskmanager

2019-09-23 Thread lining (Jira)
lining created FLINK-14176: -- Summary: add taskmanager link in vertex‘s page of taskmanager Key: FLINK-14176 URL: https://issues.apache.org/jira/browse/FLINK-14176 Project: Flink Issue Type: Improvem

[jira] [Comment Edited] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

2019-09-23 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936290#comment-16936290 ] jackylau edited comment on FLINK-14159 at 9/24/19 1:38 AM: --- Hi

[jira] [Issue Comment Deleted] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

2019-09-23 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-14159: - Comment: was deleted (was: I want to konw who is responsible for , and who can see this issue [~lzljs36

[jira] [Commented] (FLINK-14159) flink rocksdb StreamCompressionDecorator not right

2019-09-23 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936290#comment-16936290 ] jackylau commented on FLINK-14159: -- Hi [~klion26],  "If no executionconfig configured,

[jira] [Commented] (FLINK-13680) Translate "Code Style - Common Rules" page into Chinese

2019-09-23 Thread ClownfishYang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936289#comment-16936289 ] ClownfishYang commented on FLINK-13680: --- I am really very sorry, because I tried t

[GitHub] [flink] yanghua commented on issue #9720: [FLINK-13025] Elasticsearch 7.x support

2019-09-23 Thread GitBox
yanghua commented on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-534347195 @aljoscha It seems you are right, we do not need the dependency of table planner. Next, I will try to move the table-specific code from the

[jira] [Comment Edited] (FLINK-14115) Translate DataStream Code Walkthrough to Chinese

2019-09-23 Thread gaofeilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936267#comment-16936267 ] gaofeilong edited comment on FLINK-14115 at 9/24/19 12:43 AM:

[jira] [Comment Edited] (FLINK-14115) Translate DataStream Code Walkthrough to Chinese

2019-09-23 Thread gaofeilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936267#comment-16936267 ] gaofeilong edited comment on FLINK-14115 at 9/24/19 12:23 AM:

[jira] [Commented] (FLINK-14115) Translate DataStream Code Walkthrough to Chinese

2019-09-23 Thread gaofeilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936267#comment-16936267 ] gaofeilong commented on FLINK-14115: I found a [falure build information|https://gi

[jira] [Comment Edited] (FLINK-14115) Translate DataStream Code Walkthrough to Chinese

2019-09-23 Thread gaofeilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936267#comment-16936267 ] gaofeilong edited comment on FLINK-14115 at 9/24/19 12:22 AM:

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED [Build](https://t

[jira] [Created] (FLINK-14175) Upgrade KPL version in flink-connector-kinesis to fix application OOM

2019-09-23 Thread Abhilasha Seth (Jira)
Abhilasha Seth created FLINK-14175: -- Summary: Upgrade KPL version in flink-connector-kinesis to fix application OOM Key: FLINK-14175 URL: https://issues.apache.org/jira/browse/FLINK-14175 Project: Fl

[GitHub] [flink] bowenli86 commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

2019-09-23 Thread GitBox
bowenli86 commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r327338523 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.ja

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

2019-09-23 Thread Victor (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936142#comment-16936142 ] Victor edited comment on FLINK-13025 at 9/23/19 9:23 PM: - [~yang

[GitHub] [flink] bowenli86 commented on issue #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable…

2019-09-23 Thread GitBox
bowenli86 commented on issue #9721: [FLINK-14129][hive] HiveTableSource should implement ProjectableTable… URL: https://github.com/apache/flink/pull/9721#issuecomment-534287604 ok. thanks, LGTM This is an automated message fr

[jira] [Updated] (FLINK-14174) Don't swallow exception when rethrowing type mismatches with side outputs

2019-09-23 Thread John Lonergan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Lonergan updated FLINK-14174: -- Description: The change made by https://github.com/apache/flink/pull/4663/files introduces a

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED [Build](https://t

[jira] [Updated] (FLINK-5334) outdated scala SBT quickstart example

2019-09-23 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5334: --- Component/s: Documentation > outdated scala SBT quickstart example >

[jira] [Updated] (FLINK-5334) outdated scala SBT quickstart example

2019-09-23 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5334: --- Affects Version/s: 1.8.2 1.9.0 > outdated scala SBT quickstart example > -

[jira] [Commented] (FLINK-5334) outdated scala SBT quickstart example

2019-09-23 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936183#comment-16936183 ] Nico Kruber commented on FLINK-5334: Actually, the script asks for a Flink and Scala

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED [Build](https://t

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

2019-09-23 Thread Victor (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936142#comment-16936142 ] Victor edited comment on FLINK-13025 at 9/23/19 7:38 PM: - [~yang

  1   2   3   4   >