[jira] [Assigned] (FLINK-9607) Support ParquetTableSink

2018-10-15 Thread Guibo Pan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guibo Pan reassigned FLINK-9607: Assignee: Guibo Pan > Support ParquetTableSink > > > Key:

[jira] [Commented] (FLINK-9607) Support ParquetTableSink

2018-10-15 Thread Guibo Pan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651235#comment-16651235 ] Guibo Pan commented on FLINK-9607: -- [~yanghua] Thanks~ > Support ParquetTableSink > ---

[jira] [Commented] (FLINK-10559) Remove LegacyLocalStreamEnvironment

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651225#comment-16651225 ] ASF GitHub Bot commented on FLINK-10559: TisonKun commented on issue #6851: [FLI

[jira] [Updated] (FLINK-5802) Flink SQL calling Hive User-Defined Functions

2018-10-15 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-5802: Parent: FLINK-10556 Issue Type: Sub-task (was: New Feature) > Flink SQL calling Hive User-

[GitHub] TisonKun commented on issue #6851: [FLINK-10559] Remove LegacyLocalStreamEnvironment

2018-10-15 Thread GitBox
TisonKun commented on issue #6851: [FLINK-10559] Remove LegacyLocalStreamEnvironment URL: https://github.com/apache/flink/pull/6851#issuecomment-430119865 thanks, let me do a try. This is an automated message from the Apache

[jira] [Created] (FLINK-10560) JVM_ARGS doesn't work in jobmanager and taskmangers' JVM on yarn

2018-10-15 Thread Jiayi Liao (JIRA)
Jiayi Liao created FLINK-10560: -- Summary: JVM_ARGS doesn't work in jobmanager and taskmangers' JVM on yarn Key: FLINK-10560 URL: https://issues.apache.org/jira/browse/FLINK-10560 Project: Flink

[GitHub] zentol commented on issue #6851: [FLINK-10559] Remove LegacyLocalStreamEnvironment

2018-10-15 Thread GitBox
zentol commented on issue #6851: [FLINK-10559] Remove LegacyLocalStreamEnvironment URL: https://github.com/apache/flink/pull/6851#issuecomment-430119109 you (probably?) have to add an exclusion [here](https://github.com/apache/flink/blob/master/pom.xml#L1623); I've never done that either

[jira] [Commented] (FLINK-10559) Remove LegacyLocalStreamEnvironment

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651223#comment-16651223 ] ASF GitHub Bot commented on FLINK-10559: zentol commented on issue #6851: [FLINK

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651219#comment-16651219 ] ASF GitHub Bot commented on FLINK-10252: yanghua commented on a change in pull r

[jira] [Closed] (FLINK-10554) Bump flink-shaded dependency version

2018-10-15 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10554. Resolution: Fixed master: bb2b4ca49067af3625f7db91ce5f3d24c3c9 > Bump flink-shaded de

[GitHub] yanghua commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges

2018-10-15 Thread GitBox
yanghua commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#discussion_r225413055 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/Metric.java ## @@

[GitHub] zentol closed pull request #6848: [FLINK-10554][build] Bump flink-shaded to 5.0

2018-10-15 Thread GitBox
zentol closed pull request #6848: [FLINK-10554][build] Bump flink-shaded to 5.0 URL: https://github.com/apache/flink/pull/6848 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign p

[jira] [Commented] (FLINK-10554) Bump flink-shaded dependency version

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651213#comment-16651213 ] ASF GitHub Bot commented on FLINK-10554: zentol closed pull request #6848: [FLIN

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651211#comment-16651211 ] ASF GitHub Bot commented on FLINK-10252: zentol commented on a change in pull re

[GitHub] zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges

2018-10-15 Thread GitBox
zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#discussion_r225412651 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/Metric.java ## @@ -

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651209#comment-16651209 ] ASF GitHub Bot commented on FLINK-10252: yanghua commented on a change in pull r

[GitHub] yanghua commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges

2018-10-15 Thread GitBox
yanghua commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#discussion_r225412486 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/Metric.java ## @@

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651208#comment-16651208 ] ASF GitHub Bot commented on FLINK-10252: zentol commented on a change in pull re

[GitHub] zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges

2018-10-15 Thread GitBox
zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#discussion_r225411295 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/Metric.java ## @@ -

[jira] [Commented] (FLINK-10559) Remove LegacyLocalStreamEnvironment

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651202#comment-16651202 ] ASF GitHub Bot commented on FLINK-10559: TisonKun commented on issue #6851: [FLI

