[jira] [Assigned] (FLINK-5431) time format for akka status

2017-01-09 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5431: Assignee: Anton Solovev > time format for akka status > --- > >

[jira] [Commented] (FLINK-5357) WordCountTable fails

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15814112#comment-15814112 ] ASF GitHub Bot commented on FLINK-5357: --- Github user wuchong commented on a diff in

[GitHub] flink pull request #3063: [FLINK-5357] [table] Fix dropped projections

2017-01-09 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3063#discussion_r95308316 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/operators.scala --- @@ -92,20 +92,19 @@ case class Project(projectLi

[jira] [Commented] (FLINK-4920) Add a Scala Function Gauge

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

[GitHub] flink pull request #3080: [FLINK-4920] Add a Scala Function Gauge

2017-01-09 Thread KurtYoung
Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3080#discussion_r95306713 --- Diff: flink-scala/src/main/scala/org/apache/flink/api/scala/metrics/ScalaGauge.scala --- @@ -0,0 +1,27 @@ +/* + * Licensed to the Apache Softwa

[jira] [Commented] (FLINK-5122) Elasticsearch Sink loses documents when cluster has high load

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

[GitHub] flink issue #2861: [FLINK-5122] Index requests will be retried if the error ...

2017-01-09 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2861 Hi @static-max, thank you for working on this, it'll be an important fix for proper at least once support for the ES connector. Recently, the community has agreed to first restructure the mu

[jira] [Commented] (FLINK-5357) WordCountTable fails

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

[GitHub] flink pull request #3063: [FLINK-5357] [table] Fix dropped projections

2017-01-09 Thread KurtYoung
Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/3063#discussion_r95304042 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/operators.scala --- @@ -92,20 +92,19 @@ case class Project(project

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15813852#comment-15813852 ] ASF GitHub Bot commented on FLINK-5280: --- Github user wuchong commented on a diff in

[GitHub] flink pull request #3039: [FLINK-5280] Update TableSource to support nested ...

2017-01-09 Thread wuchong
Github user wuchong commented on a diff in the pull request: https://github.com/apache/flink/pull/3039#discussion_r95292990 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/TableSource.scala --- @@ -19,22 +19,23 @@ package org.apache.flink.t

[jira] [Commented] (FLINK-4692) Add tumbling group-windows for batch tables

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

[GitHub] flink issue #2938: [FLINK-4692] [tableApi] Add tumbling group-windows for ba...

2017-01-09 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2938 It's wired. I can't reproduce the wrong results in my local environment. What is the `data` in your test @twalthr ? I'm using the following data in the batch and stream test, but the result is same.

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15813707#comment-15813707 ] ASF GitHub Bot commented on FLINK-5364: --- Github user EronWright commented on the iss

[GitHub] flink issue #3057: [FLINK-5364] Rework JAAS configuration to support user-su...

2017-01-09 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/3057 @StephanEwen updated based on feedback, thanks again. --- 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

[jira] [Commented] (FLINK-4988) Elasticsearch 5.x support

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15813546#comment-15813546 ] ASF GitHub Bot commented on FLINK-4988: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #2767: [FLINK-4988] Elasticsearch 5.x support

2017-01-09 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2767#discussion_r95287899 --- Diff: flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSink.java --- @@ -

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15813450#comment-15813450 ] ASF GitHub Bot commented on FLINK-5364: --- Github user EronWright commented on a diff

[GitHub] flink pull request #3057: [FLINK-5364] Rework JAAS configuration to support ...

2017-01-09 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/3057#discussion_r95283348 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/JaasModule.java --- @@ -0,0 +1,147 @@ +/* + * Licensed to the Apac

[jira] [Commented] (FLINK-5395) support locally build distribution by script create_release_files.sh

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

[GitHub] flink pull request #3049: [FLINK-5395] [Build System] support locally build ...

2017-01-09 Thread shijinkui
Github user shijinkui commented on a diff in the pull request: https://github.com/apache/flink/pull/3049#discussion_r95276351 --- Diff: tools/create_release_files.sh --- @@ -66,16 +66,19 @@ fi GPG_PASSPHRASE=${GPG_PASSPHRASE:-XXX} GPG_KEY=${GPG_KEY:-XXX} GIT_AUTHOR=${

[jira] [Commented] (FLINK-5364) Rework JAAS configuration to support user-supplied entries

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15813113#comment-15813113 ] ASF GitHub Bot commented on FLINK-5364: --- Github user EronWright commented on a diff

