[jira] [Created] (FLINK-4285) Non-existing example in Flink quickstart setup documentation

2016-08-01 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-4285: -- Summary: Non-existing example in Flink quickstart setup documentation Key: FLINK-4285 URL: https://issues.apache.org/jira/browse/FLINK-4285 Project: Flink

[jira] [Updated] (FLINK-4285) Non-existing example in Flink quickstart setup documentation

2016-08-01 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4285: --- Labels: starter (was: ) > Non-existing example in Flink quickstart setup documentatio

[jira] [Commented] (FLINK-4154) Correction of murmur hash breaks backwards compatibility

2016-08-01 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15401665#comment-15401665 ] Ufuk Celebi commented on FLINK-4154: Backwards-compatability with 1.0 savepoints did n

[jira] [Created] (FLINK-4286) Have Kafka examples that use the Kafka 0.9 connector

2016-08-01 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-4286: -- Summary: Have Kafka examples that use the Kafka 0.9 connector Key: FLINK-4286 URL: https://issues.apache.org/jira/browse/FLINK-4286 Project: Flink

[jira] [Commented] (FLINK-4285) Non-existing example in Flink quickstart setup documentation

2016-08-01 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15401674#comment-15401674 ] Ufuk Celebi commented on FLINK-4285: +1 to change the documentation > Non-existing ex

[jira] [Created] (FLINK-4287) Unable to access secured HBase from a yarn-session.

2016-08-01 Thread Niels Basjes (JIRA)
Niels Basjes created FLINK-4287: --- Summary: Unable to access secured HBase from a yarn-session. Key: FLINK-4287 URL: https://issues.apache.org/jira/browse/FLINK-4287 Project: Flink Issue Type: I

[jira] [Commented] (FLINK-4285) Non-existing example in Flink quickstart setup documentation

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15401704#comment-15401704 ] Stephan Ewen commented on FLINK-4285: - I think we should use the newer example. I wil

[jira] [Assigned] (FLINK-4285) Non-existing example in Flink quickstart setup documentation

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-4285: --- Assignee: Stephan Ewen > Non-existing example in Flink quickstart setup documentation > -

[jira] [Commented] (FLINK-4243) Change "Scope" to "Namespace" for Metrics

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15401707#comment-15401707 ] Stephan Ewen commented on FLINK-4243: - I thought about that when reading some other me

[jira] [Closed] (FLINK-4243) Change "Scope" to "Namespace" for Metrics

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4243. --- Resolution: Won't Fix Minor issue, would be API breaking. > Change "Scope" to "Namespace" for Metrics

[jira] [Created] (FLINK-4288) Make it possible to unregister tables

2016-08-01 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4288: --- Summary: Make it possible to unregister tables Key: FLINK-4288 URL: https://issues.apache.org/jira/browse/FLINK-4288 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4277) TaskManagerConfigurationTest fails

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

[GitHub] flink issue #2308: [FLINK-4279] [py] Set flink dependencies to provided

2016-08-01 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2308 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 feat

[GitHub] flink issue #2310: [FLINK-4277] Fix TaskManagerConfigurationTest#testDefault...

2016-08-01 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2310 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 feat

[jira] [Commented] (FLINK-4279) [py] Set flink dependencies to provided

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

[GitHub] flink pull request #2310: [FLINK-4277] Fix TaskManagerConfigurationTest#test...

2016-08-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2310 --- 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-4279) [py] Set flink dependencies to provided

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

[GitHub] flink pull request #2308: [FLINK-4279] [py] Set flink dependencies to provid...

2016-08-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2308 --- 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-4277) TaskManagerConfigurationTest fails

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

[jira] [Closed] (FLINK-4279) [py] Set flink dependencies to provided

2016-08-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4279. --- Resolution: Fixed Fix Version/s: 1.1.0 Implemented in 6edc7f1e1ebd3f545975317e82e9ea02a

[jira] [Closed] (FLINK-4277) TaskManagerConfigurationTest fails

