[jira] [Commented] (FLINK-5712) update several deprecated configuration options

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15862212#comment-15862212 ] ASF GitHub Bot commented on FLINK-5712: --- Github user barcahead commented on a diff in the pull

[GitHub] flink pull request #3267: [FLINK-5712] [config] update several deprecated co...

2017-02-10 Thread barcahead
Github user barcahead commented on a diff in the pull request: https://github.com/apache/flink/pull/3267#discussion_r100660350 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/MesosServicesUtils.java --- @@ -40,9 +41,11 @@ public static

[jira] [Comment Edited] (FLINK-5773) Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge

2017-02-10 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15862176#comment-15862176 ] sunjincheng edited comment on FLINK-5773 at 2/11/17 2:54 AM: - HI,

[jira] [Commented] (FLINK-5773) Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge

2017-02-10 Thread sunjincheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15862176#comment-15862176 ] sunjincheng commented on FLINK-5773: HI, [~colinbreame], We can look at xx repeated scala'doc. {code}

[jira] [Comment Edited] (FLINK-3861) Add Scala's BigInteger and BigDecimal to Scala API

2017-02-10 Thread Artem Stasiuk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15862061#comment-15862061 ] Artem Stasiuk edited comment on FLINK-3861 at 2/11/17 2:17 AM: --- As I

[jira] [Comment Edited] (FLINK-3861) Add Scala's BigInteger and BigDecimal to Scala API

2017-02-10 Thread Artem Stasiuk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15862061#comment-15862061 ] Artem Stasiuk edited comment on FLINK-3861 at 2/11/17 12:20 AM: As I

[jira] [Commented] (FLINK-3861) Add Scala's BigInteger and BigDecimal to Scala API

2017-02-10 Thread Artem Stasiuk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15862061#comment-15862061 ] Artem Stasiuk commented on FLINK-3861: -- As I understand to be able use ```BigDecimal``` we need to

[jira] [Comment Edited] (FLINK-3861) Add Scala's BigInteger and BigDecimal to Scala API

2017-02-10 Thread Artem Stasiuk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15862061#comment-15862061 ] Artem Stasiuk edited comment on FLINK-3861 at 2/11/17 12:19 AM: As I

[jira] [Comment Edited] (FLINK-3861) Add Scala's BigInteger and BigDecimal to Scala API

2017-02-10 Thread Artem Stasiuk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15862061#comment-15862061 ] Artem Stasiuk edited comment on FLINK-3861 at 2/11/17 12:19 AM: As I

[jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861919#comment-15861919 ] ASF GitHub Bot commented on FLINK-1731: --- Github user skonto commented on the issue:

[GitHub] flink issue #3192: [FLINK-1731][ml] Add KMeans clustering(Lloyd's algorithm)

2017-02-10 Thread skonto
Github user skonto commented on the issue: https://github.com/apache/flink/pull/3192 @sachingoel0101 np as soon as you are ready let me know. Also @tillrohrmann made some comments to take into consideration. --- If your project is set up for it, you can reply to this email and have

[jira] [Created] (FLINK-5783) flink-connector-kinesis java.lang.NoClassDefFoundError: org/apache/http/conn/ssl/SSLSocketFactory

2017-02-10 Thread Huy Huynh (JIRA)
Huy Huynh created FLINK-5783: Summary: flink-connector-kinesis java.lang.NoClassDefFoundError: org/apache/http/conn/ssl/SSLSocketFactory Key: FLINK-5783 URL: https://issues.apache.org/jira/browse/FLINK-5783

[GitHub] flink issue #3293: [FLINK-5745] set an uncaught exception handler for netty ...

2017-02-10 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3293 #3290 is in --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or

[jira] [Commented] (FLINK-5745) Set uncaught exception handler for Netty threads

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861605#comment-15861605 ] ASF GitHub Bot commented on FLINK-5745: --- Github user StephanEwen commented on the issue:

[jira] [Updated] (FLINK-5618) Add queryable state documentation

2017-02-10 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5618: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-5430 > Add queryable state

[jira] [Commented] (FLINK-4364) Implement TaskManager side of heartbeat from JobManager

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861562#comment-15861562 ] ASF GitHub Bot commented on FLINK-4364: --- Github user wangzhijiang999 commented on the issue:

[jira] [Commented] (FLINK-5782) Support GPU calculations

2017-02-10 Thread Trevor Grant (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861563#comment-15861563 ] Trevor Grant commented on FLINK-5782: - 2) -1 to removing sparse array support. You don't want to be

[GitHub] flink issue #3151: [FLINK-4364][runtime]mplement TaskManager side of heartbe...

2017-02-10 Thread wangzhijiang999
Github user wangzhijiang999 commented on the issue: https://github.com/apache/flink/pull/3151 @tillrohrmann , I have submitted the updates that may cover your suggestions. There are still two issues that I am not confirmed. First, for heartbeat interval and timeout

[jira] [Created] (FLINK-5782) Support GPU calculations

2017-02-10 Thread Kate Eri (JIRA)
Kate Eri created FLINK-5782: --- Summary: Support GPU calculations Key: FLINK-5782 URL: https://issues.apache.org/jira/browse/FLINK-5782 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-5781) Generation HTML from ConfigOption

2017-02-10 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5781: -- Summary: Generation HTML from ConfigOption Key: FLINK-5781 URL: https://issues.apache.org/jira/browse/FLINK-5781 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-5773) Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge

2017-02-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5773: Fix Version/s: 1.2.1 > Cannot cast scala.util.Failure to >

[jira] [Commented] (FLINK-5773) Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge

2017-02-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861485#comment-15861485 ] Aljoscha Krettek commented on FLINK-5773: - The exception you're seeing is actually masking another

[jira] [Created] (FLINK-5780) Extend ConfigOption with descriptions

2017-02-10 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5780: -- Summary: Extend ConfigOption with descriptions Key: FLINK-5780 URL: https://issues.apache.org/jira/browse/FLINK-5780 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-5415) ContinuousFileProcessingTest failed on travis

2017-02-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5415. --- Resolution: Fixed Fix Version/s: 1.3.0 Fixed on master in:

[jira] [Created] (FLINK-5779) Auto generate configuration docs

2017-02-10 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5779: -- Summary: Auto generate configuration docs Key: FLINK-5779 URL: https://issues.apache.org/jira/browse/FLINK-5779 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5778) Split FileStateHandle into fileName and basePath

2017-02-10 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5778: -- Summary: Split FileStateHandle into fileName and basePath Key: FLINK-5778 URL: https://issues.apache.org/jira/browse/FLINK-5778 Project: Flink Issue Type:

[jira] [Created] (FLINK-5777) Pass savepoint information to CheckpointingOperation

2017-02-10 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5777: -- Summary: Pass savepoint information to CheckpointingOperation Key: FLINK-5777 URL: https://issues.apache.org/jira/browse/FLINK-5777 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-5766) Unify NoAvailableResourceException handling on ExecutionGraph

2017-02-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5766. - Resolution: Fixed Fixed in 3bde6ffb6f55ec7ff807633ab1e79d9238e5a942 > Unify

[jira] [Commented] (FLINK-5718) Handle JVM Fatal Exceptions in Tasks

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861427#comment-15861427 ] ASF GitHub Bot commented on FLINK-5718: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-5718) Handle JVM Fatal Exceptions in Tasks

2017-02-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5718. --- > Handle JVM Fatal Exceptions in Tasks > > > Key:

[GitHub] flink pull request #3290: [FLINK-5759] [jobmanager] Set UncaughtExceptionHan...

2017-02-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3290 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-5759) Set an UncaughtExceptionHandler for all Thread Pools in JobManager

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861426#comment-15861426 ] ASF GitHub Bot commented on FLINK-5759: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-5766) Unify NoAvailableResourceException handling on ExecutionGraph

2017-02-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5766. --- > Unify NoAvailableResourceException handling on ExecutionGraph >

[jira] [Assigned] (FLINK-5616) YarnPreConfiguredMasterHaServicesTest fails sometimes

2017-02-10 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-5616: Assignee: Till Rohrmann > YarnPreConfiguredMasterHaServicesTest fails sometimes >

[jira] [Updated] (FLINK-5623) TempBarrier dam has been closed

2017-02-10 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5623: - Component/s: (was: Distributed Coordination) Local Runtime > TempBarrier dam

[jira] [Resolved] (FLINK-5759) Set an UncaughtExceptionHandler for all Thread Pools in JobManager

2017-02-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5759. - Resolution: Fixed Fixed in ef77c254dadbe4c04810681fe765f5ec7d2a7400 > Set an

[jira] [Resolved] (FLINK-5718) Handle JVM Fatal Exceptions in Tasks

2017-02-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5718. - Resolution: Fixed Fix Version/s: 1.3.0 Fixed via dfc6fba5b9830e6a7804a6a0c9f69b36bf772730

[jira] [Closed] (FLINK-5759) Set an UncaughtExceptionHandler for all Thread Pools in JobManager

2017-02-10 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5759. --- > Set an UncaughtExceptionHandler for all Thread Pools in JobManager >

[GitHub] flink pull request #3276: [FLINK-5718] [core] TaskManagers exit the JVM on f...

2017-02-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3276 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-5712) update several deprecated configuration options

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861423#comment-15861423 ] ASF GitHub Bot commented on FLINK-5712: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #3267: [FLINK-5712] [config] update several deprecated co...

