[jira] [Commented] (FLINK-3675) YARN ship folder incosistent behavior

[ https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15351055#comment-15351055 ] Stefano Baghino commented on FLINK-3675: Of course, thanks for clarifying this to me. :) > YARN

[jira] [Commented] (FLINK-3675) YARN ship folder incosistent behavior

[ https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15350992#comment-15350992 ] Stefano Baghino commented on FLINK-3675: I must have misread something, I thought adding shipping

[jira] [Comment Edited] (FLINK-3675) YARN ship folder incosistent behavior

[ https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15350970#comment-15350970 ] Stefano Baghino edited comment on FLINK-3675 at 6/27/16 1:17 PM: - The

[jira] [Commented] (FLINK-3675) YARN ship folder incosistent behavior

[ https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15350970#comment-15350970 ] Stefano Baghino commented on FLINK-3675: The `lib` folder includes important JARs, like the Flink

[jira] [Updated] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0

[ https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefano Baghino updated FLINK-3239: --- Assignee: Vijay Srinivasaraghavan (was: Stefano Baghino) > Support for Kerberos enabled

[jira] [Commented] (FLINK-3699) Allow per-job Kerberos authentication

[ https://issues.apache.org/jira/browse/FLINK-3699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15297875#comment-15297875 ] Stefano Baghino commented on FLINK-3699: Hi Eron; I concur with your opinion. Thanks for taking

[jira] [Updated] (FLINK-3699) Allow per-job Kerberos authentication

[ https://issues.apache.org/jira/browse/FLINK-3699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefano Baghino updated FLINK-3699: --- Assignee: (was: Stefano Baghino) > Allow per-job Kerberos authentication >

[jira] [Commented] (FLINK-3852) Use a StreamExecutionEnvironment in the quickstart job skeleton

[ https://issues.apache.org/jira/browse/FLINK-3852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263763#comment-15263763 ] Stefano Baghino commented on FLINK-3852: I agree, but would it make sense to have a quickstart for

[jira] [Commented] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0

[ https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15263664#comment-15263664 ] Stefano Baghino commented on FLINK-3239: Beware that in my prototype the {{krb.conf.path}} does

[jira] [Commented] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0

[ https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262368#comment-15262368 ] Stefano Baghino commented on FLINK-3239: Thanks for reminding me [~vijikarthi], I've attached the

[jira] [Updated] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0

[ https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefano Baghino updated FLINK-3239: --- Attachment: flink3239-prototype.patch This is the first rough prototype to make Kafka work on

[jira] [Commented] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0

[ https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15262292#comment-15262292 ] Stefano Baghino commented on FLINK-3239: I've been able to come to a working prototype. The big

[jira] [Commented] (FLINK-3788) Local variable values are not distributed to job runners

[ https://issues.apache.org/jira/browse/FLINK-3788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15247924#comment-15247924 ] Stefano Baghino commented on FLINK-3788: Yes, I experimented this very problem when trying Flink

[jira] [Issue Comment Deleted] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefano Baghino updated FLINK-3774: --- Comment: was deleted (was: I've tested it on the 1.0 and the issue is there as well.) >

[jira] [Comment Edited] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245310#comment-15245310 ] Stefano Baghino edited comment on FLINK-3774 at 4/18/16 8:36 AM: - I've

[jira] [Commented] (FLINK-3774) Flink configuration is not correctly forwarded to PlanExecutor in ScalaShellRemoteEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245310#comment-15245310 ] Stefano Baghino commented on FLINK-3774: I've tested it on the 1.0 as well and the issue is there

[jira] [Commented] (FLINK-3729) Several SQL tests fail on Windows OS

[ https://issues.apache.org/jira/browse/FLINK-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15235391#comment-15235391 ] Stefano Baghino commented on FLINK-3729: Perhaps the {{Table.explain(boolean)}} method could use

[jira] [Assigned] (FLINK-3699) Allow per-job Kerberos authentication

[ https://issues.apache.org/jira/browse/FLINK-3699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefano Baghino reassigned FLINK-3699: -- Assignee: Stefano Baghino > Allow per-job Kerberos authentication >

[jira] [Created] (FLINK-3699) Allow per-job Kerberos authentication

Stefano Baghino created FLINK-3699: -- Summary: Allow per-job Kerberos authentication Key: FLINK-3699 URL: https://issues.apache.org/jira/browse/FLINK-3699 Project: Flink Issue Type:

[jira] [Created] (FLINK-3678) Make Flink logs directory configurable

Stefano Baghino created FLINK-3678: -- Summary: Make Flink logs directory configurable Key: FLINK-3678 URL: https://issues.apache.org/jira/browse/FLINK-3678 Project: Flink Issue Type:

[jira] [Created] (FLINK-3675) YARN ship folder incosistent behavior

Stefano Baghino created FLINK-3675: -- Summary: YARN ship folder incosistent behavior Key: FLINK-3675 URL: https://issues.apache.org/jira/browse/FLINK-3675 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-3668) Potential null deference in HadoopInputFormatBase#createInputSplits()

[ https://issues.apache.org/jira/browse/FLINK-3668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15212095#comment-15212095 ] Stefano Baghino edited comment on FLINK-3668 at 3/25/16 5:09 PM: - Maybe I

[jira] [Commented] (FLINK-3668) Potential null deference in HadoopInputFormatBase#createInputSplits()

[ https://issues.apache.org/jira/browse/FLINK-3668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15212095#comment-15212095 ] Stefano Baghino commented on FLINK-3668: Maybe I don't have a clear picture, but judging from the

[jira] [Created] (FLINK-3653) recovery.zookeeper.storageDir is not documented on the configuration page

Stefano Baghino created FLINK-3653: -- Summary: recovery.zookeeper.storageDir is not documented on the configuration page Key: FLINK-3653 URL: https://issues.apache.org/jira/browse/FLINK-3653 Project:

[jira] [Assigned] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0

[ https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefano Baghino reassigned FLINK-3239: -- Assignee: Stefano Baghino > Support for Kerberos enabled Kafka 0.9.0.0 >

[jira] [Commented] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0

[ https://issues.apache.org/jira/browse/FLINK-3239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15199162#comment-15199162 ] Stefano Baghino commented on FLINK-3239: If no one is working on this I would assign this to

[jira] [Commented] (FLINK-3518) Stale docs for quickstart setup

[ https://issues.apache.org/jira/browse/FLINK-3518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168681#comment-15168681 ] Stefano Baghino commented on FLINK-3518: Hi [~rmetzger], thanks for pointing it out, I didn't

[jira] [Created] (FLINK-3518) Stale docs for quickstart setup

Stefano Baghino created FLINK-3518: -- Summary: Stale docs for quickstart setup Key: FLINK-3518 URL: https://issues.apache.org/jira/browse/FLINK-3518 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-3438) ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings

[ https://issues.apache.org/jira/browse/FLINK-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15158844#comment-15158844 ] Stefano Baghino commented on FLINK-3438: I'm starting to think it would be better to make a search

[jira] [Updated] (FLINK-3438) ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings

[ https://issues.apache.org/jira/browse/FLINK-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefano Baghino updated FLINK-3438: --- Description: ExternalProcessRunner tries to detect a ClassNotFoundException in the run

[jira] [Commented] (FLINK-3438) ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings

[ https://issues.apache.org/jira/browse/FLINK-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15150782#comment-15150782 ] Stefano Baghino commented on FLINK-3438: This is my temporary fix to make the tests work:

[jira] [Created] (FLINK-3438) ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings

Stefano Baghino created FLINK-3438: -- Summary: ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings Key: FLINK-3438 URL: https://issues.apache.org/jira/browse/FLINK-3438

[jira] [Commented] (FLINK-1159) Case style anonymous functions not supported by Scala API

[ https://issues.apache.org/jira/browse/FLINK-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15150174#comment-15150174 ] Stefano Baghino commented on FLINK-1159: If that's ok with [~aljoscha] I would assign this issue

[jira] [Commented] (FLINK-3412) Remove implicit conversions JavaStream / ScalaStream

[ https://issues.apache.org/jira/browse/FLINK-3412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148498#comment-15148498 ] Stefano Baghino commented on FLINK-3412: I like the approach suggested by [~till.rohrmann], I've

[jira] [Commented] (FLINK-3412) Remove implicit conversions JavaStream / ScalaStream

[ https://issues.apache.org/jira/browse/FLINK-3412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148417#comment-15148417 ] Stefano Baghino commented on FLINK-3412: This one looks easy, I can take care of it immediately.

[jira] [Comment Edited] (FLINK-2609) Automatic type registration is only called from the batch execution environment

[ https://issues.apache.org/jira/browse/FLINK-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15142610#comment-15142610 ] Stefano Baghino edited comment on FLINK-2609 at 2/11/16 11:28 AM: --

[jira] [Commented] (FLINK-2609) Automatic type registration is only called from the batch execution environment

[ https://issues.apache.org/jira/browse/FLINK-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15142610#comment-15142610 ] Stefano Baghino commented on FLINK-2609: [~rmetzger] can you elaborate on this issue in

[jira] [Assigned] (FLINK-2021) Rework examples to use ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefano Baghino reassigned FLINK-2021: -- Assignee: Stefano Baghino > Rework examples to use ParameterTool >

[jira] [Created] (FLINK-3353) CSV-related tests may fail depending on locale

Stefano Baghino created FLINK-3353: -- Summary: CSV-related tests may fail depending on locale Key: FLINK-3353 URL: https://issues.apache.org/jira/browse/FLINK-3353 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-3289) Double reference to flink-contrib

[ https://issues.apache.org/jira/browse/FLINK-3289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefano Baghino reassigned FLINK-3289: -- Assignee: Stefano Baghino > Double reference to flink-contrib >

[jira] [Created] (FLINK-3289) Double reference to flink-contrib

Stefano Baghino created FLINK-3289: -- Summary: Double reference to flink-contrib Key: FLINK-3289 URL: https://issues.apache.org/jira/browse/FLINK-3289 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-3289) Double reference to flink-contrib

[ https://issues.apache.org/jira/browse/FLINK-3289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15115627#comment-15115627 ] Stefano Baghino commented on FLINK-3289: Since the last line is very recent my understanding is

[jira] [Commented] (FLINK-2021) Rework examples to use new ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15108268#comment-15108268 ] Stefano Baghino commented on FLINK-2021: I've noticed that the debate took place in the ML with a

[jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool

[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15108537#comment-15108537 ] Stefano Baghino commented on FLINK-2021: Sounds fine, thanks for the tips, I'll start working on

[jira] [Commented] (FLINK-992) Create CollectionDataSets by reading (client) local files.

[ https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15104929#comment-15104929 ] Stefano Baghino commented on FLINK-992: --- Sure, thanks for the reply. I just wanted to check out if I

[jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs

[ https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15101879#comment-15101879 ] Stefano Baghino commented on FLINK-2380: If this is still of interest for the community, I'd like

[jira] [Commented] (FLINK-3010) Add link to powered-by wiki page to project website

[ https://issues.apache.org/jira/browse/FLINK-3010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15101842#comment-15101842 ] Stefano Baghino commented on FLINK-3010: Looking at the site, I'd say this issue has been closed.

[jira] [Comment Edited] (FLINK-2380) Allow to configure default FS for file inputs

[ https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15101879#comment-15101879 ] Stefano Baghino edited comment on FLINK-2380 at 1/15/16 3:06 PM: - Is this

[jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs

[ https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15101935#comment-15101935 ] Stefano Baghino commented on FLINK-2380: Sure, please go on. :) > Allow to configure default FS

[jira] [Commented] (FLINK-992) Create CollectionDataSets by reading (client) local files.

[ https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15102061#comment-15102061 ] Stefano Baghino commented on FLINK-992: --- What is the status of this issue? > Create

[jira] [Commented] (FLINK-1947) Make Avro and Tachyon test logging less verbose

[ https://issues.apache.org/jira/browse/FLINK-1947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15102000#comment-15102000 ] Stefano Baghino commented on FLINK-1947: I've just run {{mvn test}} on {{flink-batch-connectors}}.