2016-08-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4277. --- Resolution: Fixed Fix Version/s: 1.1.0 Fixed in 3537579b7a9f111ed236e08bf51fed528773767

[GitHub] flink issue #2281: RMQ Sink: Possibility to customize queue config [FLINK-42...

2016-08-01 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2281 Thanks for opening this patch. Sorry for picking it up a bit late, it may not be in time for 1.1.0, but should be in for 1.1.1. Merging this... --- If your project is set up for it, you

[jira] [Commented] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue

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

[jira] [Created] (FLINK-4289) Source files have executable flag set

2016-08-01 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4289: -- Summary: Source files have executable flag set Key: FLINK-4289 URL: https://issues.apache.org/jira/browse/FLINK-4289 Project: Flink Issue Type: Bug R

[GitHub] flink issue #2303: [FLINK-4248] [core] [table] CsvTableSource does not suppo...

2016-08-01 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2303 @gallenvara I thought the same. But I'm not sure if it is worth it. You could save ~25 lines of code per class maybe and if we want to make the parsing more efficient (do not use the `valueOf` method

[jira] [Commented] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

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

[jira] [Created] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4290: --- Summary: CassandraConnectorTest deadlocks Key: FLINK-4290 URL: https://issues.apache.org/jira/browse/FLINK-4290 Project: Flink Issue Type: Bug Compon

[jira] [Updated] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4290: Attachment: jstack.txt > CassandraConnectorTest deadlocks > > >

[GitHub] flink pull request #2316: [FLINK-4289] Unset -x flag for .java files

2016-08-01 Thread uce
GitHub user uce opened a pull request: https://github.com/apache/flink/pull/2316 [FLINK-4289] Unset -x flag for .java files Some source files had the -x flag set: Before this change: ``` $ find . -perm +111 -type f | grep "\.java" ./flink-contrib/flink-tweet-inp

[jira] [Commented] (FLINK-4289) Source files have executable flag set

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

[GitHub] flink issue #2316: [FLINK-4289] Unset -x flag for .java files

2016-08-01 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2316 +1 I have noticed that committing from Windows often introduces that. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If y

[jira] [Commented] (FLINK-4289) Source files have executable flag set

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

[jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15401754#comment-15401754 ] Stephan Ewen commented on FLINK-4290: - This happens reproducibly on my machine. All bu

[GitHub] flink issue #2309: [FLINK-4161] Add Quickstart exclusion for flink-dist depe...

2016-08-01 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2309 +1 LGTM --- 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-4161) Quickstarts can exclude more flink-dist dependencies

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

[jira] [Created] (FLINK-4291) No log entry for unscheduled reporters

2016-08-01 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4291: --- Summary: No log entry for unscheduled reporters Key: FLINK-4291 URL: https://issues.apache.org/jira/browse/FLINK-4291 Project: Flink Issue Type: Bug

[GitHub] flink issue #2294: [FLINK-4265] [dataset api] Add a NoOpOperator

2016-08-01 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2294 @greghogan I am not sure I completely understand this. If I see it correctly, the no-op operator is in the API, but gets removed during the translation? It looks like a bit of a hacky ap

[jira] [Commented] (FLINK-4265) Add a NoOpOperator

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

[jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15401770#comment-15401770 ] Chesnay Schepler commented on FLINK-4290: - How long did you let it run? > Cassand

[jira] [Commented] (FLINK-4289) Source files have executable flag set

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

[GitHub] flink pull request #2316: [FLINK-4289] Unset -x flag for .java files

2016-08-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2316 --- 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] [Closed] (FLINK-4289) Source files have executable flag set

2016-08-01 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-4289. -- Resolution: Fixed Fix Version/s: 1.2.0 Fixed in 4bfc20a (master). > Source files have executable

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-08-01 Thread nielsbasjes
Github user nielsbasjes commented on the issue: https://github.com/apache/flink/pull/2275 I noticed that the system property java.security.krb5.conf isn't set anywhere in the code. Shouldn't there be a config setting/property that allows the user to set this? --- If your project

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

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

