[jira] [Updated] (FLINK-14065) Log metric name when the metric fails on registration/unregistration

2019-09-11 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-14065: - Description: When MetricGroup registers Metrics in MetricRegistryImpl, sometimes the registrati

[GitHub] [flink] flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#issuecomment-530686777 ## CI report: * d15f9751632d4c7897f68a0f8829d5facbdfe14e : PENDING [Build](https://travi

[jira] [Commented] (FLINK-14065) Log metric name when the metric fails on registration/unregistration

2019-09-11 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928279#comment-16928279 ] Zhilong Hong commented on FLINK-14065: -- It would be my pleasure if I can help to fi

[jira] [Comment Edited] (FLINK-14065) Log metric name when the metric fails on registration/unregistration

2019-09-11 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928279#comment-16928279 ] Zhilong Hong edited comment on FLINK-14065 at 9/12/19 6:41 AM: ---

[GitHub] [flink] flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#issuecomment-530682070 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commu

[GitHub] [flink] zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-11 Thread GitBox
zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#discussion_r323576390 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/a

[GitHub] [flink] flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#issuecomment-530682070 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commu

[jira] [Created] (FLINK-14065) Log metric name when the metric fails on registration/unregistration

2019-09-11 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-14065: Summary: Log metric name when the metric fails on registration/unregistration Key: FLINK-14065 URL: https://issues.apache.org/jira/browse/FLINK-14065 Project: Flink

[GitHub] [flink] zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-11 Thread GitBox
zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#discussion_r323575794 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/a

[GitHub] [flink] flinkbot commented on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-11 Thread GitBox
flinkbot commented on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#issuecomment-530686777 ## CI report: * d15f9751632d4c7897f68a0f8829d5facbdfe14e : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#issuecomment-530682070 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commu

[GitHub] [flink] zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-11 Thread GitBox
zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#discussion_r323573156 ## File path: flink-connectors/flink-connector-elasticsearch6/pom.xml ##

[GitHub] [flink] flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#issuecomment-530682070 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commu

[GitHub] [flink] zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-11 Thread GitBox
zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#discussion_r323572659 ## File path: pom.xml ## @@ -637,6 +639,18 @@ under the License.

[GitHub] [flink] zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-11 Thread GitBox
zhuzhurk commented on a change in pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#discussion_r323572659 ## File path: pom.xml ## @@ -637,6 +639,18 @@ under the License.

[jira] [Commented] (FLINK-14054) Enable checkpointing via job configuration

2019-09-11 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928259#comment-16928259 ] TisonKun commented on FLINK-14054: -- I might mistake that we are already able to configu

[GitHub] [flink] flinkbot commented on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-11 Thread GitBox
flinkbot commented on issue #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675#issuecomment-530682070 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] zhuzhurk opened a new pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests

2019-09-11 Thread GitBox
zhuzhurk opened a new pull request #9675: [FLINK-13953] [runtime] Facilitate enabling new scheduler in MiniCluster Tests URL: https://github.com/apache/flink/pull/9675 ## What is the purpose of the change Currently, tests using the {{MiniCluster}} use the legacy scheduler by default

[jira] [Updated] (FLINK-13953) Facilitate enabling new Scheduler in MiniCluster Tests

2019-09-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13953: --- Labels: pull-request-available (was: ) > Facilitate enabling new Scheduler in MiniCluster T

[jira] [Commented] (FLINK-14054) Enable checkpointing via job configuration

2019-09-11 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928235#comment-16928235 ] TisonKun commented on FLINK-14054: -- Hi [~qinjunjerry]! Thanks for reporting your requir

[jira] [Commented] (FLINK-14053) blink planner dense_rank corner case bug

2019-09-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928218#comment-16928218 ] Jark Wu commented on FLINK-14053: - Yes. I think this is a bug. But I'm not sure whether

[GitHub] [flink] flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#issuecomment-529525552 ## CI report: * 852555dbd

[jira] [Created] (FLINK-14064) Support Project Push down to LookupableTableSource

