[jira] [Updated] (FLINK-1343) Branching Join Program Deadlocks

2015-03-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1343: - Component/s: (was: Optimizer) Distributed Runtime Branching Join Program

[jira] [Commented] (FLINK-1319) Add static code analysis for UDFs

2015-03-24 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377902#comment-14377902 ] Fabian Hueske commented on FLINK-1319: -- (Copying my response from the mailing list)

[jira] [Commented] (FLINK-1776) APIs provide invalid Semantic Properties for Operators with SelectorFunction keys

2015-03-24 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14377907#comment-14377907 ] Fabian Hueske commented on FLINK-1776: -- The fix is straight-forward. We get the

[jira] [Created] (FLINK-1780) Rename FlatCombineFunction to GroupCombineFunction

2015-03-24 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1780: Summary: Rename FlatCombineFunction to GroupCombineFunction Key: FLINK-1780 URL: https://issues.apache.org/jira/browse/FLINK-1780 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1694) Change the split between create/run of a vertex-centric iteration

2015-03-25 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14380041#comment-14380041 ] Fabian Hueske commented on FLINK-1694: -- +1 for the second option with the

[jira] [Created] (FLINK-1784) KafkaITCase

2015-03-25 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1784: Summary: KafkaITCase Key: FLINK-1784 URL: https://issues.apache.org/jira/browse/FLINK-1784 Project: Flink Issue Type: Bug Components: Streaming

[jira] [Resolved] (FLINK-1512) Add CsvReader for reading into POJOs.

2015-03-25 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1512. -- Resolution: Implemented Fix Version/s: 0.9 Implemented in

[jira] [Commented] (FLINK-1711) Replace all usages off commons.Validate with guava.check

2015-03-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14385727#comment-14385727 ] Fabian Hueske commented on FLINK-1711: -- Welcome to the Flink community! I assigned

[jira] [Updated] (FLINK-1711) Replace all usages off commons.Validate with guava.check

2015-03-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1711: - Assignee: Mathusuthan Kannan Replace all usages off commons.Validate with guava.check

[jira] [Created] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/'

2015-03-03 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1640: Summary: FileOutputFormat writes to wrong path if path ends with '/' Key: FLINK-1640 URL: https://issues.apache.org/jira/browse/FLINK-1640 Project: Flink

[jira] [Assigned] (FLINK-1640) FileOutputFormat writes to wrong path if path ends with '/'

2015-03-03 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1640: Assignee: Fabian Hueske FileOutputFormat writes to wrong path if path ends with '/'

[jira] [Updated] (FLINK-1628) Strange behavior of where function during a join

2015-03-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1628: - Priority: Critical (was: Major) Strange behavior of where function during a join

[jira] [Assigned] (FLINK-1628) Strange behavior of where function during a join

2015-03-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1628: Assignee: Fabian Hueske Strange behavior of where function during a join

[jira] [Updated] (FLINK-1628) Strange behavior of where function during a join

2015-03-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1628: - Component/s: Optimizer Strange behavior of where function during a join

[jira] [Closed] (FLINK-839) Add GroupReduceFunction and CoGroupFunction with separate Key

2015-03-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-839. --- Resolution: Duplicate Duplicate of FLINK-553 and FLINK-1272 Add GroupReduceFunction and

[jira] [Reopened] (FLINK-1526) Add Minimum Spanning Tree library method and example

2015-02-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-1526: -- Hi Andra, thanks for working on this issue and opening the PR! I am reopening this issue for now,

[jira] [Resolved] (FLINK-1466) Add InputFormat to read HCatalog tables

2015-02-20 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1466. -- Resolution: Implemented Implemented with bed3da4a61a8637c0faa9632b8a05ccef8c5a6dc Add

[jira] [Resolved] (FLINK-1444) Add data properties for data sources

2015-02-20 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1444. -- Resolution: Implemented Implemented with f0a28bf5345084a0a43df16021e60078e322e087 Add data

[jira] [Commented] (FLINK-703) Use complete element as join key.

2015-03-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14384529#comment-14384529 ] Fabian Hueske commented on FLINK-703: - Hi, that's a very good example and shows that

[jira] [Created] (FLINK-1776) APIs provide invalid Semantic Properties for Operators with SelectorFunction keys

2015-03-23 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1776: Summary: APIs provide invalid Semantic Properties for Operators with SelectorFunction keys Key: FLINK-1776 URL: https://issues.apache.org/jira/browse/FLINK-1776

[jira] [Commented] (FLINK-1656) Filtered Semantic Properties for Operators with Iterators

