[jira] [Created] (FLINK-10310) Cassandra Sink - Handling failing requests

2018-09-09 Thread Jayant Ameta (JIRA)
Jayant Ameta created FLINK-10310: Summary: Cassandra Sink - Handling failing requests Key: FLINK-10310 URL: https://issues.apache.org/jira/browse/FLINK-10310 Project: Flink Issue Type: Improv

[jira] [Updated] (FLINK-10299) RowSerializer.copy data value cast exception Lead to Could not restart this job

2018-09-09 Thread ambition (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition updated FLINK-10299: - Summary: RowSerializer.copy data value cast exception Lead to Could not restart this job (was: RowSeria

[jira] [Updated] (FLINK-10299) RowSerializer.copy data value cast exception

2018-09-09 Thread ambition (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition updated FLINK-10299: - Description: Flink sql deal with User behavior data collection, such as: {code:java} {     "event_id": "

[jira] [Comment Edited] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-09-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608790#comment-16608790 ] Gary Yao edited comment on FLINK-10309 at 9/10/18 6:41 AM: --- [~

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-09-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608790#comment-16608790 ] Gary Yao commented on FLINK-10309: -- For job result the problem is solved in the MiniDis

[jira] [Updated] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-09-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10309: -- Description: The problem occurs when using the Yarn per-job detached mode. Trying to cancel w

[jira] [Updated] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-09-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10309: -- Fix Version/s: 1.5.4 1.6.1 > Cancel flink job occurs java.net.ConnectExcept

[jira] [Updated] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-09-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10309: -- Description: The problem occurs when using the Yarn per-job detached mode: Trying to cancel w

[jira] [Commented] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-09-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608787#comment-16608787 ] Till Rohrmann commented on FLINK-10309: --- I think one way to solve this problem is

[jira] [Commented] (FLINK-10281) Table function parse regular expression contains backslash failed

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

[GitHub] hequn8128 commented on a change in pull request #6671: [FLINK-10281] [table] Fix string literal parsing in Table API

2018-09-09 Thread GitBox
hequn8128 commented on a change in pull request #6671: [FLINK-10281] [table] Fix string literal parsing in Table API URL: https://github.com/apache/flink/pull/6671#discussion_r216206820 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/Expr

[jira] [Commented] (FLINK-10281) Table function parse regular expression contains backslash failed

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

[GitHub] hequn8128 commented on a change in pull request #6671: [FLINK-10281] [table] Fix string literal parsing in Table API

2018-09-09 Thread GitBox
hequn8128 commented on a change in pull request #6671: [FLINK-10281] [table] Fix string literal parsing in Table API URL: https://github.com/apache/flink/pull/6671#discussion_r216206820 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/Expr

[jira] [Updated] (FLINK-10300) Prometheus job level metrics not removed after job finished

2018-09-09 Thread Helmut Zechmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Helmut Zechmann updated FLINK-10300: Affects Version/s: 1.5.1 > Prometheus job level metrics not removed after job finished > -

[jira] [Comment Edited] (FLINK-10300) Prometheus job level metrics not removed after job finished

2018-09-09 Thread Helmut Zechmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16607051#comment-16607051 ] Helmut Zechmann edited comment on FLINK-10300 at 9/10/18 5:12 AM:

[jira] [Updated] (FLINK-10300) Prometheus job level metrics not removed after job finished

2018-09-09 Thread Helmut Zechmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Helmut Zechmann updated FLINK-10300: Affects Version/s: 1.5.2 > Prometheus job level metrics not removed after job finished > -

[jira] [Commented] (FLINK-10002) WebUI shows logs unfriendly, especially when the amount of logs is large

2018-09-09 Thread zhangxinyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608680#comment-16608680 ] zhangxinyu commented on FLINK-10002: Hi [~trohrm...@apache.org], could you please as

[jira] [Updated] (FLINK-10002) WebUI shows logs unfriendly, especially when the amount of logs is large

2018-09-09 Thread zhangxinyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangxinyu updated FLINK-10002: --- Attachment: image-2018-09-10-11-38-07-973.png > WebUI shows logs unfriendly, especially when the amo

[jira] [Commented] (FLINK-10245) Add DataStream HBase Sink

2018-09-09 Thread Shimin Yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608642#comment-16608642 ] Shimin Yang commented on FLINK-10245: - Hi [~hequn8128], For the comments you mentio

[jira] [Commented] (FLINK-8819) Rework travis script to use build stages

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

[jira] [Commented] (FLINK-8819) Rework travis script to use build stages

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

[jira] [Commented] (FLINK-8819) Rework travis script to use build stages

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

[GitHub] GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework travis script to use stages

2018-09-09 Thread GitBox
GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework travis script to use stages URL: https://github.com/apache/flink/pull/6642#discussion_r216167556 ## File path: tools/travis_controller.sh ## @@ -0,0 +1,211 @@ +#!/usr/bin/env bash +###

[GitHub] GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework travis script to use stages

2018-09-09 Thread GitBox
GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework travis script to use stages URL: https://github.com/apache/flink/pull/6642#discussion_r216166677 ## File path: tools/travis/fold.sh ## @@ -0,0 +1,33 @@ +#!/usr/bin/env bash +##

[GitHub] GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework travis script to use stages

2018-09-09 Thread GitBox
GJL commented on a change in pull request #6642: [FLINK-8819][travis] Rework travis script to use stages URL: https://github.com/apache/flink/pull/6642#discussion_r216162537 ## File path: tools/travis_mvn_watchdog.sh ## @@ -160,10 +55,11 @@ esac # -nsu option forbids down

[jira] [Commented] (FLINK-10223) TaskManagers should log their ResourceID during startup

2018-09-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608506#comment-16608506 ] Gary Yao commented on FLINK-10223: -- [~aitozi] What is the state of this ticket? > Task

[jira] [Updated] (FLINK-10223) TaskManagers should log their ResourceID during startup

2018-09-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10223: - Affects Version/s: 1.7.0 > TaskManagers should log their ResourceID during startup > ---

[jira] [Updated] (FLINK-10223) TaskManagers should log their ResourceID during startup

2018-09-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10223: - Fix Version/s: 1.5.4 1.7.0 1.6.1 > TaskManagers should log their R

[jira] [Commented] (FLINK-9991) Add regexp_replace supported in TableAPI and SQL

2018-09-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608473#comment-16608473 ] ASF GitHub Bot commented on FLINK-9991: --- xccui commented on issue #6450: [FLINK-999

[GitHub] xccui commented on issue #6450: [FLINK-9991] [table] Add regexp_replace supported in TableAPI and SQL

2018-09-09 Thread GitBox
xccui commented on issue #6450: [FLINK-9991] [table] Add regexp_replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6450#issuecomment-419724525 Hi @yanghua, I will take a look at this these days. Thanks, Xingcan --

[jira] [Updated] (FLINK-9824) Support IPv6 literal

2018-09-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9824: -- Description: Currently we use colon as separator when parsing host and port. We should support the usage of I

[jira] [Updated] (FLINK-7795) Utilize error-prone to discover common coding mistakes

2018-09-09 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7795: -- Description: http://errorprone.info/ is a tool which detects common coding mistakes. We should incorporate int

[jira] [Commented] (FLINK-10290) Conversion error in StreamScan and BatchScan

2018-09-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608434#comment-16608434 ] ASF GitHub Bot commented on FLINK-10290: jrthe42 commented on issue #: [FLIN

[GitHub] jrthe42 commented on issue #6666: [FLINK-10290] [table] Fix conversion error in StreamScan and BatchScan

2018-09-09 Thread GitBox
jrthe42 commented on issue #: [FLINK-10290] [table] Fix conversion error in StreamScan and BatchScan URL: https://github.com/apache/flink/pull/#issuecomment-419711972 thanks for you suggestion @hequn8128, already fixed. -

[jira] [Commented] (FLINK-7271) ExpressionReducer does not optimize string-to-time conversion

2018-09-09 Thread xueyu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608412#comment-16608412 ] xueyu commented on FLINK-7271: -- It looks that this issue has alread been resolved, I don't k

[jira] [Commented] (FLINK-10306) Support the display of log file from any position on webUI

2018-09-09 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608380#comment-16608380 ] Jiayi Liao commented on FLINK-10306: [~yanghua] It makes sense. I'll do it soon. >

[jira] [Commented] (FLINK-10306) Support the display of log file from any position on webUI

2018-09-09 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608379#comment-16608379 ] vinoyang commented on FLINK-10306: -- Yes, this is a good suggestion, and maybe we can su

[jira] [Commented] (FLINK-10306) Support the display of log file from any position on webUI

2018-09-09 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608377#comment-16608377 ] Jiayi Liao commented on FLINK-10306: [~yanghua] Yes, the log file is too large which

[jira] [Updated] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-09-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10309: - Component/s: REST Distributed Coordination > Cancel flink job occurs java.net.ConnectEx

[jira] [Updated] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-09-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10309: - Priority: Critical (was: Major) > Cancel flink job occurs java.net.ConnectException > -

[jira] [Updated] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-09-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10309: - Affects Version/s: 1.7.0 1.5.3 1.6.0 > Cancel flink job oc

[jira] [Updated] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-09-09 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10309: - Fix Version/s: 1.7.0 > Cancel flink job occurs java.net.ConnectException > -

[GitHub] yanghua commented on issue #6675: [FLINK-10258] Allow streaming sources to be present for batch executions

2018-09-09 Thread GitBox
yanghua commented on issue #6675: [FLINK-10258] Allow streaming sources to be present for batch executions URL: https://github.com/apache/flink/pull/6675#issuecomment-419698395 cc @fhueske and @twalthr This is an automated m

[jira] [Commented] (FLINK-10258) Allow streaming sources to be present for batch executions

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

[jira] [Commented] (FLINK-10306) Support the display of log file from any position on webUI

2018-09-09 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16608369#comment-16608369 ] vinoyang commented on FLINK-10306: -- In what scenario does the Flink web UI fail to read

[jira] [Created] (FLINK-10309) Cancel flink job occurs java.net.ConnectException

2018-09-09 Thread vinoyang (JIRA)
vinoyang created FLINK-10309: Summary: Cancel flink job occurs java.net.ConnectException Key: FLINK-10309 URL: https://issues.apache.org/jira/browse/FLINK-10309 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-10258) Allow streaming sources to be present for batch executions

2018-09-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10258: --- Labels: pull-request-available (was: ) > Allow streaming sources to be present for batch ex

[jira] [Commented] (FLINK-10258) Allow streaming sources to be present for batch executions

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

[GitHub] yanghua opened a new pull request #6675: [FLINK-10258] Allow streaming sources to be present for batch executions

2018-09-09 Thread GitBox
yanghua opened a new pull request #6675: [FLINK-10258] Allow streaming sources to be present for batch executions URL: https://github.com/apache/flink/pull/6675 ## What is the purpose of the change *This pull request allow streaming sources to be present for batch executions*

[jira] [Commented] (FLINK-10304) Remove deprecated AbstractYarnClusterDescriptor field

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