2017-02-10 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/3267#discussion_r100556946 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/services/MesosServicesUtils.java --- @@ -40,9 +41,11 @@ public

[jira] [Commented] (FLINK-5710) Add ProcTime() function to indicate StreamSQL

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861401#comment-15861401 ] ASF GitHub Bot commented on FLINK-5710: --- Github user tonycox commented on the issue:

[jira] [Commented] (FLINK-5744) Check remote connection in Flink-shell

2017-02-10 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861403#comment-15861403 ] Till Rohrmann commented on FLINK-5744: -- Hi Anton, could you specify what exactly the problem is? >

[GitHub] flink issue #3271: FLINK-5710

2017-02-10 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/3271 Hi @huawei-flink, please name your PR with "[FLINK-XXX] Jira title text" pattern --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-5481) Cannot create Collection of Row

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861389#comment-15861389 ] ASF GitHub Bot commented on FLINK-5481: --- Github user tonycox commented on the issue:

[GitHub] flink issue #3127: [FLINK-5481] Add type extraction from collection

2017-02-10 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/3127 I think I should rename this issuea to "Simplify Row creation". What do you think? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Created] (FLINK-5776) Improve XXMapRunner support create instance by carrying constructor parameters

2017-02-10 Thread sunjincheng (JIRA)
sunjincheng created FLINK-5776: -- Summary: Improve XXMapRunner support create instance by carrying constructor parameters Key: FLINK-5776 URL: https://issues.apache.org/jira/browse/FLINK-5776 Project:

[jira] [Commented] (FLINK-5476) Fail fast if trying to submit a job to a non-existing Flink cluster

2017-02-10 Thread Dmitrii Kniazev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861388#comment-15861388 ] Dmitrii Kniazev commented on FLINK-5476: For solving this task i decide invoke method

[jira] [Closed] (FLINK-5733) Link to Bahir connectors

2017-02-10 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-5733. - Resolution: Fixed Closing since the documentation is being updated by [~wints]'s pull request. > Link to

[jira] [Resolved] (FLINK-5017) Introduce StreamStatus stream element to allow for temporarily idle streaming sources

2017-02-10 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-5017. Resolution: Fixed Resolved for {{master}} via

[jira] [Commented] (FLINK-5017) Introduce StreamStatus stream element to allow for temporarily idle streaming sources

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861364#comment-15861364 ] ASF GitHub Bot commented on FLINK-5017: --- Github user tzulitai commented on the issue:

[jira] [Commented] (FLINK-5017) Introduce StreamStatus stream element to allow for temporarily idle streaming sources

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861365#comment-15861365 ] ASF GitHub Bot commented on FLINK-5017: --- Github user tzulitai closed the pull request at:

[GitHub] flink pull request #2801: [FLINK-5017] [streaming] Introduce StreamStatus to...

2017-02-10 Thread tzulitai
Github user tzulitai closed the pull request at: https://github.com/apache/flink/pull/2801 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink issue #2801: [FLINK-5017] [streaming] Introduce StreamStatus to facili...

2017-02-10 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2801 @aljoscha thanks! closing this --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[jira] [Commented] (FLINK-5017) Introduce StreamStatus stream element to allow for temporarily idle streaming sources

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861362#comment-15861362 ] ASF GitHub Bot commented on FLINK-5017: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #2801: [FLINK-5017] [streaming] Introduce StreamStatus to facili...

2017-02-10 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2801 Thanks for your very good work! 👍 Could you please close this PR and the Jira issue, I just merged. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Assigned] (FLINK-5760) "Introduction to Apache Flink" links to 1.1 release