[jira] [Created] (FLINK-4292) HCatalog project incorrectly set up

2016-08-01 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4292: --- Summary: HCatalog project incorrectly set up Key: FLINK-4292 URL: https://issues.apache.org/jira/browse/FLINK-4292 Project: Flink Issue Type: Bug Com

[jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15401792#comment-15401792 ] Stephan Ewen commented on FLINK-4290: - I killed it after a bunch of minutes > Cassand

[jira] [Created] (FLINK-4293) Malformatted Apache Haders

2016-08-01 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4293: --- Summary: Malformatted Apache Haders Key: FLINK-4293 URL: https://issues.apache.org/jira/browse/FLINK-4293 Project: Flink Issue Type: Bug Affects Versions:

[jira] [Updated] (FLINK-4293) Malformatted Apache Haders

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4293: Priority: Minor (was: Major) > Malformatted Apache Haders > -- > >

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

2016-08-01 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15401814#comment-15401814 ] Lorenz Bühmann commented on FLINK-2662: --- I do have the same problem: Exception in t

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-08-01 Thread nielsbasjes
Github user nielsbasjes commented on the issue: https://github.com/apache/flink/pull/2275 Question: Does this also work when starting yarn-session.sh? --- 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 n

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

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

[jira] [Commented] (FLINK-4287) Unable to access secured HBase from a yarn-session.

2016-08-01 Thread Niels Basjes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15401866#comment-15401866 ] Niels Basjes commented on FLINK-4287: - Because of the extensive work being done in FLI

[GitHub] flink pull request #2317: [FLINK-4287] Ensure the yarn-session.sh classpath ...

2016-08-01 Thread nielsbasjes
GitHub user nielsbasjes opened a pull request: https://github.com/apache/flink/pull/2317 [FLINK-4287] Ensure the yarn-session.sh classpath contains all Hadoop related paths You can merge this pull request into a Git repository by running: $ git pull https://github.com/nielsba

[jira] [Commented] (FLINK-4287) Unable to access secured HBase from a yarn-session.

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15401869#comment-15401869 ] ASF GitHub Bot commented on FLINK-4287: --- GitHub user nielsbasjes opened a pull reque

[jira] [Commented] (FLINK-4284) DataSet/CEP link to non-existant "Linking with Flink" section

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

[GitHub] flink issue #2311: [FLINK-4284] [docu] Fix broken links

2016-08-01 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2311 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 feat

[GitHub] flink pull request #2311: [FLINK-4284] [docu] Fix broken links

2016-08-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2311 --- 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-4284) DataSet/CEP link to non-existant "Linking with Flink" section

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

[jira] [Closed] (FLINK-4284) DataSet/CEP link to non-existant "Linking with Flink" section

2016-08-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4284. --- Resolution: Fixed Fix Version/s: 1.1.0 Fixed in aed56aeebadcd39910e7831f24da8a90953d591

[jira] [Created] (FLINK-4294) Allow access of composite type fields

2016-08-01 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4294: --- Summary: Allow access of composite type fields Key: FLINK-4294 URL: https://issues.apache.org/jira/browse/FLINK-4294 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-4294) Allow access of composite type fields

2016-08-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4294: Description: Currently all Flink CompositeTypes are treated as GenericRelDataTypes. It would be bet

[GitHub] flink pull request #2318: [FLINK-4291] Add log entry for scheduled reporters

2016-08-01 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/2318 [FLINK-4291] Add log entry for scheduled reporters simple PR that adds a log message for instantiated unscheduled reporters containing the name and class. You can merge this pull request into a Git

[jira] [Commented] (FLINK-4291) No log entry for unscheduled reporters

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

[jira] [Assigned] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up

2016-08-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-4236: --- Assignee: Chesnay Schepler > Flink Dashboard stops showing list of uploaded jars if m

[GitHub] flink pull request #2319: [FLINK-4294] [table] Allow access of composite typ...

