[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

2018-01-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342484#comment-16342484 ] ASF GitHub Bot commented on FLINK-7608: --- Github user zentol commented on the issue:

[GitHub] flink issue #5161: [FLINK-7608][metric] Refactor latency statistics metric

2018-01-27 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5161 @yew1eb Are you suggesting to store the operatorName in the latency marker? ---

[jira] [Updated] (FLINK-8415) Unprotected access to recordsToSend in LongRecordWriterThread#shutdown()

2018-01-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8415: -- Component/s: Streaming > Unprotected access to recordsToSend in LongRecordWriterThread#shutdown() >

[jira] [Updated] (FLINK-8394) Lack of synchronization accessing expectedRecord in ReceiverThread#shutdown

2018-01-27 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8394: -- Component/s: Streaming > Lack of synchronization accessing expectedRecord in ReceiverThread#shutdown > -

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

2018-01-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342138#comment-16342138 ] ASF GitHub Bot commented on FLINK-7608: --- Github user yew1eb commented on the issue:

[GitHub] flink issue #5161: [FLINK-7608][metric] Refactor latency statistics metric

2018-01-27 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/5161 @zentol :+1: **1)**, I have no opinion. **2), 3)**, Replace `operatorID` with `operatorName`, will be better? @aljoscha @rmetzger what are your opinions? ---

[jira] [Commented] (FLINK-7095) Add proper command line parsing tool to TaskManagerRunner.main

2018-01-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342130#comment-16342130 ] ASF GitHub Bot commented on FLINK-7095: --- GitHub user zhangminglei opened a pull requ

[GitHub] flink pull request #5375: [FLINK-7095] [TaskManager] Add Command line parsin...

2018-01-27 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/5375 [FLINK-7095] [TaskManager] Add Command line parsing tool to TaskManag… ## What is the purpose of the change *Add a proper command line parsing tool to the entry point of the TaskMana

[jira] [Commented] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

2018-01-27 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342087#comment-16342087 ] mingleizhang commented on FLINK-4084: - What is the status of this jira ? > Add config

[jira] [Created] (FLINK-8519) FileAlreadyExistsException on Start Flink Session

2018-01-27 Thread Hai Zhou UTC+8 (JIRA)
Hai Zhou UTC+8 created FLINK-8519: - Summary: FileAlreadyExistsException on Start Flink Session Key: FLINK-8519 URL: https://issues.apache.org/jira/browse/FLINK-8519 Project: Flink Issue Type

[jira] [Assigned] (FLINK-8308) Update yajl-ruby dependency to 1.3.1 or higher

2018-01-27 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-8308: -- Assignee: Steven Langbroek > Update yajl-ruby dependency to 1.3.1 or higher > -

[jira] [Commented] (FLINK-8101) Elasticsearch 6.x support

2018-01-27 Thread Christophe Jolif (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342072#comment-16342072 ] Christophe Jolif commented on FLINK-8101: - Yes Flavio, the very good news, is that

[jira] [Commented] (FLINK-7980) Bump joda-time to 2.9.9

2018-01-27 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342038#comment-16342038 ] Hai Zhou UTC+8 commented on FLINK-7980: --- agree. :) I will work FLINK-7344:Migrate u

[jira] [Closed] (FLINK-7980) Bump joda-time to 2.9.9

2018-01-27 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 closed FLINK-7980. - Resolution: Won't Fix > Bump joda-time to 2.9.9 > --- > > Key:

[jira] [Assigned] (FLINK-7344) Migrate usage of joda-time to the Java 8 DateTime API

2018-01-27 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 reassigned FLINK-7344: - Assignee: Hai Zhou UTC+8 (was: Haohui Mai) > Migrate usage of joda-time to the Java 8 Da

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2018-01-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342034#comment-16342034 ] ASF GitHub Bot commented on FLINK-7923: --- Github user hequn8128 commented on a diff i

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2018-01-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342030#comment-16342030 ] ASF GitHub Bot commented on FLINK-7923: --- Github user hequn8128 commented on a diff i

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2018-01-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342032#comment-16342032 ] ASF GitHub Bot commented on FLINK-7923: --- Github user hequn8128 commented on a diff i

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2018-01-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342029#comment-16342029 ] ASF GitHub Bot commented on FLINK-7923: --- Github user hequn8128 commented on a diff i

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2018-01-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342031#comment-16342031 ] ASF GitHub Bot commented on FLINK-7923: --- Github user hequn8128 commented on a diff i

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2018-01-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342028#comment-16342028 ] ASF GitHub Bot commented on FLINK-7923: --- Github user hequn8128 commented on a diff i

[jira] [Commented] (FLINK-7923) SQL parser exception when accessing subfields of a Composite element in an Object Array type column

2018-01-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16342033#comment-16342033 ] ASF GitHub Bot commented on FLINK-7923: --- Github user hequn8128 commented on a diff i

[GitHub] flink pull request #5367: [FLINK-7923][Table API & SQL] Support field access...

2018-01-27 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/5367#discussion_r164266892 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/sql/CalcTest.scala --- @@ -0,0 +1,47 @@ +/* + * Licensed to

[GitHub] flink pull request #5367: [FLINK-7923][Table API & SQL] Support field access...

2018-01-27 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/5367#discussion_r164266896 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala --- @@ -984,6 +987,63 @@ object ScalarOper

[GitHub] flink pull request #5367: [FLINK-7923][Table API & SQL] Support field access...

2018-01-27 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/5367#discussion_r164266907 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SqlITCase.scala --- @@ -469,6 +473,148 @@ class SqlITCase e

[GitHub] flink pull request #5367: [FLINK-7923][Table API & SQL] Support field access...

2018-01-27 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/5367#discussion_r164266897 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala --- @@ -984,6 +987,63 @@ object ScalarOper

[GitHub] flink pull request #5367: [FLINK-7923][Table API & SQL] Support field access...

2018-01-27 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/5367#discussion_r164266903 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala --- @@ -984,6 +987,63 @@ object ScalarOper

[GitHub] flink pull request #5367: [FLINK-7923][Table API & SQL] Support field access...

2018-01-27 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/5367#discussion_r164266898 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala --- @@ -984,6 +987,63 @@ object ScalarOper

[GitHub] flink pull request #5367: [FLINK-7923][Table API & SQL] Support field access...

2018-01-27 Thread hequn8128
Github user hequn8128 commented on a diff in the pull request: https://github.com/apache/flink/pull/5367#discussion_r164266900 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala --- @@ -984,6 +987,63 @@ object ScalarOper