2017-02-10 Thread Mike Winters (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Winters reassigned FLINK-5760: --- Assignee: Mike Winters > "Introduction to Apache Flink" links to 1.1 release >

[jira] [Commented] (FLINK-5760) "Introduction to Apache Flink" links to 1.1 release

2017-02-10 Thread Mike Winters (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861351#comment-15861351 ] Mike Winters commented on FLINK-5760: - Fixed by this PR: https://github.com/apache/flink-web/pull/46

[jira] [Commented] (FLINK-5733) Link to Bahir connectors

2017-02-10 Thread Mike Winters (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861347#comment-15861347 ] Mike Winters commented on FLINK-5733: - [~greghogan] this PR includes linking to the bahir-flink

[jira] [Commented] (FLINK-5309) documentation links on the home page point to 1.2-SNAPSHOT

2017-02-10 Thread Mike Winters (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861345#comment-15861345 ] Mike Winters commented on FLINK-5309: - https://github.com/apache/flink-web/pull/46 covers these

[jira] [Created] (FLINK-5775) NullReferenceException when running job on local cluster

2017-02-10 Thread Colin Breame (JIRA)
Colin Breame created FLINK-5775: --- Summary: NullReferenceException when running job on local cluster Key: FLINK-5775 URL: https://issues.apache.org/jira/browse/FLINK-5775 Project: Flink Issue

[jira] [Commented] (FLINK-5745) Set uncaught exception handler for Netty threads

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861301#comment-15861301 ] ASF GitHub Bot commented on FLINK-5745: --- Github user NicoK commented on the issue:

[GitHub] flink issue #3293: [FLINK-5745] set an uncaught exception handler for netty ...

2017-02-10 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/3293 @uce I'll extract the inner class and use it here as well as soon as the final #3290 is merged --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Assigned] (FLINK-5415) ContinuousFileProcessingTest failed on travis

2017-02-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-5415: --- Assignee: Aljoscha Krettek > ContinuousFileProcessingTest failed on travis >

[jira] [Closed] (FLINK-5774) ContinuousFileProcessingTest has test instability

2017-02-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5774. --- Resolution: Duplicate Ah dammit, this is a duplicate of FLINK-5415, closing again. >

[jira] [Commented] (FLINK-5415) ContinuousFileProcessingTest failed on travis

2017-02-10 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861299#comment-15861299 ] Aljoscha Krettek commented on FLINK-5415: - Inserting a {{Thread.sleep(200)}} in

[jira] [Commented] (FLINK-5745) Set uncaught exception handler for Netty threads

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861293#comment-15861293 ] ASF GitHub Bot commented on FLINK-5745: --- Github user NicoK commented on the issue:

[jira] [Created] (FLINK-5774) ContinuousFileProcessingTest has test instability

2017-02-10 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-5774: --- Summary: ContinuousFileProcessingTest has test instability Key: FLINK-5774 URL: https://issues.apache.org/jira/browse/FLINK-5774 Project: Flink Issue

[GitHub] flink issue #3293: [FLINK-5745] set an uncaught exception handler for netty ...

2017-02-10 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/3293 I was actually looking through the code to find something like this but it seems that every class does this locally for now. Global exit codes make sense though - also for documentation --- If your

[jira] [Commented] (FLINK-5718) Handle JVM Fatal Exceptions in Tasks

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861288#comment-15861288 ] ASF GitHub Bot commented on FLINK-5718: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3276: [FLINK-5718] [core] TaskManagers exit the JVM on fatal ex...

2017-02-10 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3276 Addressing the comment and merging this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[GitHub] flink issue #3293: [FLINK-5745] set an uncaught exception handler for netty ...

2017-02-10 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3293 Looking at this and at my previous pull request, I am wondering if we should actually define and collect exit codes somewhere globally, like in

[jira] [Commented] (FLINK-5745) Set uncaught exception handler for Netty threads

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861285#comment-15861285 ] ASF GitHub Bot commented on FLINK-5745: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-5759) Set an UncaughtExceptionHandler for all Thread Pools in JobManager

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861281#comment-15861281 ] ASF GitHub Bot commented on FLINK-5759: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #3290: [FLINK-5759] [jobmanager] Set UncaughtExceptionHandlers f...

2017-02-10 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3290 Addressing the comments and merging this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-5745) Set uncaught exception handler for Netty threads

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861278#comment-15861278 ] ASF GitHub Bot commented on FLINK-5745: --- Github user uce commented on the issue:

[GitHub] flink issue #3293: [FLINK-5745] set an uncaught exception handler for netty ...

2017-02-10 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3293 I thought that this is only going to be one, sorry. Imo only one is good. The thread name is logged in the message. --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-5759) Set an UncaughtExceptionHandler for all Thread Pools in JobManager

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861274#comment-15861274 ] ASF GitHub Bot commented on FLINK-5759: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #3290: [FLINK-5759] [jobmanager] Set UncaughtExceptionHan...

2017-02-10 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3290#discussion_r100535521 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerServices.java --- @@ -116,12 +116,17 @@ public static

[jira] [Commented] (FLINK-5759) Set an UncaughtExceptionHandler for all Thread Pools in JobManager

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861271#comment-15861271 ] ASF GitHub Bot commented on FLINK-5759: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5759) Set an UncaughtExceptionHandler for all Thread Pools in JobManager

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861272#comment-15861272 ] ASF GitHub Bot commented on FLINK-5759: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #3290: [FLINK-5759] [jobmanager] Set UncaughtExceptionHan...

2017-02-10 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3290#discussion_r100535279 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/util/ExecutorThreadFactory.java --- @@ -18,49 +18,112 @@ package

[GitHub] flink pull request #3290: [FLINK-5759] [jobmanager] Set UncaughtExceptionHan...

2017-02-10 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3290#discussion_r100535249 --- Diff: flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosApplicationMasterRunner.java --- @@ -216,11 +220,11 @@

[GitHub] flink pull request #3290: [FLINK-5759] [jobmanager] Set UncaughtExceptionHan...

2017-02-10 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3290#discussion_r100534934 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java --- @@ -99,7 +99,8 @@ public FileCache(String[]

[jira] [Commented] (FLINK-5759) Set an UncaughtExceptionHandler for all Thread Pools in JobManager

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861266#comment-15861266 ] ASF GitHub Bot commented on FLINK-5759: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5745) Set uncaught exception handler for Netty threads

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861249#comment-15861249 ] ASF GitHub Bot commented on FLINK-5745: --- Github user NicoK commented on the issue:

[GitHub] flink issue #3293: [FLINK-5745] set an uncaught exception handler for netty ...

2017-02-10 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/3293 wouldn't it be `NettyServer$FatalExitExceptionHandler` vs. `ExecutorThreadFactory$FatalExitExceptionHandler`? --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-5745) Set uncaught exception handler for Netty threads

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861224#comment-15861224 ] ASF GitHub Bot commented on FLINK-5745: --- Github user uce commented on the issue:

[GitHub] flink issue #3293: [FLINK-5745] set an uncaught exception handler for netty ...

2017-02-10 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3293 I think it's logged as `FatalExitExceptionHandler` in both places right now as well (Stephan's PR and your PR). So nothing would change if we move it out, or am I overlooking something? --- If your

[jira] [Commented] (FLINK-5745) Set uncaught exception handler for Netty threads

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861212#comment-15861212 ] ASF GitHub Bot commented on FLINK-5745: --- Github user NicoK commented on the issue:

[GitHub] flink issue #3293: [FLINK-5745] set an uncaught exception handler for netty ...

2017-02-10 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/3293 would be a different LOG handler though - does it make sense to have two or is it enough to have a single one in an outer class? --- If your project is set up for it, you can reply to this email and

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

2017-02-10 Thread radu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861207#comment-15861207 ] radu commented on FLINK-5654: - Thanks Haohui for the suggestion. You are right with the suggestions you make

[jira] [Commented] (FLINK-2168) Add HBaseTableSource

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861181#comment-15861181 ] ASF GitHub Bot commented on FLINK-2168: --- Github user tonycox commented on the issue:

[GitHub] flink issue #3149: FLINK-2168 Add HBaseTableSource

2017-02-10 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/3149 @ramkrish86 Try to add ``` -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath="/tmp" ``` as parameter of JVM --- If your project is set up for it, you can reply to this email

[jira] [Created] (FLINK-5773) Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge

2017-02-10 Thread Colin Breame (JIRA)
Colin Breame created FLINK-5773: --- Summary: Cannot cast scala.util.Failure to org.apache.flink.runtime.messages.Acknowledge Key: FLINK-5773 URL: https://issues.apache.org/jira/browse/FLINK-5773 Project:

[jira] [Updated] (FLINK-5771) DelimitedInputFormat does not correctly handle multi-byte delimiters

2017-02-10 Thread Colin Breame (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin Breame updated FLINK-5771: Summary: DelimitedInputFormat does not correctly handle multi-byte delimiters (was:

[jira] [Commented] (FLINK-5745) Set uncaught exception handler for Netty threads

2017-02-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15861154#comment-15861154 ] ASF GitHub Bot commented on FLINK-5745: --- Github user uce commented on the issue:

[GitHub] flink issue #3293: [FLINK-5745] set an uncaught exception handler for netty ...

2017-02-10 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3293 Should we instead of copying the uncaught exception handler code move it out to an outer class? You would have to base this PR on #3290, move the class out and only use it here. --- If your project is

[jira] [Updated] (FLINK-5650) Flink-python tests executing cost too long time

2017-02-10 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-5650: - Description: When execute `mvn clean test` in flink-python, it will wait more than half hour after the

[jira] [Updated] (FLINK-5650) Flink-python tests executing cost too long time

2017-02-10 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui updated FLINK-5650: - Summary: Flink-python tests executing cost too long time (was: Flink-python tests can time out) >

  1   2   >