2016-08-01 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2319 [FLINK-4294] [table] Allow access of composite type fields Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If

[jira] [Commented] (FLINK-4294) Allow access of composite type fields

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

[jira] [Updated] (FLINK-4236) Flink Dashboard stops showing list of uploaded jars if main method cannot be looked up

2016-08-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4236: Assignee: (was: Chesnay Schepler) > Flink Dashboard stops showing list of uploaded jars

[jira] [Commented] (FLINK-4154) Correction of murmur hash breaks backwards compatibility

2016-08-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15401989#comment-15401989 ] Till Rohrmann commented on FLINK-4154: -- +1 for introducing the correct murmur hash fu

[jira] [Commented] (FLINK-3414) Add Scala API for CEP's pattern definition

2016-08-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402000#comment-15402000 ] Till Rohrmann commented on FLINK-3414: -- Hi [~ivan.mushketyk], great to hear that you

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402004#comment-15402004 ] Till Rohrmann commented on FLINK-4094: -- I think that having in both cases (preallocat

[jira] [Created] (FLINK-4295) CoGroupSortTranslationTest#testGroupSortTuplesDefaultCoGroup fails to run

2016-08-01 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4295: --- Summary: CoGroupSortTranslationTest#testGroupSortTuplesDefaultCoGroup fails to run Key: FLINK-4295 URL: https://issues.apache.org/jira/browse/FLINK-4295 Project

[jira] [Created] (FLINK-4296) Scheduler accepts more tasks than it has task slots available

2016-08-01 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4296: - Summary: Scheduler accepts more tasks than it has task slots available Key: FLINK-4296 URL: https://issues.apache.org/jira/browse/FLINK-4296 Project: Flink

[GitHub] flink pull request #2320: [FLINK-4297][yarn] decode URL encoded fat jar path

2016-08-01 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2320 [FLINK-4297][yarn] decode URL encoded fat jar path This solves problems with spaces and special characters in the automatically determined fat jar path which is returned URL encoded. You can merge t

[jira] [Commented] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

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

[jira] [Created] (FLINK-4297) Yarn client can't determine fat jar location if path contains spaces

2016-08-01 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4297: - Summary: Yarn client can't determine fat jar location if path contains spaces Key: FLINK-4297 URL: https://issues.apache.org/jira/browse/FLINK-4297 Project:

[jira] [Commented] (FLINK-4287) Unable to access secured HBase from a yarn-session.

2016-08-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402067#comment-15402067 ] ASF GitHub Bot commented on FLINK-4287: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #2317: [FLINK-4287] Ensure the yarn-session.sh classpath ...

2016-08-01 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2317#discussion_r72981367 --- Diff: flink-dist/src/main/flink-bin/yarn-bin/yarn-session.sh --- @@ -52,5 +52,5 @@ log_setting="-Dlog.file="$log" -Dlog4j.configuration=file:"$FLINK_CONF_D

[jira] [Created] (FLINK-4298) Clean up Storm Compatibility Dependencies

2016-08-01 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4298: --- Summary: Clean up Storm Compatibility Dependencies Key: FLINK-4298 URL: https://issues.apache.org/jira/browse/FLINK-4298 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-4296) Scheduler accepts more tasks than it has task slots available

2016-08-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4296: -- Assignee: Till Rohrmann > Scheduler accepts more tasks than it has task slots available

[jira] [Updated] (FLINK-4296) Scheduler accepts more tasks than it has task slots available

2016-08-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4296: -- Description: Flink's scheduler doesn't support queued scheduling but expects to find all

[GitHub] flink pull request #2317: [FLINK-4287] Ensure the yarn-session.sh classpath ...

2016-08-01 Thread nielsbasjes
Github user nielsbasjes commented on a diff in the pull request: https://github.com/apache/flink/pull/2317#discussion_r72990290 --- Diff: flink-dist/src/main/flink-bin/yarn-bin/yarn-session.sh --- @@ -52,5 +52,5 @@ log_setting="-Dlog.file="$log" -Dlog4j.configuration=file:"$FLINK_C

