[jira] [Commented] (FLINK-5434) Remove unsupported project() transformation from Scala DataStream docs

2017-01-13 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822045#comment-15822045 ] GaoLun commented on FLINK-5434: --- Just remove from the doc as the following pr. Should we create another jira

[GitHub] flink issue #3086: Improve docker setup

2017-01-13 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/3086 No, looks good. Thanks. As Greg mentioned, please open a JIRA issue next time. --- 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

[jira] [Created] (FLINK-5485) Mark compiled web frontend files as binary when processed by git diff

2017-01-13 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-5485: - Summary: Mark compiled web frontend files as binary when processed by git diff Key: FLINK-5485 URL: https://issues.apache.org/jira/browse/FLINK-5485 Project: Flink

[jira] [Commented] (FLINK-5434) Remove unsupported project() transformation from Scala DataStream docs

2017-01-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822251#comment-15822251 ] Fabian Hueske commented on FLINK-5434: -- Hi [~gallenvara_bg], projection was not added to the Scala

[jira] [Commented] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

2017-01-13 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822346#comment-15822346 ] Ted Yu commented on FLINK-5486: --- Lock on State.bucketStates should be held in the following method: {code}

[jira] [Commented] (FLINK-5250) Make AbstractUdfStreamOperator aware of WrappingFunction

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

[jira] [Updated] (FLINK-5487) Proper at-least-once support for ElasticsearchSink

2017-01-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5487: --- Description: Discussion in ML:

[jira] [Updated] (FLINK-5487) Proper at-least-once support for ElasticsearchSink

2017-01-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5487: --- Description: Discussion in ML:

[jira] [Updated] (FLINK-5487) Proper at-least-once support for ElasticsearchSink

2017-01-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5487: --- Description: Discussion in ML:

[GitHub] flink issue #3115: [FLINK-5250] Make AbstractUdfStreamOperator aware of Wrap...

2017-01-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3115 Thanks! Could you please close this PR? I merged it on master and am waiting for travis to merge to release-1.2 branch. --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-5265) Introduce state handle replication mode for CheckpointCoordinator

2017-01-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822414#comment-15822414 ] Aljoscha Krettek commented on FLINK-5265: - Lower level code in master in:

[jira] [Commented] (FLINK-5265) Introduce state handle replication mode for CheckpointCoordinator

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

[jira] [Created] (FLINK-5487) Proper at-least-once support for ElasticsearchSink

2017-01-13 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-5487: -- Summary: Proper at-least-once support for ElasticsearchSink Key: FLINK-5487 URL: https://issues.apache.org/jira/browse/FLINK-5487 Project: Flink

[jira] [Created] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

2017-01-13 Thread Ted Yu (JIRA)
Ted Yu created FLINK-5486: - Summary: Lack of synchronization in BucketingSink#handleRestoredBucketState() Key: FLINK-5486 URL: https://issues.apache.org/jira/browse/FLINK-5486 Project: Flink Issue

[GitHub] flink issue #2948: [FLINK-5265] Introduce state handle replication mode for ...

2017-01-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2948 Thanks for your work! 👍 I merged, could you please close this PR? --- 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

[jira] [Commented] (FLINK-5250) Make AbstractUdfStreamOperator aware of WrappingFunction

2017-01-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822412#comment-15822412 ] Aljoscha Krettek commented on FLINK-5250: - Implemented on master in:

[jira] [Created] (FLINK-5488) yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions

2017-01-13 Thread Ted Yu (JIRA)
Ted Yu created FLINK-5488: - Summary: yarnClient should be closed in AbstractYarnClusterDescriptor for error conditions Key: FLINK-5488 URL: https://issues.apache.org/jira/browse/FLINK-5488 Project: Flink

[jira] [Commented] (FLINK-5487) Proper at-least-once support for ElasticsearchSink

2017-01-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822356#comment-15822356 ] Tzu-Li (Gordon) Tai commented on FLINK-5487: Restructuring for the ES connectors is included

[jira] [Comment Edited] (FLINK-5487) Proper at-least-once support for ElasticsearchSink

