[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&focusedCommentId=15822727#comment-15822727 ] ASF GitHub Bot commented on FLINK-5417: --- Github user WangTaoTheTonic commented on th

[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 not

[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: 8041deabe8e1e968b

[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 feature

[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&focusedCommentId=15822488#comment-15822488 ] ASF GitHub Bot commented on FLINK-5265: --- Github user StefanRRichter closed the pull

[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&focusedCommentId=15822489#comment-15822489 ] ASF GitHub Bot commented on FLINK-5250: --- Github user StefanRRichter closed the pull

[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 feature

[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&focusedCommentId=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] [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

[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 enab

[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&focusedCommentId=15822472#comment-15822472 ] 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 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 s

[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&focusedCommentId=15822473#comment-15822473 ] ASF GitHub Bot commented on FLINK-5464: --- Github user zentol closed the pull request

[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&focusedCommentId=15822415#comment-15822415 ] ASF GitHub Bot commented on FLINK-5250: --- Github user aljoscha commented on the issue

[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 yo

[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&focusedCommentId=15822414#comment-15822414 ] Aljoscha Krettek commented on FLINK-5265: - Lower level code in master in: 1020ba2c

[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&focusedCommentId=15822413#comment-15822413 ] ASF GitHub Bot commented on FLINK-5265: --- Github user aljoscha commented on the issue

[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&focusedCommentId=15822412#comment-15822412 ] Aljoscha Krettek commented on FLINK-5250: - Implemented on master in: ce023503f6f96

[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 d

[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&focusedCommentId=15822356#comment-15822356 ] Tzu-Li (Gordon) Tai edited comment on FLINK-5487 at 1/13/17 9:17 PM: ---

[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&focusedCommentId=15822356#comment-15822356 ] Tzu-Li (Gordon) Tai commented on FLINK-5487: Restructuring for the ES connecto

[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] [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: http://apache-flink-user-mailing-list-archive.2336050.

[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: http://apache-flink-user-mailing-list-archive.2336050.

[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: http://apache-flink-user-mailing-list-archive.2336050.

[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] [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&focusedCommentId=15822346#comment-15822346 ] Ted Yu commented on FLINK-5486: --- Lock on State.bucketStates should be held in the following

[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&focusedCommentId=15822251#comment-15822251 ] Fabian Hueske commented on FLINK-5434: -- Hi [~gallenvara_bg], projection was not added

[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 T

[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&focusedCommentId=15822127#comment-15822127 ] ASF GitHub Bot commented on FLINK-5485: --- GitHub user greghogan opened a pull request

[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 a

[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

[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 enab

[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 pr

[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 > --

[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&focusedCommentId=15822050#comment-15822050 ] ASF GitHub Bot commented on FLINK-5434: --- GitHub user gallenvara opened a pull reques

[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 l

[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&focusedCommentId=15822045#comment-15822045 ] GaoLun commented on FLINK-5434: --- Just remove from the doc as the following pr. Should we cre

[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&focusedCommentId=15822025#comment-15822025 ] ASF GitHub Bot commented on FLINK-2720: --- Github user mjsax commented on the issue:

[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 em

[jira] [Created] (FLINK-5484) Kryo serialization changed between 1.1 and 1.2

2017-01-13 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5484: -- Summary: Kryo serialization changed between 1.1 and 1.2 Key: FLINK-5484 URL: https://issues.apache.org/jira/browse/FLINK-5484 Project: Flink Issue Type: Bug

[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&focusedCommentId=15821920#comment-15821920 ] ASF GitHub Bot commented on FLINK-5464: --- Github user rmetzger commented on the issue

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

2017-01-13 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3103 While testing this PR, I found that the jobmanager.log is now full with exceptions like this one: ``` java.io.EOFException at java.io.DataInputStream.readInt(DataInputStream.

[jira] [Comment Edited] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

2017-01-13 Thread Evgeny Kincharov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821899#comment-15821899 ] Evgeny Kincharov edited comment on FLINK-3133 at 1/13/17 3:42 PM: --

[jira] [Assigned] (FLINK-5375) Fix watermark documentation

2017-01-13 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-5375: -- Assignee: Tzu-Li (Gordon) Tai > Fix watermark documentation > -

[jira] [Created] (FLINK-5483) Link to "linking modules not contained in binary distribution" broken in all connector documentations

2017-01-13 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-5483: -- Summary: Link to "linking modules not contained in binary distribution" broken in all connector documentations Key: FLINK-5483 URL: https://issues.apache.org/jira/brow

[jira] [Commented] (FLINK-5482) QueryableStateClient does not recover from a failed lookup due to a non-running job

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

[GitHub] flink pull request #3120: [FLINK-5482] QueryableStateClient does not recover...

2017-01-13 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/3120 [FLINK-5482] QueryableStateClient does not recover from a failed lookup due to a non-running job This PR checks each cached lookup query whether it is complete and removes any failed lookup from the

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

2017-01-13 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5481: - Priority: Trivial (was: Major) Affects Version/s: 1.2.0 > Cannot create Collection o

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

2017-01-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-5465. --- Resolution: Won't Fix Thank you guys for looking into it. I'm closing the issue as won't fix.

[jira] [Created] (FLINK-5482) QueryableStateClient does not recover from a failed lookup due to a non-running job

2017-01-13 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5482: -- Summary: QueryableStateClient does not recover from a failed lookup due to a non-running job Key: FLINK-5482 URL: https://issues.apache.org/jira/browse/FLINK-5482 Project

[jira] [Comment Edited] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

2017-01-13 Thread Evgeny Kincharov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821899#comment-15821899 ] Evgeny Kincharov edited comment on FLINK-3133 at 1/13/17 3:20 PM: --

[jira] [Commented] (FLINK-3133) Introduce collect()/count()/print() methods in DataStream API

2017-01-13 Thread Evgeny Kincharov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821899#comment-15821899 ] Evgeny Kincharov commented on FLINK-3133: - Hi [~mxm], I assign this issue to me ag

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

2017-01-13 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5481: Summary: Cannot create Collection of Row Key: FLINK-5481 URL: https://issues.apache.org/jira/browse/FLINK-5481 Project: Flink Issue Type: Bug Re

[jira] [Comment Edited] (FLINK-5268) Split TableProgramsTestBase into TableProgramsCollectionTestBase and TableProgramsClusterTestBase

2017-01-13 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821889#comment-15821889 ] Jark Wu edited comment on FLINK-5268 at 1/13/17 3:03 PM: - Hi [~fhu

[jira] [Commented] (FLINK-3150) Make YARN container invocation configurable

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

[jira] [Commented] (FLINK-5268) Split TableProgramsTestBase into TableProgramsCollectionTestBase and TableProgramsClusterTestBase

2017-01-13 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821889#comment-15821889 ] Jark Wu commented on FLINK-5268: Hi [~fhueske] , do we have the case that an IT case shoul

[GitHub] flink issue #3056: [FLINK-3150] make YARN container invocation configurable

2017-01-13 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3056 +1 to merge. The cluster test was successful. --- 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 featu

[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&focusedCommentId=15821880#comment-15821880 ] ASF GitHub Bot commented on FLINK-5441: --- Github user wuchong commented on the issue:

[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 or

[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-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&focusedCommentId=15821850#comment-15821850 ] ASF GitHub Bot commented on FLINK-5468: --- Github user StefanRRichter commented on the

[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&focusedCommentId=15821849#comment-15821849 ] ASF GitHub Bot commented on FLINK-5468: --- GitHub user StefanRRichter opened a pull re

[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 https:/

[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&focusedCommentId=15821841#comment-15821841 ] ASF GitHub Bot commented on FLINK-5224: --- GitHub user wuchong opened a pull request:

[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 into

[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&focusedCommentId=15821827#comment-15821827 ] Stephan Ewen commented on FLINK-5465: - +1 for setting it to won't fix for now and prop

[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-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear()

2017-01-13 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821808#comment-15821808 ] Stefan Richter commented on FLINK-5465: --- After talking to [~StephanEwen], we came to

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15821807#comment-15821807 ] Stefan Richter commented on FLINK-5468: --- Migrating from semi async snapshotting will

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

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

[GitHub] flink issue #3083: [FLINK-2662] [optimizer] Fix translation of broadcasted u...

2017-01-13 Thread KurtYoung
Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/3083 Seems there is a long story under this issue. I will try to catch up all the histories and have a look at this pr. --- If your project is set up for it, you can reply to this email and have your r

[jira] [Commented] (FLINK-5438) Typo in JobGraph generator Exception

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

[GitHub] flink issue #3098: [FLINK-5438] Typo in JobGraph generator Exception

2017-01-13 Thread KurtYoung
Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/3098 Hi @mtunique , thanks for your effort. Can't see any reason we shouldn't merge this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as we

[jira] [Closed] (FLINK-5283) InputStream should be closed in RocksDBKeyedStateBackend#restoreOldSavepointKeyedState

2017-01-13 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-5283. - Resolution: Fixed > InputStream should be closed in > RocksDBKeyedStateBackend#restoreOldSavepoin

[jira] [Closed] (FLINK-4956) Introduce convenient methods for testing checkpoint/restore in StreamTaskTestHarness

2017-01-13 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-4956. - Resolution: Implemented > Introduce convenient methods for testing checkpoint/restore in > Stream

[jira] [Commented] (FLINK-3849) Add FilterableTableSource interface and translation rule

2017-01-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821752#comment-15821752 ] Fabian Hueske commented on FLINK-3849: -- The table source must make sure that the pred

[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&focusedCommentId=15821749#comment-15821749 ] ASF GitHub Bot commented on FLINK-5265: --- Github user StefanRRichter commented on a d

[GitHub] flink issue #3086: Improve docker setup

2017-01-13 Thread kaelumania
Github user kaelumania commented on the issue: https://github.com/apache/flink/pull/3086 @mxm thanks :) needs there anything to be done, until this PR can be merged? --- 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

[GitHub] flink pull request #2948: [FLINK-5265] Introduce state handle replication mo...

2017-01-13 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2948#discussion_r95991932 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateCheckpointOutputStream.java --- @@ -66,8 +66,10 @@ OperatorStateHand

[jira] [Commented] (FLINK-5480) User-provided hashes for operators

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

[GitHub] flink pull request #3117: [FLINK-5480] Introduce user-provided hash for JobV...

2017-01-13 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/3117 [FLINK-5480] Introduce user-provided hash for JobVertexes This PR allows users to provided (alternative) hashes for operators in a StreamGraph. This can make migration between Flink versions

[jira] [Commented] (FLINK-5480) User-provided hashes for operators

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

[GitHub] flink issue #3117: [FLINK-5480] Introduce user-provided hash for JobVertexes

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

[jira] [Created] (FLINK-5480) User-provided hashes for operators

2017-01-13 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-5480: - Summary: User-provided hashes for operators Key: FLINK-5480 URL: https://issues.apache.org/jira/browse/FLINK-5480 Project: Flink Issue Type: Improvement

[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&focusedCommentId=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 th

[jira] [Comment Edited] (FLINK-3849) Add FilterableTableSource interface and translation rule

2017-01-13 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821676#comment-15821676 ] Anton Solovev edited comment on FLINK-3849 at 1/13/17 11:41 AM:

[jira] [Commented] (FLINK-3849) Add FilterableTableSource interface and translation rule

2017-01-13 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15821676#comment-15821676 ] Anton Solovev commented on FLINK-3849: -- Hi [~fhueske], so {{setPredicate(predicate: E

[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&focusedCommentId=15821673#comment-15821673 ] ASF GitHub Bot commented on FLINK-5432: --- Github user zentol commented on the issue:

[GitHub] flink issue #3090: [FLINK-5432] Fix nested files enumeration in ContinuousFi...

2017-01-13 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3090 looks good to me, adding it to my next batch, --- 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

[jira] [Commented] (FLINK-4396) GraphiteReporter class not found at startup of jobmanager

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

[GitHub] flink pull request #3116: [docs} [metrics] Update metrics documentation

2017-01-13 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3116 [docs} [metrics] Update metrics documentation This PR makes several changes to the metrics documentation. Changes include * clearly document that reporter jars must be placed in the /lib

[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&focusedCommentId=15821662#comment-15821662 ] ASF GitHub Bot commented on FLINK-4988: --- Github user rmetzger commented on a diff 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&focusedCommentId=15821661#comment-15821661 ] ASF GitHub Bot commented on FLINK-4988: --- Github user rmetzger commented on a diff in

[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-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&focusedCommentId=15821660#comment-15821660 ] ASF GitHub Bot commented on FLINK-5432: --- Github user aljoscha commented on the issue

  1   2   3   >