[jira] [Commented] (FLINK-4287) Unable to access secured HBase from a yarn-session.

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

[jira] [Created] (FLINK-4299) Show loss of job manager in Client

2016-08-01 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4299: -- Summary: Show loss of job manager in Client Key: FLINK-4299 URL: https://issues.apache.org/jira/browse/FLINK-4299 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402172#comment-15402172 ] Stephan Ewen commented on FLINK-4290: - Running it with maven (command line), I get {{j

[jira] [Commented] (FLINK-4265) Add a NoOpOperator

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

[GitHub] flink issue #2294: [FLINK-4265] [dataset api] Add a NoOpOperator

2016-08-01 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2294 This would replace `Delegate` and is much simpler. I placed it in the Java API package but it would not be visible to users through the `DataSet` API. The ultimate goal is to implicitly reu

[jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402179#comment-15402179 ] Stephan Ewen commented on FLINK-4290: - My environment is Ubuntu 14.4, Maven 3.0.5, Jav

[jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402201#comment-15402201 ] Stephan Ewen commented on FLINK-4290: - Sorry, correcting myself. The command line was

[jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402204#comment-15402204 ] Stephan Ewen commented on FLINK-4290: - Seems Cassandra does not work with Java 7, actu

[jira] [Created] (FLINK-4300) Improve error message for different Scala versions of JM and Client

2016-08-01 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4300: --- Summary: Improve error message for different Scala versions of JM and Client Key: FLINK-4300 URL: https://issues.apache.org/jira/browse/FLINK-4300 Project: Flink

[jira] [Commented] (FLINK-4094) Off heap memory deallocation might not properly work

2016-08-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402231#comment-15402231 ] Maximilian Michels commented on FLINK-4094: --- Thanks for elaborating on your thou

[jira] [Commented] (FLINK-4290) CassandraConnectorTest deadlocks

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402243#comment-15402243 ] Stephan Ewen commented on FLINK-4290: - Updating the test assumption to skip the Cassan

[jira] [Created] (FLINK-4301) Parameterize Flink version in Quickstart bash script

2016-08-01 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4301: --- Summary: Parameterize Flink version in Quickstart bash script Key: FLINK-4301 URL: https://issues.apache.org/jira/browse/FLINK-4301 Project: Flink Issue Type:

[jira] [Updated] (FLINK-4301) Parameterize Flink version in Quickstart bash script

2016-08-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4301: Labels: starter (was: ) > Parameterize Flink version in Quickstart bash script > --

[jira] [Updated] (FLINK-4301) Parameterize Flink version in Quickstart bash script

2016-08-01 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-4301: Description: The Flink version is hard coded in the quickstart script (for Scala and Java). Thus, ev

[jira] [Created] (FLINK-4302) Add JavaDocs to MetricConfig

2016-08-01 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-4302: -- Summary: Add JavaDocs to MetricConfig Key: FLINK-4302 URL: https://issues.apache.org/jira/browse/FLINK-4302 Project: Flink Issue Type: Improvement Comp

[jira] [Commented] (FLINK-2237) Add hash-based Aggregation

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402281#comment-15402281 ] Stephan Ewen commented on FLINK-2237: - It it is just about the fact the it is currentl

[jira] [Commented] (FLINK-4154) Correction of murmur hash breaks backwards compatibility

2016-08-01 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402300#comment-15402300 ] Ufuk Celebi commented on FLINK-4154: Reverted in 0274f9c (release-1.1) and 0f92a6b (ma

[jira] [Commented] (FLINK-4282) Add Offset Parameter to WindowAssigners

2016-08-01 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402301#comment-15402301 ] Stephan Ewen commented on FLINK-4282: - Seems the offset can serve two purposes: 1.

[jira] [Commented] (FLINK-4296) Scheduler accepts more tasks than it has task slots available

2016-08-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15402303#comment-15402303 ] Till Rohrmann commented on FLINK-4296: -- I found the issue. The problem is that a sche

  1   2   >