2017-01-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822356#comment-15822356 ] Tzu-Li (Gordon) Tai edited comment on FLINK-5487 at 1/13/17 9:17 PM: -

[jira] [Assigned] (FLINK-5413) Convert TableEnvironmentITCases to unit tests

2017-01-13 Thread GaoLun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GaoLun reassigned FLINK-5413: - Assignee: GaoLun > Convert TableEnvironmentITCases to unit tests >

[GitHub] flink issue #1157: [FLINK-2720][storm-compatibility]Add Storm-CountMetric fo...

2017-01-13 Thread mjsax
Github user mjsax commented on the issue: https://github.com/apache/flink/pull/1157 Did not have a chance to work on this either -- I am in a new job, too :) You can pick this up again if you are still interested. --- If your project is set up for it, you can reply to this

[jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility

2017-01-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822025#comment-15822025 ] ASF GitHub Bot commented on FLINK-2720: --- Github user mjsax commented on the issue:

[jira] [Commented] (FLINK-5434) Remove unsupported project() transformation from Scala DataStream docs

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

[GitHub] flink pull request #3121: [FLINK-5434] Remove unsupported project() transfor...

2017-01-13 Thread gallenvara
GitHub user gallenvara opened a pull request: https://github.com/apache/flink/pull/3121 [FLINK-5434] Remove unsupported project() transformation from Scala DataStream docs. Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check

[GitHub] flink pull request #3122: [FLINK-5485] [webfrontend] Mark compiled web front...

2017-01-13 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3122 [FLINK-5485] [webfrontend] Mark compiled web frontend files as binary when processed by git diff Particularly beneficial now that javascript is minified, we can mark compiled web frontend files

[jira] [Commented] (FLINK-5485) Mark compiled web frontend files as binary when processed by git diff

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

[GitHub] flink pull request #3086: Improve docker setup

2017-01-13 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3086 --- 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] [Created] (FLINK-5489) maven release:prepare fails due to invalid JDOM comments in pom.xml

2017-01-13 Thread Haohui Mai (JIRA)
Haohui Mai created FLINK-5489: - Summary: maven release:prepare fails due to invalid JDOM comments in pom.xml Key: FLINK-5489 URL: https://issues.apache.org/jira/browse/FLINK-5489 Project: Flink

[jira] [Commented] (FLINK-5489) maven release:prepare fails due to invalid JDOM comments in pom.xml

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

[GitHub] flink pull request #3123: [FLINK-5489] maven release:prepare fails due to in...

2017-01-13 Thread haohui
GitHub user haohui opened a pull request: https://github.com/apache/flink/pull/3123 [FLINK-5489] maven release:prepare fails due to invalid JDOM comments… When I was trying to publish Flink to our internal artifactory, I found out that maven release:prepare has failed because the

[jira] [Commented] (FLINK-5464) MetricQueryService throws NullPointerException on JobManager

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

[jira] [Commented] (FLINK-5265) Introduce state handle replication mode for CheckpointCoordinator

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

[jira] [Commented] (FLINK-5250) Make AbstractUdfStreamOperator aware of WrappingFunction

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

[GitHub] flink pull request #3115: [FLINK-5250] Make AbstractUdfStreamOperator aware ...

2017-01-13 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/3115 --- 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

[GitHub] flink issue #3103: [FLINK-5464] [metrics] Prevent some NPEs

2017-01-13 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3103 yeah I'll have to rethink this :/ I wanted to just ignore gauges returning null (since nothing in the web-interface accounts for that case), but did not adjust the count of metrics that are

[jira] [Commented] (FLINK-5464) MetricQueryService throws NullPointerException on JobManager

2017-01-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822472#comment-15822472 ] ASF GitHub Bot commented on FLINK-5464: --- Github user zentol commented on the issue:

[GitHub] flink pull request #3103: [FLINK-5464] [metrics] Prevent some NPEs

2017-01-13 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/3103 --- 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 pull request #2948: [FLINK-5265] Introduce state handle replication mo...

2017-01-13 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/2948 --- 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

[jira] [Assigned] (FLINK-5489) maven release:prepare fails due to invalid JDOM comments in pom.xml