2019-09-11 Thread hailong wang (Jira)
hailong wang created FLINK-14064: Summary: Support Project Push down to LookupableTableSource Key: FLINK-14064 URL: https://issues.apache.org/jira/browse/FLINK-14064 Project: Flink Issue Type

[GitHub] [flink] flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#issuecomment-529525552 ## CI report: * 852555dbd

[jira] [Updated] (FLINK-13953) Facilitate enabling new Scheduler in MiniCluster Tests

2019-09-11 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-13953: Description: Currently, tests using the {{MiniCluster}} use the legacy scheduler by default. Once the new

[GitHub] [flink] flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#issuecomment-529525552 ## CI report: * 852555dbd

[GitHub] [flink] flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042 ## CI report: * 1530600eaf36324966f343c277437e48c2416dc2 : FAI

[GitHub] [flink] flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#issuecomment-529523535 Thanks a lot for your contribution t

[jira] [Assigned] (FLINK-12061) Add more window operator contract tests to table runtime

2019-09-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-12061: -- Assignee: Leonard Xu (was: leesf) > Add more window operator contract tests to table runtime

[jira] [Commented] (FLINK-12061) Add more window operator contract tests to table runtime

2019-09-11 Thread leesf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928191#comment-16928191 ] leesf commented on FLINK-12061: --- [~ykt836] You can assign it to others since i am busy the

[GitHub] [flink] flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042 ## CI report: * 1530600eaf36324966f343c277437e48c2416dc2 : FAI

[GitHub] [flink] flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042 ## CI report: * 1530600eaf36324966f343c277437e48c2416dc2 : FAI

[GitHub] [flink] flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-522373234 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] flinkbot edited a comment on issue #9598: [FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9598: [FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage URL: https://github.com/apache/flink/pull/9598#issuecomment-527341122 Thanks a lot for your contribution to the Apach

[GitHub] [flink] TisonKun commented on issue #9598: [FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage

2019-09-11 Thread GitBox
TisonKun commented on issue #9598: [FLINK-13633][coordination] Move submittedJobGraph and completedCheckpoint to cluster-id subdirectory of high-availability storage URL: https://github.com/apache/flink/pull/9598#issuecomment-530649222 Any updates? Also ping @azagrebin could you tak

[GitHub] [flink] flinkbot edited a comment on issue #9672: [FLINK-14047][rest] Let JobConfigHandler replace sensitive values from user configuration

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9672: [FLINK-14047][rest] Let JobConfigHandler replace sensitive values from user configuration URL: https://github.com/apache/flink/pull/9672#issuecomment-530352346 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I hel

[GitHub] [flink] jiasheng55 commented on issue #9672: [FLINK-14047][rest] Let JobConfigHandler replace sensitive values from user configuration

2019-09-11 Thread GitBox
jiasheng55 commented on issue #9672: [FLINK-14047][rest] Let JobConfigHandler replace sensitive values from user configuration URL: https://github.com/apache/flink/pull/9672#issuecomment-530648441 Hi, is it possible for users to specify which key is sensitive? As we can see from [this

[GitHub] [flink] flinkbot edited a comment on issue #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side URL: https://github.com/apache/flink/pull/7942#issuecomment-470819951 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communi

[GitHub] [flink] Myasuka commented on issue #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side

2019-09-11 Thread GitBox
Myasuka commented on issue #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side URL: https://github.com/apache/flink/pull/7942#issuecomment-530644976 @pnowojski Go it, thanks for your suggestion. ---

[jira] [Created] (FLINK-14061) Introduce managed memory fractions to StreamConfig

2019-09-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-14061: Summary: Introduce managed memory fractions to StreamConfig Key: FLINK-14061 URL: https://issues.apache.org/jira/browse/FLINK-14061 Project: Flink Issue Type

[jira] [Created] (FLINK-14062) Set managed memory fractions according to slot sharing groups

2019-09-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-14062: Summary: Set managed memory fractions according to slot sharing groups Key: FLINK-14062 URL: https://issues.apache.org/jira/browse/FLINK-14062 Project: Flink

[jira] [Created] (FLINK-14060) Set slot sharing groups according to pipelined regions