[GitHub] zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges

2018-10-15 Thread GitBox
zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#discussion_r225411856 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/Metric.java ## @@ -

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651201#comment-16651201 ] ASF GitHub Bot commented on FLINK-10252: zentol commented on a change in pull re

[GitHub] TisonKun commented on issue #6851: [FLINK-10559] Remove LegacyLocalStreamEnvironment

2018-10-15 Thread GitBox
TisonKun commented on issue #6851: [FLINK-10559] Remove LegacyLocalStreamEnvironment URL: https://github.com/apache/flink/pull/6851#issuecomment-430117318 Thanks for you reply @zentol! Then how to solve this api incompatibility error? I am not familiar with `japicmp:japicmp` :-( -

[jira] [Commented] (FLINK-10559) Remove LegacyLocalStreamEnvironment

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651199#comment-16651199 ] ASF GitHub Bot commented on FLINK-10559: zentol commented on issue #6851: [FLINK

[GitHub] zentol commented on issue #6851: [FLINK-10559] Remove LegacyLocalStreamEnvironment

2018-10-15 Thread GitBox
zentol commented on issue #6851: [FLINK-10559] Remove LegacyLocalStreamEnvironment URL: https://github.com/apache/flink/pull/6851#issuecomment-430116914 I would be fine with removing it. The class should never have been public, and I reckon this was simply an oversight when renaming it. -

[GitHub] zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges

2018-10-15 Thread GitBox
zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#discussion_r225411295 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/Metric.java ## @@ -

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651197#comment-16651197 ] ASF GitHub Bot commented on FLINK-10252: zentol commented on a change in pull re

[jira] [Commented] (FLINK-4052) Unstable test ConnectionUtilsTest

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651194#comment-16651194 ] ASF GitHub Bot commented on FLINK-4052: --- leanken edited a comment on issue #6853: [

[GitHub] leanken edited a comment on issue #6853: [FLINK-4052] using non-local unreachable ip:port to fix unstable Test testReturnLocalHostAddressUsingHeuristics

2018-10-15 Thread GitBox
leanken edited a comment on issue #6853: [FLINK-4052] using non-local unreachable ip:port to fix unstable Test testReturnLocalHostAddressUsingHeuristics URL: https://github.com/apache/flink/pull/6853#issuecomment-430116056 cc @tillrohrmann Saw a couple of issue relate to testReturnLoca

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651192#comment-16651192 ] ASF GitHub Bot commented on FLINK-10252: yanghua commented on a change in pull r

[GitHub] yanghua commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges

2018-10-15 Thread GitBox
yanghua commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#discussion_r225410888 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/Metric.java ## @@

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651190#comment-16651190 ] ASF GitHub Bot commented on FLINK-10252: zentol commented on a change in pull re

[jira] [Commented] (FLINK-4052) Unstable test ConnectionUtilsTest

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651191#comment-16651191 ] ASF GitHub Bot commented on FLINK-4052: --- leanken commented on issue #6853: [FLINK-4

[GitHub] leanken commented on issue #6853: [FLINK-4052] using non-local unreachable ip:port to fix unstable Test testReturnLocalHostAddressUsingHeuristics

2018-10-15 Thread GitBox
leanken commented on issue #6853: [FLINK-4052] using non-local unreachable ip:port to fix unstable Test testReturnLocalHostAddressUsingHeuristics URL: https://github.com/apache/flink/pull/6853#issuecomment-430116056 cc @tillrohrmann

[GitHub] zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges

2018-10-15 Thread GitBox
zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#discussion_r225410159 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/Metric.java ## @@ -

[jira] [Commented] (FLINK-4052) Unstable test ConnectionUtilsTest

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651188#comment-16651188 ] ASF GitHub Bot commented on FLINK-4052: --- leanken opened a new pull request #6853: [

[jira] [Updated] (FLINK-4052) Unstable test ConnectionUtilsTest

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-4052: -- Labels: pull-request-available test-stability (was: test-stability) > Unstable test Connection

[GitHub] leanken opened a new pull request #6853: [FLINK-4052] using non-local unreachable ip:port to fix unstable Test testReturnLocalHostAddressUsingHeuristics

2018-10-15 Thread GitBox
leanken opened a new pull request #6853: [FLINK-4052] using non-local unreachable ip:port to fix unstable Test testReturnLocalHostAddressUsingHeuristics URL: https://github.com/apache/flink/pull/6853 ## What is the purpose of the change See. [FLINK-4052](https://issues.apache.org/ji

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651184#comment-16651184 ] ASF GitHub Bot commented on FLINK-10252: zentol commented on a change in pull re

