[jira] [Resolved] (FLINK-3292) Bug in flink-jdbc. Not all JDBC drivers supported

2016-01-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3292. - Resolution: Fixed Fixed via d97fcda6635b6821ac3f61c39e0fa156bc7c7fd4 Thank you for the

[jira] [Closed] (FLINK-3292) Bug in flink-jdbc. Not all JDBC drivers supported

2016-01-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3292. --- > Bug in flink-jdbc. Not all JDBC drivers supported > - >

[jira] [Commented] (FLINK-3242) User-specified StateBackend is not Respected if Checkpointing is Disabled

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

[jira] [Commented] (FLINK-3295) Flink Kafka consumer fails with NoNodeException if zkConnect string contains chroot-path

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121664#comment-15121664 ] ASF GitHub Bot commented on FLINK-3295: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: [FLINK-3295][Kafka 0.8] Improve ZK error behav...

2016-01-28 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1555#issuecomment-176230855 Yes, curator is retrying using an exponential backoff retry. I've addressed your comments. --- If your project is set up for it, you can reply to this email

[GitHub] flink pull request: [Flink-3196] InputStream should be closed in E...

2016-01-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1552 --- 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

[GitHub] flink pull request: [FLINK-3265] Make RabbitMQ source threadsafe

2016-01-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1534 --- 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

[GitHub] flink pull request: [FLINK-3292]Fix for Bug in flink-jdbc. Not all...

2016-01-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1551 --- 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

[GitHub] flink pull request: [FLINK-3178] Don't Emit In-Flight Windows When...

2016-01-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1542 --- 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

[GitHub] flink pull request: [FLINK-3242] Also Set User-specified StateBack...

2016-01-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1516 --- 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-3299) Remove ApplicationID from Environment

2016-01-28 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121737#comment-15121737 ] Gyula Fora commented on FLINK-3299: --- I am not sure if I would rush to remove it in fact I would probably

[jira] [Closed] (FLINK-3242) User-specified StateBackend is not Respected if Checkpointing is Disabled

2016-01-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3242. --- > User-specified StateBackend is not Respected if Checkpointing is Disabled >

[jira] [Resolved] (FLINK-3242) User-specified StateBackend is not Respected if Checkpointing is Disabled

2016-01-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3242. - Resolution: Fixed Fix Version/s: 0.10.2 1.0.0 Fixed in - 0.10.2 via

[jira] [Resolved] (FLINK-3178) Make Closing Behavior of Window Operators Configurable

2016-01-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3178. - Resolution: Fixed Fix Version/s: 1.0.0 Fixed via c4e5a55f027ed73ce557f10d5125a0b168832889

[jira] [Closed] (FLINK-3196) InputStream should be closed in EnvironmentInformation#getRevisionInformation()

2016-01-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3196. --- > InputStream should be closed in > EnvironmentInformation#getRevisionInformation() >

[jira] [Resolved] (FLINK-3196) InputStream should be closed in EnvironmentInformation#getRevisionInformation()

2016-01-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3196. - Resolution: Fixed Assignee: Suneel Marthi Fix Version/s: 1.0.0 Fixed via

[jira] [Commented] (FLINK-3292) Bug in flink-jdbc. Not all JDBC drivers supported

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

[jira] [Commented] (FLINK-3178) Make Closing Behavior of Window Operators Configurable

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

[jira] [Commented] (FLINK-3265) RabbitMQ Source not threadsafe: ConcurrentModificationException

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

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

2016-01-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121750#comment-15121750 ] Till Rohrmann commented on FLINK-2678: -- Done. Great that you're picking this issue up :-) > DataSet

[jira] [Resolved] (FLINK-3265) RabbitMQ Source not threadsafe: ConcurrentModificationException

2016-01-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3265. - Resolution: Fixed Fix Version/s: 1.0.0 Fixed via 6b01a89020f2de3f7710cf72336291b1e8ca8562

[jira] [Closed] (FLINK-3265) RabbitMQ Source not threadsafe: ConcurrentModificationException

2016-01-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3265. --- > RabbitMQ Source not threadsafe: ConcurrentModificationException >

[jira] [Assigned] (FLINK-3294) KafkaConsumer (0.8) commit offsets using SimpleConsumer.commitOffsets()

2016-01-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3294: - Assignee: Robert Metzger > KafkaConsumer (0.8) commit offsets using

[GitHub] flink pull request: [FLINK-3216] [FLINK-3217] [cep] Initial versio...