2017-01-13 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai reassigned FLINK-5489: - Assignee: Haohui Mai > maven release:prepare fails due to invalid JDOM comments in pom.xml >

[jira] [Closed] (FLINK-5250) Make AbstractUdfStreamOperator aware of WrappingFunction

2017-01-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5250. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented on release-1.2 in:

[GitHub] flink pull request #3118: [FLINK-5224] [table] Improve UDTF: emit rows direc...

2017-01-13 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/3118 [FLINK-5224] [table] Improve UDTF: emit rows directly instead of buffering them Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list

[jira] [Commented] (FLINK-5468) Restoring from a semi async rocksdb statebackend (1.1) to 1.2 fails with ClassNotFoundException

2017-01-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15821850#comment-15821850 ] ASF GitHub Bot commented on FLINK-5468: --- Github user StefanRRichter commented on the issue:

[GitHub] flink issue #3119: [FLINK-5468] Improved error message for migrating semi as...

2017-01-13 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3119 cc @rmetzger --- 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,

[jira] [Commented] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear()

2017-01-13 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15821827#comment-15821827 ] Stephan Ewen commented on FLINK-5465: - +1 for setting it to won't fix for now and properly fixing it

[jira] [Commented] (FLINK-5468) Restoring from a semi async rocksdb statebackend (1.1) to 1.2 fails with ClassNotFoundException

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

[GitHub] flink issue #3107: [FLINK-5441] [table] Directly allow SQL queries on a Tabl...

2017-01-13 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/3107 Hi @KurtYoung , thank your for reviewing. I'm not sure about that. Do you mean omitting the "FROM" syntax ? But it will be hard to validate SQL syntax. Because the query can follow a WHERE clause

[jira] [Commented] (FLINK-5441) Directly allow SQL queries on a Table

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

[jira] [Assigned] (FLINK-5468) Restoring from a semi async rocksdb statebackend (1.1) to 1.2 fails with ClassNotFoundException

2017-01-13 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-5468: - Assignee: Stefan Richter > Restoring from a semi async rocksdb statebackend (1.1) to 1.2

[jira] [Commented] (FLINK-5224) Improve UDTF: emit rows directly instead of buffering them

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

[GitHub] flink pull request #3119: [FLINK-5468] Improved error message for migrating ...

2017-01-13 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/3119 [FLINK-5468] Improved error message for migrating semi async snapshot This PR addresses [FLINK-5468]. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (FLINK-5417) Fix the wrong config file name

2017-01-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822727#comment-15822727 ] ASF GitHub Bot commented on FLINK-5417: --- Github user WangTaoTheTonic commented on the issue:

[GitHub] flink issue #3071: [FLINK-5417][DOCUMENTATION]correct the wrong config file ...

2017-01-13 Thread WangTaoTheTonic
Github user WangTaoTheTonic commented on the issue: https://github.com/apache/flink/pull/3071 Hi @zentol , I've updated the svg using Inkscape. Is the whitespace you refer to on the topest(the red highlighted part)? I think it's normal as the original one has them to. It would

[GitHub] flink issue #3113: [FLINK-4912] Introduce RECONCILIATING state in ExecutionG...

2017-01-13 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3113 Thanks for the PR. This looks good to me. I'm not too familiar with the FLIP-6 plans though. I would wait for someone who is in on that to merge this. --- If your project is set up for it, you can

[jira] [Commented] (FLINK-4912) Introduce RECONCILING state in ExecutionGraph

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

[GitHub] flink pull request #3113: [FLINK-4912] Introduce RECONCILIATING state in Exe...

2017-01-13 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/3113#discussion_r95960106 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/execution/ExecutionState.java --- @@ -25,16 +25,23 @@ * {@code * * CREATED

[jira] [Closed] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

2017-01-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5296. --- Resolution: Fixed Implemented on master in: fc343e0c390991d1d647df89041b4d872e29b6d3

[jira] [Commented] (FLINK-5155) Deprecate ValueStateDescriptor constructors with default value

2017-01-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15821498#comment-15821498 ] Aljoscha Krettek commented on FLINK-5155: - PR in https://github.com/apache/flink/pull/3108 >

