[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=15401674#comment-15401674 ] Ufuk Celebi commented on FLINK-4285: +1 to change the documentation > Non-existing example in Flink

[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-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=15401665#comment-15401665 ] Ufuk Celebi commented on FLINK-4154: Backwards-compatability with 1.0 savepoints did not work out

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

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

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

[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

[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-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=15402004#comment-15402004 ] Till Rohrmann commented on FLINK-4094: -- I think that having in both cases (preallocate and no

[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

[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

[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=15402040#comment-15402040 ] ASF GitHub Bot commented on FLINK-4297: --- GitHub user mxm opened a pull request:

[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=15401869#comment-15401869 ] ASF GitHub Bot commented on FLINK-4287: --- GitHub user nielsbasjes opened a pull request:

[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] [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=15402000#comment-15402000 ] Till Rohrmann commented on FLINK-3414: -- Hi [~ivan.mushketyk], great to hear that you want to work on

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

[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

[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

[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

[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=15401765#comment-15401765 ] ASF GitHub Bot commented on FLINK-4265: --- Github user StephanEwen commented on the issue:

[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

[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=15401783#comment-15401783 ] ASF GitHub Bot commented on FLINK-4289: --- Github user asfgit closed the pull request at:

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

[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

[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=15401866#comment-15401866 ] Niels Basjes commented on FLINK-4287: - Because of the extensive work being done in FLINK-3929 I'm

[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=15401893#comment-15401893 ] ASF GitHub Bot commented on FLINK-4284: --- Github user asfgit closed the pull request at:

[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

[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

[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=15401920#comment-15401920 ] ASF GitHub Bot commented on FLINK-4291: --- GitHub user zentol opened a pull request:

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

[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

[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=15401863#comment-15401863 ] ASF GitHub Bot commented on FLINK-3929: --- Github user nielsbasjes commented on the issue:

[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

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

[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=15401989#comment-15401989 ] Till Rohrmann commented on FLINK-4154: -- +1 for introducing the correct murmur hash function. >

[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

[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

[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=15401747#comment-15401747 ] ASF GitHub Bot commented on FLINK-4248: --- Github user twalthr commented on the issue:

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

[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

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

[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

[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

[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

[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=15401731#comment-15401731 ] ASF GitHub Bot commented on FLINK-4251: --- Github user StephanEwen commented on the issue:

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

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

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

[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

[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=15401787#comment-15401787 ] ASF GitHub Bot commented on FLINK-3929: --- Github user nielsbasjes commented on the issue:

[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

[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=15401704#comment-15401704 ] Stephan Ewen commented on FLINK-4285: - I think we should use the newer example. I will try to update

[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-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=15401725#comment-15401725 ] ASF GitHub Bot commented on FLINK-4277: --- Github user asfgit closed the pull request at:

[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

[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=15401724#comment-15401724 ] ASF GitHub Bot commented on FLINK-4279: --- Github user asfgit closed the pull request at:

[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

[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=15401754#comment-15401754 ] Stephan Ewen commented on FLINK-4290: - This happens reproducibly on my machine. All build deadlock in

[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=15401814#comment-15401814 ] Lorenz Bühmann commented on FLINK-2662: --- I do have the same problem: Exception in thread "main"

[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=15401707#comment-15401707 ] Stephan Ewen commented on FLINK-4243: - I thought about that when reading some other metric docs. This

[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-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=15401751#comment-15401751 ] ASF GitHub Bot commented on FLINK-4289: --- Github user StephanEwen commented on the issue:

[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=15401756#comment-15401756 ] ASF GitHub Bot commented on FLINK-4161: --- Github user mxm commented on the issue:

[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

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

[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=15401770#comment-15401770 ] Chesnay Schepler commented on FLINK-4290: - How long did you let it run? > CassandraConnectorTest

[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

[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=15401792#comment-15401792 ] Stephan Ewen commented on FLINK-4290: - I killed it after a bunch of minutes > CassandraConnectorTest

[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

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

[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=15402067#comment-15402067 ] ASF GitHub Bot commented on FLINK-4287: --- Github user zentol commented on a diff in the pull request:

[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=15402179#comment-15402179 ] Stephan Ewen commented on FLINK-4290: - My environment is Ubuntu 14.4, Maven 3.0.5, Java 8 >

[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=15402172#comment-15402172 ] Stephan Ewen commented on FLINK-4290: - Running it with maven (command line), I get

[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=15402174#comment-15402174 ] ASF GitHub Bot commented on FLINK-4265: --- Github user greghogan commented on the issue:

[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

[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

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

[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=15402149#comment-15402149 ] ASF GitHub Bot commented on FLINK-4287: --- Github user nielsbasjes commented on a diff in the pull

[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

[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] [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=15402201#comment-15402201 ] Stephan Ewen commented on FLINK-4290: - Sorry, correcting myself. The command line was Java 7, I

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

[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] [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=15402204#comment-15402204 ] Stephan Ewen commented on FLINK-4290: - Seems Cassandra does not work with Java 7, actually. We should

[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=15402231#comment-15402231 ] Maximilian Michels commented on FLINK-4094: --- Thanks for elaborating on your thoughts

[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=15402243#comment-15402243 ] Stephan Ewen commented on FLINK-4290: - Updating the test assumption to skip the Cassandra tests on all

[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=15402281#comment-15402281 ] Stephan Ewen commented on FLINK-2237: - It it is just about the fact the it is currently called

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

[GitHub] flink pull request #2321: [FLINK-4296] Fixes failure reporting of consumer t...

2016-08-01 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2321 [FLINK-4296] Fixes failure reporting of consumer task scheduling when producer has already finished This PR changes the failure behaviour such that the consumer task is failed instead of the

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

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

[jira] [Commented] (FLINK-4283) ExecutionGraphRestartTest fails

2016-08-01 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15402332#comment-15402332 ] Till Rohrmann commented on FLINK-4283: -- I tried to reproduce this issue locally but I was not

  1   2   >