[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=16936422#comment-16936422 ] vinoyang commented on FLINK-13025: -- [~victorvilladev] Thanks for your verification and suggestion.

[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

[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

[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

[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

[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

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

[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

[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

[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

[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

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

[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

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

[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

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

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

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

[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

[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

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

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

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

[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

[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=16936348#comment-16936348 ] zhijiang commented on FLINK-12576: -- Thanks for reporting this [~alpinegizmo] I want to confirm two

[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

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

[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

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

[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

[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

[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

[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

[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=16936323#comment-16936323 ] Zhu Zhu commented on FLINK-14164: - Maybe a Meter/MeterView is a better choice as it directly reports the

[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

[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=16936318#comment-16936318 ] vinoyang commented on FLINK-13025: -- [~lilyevsky] From [~victorvilladev]'s description, it seems Flink

[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

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

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

[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

[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

[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

[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

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

[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=16936290#comment-16936290 ] jackylau edited comment on FLINK-14159 at 9/24/19 1:38 AM: --- Hi [~klion26],  

[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

[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=16936290#comment-16936290 ] jackylau commented on FLINK-14159: -- Hi [~klion26],  "If no executionconfig configured, the 

[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=16936289#comment-16936289 ] ClownfishYang commented on FLINK-13680: --- I am really very sorry, because I tried the translation

[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=16936267#comment-16936267 ] gaofeilong edited comment on FLINK-14115 at 9/24/19 12:43 AM: -- I found a

[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=16936267#comment-16936267 ] gaofeilong edited comment on FLINK-14115 at 9/24/19 12:23 AM: -- I found a

[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=16936267#comment-16936267 ] gaofeilong commented on FLINK-14115: I found a [falure build

[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=16936267#comment-16936267 ] gaofeilong edited comment on FLINK-14115 at 9/24/19 12:22 AM: -- I found 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

[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

[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

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

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

[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=16936142#comment-16936142 ] Victor edited comment on FLINK-13025 at 9/23/19 9:23 PM: - [~yanghua] I've tested

[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

[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

[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

[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=16936183#comment-16936183 ] Nico Kruber commented on FLINK-5334: Actually, the script asks for a Flink and Scala version but then

[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

[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

[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=16936142#comment-16936142 ] Victor edited comment on FLINK-13025 at 9/23/19 7:38 PM: - [~yanghua] I've tested

[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

[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=16936142#comment-16936142 ] Victor edited comment on FLINK-13025 at 9/23/19 7:37 PM: - [~yanghua] I've tested

[jira] [Commented] (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=16936142#comment-16936142 ] Victor commented on FLINK-13025: [~yanghua] I've tested the basic ES sink in a live project I have

[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

[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

[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: -- Issue Type: Bug (was: Improvement) > Don't swallow exception when rethrowing type mismatches

[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

[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

[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

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

2019-09-23 Thread Leonid Ilyevsky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936083#comment-16936083 ] Leonid Ilyevsky commented on FLINK-13025: - Thanks [~yanghua]. I could not download the file (did

[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

[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

[GitHub] [flink] flinkbot edited a comment on issue #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#issuecomment-524181331 ## CI report: * 512499aae1ab33c5ae96c8a2100016e40d83b654 : CANCELED

[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

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

2019-09-23 Thread John Lonergan (Jira)
John Lonergan created FLINK-14174: - Summary: Don't swallow exception when rethrowing type mismatches with side outputs Key: FLINK-14174 URL: https://issues.apache.org/jira/browse/FLINK-14174 Project:

[GitHub] [flink] flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468#issuecomment-522106295 ## CI report: * 78654e8f80aa0b1a01654e7684f4610eb1d3aff4 : SUCCESS

[GitHub] [flink] Johnlon commented on a change in pull request #4663: [FLINK-6549] [DataStream API] Improve error message for type mismatches with side outputs

2019-09-23 Thread GitBox
Johnlon commented on a change in pull request #4663: [FLINK-6549] [DataStream API] Improve error message for type mismatches with side outputs URL: https://github.com/apache/flink/pull/4663#discussion_r327226943 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9483: [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #9483: [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus URL: https://github.com/apache/flink/pull/9483#issuecomment-522602263 ## CI report: * 5d079442de5815edf896b85fa7aa3ca599975bb0 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

2019-09-23 Thread GitBox
flinkbot edited a comment on issue #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#issuecomment-524181331 ## CI report: * 512499aae1ab33c5ae96c8a2100016e40d83b654 : CANCELED

  1   2   3   4   >