[GitHub] zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges

2018-10-15 Thread GitBox
zentol commented on a change in pull request #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#discussion_r225410159 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/Metric.java ## @@ -

[jira] [Commented] (FLINK-10559) Remove LegacyLocalStreamEnvironment

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651143#comment-16651143 ] ASF GitHub Bot commented on FLINK-10559: TisonKun edited a comment on issue #685

[jira] [Commented] (FLINK-10559) Remove LegacyLocalStreamEnvironment

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651142#comment-16651142 ] ASF GitHub Bot commented on FLINK-10559: TisonKun commented on issue #6851: [FLI

[GitHub] TisonKun commented on issue #6851: [FLINK-10559] Remove LegacyLocalStreamEnvironment

2018-10-15 Thread GitBox
TisonKun commented on issue #6851: [FLINK-10559] Remove LegacyLocalStreamEnvironment URL: https://github.com/apache/flink/pull/6851#issuecomment-430105332 Travis fails on ``` 05:09:30.233 [ERROR] Failed to execute goal com.github.siom79.japicmp:japicmp-maven-plugin:0.11.0:cmp (defau

[GitHub] TisonKun edited a comment on issue #6851: [FLINK-10559] Remove LegacyLocalStreamEnvironment

2018-10-15 Thread GitBox
TisonKun edited a comment on issue #6851: [FLINK-10559] Remove LegacyLocalStreamEnvironment URL: https://github.com/apache/flink/pull/6851#issuecomment-430105332 Travis fails on >05:09:30.233 [ERROR] Failed to execute goal com.github.siom79.japicmp:japicmp-maven-plugin:0.11.0:cmp (

[GitHub] TisonKun opened a new pull request #6852: [hotfix] correct document

2018-10-15 Thread GitBox
TisonKun opened a new pull request #6852: [hotfix] correct document URL: https://github.com/apache/flink/pull/6852 ## What is the purpose of the change We don't use `LocalFlinkMiniCluster`, in fact we use `MiniCluster` ## Verifying this change This change is a trivial re

[jira] [Updated] (FLINK-10559) Remove LegacyLocalStreamEnvironment

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10559: --- Labels: pull-request-available (was: ) > Remove LegacyLocalStreamEnvironment >

[jira] [Commented] (FLINK-10559) Remove LegacyLocalStreamEnvironment

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651120#comment-16651120 ] ASF GitHub Bot commented on FLINK-10559: TisonKun opened a new pull request #685

[GitHub] TisonKun opened a new pull request #6851: [FLINK-10559] Remove LegacyLocalStreamEnvironment

2018-10-15 Thread GitBox
TisonKun opened a new pull request #6851: [FLINK-10559] Remove LegacyLocalStreamEnvironment URL: https://github.com/apache/flink/pull/6851 ## What is the purpose of the change Remove `LegacyLocalStreamEnvironment` which based on legacy mode and now we have its replacement `LocalStre

[jira] [Created] (FLINK-10559) Remove LegacyLocalStreamEnvironment

2018-10-15 Thread TisonKun (JIRA)
TisonKun created FLINK-10559: Summary: Remove LegacyLocalStreamEnvironment Key: FLINK-10559 URL: https://issues.apache.org/jira/browse/FLINK-10559 Project: Flink Issue Type: Sub-task Co

[jira] [Commented] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651114#comment-16651114 ] ASF GitHub Bot commented on FLINK-10356: zhijiangW commented on a change in pull

[GitHub] zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-15 Thread GitBox
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#discussion_r225396776 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/n

[jira] [Commented] (FLINK-10398) Add Tanh math function supported in Table API and SQL

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1665#comment-1665 ] ASF GitHub Bot commented on FLINK-10398: yanghua commented on issue #6736: [FLIN

[GitHub] yanghua commented on issue #6736: [FLINK-10398][table] Add Tanh math function supported in Table API and SQL

2018-10-15 Thread GitBox
yanghua commented on issue #6736: [FLINK-10398][table] Add Tanh math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6736#issuecomment-430099630 @xccui Does it look good to you? This is an au

[jira] [Commented] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651110#comment-16651110 ] ASF GitHub Bot commented on FLINK-10356: zhijiangW commented on issue #6705: [FL

