[jira] [Commented] (FLINK-8352) Flink UI Reports No Error on Job Submission Failures

2018-01-07 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315826#comment-16315826 ] Ufuk Celebi commented on FLINK-8352: [~Zentol], do you know whether this is handled in the recently

[jira] [Assigned] (FLINK-3089) State API Should Support Data Expiration (State TTL)

2018-01-07 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-3089: --- Assignee: Bowen Li > State API Should Support Data Expiration (State TTL) >

[jira] [Updated] (FLINK-8364) add getIterator() to ListState, and returns empty iterator when it has no value

2018-01-07 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8364: Summary: add getIterator() to ListState, and returns empty iterator when it has no value (was: ListState

[jira] [Commented] (FLINK-8364) ListState should return empty iterator rather than null when it has no value

2018-01-07 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315767#comment-16315767 ] Bowen Li commented on FLINK-8364: - [~fhueske] [~aljoscha] Sounds reasonable to me. Updating the ticket

[jira] [Assigned] (FLINK-8368) Port SubtaskExecutionAttemptDetailsHandler to new REST endpoint

2018-01-07 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-8368: --- Assignee: Biao Liu > Port SubtaskExecutionAttemptDetailsHandler to new REST endpoint >

[jira] [Assigned] (FLINK-8367) Port SubtaskCurrentAttemptDetailsHandler to new REST endpoint

2018-01-07 Thread Biao Liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-8367: --- Assignee: Biao Liu > Port SubtaskCurrentAttemptDetailsHandler to new REST endpoint >

[jira] [Updated] (FLINK-8382) sheduleRunAsync with a positive schedule delay does not work in JobMaster

2018-01-07 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-8382: --- Description: Here's the process of invoking scheduleRunAsync in JM: 1. The method scheduleRunAsync in

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315480#comment-16315480 ] ASF GitHub Bot commented on FLINK-2055: --- Github user nielsbasjes commented on the issue:

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2018-01-07 Thread nielsbasjes
Github user nielsbasjes commented on the issue: https://github.com/apache/flink/pull/2332 FYI: In close relation to this issue I submitted an enhancement at the HBase side to support these kinds of usecases much better: https://issues.apache.org/jira/browse/HBASE-19486

[jira] [Commented] (FLINK-8322) support getting number of existing timers in TimerService

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315408#comment-16315408 ] ASF GitHub Bot commented on FLINK-8322: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #5236: [FLINK-8322] support getting number of existing timers in...

2018-01-07 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5236 If we want to implement something like that, we should tap into what the data structures give us anyways, so we don't add additional overhead. Its a bit tricky to do that, though, because

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315232#comment-16315232 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315226#comment-16315226 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315230#comment-16315230 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315219#comment-16315219 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315227#comment-16315227 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315225#comment-16315225 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315228#comment-16315228 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315221#comment-16315221 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315222#comment-16315222 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315223#comment-16315223 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315224#comment-16315224 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315220#comment-16315220 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315229#comment-16315229 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315233#comment-16315233 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315231#comment-16315231 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[jira] [Commented] (FLINK-8302) Support shift_left and shift_right in TableAPI

2018-01-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315218#comment-16315218 ] ASF GitHub Bot commented on FLINK-8302: --- Github user sunjincheng121 commented on a diff in the pull

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160046851 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -109,4 +110,45 @@ object

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160046954 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -109,4 +110,45 @@ object

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160046904 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -109,4 +110,45 @@ object

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160046913 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -109,4 +110,45 @@ object

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160047907 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarFunctionsTest.scala --- @@ -1216,6 +1216,64 @@ class

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160046875 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -109,4 +110,45 @@ object

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160046817 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -109,4 +110,45 @@ object

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160046872 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -109,4 +110,45 @@ object

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160046823 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -109,4 +110,45 @@ object

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160046929 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -109,4 +110,45 @@ object

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160047969 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/sql/ScalarSqlFunctions.scala --- @@ -58,4 +58,22 @@ object

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160046944 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -109,4 +110,45 @@ object

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160047972 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/sql/ScalarSqlFunctions.scala --- @@ -58,4 +58,22 @@ object

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160046879 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -109,4 +110,45 @@ object

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160047012 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/functions/ScalarFunctions.scala --- @@ -109,4 +110,45 @@ object

[GitHub] flink pull request #5202: [FLINK-8302][table]Add SHIFT_LEFT and SHIFT_RIGHT ...

2018-01-07 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5202#discussion_r160047888 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarFunctionsTest.scala --- @@ -1216,6 +1216,64 @@ class