[GitHub] flink pull request #3057: [FLINK-5364] Rework JAAS configuration to support ...

2017-01-09 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/3057#discussion_r95265401 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityUtils.java --- @@ -71,163 +64,93 @@ */ public static void

[jira] [Created] (FLINK-5432) ContinuousFileMonitoringFunction is not monitoring nested files

2017-01-09 Thread Yassine Marzougui (JIRA)
Yassine Marzougui created FLINK-5432: Summary: ContinuousFileMonitoringFunction is not monitoring nested files Key: FLINK-5432 URL: https://issues.apache.org/jira/browse/FLINK-5432 Project: Flink

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812931#comment-15812931 ] ASF GitHub Bot commented on FLINK-5386: --- Github user shaoxuan-wang commented on a di

[GitHub] flink pull request #3046: [FLINK-5386][Table API & SQL] refactoring Window C...

2017-01-09 Thread shaoxuan-wang
Github user shaoxuan-wang commented on a diff in the pull request: https://github.com/apache/flink/pull/3046#discussion_r95244683 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/windows.scala --- @@ -150,7 +147,7 @@ class TumblingWindow(size: Expres

[jira] [Commented] (FLINK-5355) Handle AmazonKinesisException gracefully in Kinesis Streaming Connector

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

[GitHub] flink issue #3078: [FLINK-5355] Handle AmazonKinesisException gracefully in ...

2017-01-09 Thread skidder
Github user skidder commented on the issue: https://github.com/apache/flink/pull/3078 Thanks @tzulitai , great feedback! The `ProvisionedThroughputExceededException` exception will be reported with an HTTP 400 response status code: http://docs.aws.amazon.com/kinesis/lates

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812569#comment-15812569 ] ASF GitHub Bot commented on FLINK-2821: --- Github user schmichri commented on the issu

[GitHub] flink issue #2917: [FLINK-2821] use custom Akka build to listen on all inter...

2017-01-09 Thread schmichri
Github user schmichri commented on the issue: https://github.com/apache/flink/pull/2917 short: it works! long: my scenario a docker-compose setup: ` jobmanager: image: flink:1.2.0_rc0 container_name: "jobmanager" expose: - "6123"

[GitHub] flink pull request #3046: [FLINK-5386][Table API & SQL] refactoring Window C...

2017-01-09 Thread shaoxuan-wang
Github user shaoxuan-wang commented on a diff in the pull request: https://github.com/apache/flink/pull/3046#discussion_r95219196 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala --- @@ -785,13 +793,19 @@ class Table( * will be p

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812507#comment-15812507 ] ASF GitHub Bot commented on FLINK-5386: --- Github user shaoxuan-wang commented on a di

[GitHub] flink issue #3061: [FLINK-5030] Support hostname verification

2017-01-09 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/3061 @tillrohrmann @StephanEwen --- 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 wi

[jira] [Commented] (FLINK-5030) Support hostname verification

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812494#comment-15812494 ] ASF GitHub Bot commented on FLINK-5030: --- Github user EronWright commented on the iss

[GitHub] flink issue #3059: [docs] Clarify restart strategy defaults set by checkpoin...

2017-01-09 Thread rehevkor5
Github user rehevkor5 commented on the issue: https://github.com/apache/flink/pull/3059 It does, thanks! I'll try to remember to include "closes #_{pr number}_" in my commit messages which might be handy. --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink issue #3059: [docs] Clarify restart strategy defaults set by checkpoin...

