[GitHub] flink issue #2761: [FLINK-3551] [examples] Sync Scala Streaming Examples

2017-01-20 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2761 Hi @ch33hau, I'm sorry! I haven't had a look at it yet. I'll do that 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

[jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples

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

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

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

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

2017-01-20 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3149 Hi @ramkrish86, @tonycox, and @wuchong, sorry for joining the discussion a bit late. I haven't looked at the code yet, but I think the discussion is going into the right direction.

[jira] [Commented] (FLINK-5593) Service: Modify current dcos-flink implementation to use runit service

2017-01-20 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15832621#comment-15832621 ] Vijay Srinivasaraghavan commented on FLINK-5593: The draft version of the

[jira] [Commented] (FLINK-5564) User Defined Aggregates

2017-01-20 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15832615#comment-15832615 ] Fabian Hueske commented on FLINK-5564: -- Thanks for the great proposal! User defined

[jira] [Updated] (FLINK-5598) Return jar name when jar is uploaded

2017-01-20 Thread Sendoh (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sendoh updated FLINK-5598: -- Description: As as a Jenkins user who wants to uplaod jar through http call, I want jar file name is returned

[jira] [Updated] (FLINK-5598) Return jar name when jar is uploaded

2017-01-20 Thread Sendoh (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sendoh updated FLINK-5598: -- Description: As as a Jenkins user who wants to uplaod jar through http call, I want jar file name is returned

[jira] [Created] (FLINK-5598) Return jar name when jar is uploaded

2017-01-20 Thread Sendoh (JIRA)
Sendoh created FLINK-5598: - Summary: Return jar name when jar is uploaded Key: FLINK-5598 URL: https://issues.apache.org/jira/browse/FLINK-5598 Project: Flink Issue Type: Improvement Compon

[jira] [Commented] (FLINK-5582) Add a general distributive aggregate function

2017-01-20 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15832607#comment-15832607 ] Fabian Hueske commented on FLINK-5582: -- Thanks for the proposal! This will be a great

[GitHub] flink issue #2396: [FLINK-4395][cep] Eager processing of late arrivals in CE...

2017-01-20 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2396 Hi @chermenin, To avoid rebasing this PR multiple times I'll wait until Till or another core reviewer will be available to review and merge this pull request. Feel free to review i

[jira] [Commented] (FLINK-4395) Eager processing of late arrivals in CEP operator

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

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

2017-01-20 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-5488: -- Description: Here is one example: {code} if(jobManagerMemoryMb > maxRes.getMemory() ) { failSessionDur

[GitHub] flink pull request #3188: [FLINK-5562] [gelly] Driver fixes

2017-01-20 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3188 [FLINK-5562] [gelly] Driver fixes [FLINK-5562] [gelly] Driver fixes Improve parametrization and output formatting. [hotfix] [build] Include flink-gelly-examples in opt/

[jira] [Commented] (FLINK-5562) Driver fixes

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

[jira] [Commented] (FLINK-5562) Driver fixes

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

[GitHub] flink pull request #3187: [FLINK-5562] [gelly] Driver fixes for release-1.2

2017-01-20 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3187 [FLINK-5562] [gelly] Driver fixes for release-1.2 [FLINK-5562] [gelly] Driver fixes Improve parametrization and output formatting. [hotfix] [build] Include flink-gelly-exampl

[GitHub] flink pull request #3168: [FLINK-5562] [gelly] Driver fixes

2017-01-20 Thread greghogan
Github user greghogan closed the pull request at: https://github.com/apache/flink/pull/3168 --- 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-5562) Driver fixes

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

[jira] [Created] (FLINK-5597) Improve the LocalClusteringCoefficient documentation

2017-01-20 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-5597: Summary: Improve the LocalClusteringCoefficient documentation Key: FLINK-5597 URL: https://issues.apache.org/jira/browse/FLINK-5597 Project: Flink Issue Type

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

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

[GitHub] flink pull request #3185: [FLINK-5375] [doc] Fix Watermark Semantics

2017-01-20 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/3185 [FLINK-5375] [doc] Fix Watermark Semantics Fix watermark semantics in documenation to be correctly aligned with implementation: a Watermark _t_ declares that event time has reached time _t_ in tha

[jira] [Closed] (FLINK-5585) NullPointer Exception in JobManager.updateAccumulators

2017-01-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5585. --- > NullPointer Exception in JobManager.updateAccumulators > ---

[jira] [Resolved] (FLINK-5585) NullPointer Exception in JobManager.updateAccumulators

2017-01-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5585. - Resolution: Fixed Fixed in - 1.1.5 via f6f1c244cf149d451a32fb3231a6bf1168bc31d1 - 1.2.0 via e

[jira] [Commented] (FLINK-5585) NullPointer Exception in JobManager.updateAccumulators

2017-01-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15832201#comment-15832201 ] Stephan Ewen commented on FLINK-5585: - Added an additional check to the JobManager tha

[jira] [Updated] (FLINK-5596) Add padding to nav menu on mobile site

2017-01-20 Thread Mike Winters (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Winters updated FLINK-5596: Attachment: flink-mobile-nav.png > Add padding to nav menu on mobile site >

[jira] [Created] (FLINK-5596) Add padding to nav menu on mobile site

2017-01-20 Thread Mike Winters (JIRA)
Mike Winters created FLINK-5596: --- Summary: Add padding to nav menu on mobile site Key: FLINK-5596 URL: https://issues.apache.org/jira/browse/FLINK-5596 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-5459) Add documentation how to debug classloading issues

2017-01-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5459. - Resolution: Fixed Assignee: Stephan Ewen Fixed in - 1.2.0 via 289932cdbea695a529bbd618fe17

[jira] [Closed] (FLINK-5459) Add documentation how to debug classloading issues

2017-01-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5459. --- > Add documentation how to debug classloading issues > --

[jira] [Assigned] (FLINK-5454) Add Documentation about how to tune Checkpointing for large state

2017-01-20 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-5454: --- Assignee: Stephan Ewen > Add Documentation about how to tune Checkpointing for large state >

[jira] [Created] (FLINK-5595) Add links to sub-sections in the left-hand navigation bar

2017-01-20 Thread Mike Winters (JIRA)
Mike Winters created FLINK-5595: --- Summary: Add links to sub-sections in the left-hand navigation bar Key: FLINK-5595 URL: https://issues.apache.org/jira/browse/FLINK-5595 Project: Flink Issue T

[jira] [Updated] (FLINK-5594) Use higher-resolution graphic on Flink project site homepage

2017-01-20 Thread Mike Winters (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Winters updated FLINK-5594: Component/s: Project Website > Use higher-resolution graphic on Flink project site homepage > --

[jira] [Updated] (FLINK-5594) Use higher-resolution graphic on Flink project site homepage

2017-01-20 Thread Mike Winters (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mike Winters updated FLINK-5594: Attachment: flink-home-graphic.png > Use higher-resolution graphic on Flink project site homepage >

[jira] [Created] (FLINK-5594) Use higher-resolution graphic on Flink project site homepage

2017-01-20 Thread Mike Winters (JIRA)
Mike Winters created FLINK-5594: --- Summary: Use higher-resolution graphic on Flink project site homepage Key: FLINK-5594 URL: https://issues.apache.org/jira/browse/FLINK-5594 Project: Flink Iss

[jira] [Updated] (FLINK-5593) Service: Modify current dcos-flink implementation to use runit service

2017-01-20 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan updated FLINK-5593: --- Summary: Service: Modify current dcos-flink implementation to use runit servic

[jira] [Created] (FLINK-5593) Modify current dcos-flink implementation to use runit service

2017-01-20 Thread Vijay Srinivasaraghavan (JIRA)
Vijay Srinivasaraghavan created FLINK-5593: -- Summary: Modify current dcos-flink implementation to use runit service Key: FLINK-5593 URL: https://issues.apache.org/jira/browse/FLINK-5593 Proje

[jira] [Assigned] (FLINK-5537) Config option: SSL

2017-01-20 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan reassigned FLINK-5537: -- Assignee: Vijay Srinivasaraghavan > Config option: SSL > --

[jira] [Assigned] (FLINK-5538) Config option: Kerberos

2017-01-20 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan reassigned FLINK-5538: -- Assignee: Vijay Srinivasaraghavan > Config option: Kerberos > -

[jira] [Assigned] (FLINK-5535) Config option: HDFS

2017-01-20 Thread Vijay Srinivasaraghavan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vijay Srinivasaraghavan reassigned FLINK-5535: -- Assignee: Vijay Srinivasaraghavan > Config option: HDFS > -

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

2017-01-20 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2662. Resolution: Fixed Fixed for 1.1.5 with 6566b63aa50af946ecf0d028c4e284fc6dc2a55b Fixed for 1.2.0 with

[GitHub] flink pull request #3184: [5456] [docs] state intro and new interfaces

2017-01-20 Thread alpinegizmo
GitHub user alpinegizmo opened a pull request: https://github.com/apache/flink/pull/3184 [5456] [docs] state intro and new interfaces This is an update to the state intro for Flink 1.2, along with some introduction to the new state interfaces. You can merge this pull request into

[jira] [Commented] (FLINK-5559) queryable state: KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException without own failure message if deserialisation fails

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

[jira] [Commented] (FLINK-5559) queryable state: KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException without own failure message if deserialisation fails

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

[GitHub] flink issue #3172: [FLINK-5559] let KvStateRequestSerializer#deserializeKeyA...

2017-01-20 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3172 I agree that it is more appropriate to throw the `IOException`. --- 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-5559) queryable state: KvStateRequestSerializer#deserializeKeyAndNamespace() throws an IOException without own failure message if deserialisation fails

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

[GitHub] flink pull request #3172: [FLINK-5559] let KvStateRequestSerializer#deserial...

2017-01-20 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/3172#discussion_r97100430 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/query/netty/message/KvStateRequestSerializer.java --- @@ -377,22 +376,24 @@ public static Throwabl

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

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

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

2017-01-20 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15832011#comment-15832011 ] Tzu-Li (Gordon) Tai commented on FLINK-5483: This is fixed by hotfix 6a2970a3b

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

2017-01-20 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-5483. Resolution: Fixed > Link to "linking modules not contained in binary distribution" b

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

2017-01-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3083 --- 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 #3172: [FLINK-5559] let KvStateRequestSerializer#deserial...

2017-01-20 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/3172#discussion_r97099962 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/query/netty/message/KvStateRequestSerializer.java --- @@ -377,22 +376,24 @@ public static Throwabl

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

2017-01-20 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-5355. Resolution: Fixed Resolved for master with b380bd313e036f2bc66941367f014c12bf8baa6d.

[jira] [Closed] (FLINK-5528) tests: reduce the retry delay in QueryableStateITCase

2017-01-20 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5528. -- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in 03a1f25 (release-1.2), 8

[jira] [Resolved] (FLINK-5580) Kerberos keytabs not working for YARN deployment mode

2017-01-20 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-5580. Resolution: Fixed > Kerberos keytabs not working for YARN deployment mode >

[jira] [Commented] (FLINK-5580) Kerberos keytabs not working for YARN deployment mode

2017-01-20 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15831995#comment-15831995 ] Tzu-Li (Gordon) Tai commented on FLINK-5580: Resolved for master with 640a149e

[jira] [Resolved] (FLINK-5368) Let Kafka consumer show something when it fails to read one topic out of topic list

2017-01-20 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-5368. Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 > Let Kafka c

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

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

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

2017-01-20 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3083 Thanks @StephanEwen. Will merge the fix. --- 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 ena

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

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

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

2017-01-20 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3083 Had a quick look as well. Seems to fix the bug correctly, test is included. +1 from my side --- If your project is set up for it, you can reply to this email and have your reply appear o

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

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

[jira] [Commented] (FLINK-5368) Let Kafka consumer show something when it fails to read one topic out of topic list

2017-01-20 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15831994#comment-15831994 ] Tzu-Li (Gordon) Tai commented on FLINK-5368: Resolved for master with f266e825

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

2017-01-20 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3117 Thanks for addressing the comments. I had a quick offline chat with Stephan regarding the naming of `setAdditionalNodeHash`. He also agrees that the name moves internal implementation details to

[jira] [Commented] (FLINK-5525) Streaming Version of a Linear Regression model

2017-01-20 Thread Tao Meng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15831987#comment-15831987 ] Tao Meng commented on FLINK-5525: - Maybe we can open more issues about streaming version a

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

2017-01-20 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5386. Resolution: Implemented Fix Version/s: 1.3.0 1.2.0 Done for 1.2.0 with be0

[jira] [Commented] (FLINK-5368) Let Kafka consumer show something when it fails to read one topic out of topic list

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

[GitHub] flink pull request #3078: [FLINK-5355] Handle AmazonKinesisException gracefu...

2017-01-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3078 --- 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-5355) Handle AmazonKinesisException gracefully in Kinesis Streaming Connector

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

[GitHub] flink pull request #3036: [FLINK-5368] Log msg if kafka topic doesn't have a...

2017-01-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3036 --- 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-5580) Kerberos keytabs not working for YARN deployment mode

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

[GitHub] flink pull request #3177: [FLINK-5580] [security] Fix path setting of shippe...

2017-01-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3177 --- 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-5214) Clean up checkpoint files when failing checkpoint operation on TM

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

[GitHub] flink pull request #3183: [backport] [FLINK-5214] [FLINK-5229] Backport Stre...

2017-01-20 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/3183 [backport] [FLINK-5214] [FLINK-5229] Backport StreamTask and StreamOperator checkpoint cleanup Backport of #3179 and #3178 onto the `release-1.2` branch. Adds exception handling to the

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

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

[jira] [Commented] (FLINK-5473) setMaxParallelism() higher than 1 is possible on non-parallel operators

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

[jira] [Commented] (FLINK-5473) setMaxParallelism() higher than 1 is possible on non-parallel operators

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

[GitHub] flink pull request #3182: [FLINK-5473] Limit MaxParallelism to 1 for non-par...

2017-01-20 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/3182 [FLINK-5473] Limit MaxParallelism to 1 for non-parallel operators and improve choice of max parallelism without explicit configuration This PR limits the maximum parallelism for non-parallel

[GitHub] flink issue #3182: [FLINK-5473] Limit MaxParallelism to 1 for non-parallel o...

2017-01-20 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3182 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

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

2017-01-20 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3078 Thank you @skidder for addressing the comments! Merging .. --- 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

[GitHub] flink issue #3139: [FLINK-5528][query][tests] reduce the retry delay in Quer...

2017-01-20 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/3139 Good idea! Will merge this with one minor change (see inline comment). --- 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

[jira] [Commented] (FLINK-5580) Kerberos keytabs not working for YARN deployment mode

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

[jira] [Commented] (FLINK-5528) tests: reduce the retry delay in QueryableStateITCase

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

[GitHub] flink pull request #3139: [FLINK-5528][query][tests] reduce the retry delay ...

2017-01-20 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/3139#discussion_r97091734 --- Diff: flink-tests/src/test/java/org/apache/flink/test/query/QueryableStateITCase.java --- @@ -1073,6 +1056,20 @@ public Integer getKey(Tuple2 value) throws

[jira] [Commented] (FLINK-5528) tests: reduce the retry delay in QueryableStateITCase

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

[GitHub] flink issue #3177: [FLINK-5580] [security] Fix path setting of shipped Kerbe...

2017-01-20 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3177 Thanks @EronWright for investigating this together and @rmetzger for the review. Merging .. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHu

[GitHub] flink pull request #3181: [FLINK-5581] [doc] Improve user accessibility for ...

2017-01-20 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/3181 [FLINK-5581] [doc] Improve user accessibility for Kerberos-related documentation The goal of this PR is to organize Kerberos related information as so: 1. `flink-conf.yaml` configuration f

[jira] [Commented] (FLINK-5581) Improve Kerberos security related documentation

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

[jira] [Assigned] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-20 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5592: Assignee: (was: Anton Solovev) > Wrong number of RowSerializers with nested Rows in Col

[jira] [Resolved] (FLINK-5549) TypeExtractor fails with RuntimeException, but should use GenericTypeInfo

2017-01-20 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-5549. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 1.3.0: 2703d339abafdd9f39bc35faa1eed718501f

[GitHub] flink pull request #3154: [FLINK-5549] [core] TypeExtractor fails with Runti...

2017-01-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3154 --- 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-5468) Restoring from a semi async rocksdb statebackend (1.1) to 1.2 fails with ClassNotFoundException

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

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

2017-01-20 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5468. -- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in d431373 (release-1.2), 9

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

2017-01-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3119 --- 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] [Updated] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-20 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5592: - Description: {code} @Test def testNestedRowTypes(): Unit = { val env = ExecutionEnvironmen

[jira] [Commented] (FLINK-5532) Make the marker WindowAssigners for the fast aligned windows non-extendable.

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

[jira] [Created] (FLINK-5592) Wrong number of RowSerializers with nested Rows in Collection mode

2017-01-20 Thread Anton Solovev (JIRA)
Anton Solovev created FLINK-5592: Summary: Wrong number of RowSerializers with nested Rows in Collection mode Key: FLINK-5592 URL: https://issues.apache.org/jira/browse/FLINK-5592 Project: Flink

[GitHub] flink pull request #3180: [FLINK-5532] Make window assigners for aligned win...

2017-01-20 Thread kl0u
GitHub user kl0u opened a pull request: https://github.com/apache/flink/pull/3180 [FLINK-5532] Make window assigners for aligned window operators non-extendable Makes the TumblingAlignedProcessingTimeWindows and the SlidingAlignedProcessingTimeWindows final so that users cannot

[GitHub] flink issue #3154: [FLINK-5549] [core] TypeExtractor fails with RuntimeExcep...

2017-01-20 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3154 Merging... --- 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-5561) DataInputDeserializer#available returns one too few

2017-01-20 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5561. -- Resolution: Fixed Fix Version/s: 1.3.0 1.2.0 Fixed in 108865d (release-1.2), 6

[jira] [Commented] (FLINK-5584) Support Sliding-count row-window on streaming sql

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

  1   2   3   >