2015-03-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14375665#comment-14375665 ] Fabian Hueske commented on FLINK-1656: -- I am going to address this issue on two

[jira] [Updated] (FLINK-1656) Filtered Semantic Properties for Operators with Iterators

2015-03-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1656: - Summary: Filtered Semantic Properties for Operators with Iterators (was: Fix ForwardedField

[jira] [Commented] (FLINK-1821) simplify coding

2015-04-03 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14394380#comment-14394380 ] Fabian Hueske commented on FLINK-1821: -- I think this is arguable whether removing the

[jira] [Comment Edited] (FLINK-1821) simplify coding

2015-04-03 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14394380#comment-14394380 ] Fabian Hueske edited comment on FLINK-1821 at 4/3/15 12:56 PM:

[jira] [Commented] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-04-03 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14394853#comment-14394853 ] Fabian Hueske commented on FLINK-1820: -- I would not call this a bug. The behavior

[jira] [Created] (FLINK-1919) Add HCatOutputFormat for Tuple data types

2015-04-21 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1919: Summary: Add HCatOutputFormat for Tuple data types Key: FLINK-1919 URL: https://issues.apache.org/jira/browse/FLINK-1919 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-1890) Add note to docs that ReadFields annotations are currently not evaluated

2015-04-21 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1890: - Summary: Add note to docs that ReadFields annotations are currently not evaluated (was: Add

[jira] [Updated] (FLINK-703) Use complete element as join key.

2015-04-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-703: Fix Version/s: (was: pre-apache) 0.9 Use complete element as join key.

[jira] [Resolved] (FLINK-703) Use complete element as join key.

2015-04-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-703. - Resolution: Implemented Implemented with 45e680c2b6c9c2f64ce55423b755a13d402ff8ba Use complete

[jira] [Resolved] (FLINK-1891) Add isEmpty check when the input dir

2015-04-22 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1891. -- Resolution: Fixed Fix Version/s: 0.9 Fixed with a0147c493cf210a0914c35200ebfacd47515374d

[jira] [Commented] (FLINK-1682) Port Record-API based optimizer tests to new Java API

2015-04-24 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14511631#comment-14511631 ] Fabian Hueske commented on FLINK-1682: -- The following classes in the

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

2015-04-24 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14511638#comment-14511638 ] Fabian Hueske commented on FLINK-1848: -- No, the issue hasn't been fixed yet Paths

[jira] [Updated] (FLINK-1963) Improve distinct() transformation

2015-04-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1963: - Labels: starter (was: start) Improve distinct() transformation

[jira] [Updated] (FLINK-1963) Improve distinct() transformation

2015-04-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1963: - Description: The `distinct()` transformation is a bit limited right now with respect to

[jira] [Commented] (FLINK-1951) NullPointerException in DeltaIteration when no ForwardedFileds

2015-04-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14521507#comment-14521507 ] Fabian Hueske commented on FLINK-1951: -- It was a bit tricky and took some time but I

[jira] [Updated] (FLINK-1951) NullPointerException in DeltaIteration when no ForwardedFileds

2015-04-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1951: - Priority: Critical (was: Minor) NullPointerException in DeltaIteration when no ForwardedFileds

[jira] [Resolved] (FLINK-1828) Impossible to output data to an HBase table

2015-04-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1828. -- Resolution: Fixed Fix Version/s: 0.8.2 Fixed in - 0.9 with

[jira] [Created] (FLINK-1991) Return Table as DataSetTuple

2015-05-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1991: Summary: Return Table as DataSetTuple Key: FLINK-1991 URL: https://issues.apache.org/jira/browse/FLINK-1991 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-1978) POJO serialization NPE

2015-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1978: - Fix Version/s: 0.8.2 POJO serialization NPE -- Key:

[jira] [Created] (FLINK-1990) Uppercase AS keyword not allowed in select expression

2015-05-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1990: Summary: Uppercase AS keyword not allowed in select expression Key: FLINK-1990 URL: https://issues.apache.org/jira/browse/FLINK-1990 Project: Flink Issue

[jira] [Commented] (FLINK-1991) Return Table as DataSetTuple

2015-05-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14534281#comment-14534281 ] Fabian Hueske commented on FLINK-1991: -- I know, but `Pojo` or `Row` are not good

[jira] [Created] (FLINK-1996) Add output methods to Table API

2015-05-08 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1996: Summary: Add output methods to Table API Key: FLINK-1996 URL: https://issues.apache.org/jira/browse/FLINK-1996 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-1151) CollectionDataSource does not provide statistics

2015-05-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1151: - Assignee: (was: Fabian Hueske) CollectionDataSource does not provide statistics

[jira] [Resolved] (FLINK-1974) JobExecutionResult NetRuntime - document result type

2015-05-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1974. -- Resolution: Fixed Fix Version/s: 0.9 Fixed with 7e5a97062c8d5d322be81a9d8af35f942a929f57

[jira] [Commented] (FLINK-1996) Add output methods to Table API

2015-05-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14534451#comment-14534451 ] Fabian Hueske commented on FLINK-1996: -- Would it be more than having the interfaces

[jira] [Commented] (FLINK-1997) Neither nor != supported for non-equals predicates in .filter()

2015-05-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14534408#comment-14534408 ] Fabian Hueske commented on FLINK-1997: -- With some help from [~aljoscha] I found out

[jira] [Updated] (FLINK-2000) Add SQL-style aggregations for Table API

2015-05-12 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2000: - Assignee: Cheng Hao Add SQL-style aggregations for Table API

[jira] [Created] (FLINK-2020) Table API JoinITCase fails non-deterministically

2015-05-15 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2020: Summary: Table API JoinITCase fails non-deterministically Key: FLINK-2020 URL: https://issues.apache.org/jira/browse/FLINK-2020 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-1976) Add ForwardedFields* hints for the optimizer

2015-05-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1976. -- Resolution: Fixed Fix Version/s: 0.9 Fixed with a35c7201e010ee34629a7fbd9ffcd9b149fe5f93

[jira] [Resolved] (FLINK-1975) Graph getUndirected improvement

2015-05-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1975. -- Resolution: Fixed Fix Version/s: 0.9 Fixed with beb7f31227766cfa17691525ccc666d105d442da

[jira] [Created] (FLINK-2038) Extend headline of website

2015-05-18 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2038: Summary: Extend headline of website Key: FLINK-2038 URL: https://issues.apache.org/jira/browse/FLINK-2038 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-2032) Migrate integration tests from temp output files to collect()

2015-05-18 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2032: Summary: Migrate integration tests from temp output files to collect() Key: FLINK-2032 URL: https://issues.apache.org/jira/browse/FLINK-2032 Project: Flink

[jira] [Commented] (FLINK-2020) Table API JoinITCase fails non-deterministically

2015-05-18 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14547713#comment-14547713 ] Fabian Hueske commented on FLINK-2020: -- There are a lot of tests using temp files and

[jira] [Resolved] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-05-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1820. -- Resolution: Fixed Resolved with ea23f28c449a1a11e509ca62a36f770a6940d40a Thanks for the fix!

[jira] [Updated] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-1985: - Reporter: Matthias J. Sax (was: Aljoscha Krettek) Streaming does not correctly forward

[jira] [Commented] (FLINK-2026) Error message in count() only jobs

2015-05-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14550040#comment-14550040 ] Fabian Hueske commented on FLINK-2026: -- That might be counter-intuitive for users who

[jira] [Created] (FLINK-2042) Increase font size for stack figure on website home

2015-05-19 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2042: Summary: Increase font size for stack figure on website home Key: FLINK-2042 URL: https://issues.apache.org/jira/browse/FLINK-2042 Project: Flink Issue

[jira] [Commented] (FLINK-1903) Joins where one side uses a field more than once don't work

2015-04-17 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14499615#comment-14499615 ] Fabian Hueske commented on FLINK-1903: -- +1 for removing the duplicate removal. I

[jira] [Created] (FLINK-1906) Add tip to work around plain Tuple return type of project operator

2015-04-17 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1906: Summary: Add tip to work around plain Tuple return type of project operator Key: FLINK-1906 URL: https://issues.apache.org/jira/browse/FLINK-1906 Project: Flink

[jira] [Commented] (FLINK-1872) How can generation dataset in flink automatic depend on number of filed and data type

2015-04-13 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492632#comment-14492632 ] Fabian Hueske commented on FLINK-1872: -- The names of the CSV fields are actually not

[jira] [Resolved] (FLINK-1664) Forbid sorting on POJOs

2015-04-03 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1664. -- Resolution: Fixed Fix Version/s: 0.9 Fixed with f36eb54ee6d8cc130439def98559b6b0a70b6c7b

[jira] [Resolved] (FLINK-1656) Filtered Semantic Properties for Operators with Iterators

2015-04-03 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1656. -- Resolution: Fixed Fix Version/s: 0.9 Fixed with dda8565e6b4f519ac77d66d710a5dc64f1c5740b

[jira] [Commented] (FLINK-1820) Bug in DoubleParser and FloatParser - empty String is not casted to 0

2015-04-03 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14394954#comment-14394954 ] Fabian Hueske commented on FLINK-1820: -- That would be the proper way to handle this

[jira] [Resolved] (FLINK-1776) APIs provide invalid Semantic Properties for Operators with SelectorFunction keys

2015-04-03 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1776. -- Resolution: Fixed Fixed with f39aec82d6cd1286f129b11366d101cb646716ee APIs provide invalid

[jira] [Commented] (FLINK-1834) Is mapred.output.dir conf parameter really required?

2015-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483249#comment-14483249 ] Fabian Hueske commented on FLINK-1834: -- I totally agree. We should get rid of this

[jira] [Commented] (FLINK-1834) Is mapred.output.dir conf parameter really required?

2015-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14483142#comment-14483142 ] Fabian Hueske commented on FLINK-1834: -- I would be careful with this. Do we know

[jira] [Resolved] (FLINK-1817) ClassLoaderObjectInputStream fails with ClassNotFoundException for primitive classes

2015-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1817. -- Resolution: Fixed Fixed with - 0.9: d33b44549d416c30f01ead9aacf5cf7ed30674ca - 0.8:

[jira] [Created] (FLINK-1840) Job execution fails on Windows (native and Cygwin)

2015-04-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1840: Summary: Job execution fails on Windows (native and Cygwin) Key: FLINK-1840 URL: https://issues.apache.org/jira/browse/FLINK-1840 Project: Flink Issue Type:

[jira] [Commented] (FLINK-1840) Job execution fails on Windows (native and Cygwin)

2015-04-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484001#comment-14484001 ] Fabian Hueske commented on FLINK-1840: -- The exception is cause by the

[jira] [Created] (FLINK-1841) WindowJoinITCase fails

2015-04-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1841: Summary: WindowJoinITCase fails Key: FLINK-1841 URL: https://issues.apache.org/jira/browse/FLINK-1841 Project: Flink Issue Type: Bug Components:

[jira] [Assigned] (FLINK-1832) start-local.bat/start-local.sh does not work if there is a white space in the file path (windows)

2015-04-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-1832: Assignee: Fabian Hueske start-local.bat/start-local.sh does not work if there is a white

[jira] [Resolved] (FLINK-1840) Job execution fails on Windows (native and Cygwin)

2015-04-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-1840. -- Resolution: Fixed Fixed with 0afed4dcf9f9639fc90a8f18933be0516b9d7cd3 Job execution fails on

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

2015-04-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485309#comment-14485309 ] Fabian Hueske commented on FLINK-1848: -- That gives {{file:/c:/my/dir}}. If I use that

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

2015-04-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485260#comment-14485260 ] Fabian Hueske commented on FLINK-1848: -- Yes, thought so as well and tried that

[jira] [Created] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

2015-04-08 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-1848: Summary: Paths containing a Windows drive letter cannot be used in FileOutputFormats Key: FLINK-1848 URL: https://issues.apache.org/jira/browse/FLINK-1848 Project:

[jira] [Commented] (FLINK-1848) Paths containing a Windows drive letter cannot be used in FileOutputFormats

2015-05-20 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14551942#comment-14551942 ] Fabian Hueske commented on FLINK-1848: -- Hi [~Laurent Tardif], thanks for the

[jira] [Commented] (FLINK-1912) how can get top 10 row in flink

2015-04-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501992#comment-14501992 ] Fabian Hueske commented on FLINK-1912: -- Please use the user mailing list to ask

[jira] [Created] (FLINK-2031) Missing images in blog posts

2015-05-17 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2031: Summary: Missing images in blog posts Key: FLINK-2031 URL: https://issues.apache.org/jira/browse/FLINK-2031 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2165) Rename Table conversion methods in TableEnvironment

2015-06-05 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2165: Summary: Rename Table conversion methods in TableEnvironment Key: FLINK-2165 URL: https://issues.apache.org/jira/browse/FLINK-2165 Project: Flink Issue

[jira] [Created] (FLINK-2166) Add fromCsvFile() to TableEnvironment

2015-06-05 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2166: Summary: Add fromCsvFile() to TableEnvironment Key: FLINK-2166 URL: https://issues.apache.org/jira/browse/FLINK-2166 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-2167) Add fromHCat() to TableEnvironment

2015-06-05 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2167: Summary: Add fromHCat() to TableEnvironment Key: FLINK-2167 URL: https://issues.apache.org/jira/browse/FLINK-2167 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-2188) Reading from big HBase Tables

2015-06-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14578784#comment-14578784 ] Fabian Hueske commented on FLINK-2188: -- Which version of Flink are you using (commit

[jira] [Updated] (FLINK-2188) Reading from big HBase Tables

2015-06-09 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2188: - Priority: Critical (was: Major) Reading from big HBase Tables -

[jira] [Created] (FLINK-2170) Add fromOrcFile() to TableEnvironment

2015-06-05 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2170: Summary: Add fromOrcFile() to TableEnvironment Key: FLINK-2170 URL: https://issues.apache.org/jira/browse/FLINK-2170 Project: Flink Issue Type: New Feature

[jira] [Assigned] (FLINK-2165) Rename Table conversion methods in TableEnvironment

2015-06-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-2165: Assignee: Fabian Hueske Rename Table conversion methods in TableEnvironment

[jira] [Created] (FLINK-2171) Add instruction to build Flink with Scala 2.11

2015-06-05 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2171: Summary: Add instruction to build Flink with Scala 2.11 Key: FLINK-2171 URL: https://issues.apache.org/jira/browse/FLINK-2171 Project: Flink Issue Type:

[jira] [Created] (FLINK-2192) ComplexIntegrationTest.complexIntegrationTest1 fails

2015-06-09 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2192: Summary: ComplexIntegrationTest.complexIntegrationTest1 fails Key: FLINK-2192 URL: https://issues.apache.org/jira/browse/FLINK-2192 Project: Flink Issue

[jira] [Created] (FLINK-2198) Build fails on Windows

2015-06-10 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2198: Summary: Build fails on Windows Key: FLINK-2198 URL: https://issues.apache.org/jira/browse/FLINK-2198 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-2199) Build with skipped tests fails on Windows

2015-06-10 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2199: Summary: Build with skipped tests fails on Windows Key: FLINK-2199 URL: https://issues.apache.org/jira/browse/FLINK-2199 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-2196) Missplaced Class in flink-java SortPartitionOperator

2015-06-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2196. Resolution: Fixed Fixed via a8e085078499319113a213575c9f057144395f98 Missplaced Class in

[jira] [Created] (FLINK-2196) Missplaced Class in flink-java SortPartitionOperator

2015-06-10 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2196: Summary: Missplaced Class in flink-java SortPartitionOperator Key: FLINK-2196 URL: https://issues.apache.org/jira/browse/FLINK-2196 Project: Flink Issue

[jira] [Commented] (FLINK-2192) ComplexIntegrationTest.complexIntegrationTest1 fails

2015-06-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580318#comment-14580318 ] Fabian Hueske commented on FLINK-2192: -- I see. Thanks for the explanation!

[jira] [Assigned] (FLINK-2199) Build with skipped tests fails on Windows

2015-06-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-2199: Assignee: Fabian Hueske Build with skipped tests fails on Windows

[jira] [Commented] (FLINK-2198) Build fails on Windows

2015-06-10 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14580597#comment-14580597 ] Fabian Hueske commented on FLINK-2198: -- The problem seems to be caused by the

[jira] [Updated] (FLINK-2246) Add chained combine driver strategy for ReduceFunction

2015-06-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2246: - Summary: Add chained combine driver strategy for ReduceFunction (was: Combiner not chained)

[jira] [Updated] (FLINK-2246) Add chained combine driver strategy for ReduceFunction

2015-06-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2246: - Issue Type: Improvement (was: Bug) Add chained combine driver strategy for ReduceFunction

[jira] [Commented] (FLINK-2246) Add chained combine driver strategy for ReduceFunction

2015-06-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14593351#comment-14593351 ] Fabian Hueske commented on FLINK-2246: -- This is an expected behavior. There is no

[jira] [Updated] (FLINK-2246) Add chained combine driver strategy for ReduceFunction

2015-06-19 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2246: - Component/s: (was: Core) Local Runtime Add chained combine driver strategy

[jira] [Created] (FLINK-2280) GenericTypeComparator.compare() does not respect ascending flag

2015-06-26 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-2280: Summary: GenericTypeComparator.compare() does not respect ascending flag Key: FLINK-2280 URL: https://issues.apache.org/jira/browse/FLINK-2280 Project: Flink

[jira] [Updated] (FLINK-2198) BlobManager tests fail on Windows

2015-06-11 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2198: - Summary: BlobManager tests fail on Windows (was: Build fails on Windows) BlobManager tests fail

<    1   2   3   4   5   6   7   8   9   10   >