2016-01-28 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/1557 [FLINK-3216] [FLINK-3217] [cep] Initial version of CEP library This PR is the first version of Flink's CEP library. The key components are the `NFA` which uses the `SharedBuffer` to

[jira] [Commented] (FLINK-3216) Define pattern specification

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

[jira] [Created] (FLINK-3301) Ineffective synchronization in MessageAcknowledgingSourceBase#restoreState

2016-01-28 Thread Ted Yu (JIRA)
Ted Yu created FLINK-3301: - Summary: Ineffective synchronization in MessageAcknowledgingSourceBase#restoreState Key: FLINK-3301 URL: https://issues.apache.org/jira/browse/FLINK-3301 Project: Flink

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

2016-01-28 Thread Subhobrata Dey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15122486#comment-15122486 ] Subhobrata Dey commented on FLINK-2678: --- Hello Till, I was checking the implementation of

[jira] [Created] (FLINK-3300) Concurrency Bug in Yarn JobManager

2016-01-28 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3300: --- Summary: Concurrency Bug in Yarn JobManager Key: FLINK-3300 URL: https://issues.apache.org/jira/browse/FLINK-3300 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-3033) Redis Source Connector

2016-01-28 Thread Subhobrata Dey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15122563#comment-15122563 ] Subhobrata Dey commented on FLINK-3033: --- Hello, If nobody is working on this issue, I would like to

[GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table...

2016-01-28 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1559#issuecomment-176501262 @ChengXiangLi, @twalthr: Please review and give feedback. @ChengXiangLi, this PR contains stubs for the translation rules which are quite similar to the rules

[jira] [Updated] (FLINK-3210) Unnecessary call to deserializer#deserialize() in LegacyFetcher#SimpleConsumerThread#run()

2016-01-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3210: -- Description: Here is related code: {code} byte[] valueBytes; if (payload ==

[jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode()

2016-01-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3222: -- Description: Here is related code: {code} result = 31 * result + (int) (subTaskStats.length ^

[jira] [Assigned] (FLINK-3293) Custom Application Name on YARN is ignored in deploy jobmanager mode

2016-01-28 Thread Johannes (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes reassigned FLINK-3293: --- Assignee: Johannes > Custom Application Name on YARN is ignored in deploy jobmanager mode >

[jira] [Commented] (FLINK-3293) Custom Application Name on YARN is ignored in deploy jobmanager mode

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

[jira] [Commented] (FLINK-3034) Redis SInk Connector

2016-01-28 Thread Subhobrata Dey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15122562#comment-15122562 ] Subhobrata Dey commented on FLINK-3034: --- Hello, if nobody is working on this issue, I would like to

[GitHub] flink pull request: [FLINK-3293] Respect custom cli yarn name in j...

2016-01-28 Thread jkirsch
GitHub user jkirsch opened a pull request: https://github.com/apache/flink/pull/1558 [FLINK-3293] Respect custom cli yarn name in jobmanager mode Added a method to set a default application name for the flink yarn session cli. Switched the order, such that this name can now be

[jira] [Commented] (FLINK-3225) Optimize logical Table API plans in Calcite

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15122651#comment-15122651 ] ASF GitHub Bot commented on FLINK-3225: --- Github user fhueske commented on the pull request:

[jira] [Commented] (FLINK-2428) Clean up unused properties in StreamConfig

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121089#comment-15121089 ] ASF GitHub Bot commented on FLINK-2428: --- Github user rmetzger commented on the pull request:

[GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ...

2016-01-28 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1553#issuecomment-176059338 Thanks for the PR! I'll have a look at it and give feedback hopefully today or tomorrow. --- If your project is set up for it, you can reply to this email and have

[jira] [Commented] (FLINK-2985) Allow different field names for unionAll() in Table API

2016-01-28 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121048#comment-15121048 ] Fabian Hueske commented on FLINK-2985: -- Hi [~sbcd90], thanks for your interest to contribute! We are

[jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121041#comment-15121041 ] ASF GitHub Bot commented on FLINK-3179: --- Github user fhueske commented on the pull request:

[GitHub] flink pull request:

2016-01-28 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/commit/a7d4334f1843fd341be49605c2814e01bc786ccf#commitcomment-15726940 I guess this will entail some work correcting the checkstyle violations in the tests, e.g. unused imports etc. --- If your

[GitHub] flink pull request: [FLINK-2428] Clean up unused properties in Str...

2016-01-28 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1554#issuecomment-176079663 To squash commits, you have to call "git rebase -i HEAD~10" (its called interactive rebase). Then, put "fixup" or "squash" instead of "pick" to the commits you want to

[jira] [Commented] (FLINK-3282) Add FlinkRelNode interface.

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121300#comment-15121300 ] ASF GitHub Bot commented on FLINK-3282: --- Github user twalthr commented on the pull request:

[GitHub] flink pull request: [FLINK-3292]Fix for Bug in flink-jdbc. Not all...

2016-01-28 Thread sbcd90
Github user sbcd90 commented on the pull request: https://github.com/apache/flink/pull/1551#issuecomment-176153352 Hello zentol, I dont see any updates from your side. Can you kindly let me know if this PR is good to be merged so that I can close the issue? --- If your

[GitHub] flink pull request: [FLINK-3292]Fix for Bug in flink-jdbc. Not all...

2016-01-28 Thread zentol
Github user zentol commented on the pull request: https://github.com/apache/flink/pull/1551#issuecomment-176157025 looks good. +1 to merge. --- 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

[jira] [Commented] (FLINK-3292) Bug in flink-jdbc. Not all JDBC drivers supported

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121338#comment-15121338 ] ASF GitHub Bot commented on FLINK-3292: --- Github user zentol commented on the pull request:

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

2016-01-28 Thread Subhobrata Dey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121366#comment-15121366 ] Subhobrata Dey commented on FLINK-2678: --- Hello Till, If no one is working on this issue, can I take

[GitHub] flink pull request: [FLINK-3282] Add FlinkRelNode interface.

2016-01-28 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1544#issuecomment-176170046 Yes, I wanted to start a discussion about sticking with Scala as well. I'll open a PR for FLINK-3225 very soon and can take care of translating the nodes to Scala

[GitHub] flink pull request: [FLINK-3282] Add FlinkRelNode interface.

2016-01-28 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1544#issuecomment-176150700 When I wrote my SQL prototype I also thought about using Java because Calcite is written in Java, but since it is easy to use Java classes from Scala and Scala has a

[jira] [Commented] (FLINK-1719) Add naive Bayes classification algorithm to machine learning library

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121371#comment-15121371 ] ASF GitHub Bot commented on FLINK-1719: --- Github user JonathanH5 commented on the pull request:

[jira] [Commented] (FLINK-3295) Flink Kafka consumer fails with NoNodeException if zkConnect string contains chroot-path

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121389#comment-15121389 ] ASF GitHub Bot commented on FLINK-3295: --- Github user StephanEwen commented on the pull request:

[jira] [Commented] (FLINK-3178) Make Closing Behavior of Window Operators Configurable

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121401#comment-15121401 ] ASF GitHub Bot commented on FLINK-3178: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: [FLINK-3178] Don't Emit In-Flight Windows When...

2016-01-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1542#issuecomment-176181849 Merging this... --- 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

[GitHub] flink pull request: [FLINK-3242] Also Set User-specified StateBack...

2016-01-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1516#issuecomment-176184025 Merging this... --- 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

[GitHub] flink pull request: [Flink-3226] Implement project and filter tran...

2016-01-28 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1556#issuecomment-176157407 As far as I know the `Expressions` are for the user-facing API only, right? I think we won't need the `RexToExpr` class anymore, as I am currently writing a rex to code

[GitHub] flink pull request: [FLINK-1719] [ml] Add Multinomial Naive Bayes ...

2016-01-28 Thread JonathanH5
Github user JonathanH5 commented on the pull request: https://github.com/apache/flink/pull/1156#issuecomment-176168967 Ok, I think I incorporated everything that you asked for. I will squash all of the commits and rebase everything when you give me the go for that :). --- If your

[GitHub] flink pull request: [FLINK-3295][Kafka 0.8] Improve ZK error behav...

2016-01-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1555#issuecomment-176175300 I think we have to make this a bit more sophisticated and allow the user to specify behavior when offsets cannot be fetched: - FAIL (fail if any offset

[GitHub] flink pull request: [Flink-3196] InputStream should be closed in E...

2016-01-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1552#issuecomment-176183398 Looks good, thanks, merging this... --- 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

[jira] [Commented] (FLINK-3242) User-specified StateBackend is not Respected if Checkpointing is Disabled

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121410#comment-15121410 ] ASF GitHub Bot commented on FLINK-3242: --- Github user StephanEwen commented on the pull request:

[jira] [Commented] (FLINK-3295) Flink Kafka consumer fails with NoNodeException if zkConnect string contains chroot-path

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

[GitHub] flink pull request: [FLINK-3282] Add FlinkRelNode interface.

2016-01-28 Thread ChengXiangLi
Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/1544#issuecomment-176144759 I didn't prefer Java or Scala, the reason why i writen this in Java is that, this part logic would be translated from Calcite RelNodes(which is in Java) and

[jira] [Commented] (FLINK-3282) Add FlinkRelNode interface.

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121279#comment-15121279 ] ASF GitHub Bot commented on FLINK-3282: --- Github user ChengXiangLi commented on the pull request:

[GitHub] flink pull request: [FLINK-3295][Kafka 0.8] Improve ZK error behav...

2016-01-28 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/1555 [FLINK-3295][Kafka 0.8] Improve ZK error behavior This PR changes the behavior of the Kafka 0.8 source if there is an error while getting the initial offsets from ZK. Instead of failing, the

[jira] [Closed] (FLINK-3275) [py] Add support for Dataset.setParallelism()

2016-01-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-3275. --- Resolution: Fixed Implemented in 40422d5057e5c1d7b75aec48bacbd7518cd7c9e1 > [py] Add support

[jira] [Created] (FLINK-3298) Streaming connector for ActiveMQ

2016-01-28 Thread Mohit Sethi (JIRA)
Mohit Sethi created FLINK-3298: -- Summary: Streaming connector for ActiveMQ Key: FLINK-3298 URL: https://issues.apache.org/jira/browse/FLINK-3298 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-3297) Streaming connector for ZeroMQ

2016-01-28 Thread Mohit Sethi (JIRA)
Mohit Sethi created FLINK-3297: -- Summary: Streaming connector for ZeroMQ Key: FLINK-3297 URL: https://issues.apache.org/jira/browse/FLINK-3297 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-3140) NULL value data layout in Row Serializer/Comparator

2016-01-28 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121208#comment-15121208 ] Timo Walther commented on FLINK-3140: - Fixed via 440137cc3ad8ab47dff84212c81e960e0a254eaa. > NULL

[jira] [Commented] (FLINK-3140) NULL value data layout in Row Serializer/Comparator

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

[GitHub] flink pull request: [FLINK-3140] NULL value data layout in Row Ser...

2016-01-28 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1465 --- 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-3175) KafkaITCase.testOffsetAutocommitTest

2016-01-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121237#comment-15121237 ] Robert Metzger commented on FLINK-3175: --- Another case:

[jira] [Assigned] (FLINK-3175) KafkaITCase.testOffsetAutocommitTest

2016-01-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3175: - Assignee: Robert Metzger > KafkaITCase.testOffsetAutocommitTest >

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-01-28 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121196#comment-15121196 ] ramkrishna.s.vasudevan commented on FLINK-2055: --- Is some one working on this -

[jira] [Commented] (FLINK-3282) Add FlinkRelNode interface.

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121252#comment-15121252 ] ASF GitHub Bot commented on FLINK-3282: --- Github user twalthr commented on the pull request:

[GitHub] flink pull request: [FLINK-3282] Add FlinkRelNode interface.

2016-01-28 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/1544#issuecomment-176133567 @fhueske and @ChengXiangLi: Sorry but I have to discuss this PR again. Do we really want to have parts of the Table API written in Java and some other parts written in

[GitHub] flink pull request: [Flink-3226] Implement project and filter tran...

2016-01-28 Thread ChengXiangLi
GitHub user ChengXiangLi opened a pull request: https://github.com/apache/flink/pull/1556 [Flink-3226] Implement project and filter translator. This is just prototype implementation to translate Calcite Project and Filter into Flink RelNode. It still miss several parts, which could

[jira] [Resolved] (FLINK-3140) NULL value data layout in Row Serializer/Comparator

2016-01-28 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-3140. - Resolution: Fixed Fix Version/s: 1.00 > NULL value data layout in Row

[jira] [Created] (FLINK-3296) DataStream.write*() methods are not flushing properly

2016-01-28 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3296: - Summary: DataStream.write*() methods are not flushing properly Key: FLINK-3296 URL: https://issues.apache.org/jira/browse/FLINK-3296 Project: Flink Issue

[jira] [Commented] (FLINK-3034) Redis SInk Connector

2016-01-28 Thread subhankar biswas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15122946#comment-15122946 ] subhankar biswas commented on FLINK-3034: - i already finished the sink. > Redis SInk Connector

[jira] [Commented] (FLINK-3033) Redis Source Connector

2016-01-28 Thread subhankar biswas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15122945#comment-15122945 ] subhankar biswas commented on FLINK-3033: - i already finished writing the source. > Redis

[GitHub] flink pull request: FLINK-3301 Ineffective synchronization in Mess...

2016-01-28 Thread tedyu
GitHub user tedyu opened a pull request: https://github.com/apache/flink/pull/1560 FLINK-3301 Ineffective synchronization in MessageAcknowledgingSourceBase#restoreState This PR changes synchronization on pendingCheckpoints to this (MessageAcknowledgingSourceBase) You can merge

[jira] [Created] (FLINK-3299) Remove ApplicationID from Environment

2016-01-28 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-3299: -- Summary: Remove ApplicationID from Environment Key: FLINK-3299 URL: https://issues.apache.org/jira/browse/FLINK-3299 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3292) Bug in flink-jdbc. Not all JDBC drivers supported

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121452#comment-15121452 ] ASF GitHub Bot commented on FLINK-3292: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: [FLINK-3292]Fix for Bug in flink-jdbc. Not all...

2016-01-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1551#issuecomment-176188709 Thank for the contribution and review! Will merge this... --- If your project is set up for it, you can reply to this email and have your reply appear on

[jira] [Commented] (FLINK-3265) RabbitMQ Source not threadsafe: ConcurrentModificationException

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121470#comment-15121470 ] ASF GitHub Bot commented on FLINK-3265: --- Github user StephanEwen commented on the pull request:

[GitHub] flink pull request: FLINK-2523: making the task cancellation inter...

2016-01-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1546#issuecomment-176189641 This is going into a good direction. Two suggestions: - Since you already have the `ExecutionConfig` in the Task, I would put it into the `Environment`

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

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121477#comment-15121477 ] ASF GitHub Bot commented on FLINK-2380: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request: FLINK-2380: allow to specify the default files...

2016-01-28 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1524#discussion_r51123237 --- Diff: flink-core/src/test/java/org/apache/flink/configuration/GlobalConfigurationTest.java --- @@ -19,13 +19,19 @@ package

[GitHub] flink pull request: FLINK-2380: allow to specify the default files...

2016-01-28 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/1524#issuecomment-176194702 Thanks for picking up this issue. This goes into a very good direction. Few remaining points: - There are a lot of unrelated reformattings. The general

[jira] [Closed] (FLINK-3262) Remove fuzzy versioning from Bower dependencies

2016-01-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3262. --- > Remove fuzzy versioning from Bower dependencies > --- > >

[jira] [Resolved] (FLINK-3262) Remove fuzzy versioning from Bower dependencies

2016-01-28 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-3262. - Resolution: Fixed Fixed via 1ea5e138793e343010f1cee07d8a0d88e67b6e51 Thank you for the

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

2016-01-28 Thread Subhobrata Dey (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121516#comment-15121516 ] Subhobrata Dey commented on FLINK-2678: --- Hello Till, Please assign me the issue. I would like to

[GitHub] flink pull request: [Flink-3226] Implement project and filter tran...

2016-01-28 Thread ChengXiangLi
Github user ChengXiangLi closed the pull request at: https://github.com/apache/flink/pull/1556 --- 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-2523) Make task canceling interrupt interval configurable

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121456#comment-15121456 ] ASF GitHub Bot commented on FLINK-2523: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request: FLINK-2523: making the task cancellation inter...

2016-01-28 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1546#discussion_r51122613 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java --- @@ -93,24 +94,28 @@ private final

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

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121481#comment-15121481 ] ASF GitHub Bot commented on FLINK-2380: --- Github user StephanEwen commented on a diff in the pull

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

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121485#comment-15121485 ] ASF GitHub Bot commented on FLINK-2380: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request: FLINK-2380: allow to specify the default files...

2016-01-28 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/1524#discussion_r51123709 --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java --- @@ -159,56 +163,109 @@ public int hashCode() { /** *

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

2016-01-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121495#comment-15121495 ] ASF GitHub Bot commented on FLINK-2380: --- Github user StephanEwen commented on the pull request:

[jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys

2016-01-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121490#comment-15121490 ] Till Rohrmann commented on FLINK-2678: -- Hi [~sbcd90], as far as I know, there is nobody working on

  1   2   >