[GitHub] flink pull request #3111: [FLINK-3475] [Table] DISTINCT aggregate function s...

2017-01-13 Thread docete
GitHub user docete opened a pull request: https://github.com/apache/flink/pull/3111 [FLINK-3475] [Table] DISTINCT aggregate function support for SQL queries Copy calcite's AggregateExpandDistinctAggregatesRule to Flink project, and do a quick fix to avoid some bad case mentioned in

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

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

[GitHub] flink pull request #3112: [FLINK-4988] [elasticsearch] Add Elasticsearch 5.x...

2017-01-13 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/3112 [FLINK-4988] [elasticsearch] Add Elasticsearch 5.x Connector This PR is based on @mikedias's work in #2767 (1st commit), with additional work to restructure the Elasticsearch connectors (2nd

[GitHub] flink issue #3088: [FLINK-5407] Fix savepoints for iterative jobs

2017-01-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3088 Merged, could you please close this PR? --- 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

[GitHub] flink issue #1157: [FLINK-2720][storm-compatibility]Add Storm-CountMetric fo...

2017-01-13 Thread HuangWHWHW
Github user HuangWHWHW commented on the issue: https://github.com/apache/flink/pull/1157 @mjsax Hi, very sorry to hang you out. I just did some other jobs last year because of some special circumstances. How is the progress been recently? Please let me know if you need some

[GitHub] flink pull request #3113: [FLINK-4912] Introduce RECONCILIATING state in Exe...

2017-01-13 Thread wangzhijiang999
GitHub user wangzhijiang999 opened a pull request: https://github.com/apache/flink/pull/3113 [FLINK-4912] Introduce RECONCILIATING state in ExecutionGraph and Exe… This is part of the non-disruptive JobManager failure recovery. Add a JobStatus and ExecutionState

[jira] [Commented] (FLINK-4912) Introduce RECONCILING state in ExecutionGraph

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

[jira] [Commented] (FLINK-4912) Introduce RECONCILING state in ExecutionGraph

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

[jira] [Closed] (FLINK-5407) Savepoint for iterative Task fails.

2017-01-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5407. --- Resolution: Fixed Fixed on master in: 9c6eb5793258de15a83f4cf7b13180d370062531

[jira] [Commented] (FLINK-5407) Savepoint for iterative Task fails.

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

[jira] [Commented] (FLINK-5135) ResourceProfile for slot request should be expanded to correspond with ResourceSpec

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

[jira] [Created] (FLINK-5477) Summary columns not aligned correctly

2017-01-13 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5477: -- Summary: Summary columns not aligned correctly Key: FLINK-5477 URL: https://issues.apache.org/jira/browse/FLINK-5477 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-5407) Savepoint for iterative Task fails.

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

[jira] [Commented] (FLINK-5407) Savepoint for iterative Task fails.

2017-01-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15821488#comment-15821488 ] ASF GitHub Bot commented on FLINK-5407: --- Github user StefanRRichter commented on the issue:

[GitHub] flink pull request #3088: [FLINK-5407] Fix savepoints for iterative jobs

2017-01-13 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/3088 --- 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

[GitHub] flink issue #3088: [FLINK-5407] Fix savepoints for iterative jobs

2017-01-13 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3088 Thanks for reviewing and merging @aljoscha ! --- 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 #3102: [FLINK-5467] Avoid legacy state for CheckpointedRestoring...

2017-01-13 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3102 I modified a test to catch this problem, as suggested. --- 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

[jira] [Commented] (FLINK-5467) Stateless chained tasks set legacy operator state

2017-01-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15821507#comment-15821507 ] ASF GitHub Bot commented on FLINK-5467: --- Github user StefanRRichter commented on the issue:

[GitHub] flink pull request #2907: [FLINK-5135][JM]ResourceProfile for slot request s...

2017-01-13 Thread wangzhijiang999
Github user wangzhijiang999 closed the pull request at: https://github.com/apache/flink/pull/2907 --- 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

[jira] [Closed] (FLINK-5421) Explicit restore method in Snapshotable

2017-01-13 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5421. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented on release-1.2 in:

[jira] [Commented] (FLINK-5155) Deprecate ValueStateDescriptor constructors with default value

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