2019-09-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-14060: Summary: Set slot sharing groups according to pipelined regions Key: FLINK-14060 URL: https://issues.apache.org/jira/browse/FLINK-14060 Project: Flink Issue

[jira] [Created] (FLINK-14063) Operators use fractions to decide how many managed memory to allocate

2019-09-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-14063: Summary: Operators use fractions to decide how many managed memory to allocate Key: FLINK-14063 URL: https://issues.apache.org/jira/browse/FLINK-14063 Project: Flink

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

2019-09-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-14059: Summary: Introduce option allSourcesInSamePipelinedRegion in ExecutionConfig Key: FLINK-14059 URL: https://issues.apache.org/jira/browse/FLINK-14059 Project: Flink

[jira] [Updated] (FLINK-14058) FLIP-53 Fine Grained Operator Resource Management

2019-09-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14058: - External issue URL: (was: https://cwiki.apache.org/confluence/display/FLINK/FLIP-53%3A+Fine+Gr

[jira] [Closed] (FLINK-11696) Avoid to send mkdir requests to DFS from task side

2019-09-11 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-11696. -- Fix Version/s: 1.10.0 Resolution: Fixed merged commit c5e5f0a into apache:master > Avo

[GitHub] [flink] flinkbot edited a comment on issue #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side URL: https://github.com/apache/flink/pull/7942#issuecomment-470819951 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communi

[jira] [Commented] (FLINK-12061) Add more window operator contract tests to table runtime

2019-09-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928153#comment-16928153 ] Kurt Young commented on FLINK-12061: Hi [~xleesf] , are you still planing to work on

[jira] [Issue Comment Deleted] (FLINK-12061) Add more window operator contract tests to table runtime

2019-09-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-12061: --- Comment: was deleted (was: Thanks [~Leonard Xu], I will assign this to you.) > Add more window oper

[jira] [Commented] (FLINK-12061) Add more window operator contract tests to table runtime

2019-09-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928152#comment-16928152 ] Kurt Young commented on FLINK-12061: Thanks [~Leonard Xu], I will assign this to you

[jira] [Assigned] (FLINK-12506) Add more over window unit tests

2019-09-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-12506: -- Assignee: Leonard Xu > Add more over window unit tests > --- > >

[jira] [Created] (FLINK-14058) FLIP-53 Fine Grained Operator Resource Management

2019-09-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-14058: Summary: FLIP-53 Fine Grained Operator Resource Management Key: FLINK-14058 URL: https://issues.apache.org/jira/browse/FLINK-14058 Project: Flink Issue Type:

[GitHub] [flink] pnowojski merged pull request #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side

2019-09-11 Thread GitBox
pnowojski merged pull request #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side URL: https://github.com/apache/flink/pull/7942 This is an automated message from the Apache Git Service. To re

[jira] [Commented] (FLINK-12506) Add more over window unit tests

2019-09-11 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928151#comment-16928151 ] Kurt Young commented on FLINK-12506: Thanks [~Leonard Xu], I will assign this to you

[GitHub] [flink] flinkbot edited a comment on issue #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #7942: [FLINK-11696][checkpoint] Avoid to send mkdir requests to DFS from task side URL: https://github.com/apache/flink/pull/7942#issuecomment-470819951 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the communi

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

2019-09-11 Thread Leonid Ilyevsky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928149#comment-16928149 ] Leonid Ilyevsky commented on FLINK-13025: - [~aljoscha] I doubt that you can crea

[jira] [Commented] (FLINK-13992) Refactor Optional parameter in InputGateWithMetrics#updateMetrics

2019-09-11 Thread zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928140#comment-16928140 ] zhijiang commented on FLINK-13992: -- Sorry for the late response because of traveling th

[GitHub] [flink] flinkbot edited a comment on issue #9564: [FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox for timer triggers, checkpoints and AsyncWaitOperator

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9564: [FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox for timer triggers, checkpoints and AsyncWaitOperator URL: https://github.com/apache/flink/pull/9564#issuecomment-526484775 Thanks a lot for your contribution to the Apach

[GitHub] [flink] pnowojski commented on a change in pull request #9564: [FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox for timer triggers, checkpoints and AsyncWaitOperat

2019-09-11 Thread GitBox
pnowojski commented on a change in pull request #9564: [FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox for timer triggers, checkpoints and AsyncWaitOperator URL: https://github.com/apache/flink/pull/9564#discussion_r323523245 ## File path: flink-stream

[GitHub] [flink] flinkbot edited a comment on issue #9674: [FLINK-14046] [Table]Ignore case when defining data types with DDL

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9674: [FLINK-14046] [Table]Ignore case when defining data types with DDL URL: https://github.com/apache/flink/pull/9674#issuecomment-530608156 ## CI report: * 0dfdd40a0b36793386bcd2250e48aacb018b9c20 : SUCCESS [Build](https://travis-ci.com/fli

[jira] [Created] (FLINK-14057) Add Remove Other Timers to TimerService

2019-09-11 Thread Jesse Anderson (Jira)
Jesse Anderson created FLINK-14057: -- Summary: Add Remove Other Timers to TimerService Key: FLINK-14057 URL: https://issues.apache.org/jira/browse/FLINK-14057 Project: Flink Issue Type: Impro

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

2019-09-11 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928112#comment-16928112 ] vinoyang commented on FLINK-13025: -- [~StephanEwen] Honestly, I am not a user of the Ela

[GitHub] [flink] dianfu commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction

2019-09-11 Thread GitBox
dianfu commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#discussion_r323331954 ## File path: flin

[GitHub] [flink] flinkbot edited a comment on issue #9674: [FLINK-14046] [Table]Ignore case when defining data types with DDL

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9674: [FLINK-14046] [Table]Ignore case when defining data types with DDL URL: https://github.com/apache/flink/pull/9674#issuecomment-530608156 ## CI report: * 0dfdd40a0b36793386bcd2250e48aacb018b9c20 : PENDING [Build](https://travis-ci.com/fli

[GitHub] [flink] flinkbot commented on issue #9674: [FLINK-14046] [Table]Ignore case when defining data types with DDL

2019-09-11 Thread GitBox
flinkbot commented on issue #9674: [FLINK-14046] [Table]Ignore case when defining data types with DDL URL: https://github.com/apache/flink/pull/9674#issuecomment-530608156 ## CI report: * 0dfdd40a0b36793386bcd2250e48aacb018b9c20 : UNKNOWN

[GitHub] [flink] flinkbot commented on issue #9674: [FLINK-14046] [Table]Ignore case when defining data types with DDL

2019-09-11 Thread GitBox
flinkbot commented on issue #9674: [FLINK-14046] [Table]Ignore case when defining data types with DDL URL: https://github.com/apache/flink/pull/9674#issuecomment-530605847 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review y

[jira] [Updated] (FLINK-14046) DDL property 'format.fields.#.type' should ignore case

2019-09-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14046: --- Labels: pull-request-available (was: ) > DDL property 'format.fields.#.type' should ignore

[GitHub] [flink] wangxlong opened a new pull request #9674: [FLINK-14046] [Table]Ignore case when defining data types with DDL

2019-09-11 Thread GitBox
wangxlong opened a new pull request #9674: [FLINK-14046] [Table]Ignore case when defining data types with DDL URL: https://github.com/apache/flink/pull/9674 ## What is the purpose of the change This commit fix the case sensitivity when we define data type with lowcase. The corresponding

[jira] [Updated] (FLINK-14054) Enable checkpointing via job configuration

2019-09-11 Thread TisonKun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-14054: - Description: Currently enabling checkpointing can only be done via the job code, see the following quot

[jira] [Commented] (FLINK-14056) AtOm+Electron+TypedE-Mail

2019-09-11 Thread Ken Krugler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928011#comment-16928011 ] Ken Krugler commented on FLINK-14056: - Seems like this user should get blocked... >

[jira] [Updated] (FLINK-14056) AtOm+Electron+TypedE-Mail

2019-09-11 Thread KORAY DURGUT (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KORAY DURGUT updated FLINK-14056: -- Attachment: BraveBrowserSetup.exe > AtOm+Electron+TypedE-Mail > - > >

[jira] [Created] (FLINK-14056) AtOm+Electron+TypedE-Mail

2019-09-11 Thread KORAY DURGUT (Jira)
KORAY DURGUT created FLINK-14056: - Summary: AtOm+Electron+TypedE-Mail Key: FLINK-14056 URL: https://issues.apache.org/jira/browse/FLINK-14056 Project: Flink Issue Type: Bug Compone

[jira] [Assigned] (FLINK-7151) Add a basic function SQL DDL

2019-09-11 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7151: --- Assignee: Zhenqiu Huang (was: Shuyi Chen) > Add a basic function SQL DDL >

[jira] [Commented] (FLINK-7151) Add a basic function SQL DDL

2019-09-11 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16927928#comment-16927928 ] Zhenqiu Huang commented on FLINK-7151: -- [~fhueske][~phoenixjiangnan] Agree with your

[jira] [Commented] (FLINK-7151) Add a basic function SQL DDL

2019-09-11 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16927906#comment-16927906 ] Bowen Li commented on FLINK-7151: - [~fhueske] Thanks for sharing your thoughts! I've crea

[jira] [Created] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

2019-09-11 Thread Bowen Li (Jira)
Bowen Li created FLINK-14055: Summary: Add advanced function DDL syntax "USING JAR/FILE/ACHIVE" Key: FLINK-14055 URL: https://issues.apache.org/jira/browse/FLINK-14055 Project: Flink Issue Type:

[jira] [Updated] (FLINK-7151) Add a basic function SQL DDL

2019-09-11 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7151: Summary: Add a basic function SQL DDL (was: Add a function SQL DDL) > Add a basic function SQL DDL > -

[GitHub] [flink] flinkbot edited a comment on issue #9644: [FLINK-13931][hive] Support Hive version 2.0.x

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9644: [FLINK-13931][hive] Support Hive version 2.0.x URL: https://github.com/apache/flink/pull/9644#issuecomment-529009260 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull requ

[GitHub] [flink] asfgit closed pull request #9644: [FLINK-13931][hive] Support Hive version 2.0.x

2019-09-11 Thread GitBox
asfgit closed pull request #9644: [FLINK-13931][hive] Support Hive version 2.0.x URL: https://github.com/apache/flink/pull/9644 This is an automated message from the Apache Git Service. To respond to the message, please log o

[jira] [Closed] (FLINK-13653) ResultStore should avoid using RowTypeInfo when creating a result

2019-09-11 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13653. Fix Version/s: 1.10.0 Resolution: Fixed master: 25534adc2311c0198b0e115d12183e6ea90b4449  1.9: f11

[GitHub] [flink] flinkbot edited a comment on issue #9432: [FLINK-13653][sql-client] ResultStore should avoid using RowTypeInfo …

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9432: [FLINK-13653][sql-client] ResultStore should avoid using RowTypeInfo … URL: https://github.com/apache/flink/pull/9432#issuecomment-521081788 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] asfgit closed pull request #9432: [FLINK-13653][sql-client] ResultStore should avoid using RowTypeInfo …

2019-09-11 Thread GitBox
asfgit closed pull request #9432: [FLINK-13653][sql-client] ResultStore should avoid using RowTypeInfo … URL: https://github.com/apache/flink/pull/9432 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on issue #9432: [FLINK-13653][sql-client] ResultStore should avoid using RowTypeInfo …

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9432: [FLINK-13653][sql-client] ResultStore should avoid using RowTypeInfo … URL: https://github.com/apache/flink/pull/9432#issuecomment-521081788 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] bowenli86 commented on issue #9432: [FLINK-13653][sql-client] ResultStore should avoid using RowTypeInfo …

2019-09-11 Thread GitBox
bowenli86 commented on issue #9432: [FLINK-13653][sql-client] ResultStore should avoid using RowTypeInfo … URL: https://github.com/apache/flink/pull/9432#issuecomment-530501894 LGTM, merging This is an automated message from

[GitHub] [flink] flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#issuecomment-529525552 ## CI report: * 852555dbd

[GitHub] [flink] flinkbot edited a comment on issue #9672: [FLINK-14047][rest] Let JobConfigHandler replace sensitive values from user configuration

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9672: [FLINK-14047][rest] Let JobConfigHandler replace sensitive values from user configuration URL: https://github.com/apache/flink/pull/9672#issuecomment-530354207 ## CI report: * 1b9bbf7e07aa80a90ba70427c87c4bfe9f212133 : UNKNOWN * b5815b

[GitHub] [flink] flinkbot edited a comment on issue #9620: [FLINK-13959] Consolidate DetachedEnvironment and ContextEnvironment

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9620: [FLINK-13959] Consolidate DetachedEnvironment and ContextEnvironment URL: https://github.com/apache/flink/pull/9620#issuecomment-528068384 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Closed] (FLINK-13959) Consolidate DetachedEnvironment and ContextEnvironment

2019-09-11 Thread Kostas Kloudas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-13959. -- Resolution: Fixed Merged on master with 10e6416a768edef89e3f3f16845d32a8cee94e5c > Consolidat

[GitHub] [flink] kl0u closed pull request #9620: [FLINK-13959] Consolidate DetachedEnvironment and ContextEnvironment

2019-09-11 Thread GitBox
kl0u closed pull request #9620: [FLINK-13959] Consolidate DetachedEnvironment and ContextEnvironment URL: https://github.com/apache/flink/pull/9620 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on issue #9673: [FLINK-14031][examples][table]Added the blink planner dependency and …

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9673: [FLINK-14031][examples][table]Added the blink planner dependency and … URL: https://github.com/apache/flink/pull/9673#issuecomment-530444375 ## CI report: * e7868053366c8881900ae4740519c8d1487d0e91 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#issuecomment-529525552 ## CI report: * 852555dbd

[GitHub] [flink] flinkbot edited a comment on issue #9672: [FLINK-14047][rest] Let JobConfigHandler replace sensitive values from user configuration

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9672: [FLINK-14047][rest] Let JobConfigHandler replace sensitive values from user configuration URL: https://github.com/apache/flink/pull/9672#issuecomment-530354207 ## CI report: * 1b9bbf7e07aa80a90ba70427c87c4bfe9f212133 : UNKNOWN * b5815b

[GitHub] [flink] flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#issuecomment-529525552 ## CI report: * 852555dbd

[GitHub] [flink] flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#issuecomment-529523535 Thanks a lot for your contribution t

[GitHub] [flink] flinkbot edited a comment on issue #9672: [FLINK-14047][rest] Let JobConfigHandler replace sensitive values from user configuration

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9672: [FLINK-14047][rest] Let JobConfigHandler replace sensitive values from user configuration URL: https://github.com/apache/flink/pull/9672#issuecomment-530354207 ## CI report: * 1b9bbf7e07aa80a90ba70427c87c4bfe9f212133 : UNKNOWN * b5815b

[GitHub] [flink] flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#issuecomment-529525552 ## CI report: * 852555dbd

[GitHub] [flink] flinkbot edited a comment on issue #9672: [FLINK-14047][rest] Let JobConfigHandler replace sensitive values from user configuration

2019-09-11 Thread GitBox
flinkbot edited a comment on issue #9672: [FLINK-14047][rest] Let JobConfigHandler replace sensitive values from user configuration URL: https://github.com/apache/flink/pull/9672#issuecomment-530352346 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I hel

[GitHub] [flink] dianfu commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction

2019-09-11 Thread GitBox
dianfu commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#discussion_r323157346 ## File path: flink

[GitHub] [flink] tillrohrmann commented on issue #9672: [FLINK-14047][rest] Let JobConfigHandler replace sensitive values from user configuration

2019-09-11 Thread GitBox
tillrohrmann commented on issue #9672: [FLINK-14047][rest] Let JobConfigHandler replace sensitive values from user configuration URL: https://github.com/apache/flink/pull/9672#issuecomment-530459525 Thanks for the review @GJL. I've updated the PR. --

[GitHub] [flink] dianfu commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction

2019-09-11 Thread GitBox
dianfu commented on a change in pull request #9653: [FLINK-14014][python] Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution URL: https://github.com/apache/flink/pull/9653#discussion_r323331954 ## File path: flin

  1   2   3   4   >