2017-01-09 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3059 Since the comments were very minor I addressed them myself (used the backticks and skipped the change in "If checkpointing is activated..." as it didn't really improve anything). The work flow w

[jira] [Created] (FLINK-5431) time format for akka status

2017-01-09 Thread Alexey Diomin (JIRA)
Alexey Diomin created FLINK-5431: Summary: time format for akka status Key: FLINK-5431 URL: https://issues.apache.org/jira/browse/FLINK-5431 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-5360) Fix arguments names in WindowedStream

2017-01-09 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk closed FLINK-5360. - Resolution: Fixed > Fix arguments names in WindowedStream > -

[GitHub] flink pull request #3022: [FLINK-5360] Fix argument names in WindowedStream

2017-01-09 Thread mushketyk
Github user mushketyk closed the pull request at: https://github.com/apache/flink/pull/3022 --- 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 e

[jira] [Commented] (FLINK-5360) Fix arguments names in WindowedStream

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812358#comment-15812358 ] ASF GitHub Bot commented on FLINK-5360: --- Github user mushketyk closed the pull reque

[jira] [Commented] (FLINK-5360) Fix arguments names in WindowedStream

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812357#comment-15812357 ] ASF GitHub Bot commented on FLINK-5360: --- Github user mushketyk commented on the issu

[GitHub] flink issue #3022: [FLINK-5360] Fix argument names in WindowedStream

2017-01-09 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/3022 Thank you @aljoscha, @xhumanoid Closing the issue. --- 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

[GitHub] flink issue #3059: [docs] Clarify restart strategy defaults set by checkpoin...

2017-01-09 Thread rehevkor5
Github user rehevkor5 commented on the issue: https://github.com/apache/flink/pull/3059 I'm curious as to how you added my commit to `master` and `release-1.2` but it doesn't show up in this PR. The whole "rehevkor5 committed with uce 5 days ago" thing. Github isn't aware that the cha

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812341#comment-15812341 ] ASF GitHub Bot commented on FLINK-2821: --- Github user StephanEwen commented on the is

[GitHub] flink issue #2917: [FLINK-2821] use custom Akka build to listen on all inter...

2017-01-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2917 There is a release candidate out: https://github.com/apache/flink/tree/release-1.2.0-rc0 Download at http://people.apache.org/~rmetzger/flink-1.2.0-rc0/ The official release comes whe

[GitHub] flink pull request #3049: [FLINK-5395] [Build System] support locally build ...

2017-01-09 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/3049#discussion_r95202903 --- Diff: tools/create_release_files.sh --- @@ -85,18 +88,74 @@ else MD5SUM="md5sum" fi +usage() { + set +x + echo "./create_rele

[GitHub] flink pull request #3049: [FLINK-5395] [Build System] support locally build ...

2017-01-09 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/3049#discussion_r95203611 --- Diff: tools/create_release_files.sh --- @@ -201,19 +262,34 @@ prepare make_source_release -make_binary_release "hadoop2" "" 2.10 -make

[GitHub] flink pull request #3049: [FLINK-5395] [Build System] support locally build ...

2017-01-09 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/3049#discussion_r95202566 --- Diff: tools/create_release_files.sh --- @@ -66,16 +66,19 @@ fi GPG_PASSPHRASE=${GPG_PASSPHRASE:-XXX} GPG_KEY=${GPG_KEY:-XXX} GIT_AUTHOR=${GIT_AU

[jira] [Commented] (FLINK-5395) support locally build distribution by script create_release_files.sh

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812336#comment-15812336 ] ASF GitHub Bot commented on FLINK-5395: --- Github user uce commented on a diff in the

[jira] [Commented] (FLINK-5395) support locally build distribution by script create_release_files.sh

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812337#comment-15812337 ] ASF GitHub Bot commented on FLINK-5395: --- Github user uce commented on a diff in the

[jira] [Commented] (FLINK-5395) support locally build distribution by script create_release_files.sh

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812338#comment-15812338 ] ASF GitHub Bot commented on FLINK-5395: --- Github user uce commented on a diff in the

[GitHub] flink issue #3059: [docs] Clarify restart strategy defaults set by checkpoin...

2017-01-09 Thread rehevkor5
Github user rehevkor5 commented on the issue: https://github.com/apache/flink/pull/3059 @uce Thanks. I didn't get an opportunity to address your comments... is there anything you want me to do? --- If your project is set up for it, you can reply to this email and have your reply appe

[jira] [Commented] (FLINK-5360) Fix arguments names in WindowedStream

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

[GitHub] flink issue #3022: [FLINK-5360] Fix argument names in WindowedStream

2017-01-09 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3022 Merged. Could you please close this PR and the Jira issue? --- 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 ha

[jira] [Commented] (FLINK-4651) Re-register processing time timers at the WindowOperator upon recovery.

2017-01-09 Thread Scott Kidder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812288#comment-15812288 ] Scott Kidder commented on FLINK-4651: - I can confirm that this issue appears to be fix

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812287#comment-15812287 ] ASF GitHub Bot commented on FLINK-2821: --- Github user schmichri commented on the issu

[GitHub] flink issue #2917: [FLINK-2821] use custom Akka build to listen on all inter...

2017-01-09 Thread schmichri
Github user schmichri commented on the issue: https://github.com/apache/flink/pull/2917 when is this planned to be released? --- 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 enab

[jira] [Commented] (FLINK-5178) allow BlobCache to use a distributed file system irrespective of the HA mode

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812271#comment-15812271 ] ASF GitHub Bot commented on FLINK-5178: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #3085: [FLINK-5178] allow BlobCache to use a distributed ...

2017-01-09 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/3085 [FLINK-5178] allow BlobCache to use a distributed file system irrespective of the HA mode Allow the BlobServer and BlobCache to use a distributed file system for distributing BLOBs even if not in HA-

[jira] [Commented] (FLINK-4988) Elasticsearch 5.x support

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

[GitHub] flink issue #2767: [FLINK-4988] Elasticsearch 5.x support

2017-01-09 Thread mikedias
Github user mikedias commented on the issue: https://github.com/apache/flink/pull/2767 @tzulitai sure, no problem! :) --- 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-3555) Web interface does not render job information properly

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812183#comment-15812183 ] ASF GitHub Bot commented on FLINK-3555: --- Github user sachingoel0101 commented on the

[GitHub] flink issue #2941: [FLINK-3555] Web interface does not render job informatio...

2017-01-09 Thread sachingoel0101
Github user sachingoel0101 commented on the issue: https://github.com/apache/flink/pull/2941 Imo, the best way to achieve the change equivalent to the change to vendor.css file would be to add a new class, say, .panel-body-flowable in index.styl which defines the overflow rule, and ad

[GitHub] flink pull request #3039: [FLINK-5280] Update TableSource to support nested ...

2017-01-09 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3039#discussion_r95178608 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/CsvTableSource.scala --- @@ -53,7 +53,9 @@ class CsvTableSource(

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812080#comment-15812080 ] ASF GitHub Bot commented on FLINK-5280: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5129) make the BlobServer use a distributed file system

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

[GitHub] flink pull request #3084: [FLINK-5129] make the BlobServer use a distributed...

2017-01-09 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/3084 [FLINK-5129] make the BlobServer use a distributed file system Make the BlobCache use the BlobServer's distributed file system in HA mode: previously even in HA mode and if the cache has access to the

[jira] [Commented] (FLINK-5129) make the BlobServer use a distributed file system

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812074#comment-15812074 ] ASF GitHub Bot commented on FLINK-5129: --- GitHub user NicoK opened a pull request:

[jira] [Created] (FLINK-5430) Bring documentation up to speed for current feature set

2017-01-09 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-5430: --- Summary: Bring documentation up to speed for current feature set Key: FLINK-5430 URL: https://issues.apache.org/jira/browse/FLINK-5430 Project: Flink Issue Typ

[GitHub] flink issue #3076: [FLINK-5129] make the BlobServer use a distributed file s...

2017-01-09 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/3076 fixed a typo in the unit test that lead to the tests passing although there was still something wrong which is now fixed as well --- If your project is set up for it, you can reply to this email and h

[jira] [Commented] (FLINK-4410) Report more information about operator checkpoints

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

[GitHub] flink issue #3042: [FLINK-4410] Expose more fine grained checkpoint statisti...

2017-01-09 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3042 +1 to merge --- 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 th

[jira] [Closed] (FLINK-5066) add more efficient isEvent check to EventSerializer

2017-01-09 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5066. -- Resolution: Fixed Fix Version/s: 1.3.0 Implemented in 9457465 (master). > add more efficient isE

[jira] [Closed] (FLINK-5059) only serialise events once in RecordWriter#broadcastEvent

2017-01-09 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5059. -- Resolution: Implemented Fix Version/s: 1.3.0 Fixed in 9cff8c9 (master). > only serialise events

[jira] [Commented] (FLINK-5059) only serialise events once in RecordWriter#broadcastEvent

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812039#comment-15812039 ] ASF GitHub Bot commented on FLINK-5059: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-5066) add more efficient isEvent check to EventSerializer

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812040#comment-15812040 ] ASF GitHub Bot commented on FLINK-5066: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2829: [hotfix] prevent RecordWriter#flush() to clear the...

2017-01-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2829 --- 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 enab

[GitHub] flink pull request #2806: [FLINK-5066] add more efficient isEvent check to E...

2017-01-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2806 --- 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 enab

[GitHub] flink pull request #2805: [FLINK-5059] only serialise events once in RecordW...

2017-01-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2805 --- 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 enab

[GitHub] flink pull request #3083: [FLINK-2662] [optimizer] Fix translation of broadc...

2017-01-09 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/3083 [FLINK-2662] [optimizer] Fix translation of broadcasted unions. Fix optimizer to support union with > 2 broadcasted inputs. 1. `BinaryUnionDescriptor` is changed to compute fully replicated

[jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators."

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15812018#comment-15812018 ] ASF GitHub Bot commented on FLINK-2662: --- GitHub user fhueske opened a pull request:

[GitHub] flink issue #2941: [FLINK-3555] Web interface does not render job informatio...

2017-01-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2941 Sorry, I have to take a step back here: The changes you made were directly to the resulting CSS files. These files are generated by the web build scripts, so the changes have to be made t

[jira] [Commented] (FLINK-3555) Web interface does not render job information properly

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15811940#comment-15811940 ] ASF GitHub Bot commented on FLINK-3555: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-4410) Report more information about operator checkpoints

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

[GitHub] flink issue #3042: [FLINK-4410] Expose more fine grained checkpoint statisti...

2017-01-09 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3042 Thanks for checking it out Robert. Would love to merge it for 1.2 as well. I fixed the rounding issue. --- If your project is set up for it, you can reply to this email and have your reply appear on Gi

[jira] [Commented] (FLINK-5420) Make the CEP library rescalable.

2017-01-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15811887#comment-15811887 ] Till Rohrmann commented on FLINK-5420: -- Adding a description containing some more det

[jira] [Updated] (FLINK-5423) Implement Stochastic Outlier Selection

2017-01-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5423: - Assignee: Fokko Driesprong > Implement Stochastic Outlier Selection >

[jira] [Commented] (FLINK-5426) Clean up the Flink Machine Learning library

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15811864#comment-15811864 ] ASF GitHub Bot commented on FLINK-5426: --- Github user tillrohrmann commented on the i

[jira] [Commented] (FLINK-5423) Implement Stochastic Outlier Selection

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15811868#comment-15811868 ] ASF GitHub Bot commented on FLINK-5423: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #3077: [FLINK-5423] Implement Stochastic Outlier Selection

2017-01-09 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3077 Thanks for your contribution @Fokko. I'll take a look at this PR in the next days :-) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as w

[GitHub] flink issue #3081: [FLINK-5426] Clean up the Flink Machine Learning library

2017-01-09 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/3081 Thanks for your contribution @Fokko. I'll take a look at your PR in the next days. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well

[jira] [Updated] (FLINK-5426) Clean up the Flink Machine Learning library

2017-01-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5426: - Assignee: Fokko Driesprong > Clean up the Flink Machine Learning library > ---

[jira] [Created] (FLINK-5429) Code generate types between operators in Table API

2017-01-09 Thread Timo Walther (JIRA)
Timo Walther created FLINK-5429: --- Summary: Code generate types between operators in Table API Key: FLINK-5429 URL: https://issues.apache.org/jira/browse/FLINK-5429 Project: Flink Issue Type: Ne

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

2017-01-09 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15811848#comment-15811848 ] Till Rohrmann commented on FLINK-4391: -- The plan is to document this feature: https:

[jira] [Commented] (FLINK-4410) Report more information about operator checkpoints

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

[GitHub] flink issue #3042: [FLINK-4410] Expose more fine grained checkpoint statisti...

2017-01-09 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3042 Very nice change! I would love to merge it to 1.2 as well, its so helpful! One very minor thing: I would suggest to round the percentages shown for the completion. I had an instance wher

[jira] [Commented] (FLINK-5360) Fix arguments names in WindowedStream

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

[GitHub] flink issue #3022: [FLINK-5360] Fix argument names in WindowedStream

2017-01-09 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3022 I'm running a last check and then I'm merging. Thanks for reviewing @xhumanoid! And thanks for fixing it @mushketyk. 👍 --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-4410) Report more information about operator checkpoints

2017-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15811806#comment-15811806 ] ASF GitHub Bot commented on FLINK-4410: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3042: [FLINK-4410] Expose more fine grained checkpoint statisti...

2017-01-09 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3042 I think a triggering delay would be very nice and helpful. We can do this as a next step, separate from this pull request. --- If your project is set up for it, you can reply to this email an

  1   2   >