[GitHub] flink pull request #2906: [FLINK-5132][FLINK-5133][FLINK-5134][Core,DataStre...

2017-01-13 Thread wangzhijiang999
Github user wangzhijiang999 closed the pull request at: https://github.com/apache/flink/pull/2906 --- 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

[jira] [Commented] (FLINK-5155) Deprecate ValueStateDescriptor constructors with default value

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

[GitHub] flink issue #3102: [FLINK-5467] Avoid legacy state for CheckpointedRestoring...

2017-01-13 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3102 Thanks! I verified that the adjusted test fails before this fix and runs fine after the fix. I'm going to merge this to master and release-1.2. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-5467) Stateless chained tasks set legacy operator state

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

[GitHub] flink issue #3112: [FLINK-4988] [elasticsearch] Add Elasticsearch 5.x Connec...

2017-01-13 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3112 Using maven build profiles, you can probably include the es5 connector in java8 builds only. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Created] (FLINK-5478) Redis Sink Connector should allow update of command without reinstatiation

2017-01-13 Thread Atharva Inamdar (JIRA)
Atharva Inamdar created FLINK-5478: -- Summary: Redis Sink Connector should allow update of command without reinstatiation Key: FLINK-5478 URL: https://issues.apache.org/jira/browse/FLINK-5478

[GitHub] flink issue #3113: [FLINK-4912] Introduce RECONCILIATING state in ExecutionG...

2017-01-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3113 I would like to take a look at this soon... --- 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-4912) Introduce RECONCILING state in ExecutionGraph

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

[jira] [Commented] (FLINK-5443) Create a path to migrate from the Rolling to the BucketingSink.

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

[GitHub] flink issue #3094: [FLINK-5443] [FLINK-5318] RollingSink backwards compatibl...

2017-01-13 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3094 Thanks for your work! 👌 Could you please close this PR, I merged it. --- 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

[jira] [Commented] (FLINK-3850) Add forward field annotations to DataSet operators generated by the Table API

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

[GitHub] flink pull request #3090: [FLINK-5432] Fix nested files enumeration in Conti...

2017-01-13 Thread ymarzougui
Github user ymarzougui commented on a diff in the pull request: https://github.com/apache/flink/pull/3090#discussion_r95976740 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java --- @@ -282,7 +282,7

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

2017-01-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15821630#comment-15821630 ] ASF GitHub Bot commented on FLINK-5432: --- Github user ymarzougui commented on the issue:

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

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

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

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

[GitHub] flink pull request #3112: [FLINK-4988] [elasticsearch] Add Elasticsearch 5.x...

2017-01-13 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3112#discussion_r95979205 --- Diff: docs/dev/connectors/elasticsearch2.md --- @@ -1,173 +0,0 @@ --- End diff -- Will do! --- If your project is set up for it,

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

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

[GitHub] flink pull request #3112: [FLINK-4988] [elasticsearch] Add Elasticsearch 5.x...

2017-01-13 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/3112#discussion_r95979696 --- Diff: .travis.yml --- @@ -16,14 +16,14 @@ matrix: include: # Always run test groups A and B together - jdk: "oraclejdk8" -

[GitHub] flink pull request #3112: [FLINK-4988] [elasticsearch] Add Elasticsearch 5.x...

2017-01-13 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/3112#discussion_r95979634 --- Diff: flink-connectors/pom.xml --- @@ -85,6 +86,17 @@ under the License. flink-connector-kinesis

[jira] [Commented] (FLINK-5464) MetricQueryService throws NullPointerException on JobManager

2017-01-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15821684#comment-15821684 ] ASF GitHub Bot commented on FLINK-5464: --- Github user zentol commented on the issue:

[GitHub] flink issue #3103: [FLINK-5464] [metrics] Prevent some NPEs

2017-01-13 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3103 cc @rmetzger --- 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

[GitHub] flink issue #3108: [FLINK-5155] Deprecate ValueStateDescriptor constructors ...

2017-01-13 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3108 I think this is good, +1 What would be good is to add a line in the comment of the constructor that says that the state returns `null` if there is no value present, yet, for the current

  1   2   3   >