[GitHub] zhijiangW commented on issue #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-15 Thread GitBox
zhijiangW commented on issue #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#issuecomment-430099420 @NicoK , thanks for this improvement and I think it is actually necessary to add some checks duri

[jira] [Commented] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651108#comment-16651108 ] ASF GitHub Bot commented on FLINK-10356: zhijiangW commented on a change in pull

[jira] [Commented] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651107#comment-16651107 ] ASF GitHub Bot commented on FLINK-10356: zhijiangW commented on a change in pull

[GitHub] zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-15 Thread GitBox
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#discussion_r225389817 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/n

[GitHub] zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

2018-10-15 Thread GitBox
zhijiangW commented on a change in pull request #6705: [FLINK-10356][network] add sanity checks to SpillingAdaptiveSpanningRecordDeserializer URL: https://github.com/apache/flink/pull/6705#discussion_r225395730 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/n

[jira] [Commented] (FLINK-10246) Harden and separate MetricQueryService

2018-10-15 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651085#comment-16651085 ] vinoyang commented on FLINK-10246: -- [~till.rohrmann] Now the remaining two tasks of thi

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651083#comment-16651083 ] ASF GitHub Bot commented on FLINK-10252: yanghua opened a new pull request #6850

[GitHub] yanghua opened a new pull request #6850: [FLINK-10252] Handle oversized metric messges

2018-10-15 Thread GitBox
yanghua opened a new pull request #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850 ## What is the purpose of the change *This pull request handles oversized metric messges* ## Brief change log - *Handle oversized

[jira] [Updated] (FLINK-10252) Handle oversized metric messges

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10252: --- Labels: pull-request-available (was: ) > Handle oversized metric messges >

[jira] [Commented] (FLINK-4816) Executions failed from "DEPLOYING" should retain restored checkpoint information

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651052#comment-16651052 ] ASF GitHub Bot commented on FLINK-4816: --- tony810430 closed pull request #4828: [FLI

[jira] [Updated] (FLINK-4816) Executions failed from "DEPLOYING" should retain restored checkpoint information

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-4816: -- Labels: pull-request-available (was: ) > Executions failed from "DEPLOYING" should retain rest

[jira] [Assigned] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

2018-10-15 Thread Wei-Che Wei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei-Che Wei reassigned FLINK-4574: -- Assignee: (was: Wei-Che Wei) > Strengthen fetch interval implementation in Kinesis consume

[GitHub] tony810430 closed pull request #4828: [FLINK-4816] [checkpoints] Executions failed from "DEPLOYING" should retain restored checkpoint information

2018-10-15 Thread GitBox
tony810430 closed pull request #4828: [FLINK-4816] [checkpoints] Executions failed from "DEPLOYING" should retain restored checkpoint information URL: https://github.com/apache/flink/pull/4828 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[jira] [Assigned] (FLINK-4816) Executions failed from "DEPLOYING" should retain restored checkpoint information

2018-10-15 Thread Wei-Che Wei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei-Che Wei reassigned FLINK-4816: -- Assignee: (was: Wei-Che Wei) > Executions failed from "DEPLOYING" should retain restored c

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651050#comment-16651050 ] ASF GitHub Bot commented on FLINK-4574: --- tony810430 closed pull request #2925: [FLI

[jira] [Updated] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-4574: -- Labels: pull-request-available (was: ) > Strengthen fetch interval implementation in Kinesis c

[GitHub] tony810430 closed pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch interval implementation in Kinesis consumer

2018-10-15 Thread GitBox
tony810430 closed pull request #2925: [FLINK-4574] [kinesis] Strengthen fetch interval implementation in Kinesis consumer URL: https://github.com/apache/flink/pull/2925 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651048#comment-16651048 ] ASF GitHub Bot commented on FLINK-9970: --- yanghua commented on issue #6432: [FLINK-9

[GitHub] yanghua commented on issue #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

2018-10-15 Thread GitBox
yanghua commented on issue #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#issuecomment-430076195 @xccui Some suggestion I have accepted, some of them I gave a new comment. Any problem, please let me know. -

[jira] [Commented] (FLINK-10253) Run MetricQueryService with lower priority

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651046#comment-16651046 ] ASF GitHub Bot commented on FLINK-10253: yanghua commented on issue #6839: [FLIN

[GitHub] yanghua commented on issue #6839: [FLINK-10253] Run MetricQueryService with lower priority

2018-10-15 Thread GitBox
yanghua commented on issue #6839: [FLINK-10253] Run MetricQueryService with lower priority URL: https://github.com/apache/flink/pull/6839#issuecomment-430075883 @tillrohrmann Referring to your suggestion, I have updated this PR, please review again. Thank you.

[jira] [Commented] (FLINK-10474) Don't translate IN with Literals to JOIN with VALUES for streaming queries

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651037#comment-16651037 ] ASF GitHub Bot commented on FLINK-10474: hequn8128 commented on issue #6792: [FL

[GitHub] hequn8128 commented on issue #6792: [FLINK-10474][table] Don't translate IN/NOT_IN to JOIN with VALUES

2018-10-15 Thread GitBox
hequn8128 commented on issue #6792: [FLINK-10474][table] Don't translate IN/NOT_IN to JOIN with VALUES URL: https://github.com/apache/flink/pull/6792#issuecomment-430073199 Thanks a lot for your review! This is an automated

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651034#comment-16651034 ] ASF GitHub Bot commented on FLINK-9970: --- yanghua commented on a change in pull requ

[GitHub] yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

2018-10-15 Thread GitBox
yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r225370746 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/utils/

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651031#comment-16651031 ] ASF GitHub Bot commented on FLINK-9970: --- yanghua commented on a change in pull requ

[GitHub] yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

2018-10-15 Thread GitBox
yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r225370366 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/Scalar

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651022#comment-16651022 ] ASF GitHub Bot commented on FLINK-9970: --- yanghua commented on a change in pull requ

[GitHub] yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

2018-10-15 Thread GitBox
yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r225367314 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651021#comment-16651021 ] ASF GitHub Bot commented on FLINK-9970: --- yanghua commented on a change in pull requ

[GitHub] yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

2018-10-15 Thread GitBox
yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r225367094 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/

[jira] [Commented] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16651019#comment-16651019 ] ASF GitHub Bot commented on FLINK-10527: yanghua commented on issue #6816: [FLIN

[GitHub] yanghua commented on issue #6816: [FLINK-10527] Cleanup constant isNewMode in YarnTestBase

2018-10-15 Thread GitBox
yanghua commented on issue #6816: [FLINK-10527] Cleanup constant isNewMode in YarnTestBase URL: https://github.com/apache/flink/pull/6816#issuecomment-430066720 Hi @tillrohrmann and @TisonKun what about this change? In addition, I create a single JIRA issue [FLINK-10558](https://issues.ap

[jira] [Created] (FLINK-10558) Port YARNHighAvailabilityITCase and YARNSessionCapacitySchedulerITCase to new code base

2018-10-15 Thread vinoyang (JIRA)
vinoyang created FLINK-10558: Summary: Port YARNHighAvailabilityITCase and YARNSessionCapacitySchedulerITCase to new code base Key: FLINK-10558 URL: https://issues.apache.org/jira/browse/FLINK-10558 Proje

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16650851#comment-16650851 ] ASF GitHub Bot commented on FLINK-9970: --- xccui commented on a change in pull reques

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16650847#comment-16650847 ] ASF GitHub Bot commented on FLINK-9970: --- xccui commented on a change in pull reques

[GitHub] xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

2018-10-15 Thread GitBox
xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r225311291 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/Sc

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16650844#comment-16650844 ] ASF GitHub Bot commented on FLINK-9970: --- xccui commented on a change in pull reques

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16650843#comment-16650843 ] ASF GitHub Bot commented on FLINK-9970: --- xccui commented on a change in pull reques

[GitHub] xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

2018-10-15 Thread GitBox
xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r225324041 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/utils/Sc

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16650848#comment-16650848 ] ASF GitHub Bot commented on FLINK-9970: --- xccui commented on a change in pull reques

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16650842#comment-16650842 ] ASF GitHub Bot commented on FLINK-9970: --- xccui commented on a change in pull reques

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16650846#comment-16650846 ] ASF GitHub Bot commented on FLINK-9970: --- xccui commented on a change in pull reques

[GitHub] xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

2018-10-15 Thread GitBox
xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r225311291 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/Sc

[GitHub] xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API

2018-10-15 Thread GitBox
xccui commented on a change in pull request #6432: [FLINK-9970] [table] Add ASCII/CHR function for table/sql API URL: https://github.com/apache/flink/pull/6432#discussion_r225302431 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/Sc

[jira] [Commented] (FLINK-9970) Add ASCII/CHR function for table/sql API

2018-10-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16650841#comment-16650841 ] ASF GitHub Bot commented on FLINK-9970: --- xccui commented on a change in pull reques

  1   2   3   4   >