[jira] [Commented] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout

2015-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309085#comment-14309085 ] Chesnay Schepler commented on FLINK-1418: - is this not doable without breaking

[jira] [Commented] (FLINK-1486) Add a string to the print method to identify output

2015-02-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309070#comment-14309070 ] Chesnay Schepler commented on FLINK-1486: - +1, can see this being useful, and

[jira] [Created] (FLINK-1419) DistributedCache doesn't preserver files for subsequent operations

2015-01-19 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-1419: --- Summary: DistributedCache doesn't preserver files for subsequent operations Key: FLINK-1419 URL: https://issues.apache.org/jira/browse/FLINK-1419 Project:

[jira] [Assigned] (FLINK-1419) DistributedCache doesn't preserver files for subsequent operations

2015-01-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-1419: --- Assignee: Chesnay Schepler DistributedCache doesn't preserver files for subsequent

[jira] [Commented] (FLINK-1524) Job Manager does not handle the RequestArchivedJobs message

2015-02-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316300#comment-14316300 ] Chesnay Schepler commented on FLINK-1524: - this issue was discussed earlier today

[jira] [Updated] (FLINK-1524) Job Manager does not handle the RequestArchivedJobs message

2015-02-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-1524: Assignee: Till Rohrmann (was: Chesnay Schepler) Job Manager does not handle the

[jira] [Assigned] (FLINK-1524) Job Manager does not handle the RequestArchivedJobs message

2015-02-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-1524: --- Assignee: Chesnay Schepler Job Manager does not handle the RequestArchivedJobs

[jira] [Assigned] (FLINK-785) Add Chained operators for AllReduce and AllGroupReduce

2015-02-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-785: -- Assignee: Chesnay Schepler Add Chained operators for AllReduce and AllGroupReduce

[jira] [Assigned] (FLINK-1521) Some Chained Drivers do not respect object-reuse/non-reuse flag

2015-02-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-1521: --- Assignee: Chesnay Schepler Some Chained Drivers do not respect

[jira] [Commented] (FLINK-1459) Collect DataSet to client

2015-01-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14294945#comment-14294945 ] Chesnay Schepler commented on FLINK-1459: - there is currently a PR pending for

[jira] [Updated] (FLINK-1376) SubSlots are not properly released in case that a TaskManager fatally fails, leaving the system in a corrupted state

2015-01-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-1376: Assignee: Till Rohrmann SubSlots are not properly released in case that a TaskManager

[jira] [Assigned] (FLINK-1422) Missing usage example for withParameters

2015-01-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-1422: --- Assignee: Chesnay Schepler Missing usage example for withParameters

[jira] [Assigned] (FLINK-1260) Add custom partitioning to documentation

2015-01-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-1260: --- Assignee: Chesnay Schepler Add custom partitioning to documentation

[jira] [Commented] (FLINK-1521) Some Chained Drivers do not respect object-reuse/non-reuse flag

2015-02-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14318143#comment-14318143 ] Chesnay Schepler commented on FLINK-1521: - specifically, the following drivers are

[jira] [Updated] (FLINK-1260) Add custom partitioning to documentation

2015-04-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-1260: Assignee: (was: Chesnay Schepler) Add custom partitioning to documentation

[jira] [Updated] (FLINK-1422) Missing usage example for withParameters

2015-04-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-1422: Assignee: (was: Chesnay Schepler) Missing usage example for withParameters

[jira] [Created] (FLINK-1924) [Py] Refactor a few minor things

2015-04-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-1924: --- Summary: [Py] Refactor a few minor things Key: FLINK-1924 URL: https://issues.apache.org/jira/browse/FLINK-1924 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-1924) [Py] Refactor a few minor things

2015-04-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-1924: Affects Version/s: (was: 0.8.2) 0.9 Fix Version/s:

[jira] [Updated] (FLINK-1924) [Py] Refactor a few minor things

2015-04-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-1924: Affects Version/s: (was: 0.8.1) 0.8.2 Fix Version/s:

[jira] [Updated] (FLINK-1926) [Py] Sync Python API with other API's

2015-04-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-1926: Summary: [Py] Sync Python API with other API's (was: [Py] Sync Python API with otehr

[jira] [Created] (FLINK-1926) [Py] Sync Python API with otehr API's

2015-04-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-1926: --- Summary: [Py] Sync Python API with otehr API's Key: FLINK-1926 URL: https://issues.apache.org/jira/browse/FLINK-1926 Project: Flink Issue Type:

[jira] [Created] (FLINK-1927) [Py] Rework operator distribution

2015-04-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-1927: --- Summary: [Py] Rework operator distribution Key: FLINK-1927 URL: https://issues.apache.org/jira/browse/FLINK-1927 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-1945) Make python tests less verbose

2015-04-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-1945: --- Assignee: Chesnay Schepler Make python tests less verbose

[jira] [Commented] (FLINK-1945) Make python tests less verbose

2015-04-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514117#comment-14514117 ] Chesnay Schepler commented on FLINK-1945: - There are no print statements, all

[jira] [Commented] (FLINK-1961) DataSet.partitionCustom not documented

2015-04-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14519559#comment-14519559 ] Chesnay Schepler commented on FLINK-1961: - duplicate of FLINK-1260 ?

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

2015-04-13 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14492576#comment-14492576 ] Chesnay Schepler commented on FLINK-1872: - as i understand it [~hager] wants to

[jira] [Updated] (FLINK-1910) why this code flink not reurn value when use variable in filter

2015-04-18 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-1910: Description: {code:java} public static LinkedList values=new LinkedListString(); public

[jira] [Commented] (FLINK-1910) why this code flink not reurn value when use variable in filter

2015-04-18 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501395#comment-14501395 ] Chesnay Schepler commented on FLINK-1910: - save the LinkedList in a field inside

[jira] [Commented] (FLINK-1910) why this code flink not reurn value when use variable in filter

2015-04-18 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501384#comment-14501384 ] Chesnay Schepler commented on FLINK-1910: - okay, if you create an issue, please do

[jira] [Commented] (FLINK-1910) why this code flink not reurn value when use variable in filter

2015-04-18 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501433#comment-14501433 ] Chesnay Schepler commented on FLINK-1910: - This is what i meant by saving the

[jira] [Commented] (FLINK-2173) Python uses different tmp file than Flink

2015-06-05 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14574818#comment-14574818 ] Chesnay Schepler commented on FLINK-2173: - also, in case anyone is interested in

[jira] [Commented] (FLINK-2173) Python uses different tmp file than Flink

2015-06-05 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14574804#comment-14574804 ] Chesnay Schepler commented on FLINK-2173: - small addition from the mailing list:

[jira] [Assigned] (FLINK-2501) [py] Remove the need to specify types for transformations

2015-08-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-2501: --- Assignee: Chesnay Schepler [py] Remove the need to specify types for

[jira] [Commented] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase

2015-08-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699275#comment-14699275 ] Chesnay Schepler commented on FLINK-2448: - yep that's what i mean. the environment

[jira] [Created] (FLINK-2541) TypeComparator creation fails for T2T1byte[], byte[]

2015-08-18 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2541: --- Summary: TypeComparator creation fails for T2T1byte[], byte[] Key: FLINK-2541 URL: https://issues.apache.org/jira/browse/FLINK-2541 Project: Flink

[jira] [Comment Edited] (FLINK-2541) TypeComparator creation fails for T2T1byte[], byte[]

2015-08-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703841#comment-14703841 ] Chesnay Schepler edited comment on FLINK-2541 at 8/19/15 10:20 PM:

[jira] [Commented] (FLINK-2541) TypeComparator creation fails for T2T1byte[], byte[]

2015-08-19 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703841#comment-14703841 ] Chesnay Schepler commented on FLINK-2541: - I did some digging and found the

[jira] [Created] (FLINK-2562) [py] Implement KeySelectors

2015-08-22 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2562: --- Summary: [py] Implement KeySelectors Key: FLINK-2562 URL: https://issues.apache.org/jira/browse/FLINK-2562 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-2557) Manual type information via returns fails in DataSet API

2015-08-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-2557: --- Assignee: Chesnay Schepler Manual type information via returns fails in DataSet API

[jira] [Commented] (FLINK-2557) Manual type information via returns fails in DataSet API

2015-08-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708460#comment-14708460 ] Chesnay Schepler commented on FLINK-2557: - I have a fix ready so that a

[jira] [Resolved] (FLINK-2541) TypeComparator creation fails for T2T1byte[], byte[]

2015-08-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler resolved FLINK-2541. - Resolution: Invalid TypeComparator creation fails for T2T1byte[], byte[]

[jira] [Created] (FLINK-2565) Support primitive arrays as keys

2015-08-23 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2565: --- Summary: Support primitive arrays as keys Key: FLINK-2565 URL: https://issues.apache.org/jira/browse/FLINK-2565 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-2541) TypeComparator creation fails for T2T1byte[], byte[]

2015-08-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708379#comment-14708379 ] Chesnay Schepler commented on FLINK-2541: - since this is not actually an issue of

[jira] [Commented] (FLINK-2549) Add topK operator for DataSet

2015-08-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704437#comment-14704437 ] Chesnay Schepler commented on FLINK-2549: - is the only difference between topK()

[jira] [Commented] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase

2015-08-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699163#comment-14699163 ] Chesnay Schepler commented on FLINK-2448: - this has got nothing to do with the

[jira] [Commented] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase

2015-08-17 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14699204#comment-14699204 ] Chesnay Schepler commented on FLINK-2448: - alright, I'll check again, will be back

[jira] [Updated] (FLINK-2439) [py] Expand DataSet feature coverage

2015-08-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-2439: Description: An upcoming commit of mine will add the following methods to the Python API's

[jira] [Updated] (FLINK-2432) [py] Provide support for custom serialization

2015-08-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-2432: Issue Type: Sub-task (was: New Feature) Parent: FLINK-1926 [py] Provide support

[jira] [Updated] (FLINK-2439) [py] Expand DataSet feature coverage

2015-08-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-2439: Issue Type: Sub-task (was: Improvement) Parent: FLINK-1926 [py] Expand DataSet

[jira] [Updated] (FLINK-2440) [py] Expand Environment feature coverage

2015-08-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-2440: Issue Type: Sub-task (was: Improvement) Parent: FLINK-1926 [py] Expand

[jira] [Commented] (FLINK-2541) TypeComparator creation fails for T2T1byte[], byte[]

2015-08-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704589#comment-14704589 ] Chesnay Schepler commented on FLINK-2541: - within the ExpressionKeys constructor

[jira] [Assigned] (FLINK-2541) TypeComparator creation fails for T2T1byte[], byte[]

2015-08-20 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-2541: --- Assignee: Chesnay Schepler TypeComparator creation fails for T2T1byte[], byte[]

[jira] [Created] (FLINK-2556) Fix/Refactor pre-flight Key validation

2015-08-20 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2556: --- Summary: Fix/Refactor pre-flight Key validation Key: FLINK-2556 URL: https://issues.apache.org/jira/browse/FLINK-2556 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2431) [py] refactor PlanBinder/OperationInfo

2015-07-29 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2431: --- Summary: [py] refactor PlanBinder/OperationInfo Key: FLINK-2431 URL: https://issues.apache.org/jira/browse/FLINK-2431 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

2015-08-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14650396#comment-14650396 ] Chesnay Schepler commented on FLINK-2449: - But passing the original file wouldn't

[jira] [Commented] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

2015-08-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14650466#comment-14650466 ] Chesnay Schepler commented on FLINK-2449: - yes i may be overthinking this. think

[jira] [Commented] (FLINK-2457) Tuple.getTupleClass cannot generate Tuple0

2015-08-02 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14650713#comment-14650713 ] Chesnay Schepler commented on FLINK-2457: - if you want to remove it from the core

[jira] [Updated] (FLINK-1819) Allow access to RuntimeContext from Input and OutputFormats

2015-08-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-1819: Assignee: Sachin Goel Allow access to RuntimeContext from Input and OutputFormats

[jira] [Commented] (FLINK-2476) Remove unwanted check null of input1 in ConnectedDataStream

2015-08-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14653485#comment-14653485 ] Chesnay Schepler commented on FLINK-2476: - Fixed via

[jira] [Assigned] (FLINK-1882) Remove RemoteCollectorOutputFormat

2015-08-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-1882: --- Assignee: Chesnay Schepler Remove RemoteCollectorOutputFormat

[jira] [Commented] (FLINK-2005) Remove dependencies on Record APIs for flink-jdbc module

2015-08-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14653743#comment-14653743 ] Chesnay Schepler commented on FLINK-2005: - if you check the history you will see

[jira] [Commented] (FLINK-2005) Remove dependencies on Record APIs for flink-jdbc module

2015-08-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14653760#comment-14653760 ] Chesnay Schepler commented on FLINK-2005: - Guess it's my fault you confused the

[jira] [Assigned] (FLINK-2005) Remove dependencies on Record APIs for flink-jdbc module

2015-08-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-2005: --- Assignee: Chesnay Schepler Remove dependencies on Record APIs for flink-jdbc module

[jira] [Commented] (FLINK-2479) Refactoring of org.apache.flink.runtime.operators.testutils.TestData class

2015-08-04 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14653418#comment-14653418 ] Chesnay Schepler commented on FLINK-2479: - hmm...i don't think this issue is

[jira] [Commented] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

2015-07-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14649444#comment-14649444 ] Chesnay Schepler commented on FLINK-2449: - fair enough, scratch the part about

[jira] [Commented] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

2015-07-31 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14649323#comment-14649323 ] Chesnay Schepler commented on FLINK-2449: - I know i can. But this means that you

[jira] [Created] (FLINK-2440) [py] Expand Environment feature coverage

2015-07-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2440: --- Summary: [py] Expand Environment feature coverage Key: FLINK-2440 URL: https://issues.apache.org/jira/browse/FLINK-2440 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

2015-08-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14650214#comment-14650214 ] Chesnay Schepler commented on FLINK-2449: - i still think it needs a better

[jira] [Created] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests

2015-07-31 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2449: --- Summary: DistCache doesn't work with JavaProgram Collection tests Key: FLINK-2449 URL: https://issues.apache.org/jira/browse/FLINK-2449 Project: Flink

[jira] [Created] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase

2015-07-31 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2448: --- Summary: registerCacheFile fails with MultipleProgramsTestbase Key: FLINK-2448 URL: https://issues.apache.org/jira/browse/FLINK-2448 Project: Flink

[jira] [Created] (FLINK-2439) [py] Expand DataSet feature coverage

2015-07-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2439: --- Summary: [py] Expand DataSet feature coverage Key: FLINK-2439 URL: https://issues.apache.org/jira/browse/FLINK-2439 Project: Flink Issue Type:

[jira] [Created] (FLINK-2441) [py] Introduce an OpInfo object on the python side

2015-07-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2441: --- Summary: [py] Introduce an OpInfo object on the python side Key: FLINK-2441 URL: https://issues.apache.org/jira/browse/FLINK-2441 Project: Flink Issue

[jira] [Commented] (FLINK-2351) Deprecate config builders in InputFormats and Output formats

2015-07-30 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14647456#comment-14647456 ] Chesnay Schepler commented on FLINK-2351: - does this issue only apply to

[jira] [Comment Edited] (FLINK-2501) [py] Remove the need to specify types for transformations

2015-08-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14680732#comment-14680732 ] Chesnay Schepler edited comment on FLINK-2501 at 8/11/15 2:49 PM:

[jira] [Comment Edited] (FLINK-2501) [py] Remove the need to specify types for transformations

2015-08-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14681911#comment-14681911 ] Chesnay Schepler edited comment on FLINK-2501 at 8/11/15 3:02 PM:

[jira] [Commented] (FLINK-2501) [py] Remove the need to specify types for transformations

2015-08-11 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14681911#comment-14681911 ] Chesnay Schepler commented on FLINK-2501: - yes. modified (2) would mean that you

[jira] [Commented] (FLINK-2495) Add a null point check in API DataStream.union

2015-08-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661519#comment-14661519 ] Chesnay Schepler commented on FLINK-2495: - Yes you can get a NullPointerException

[jira] [Commented] (FLINK-2107) Implement Hash Outer Join algorithm

2015-08-07 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14662083#comment-14662083 ] Chesnay Schepler commented on FLINK-2107: - looks like an optimization thing to me.

[jira] [Commented] (FLINK-2501) [py] Remove the need to specify types for transformations

2015-08-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14680502#comment-14680502 ] Chesnay Schepler commented on FLINK-2501: - is the only difference between (2) and

[jira] [Commented] (FLINK-2501) [py] Remove the need to specify types for transformations

2015-08-10 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14680732#comment-14680732 ] Chesnay Schepler commented on FLINK-2501: - hm. one

[jira] [Created] (FLINK-2501) [py] Remove the need to specify types for transformations

2015-08-08 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-2501: --- Summary: [py] Remove the need to specify types for transformations Key: FLINK-2501 URL: https://issues.apache.org/jira/browse/FLINK-2501 Project: Flink

[jira] [Assigned] (FLINK-2173) Python uses different tmp file than Flink

2015-07-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-2173: --- Assignee: Chesnay Schepler Python uses different tmp file than Flink

[jira] [Commented] (FLINK-1982) Remove dependencies on Record for Flink runtime and core

2015-10-21 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14966820#comment-14966820 ] Chesnay Schepler commented on FLINK-1982: - Which tests specifically still need porting? > Remove

[jira] [Commented] (FLINK-1988) Port Record API based tests in the common.io

2015-10-21 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14966819#comment-14966819 ] Chesnay Schepler commented on FLINK-1988: - is this issue still valid [~hsaputra]? I couldn't find

[jira] [Assigned] (FLINK-2901) Several flink-test ITCases depend on Record API features

2015-10-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-2901: --- Assignee: Chesnay Schepler > Several flink-test ITCases depend on Record API

[jira] [Updated] (FLINK-2559) Fix Javadoc Code Examples

2015-10-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-2559: Assignee: (was: Chesnay Schepler) > Fix Javadoc Code Examples >

[jira] [Assigned] (FLINK-2559) Fix Javadoc Code Examples

2015-10-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-2559: --- Assignee: Chesnay Schepler > Fix Javadoc Code Examples > - >

[jira] [Commented] (FLINK-2848) Refactor Flink benchmarks with JMH and move to flink-benchmark module

2015-10-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14968713#comment-14968713 ] Chesnay Schepler commented on FLINK-2848: - could you make a single PR for all files? > Refactor

[jira] [Commented] (FLINK-2848) Refactor Flink benchmarks with JMH and move to flink-benchmark module

2015-10-22 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14968784#comment-14968784 ] Chesnay Schepler commented on FLINK-2848: - i doubt that it will, the changes made should be a)

[jira] [Closed] (FLINK-2476) Remove unwanted check null of input1 in ConnectedDataStream

2015-10-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2476. --- Resolution: Fixed > Remove unwanted check null of input1 in ConnectedDataStream >

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

2015-10-27 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14976217#comment-14976217 ] Chesnay Schepler commented on FLINK-2662: - I tried reproducing the error but the shipping strategy

[jira] [Commented] (FLINK-2899) The groupReduceOn* methods which take types as a parameter fail with TypeErasure

2015-10-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14980448#comment-14980448 ] Chesnay Schepler commented on FLINK-2899: - Looking at the Graph class, when groupReduceOnEdges

[jira] [Updated] (FLINK-2930) ExecutionConfig execution retry delay not respected

2015-10-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-2930: Assignee: Ufuk Celebi > ExecutionConfig execution retry delay not respected >

[jira] [Commented] (FLINK-2899) The groupReduceOn* methods which take types as a parameter fail with TypeErasure

2015-10-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14980414#comment-14980414 ] Chesnay Schepler commented on FLINK-2899: - can you post the full exception? > The groupReduceOn*

[jira] [Assigned] (FLINK-2351) Deprecate config builders in InputFormats and Output formats

2015-10-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-2351: --- Assignee: Chesnay Schepler > Deprecate config builders in InputFormats and Output

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

2015-10-28 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14978670#comment-14978670 ] Chesnay Schepler commented on FLINK-2662: - are you sure that you ran it both times against the

[jira] [Commented] (FLINK-2901) Several flink-test ITCases depend on Record API features

2015-10-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14973272#comment-14973272 ] Chesnay Schepler commented on FLINK-2901: - What about {{recordJobs}}? Should all of them be ported

[jira] [Updated] (FLINK-2901) Several flink-test ITCases depend on Record API features

2015-10-25 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-2901: Description: There are several ITCases and utility classes in {{flink-tests}} that depend

[jira] [Commented] (FLINK-2851) Merge Language-Binding into Python API and move to flink-libraries

2015-11-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15002833#comment-15002833 ] Chesnay Schepler commented on FLINK-2851: - Resolved in 824074aac620a940d33cb484f97e16c640d5d6b7.

[jira] [Closed] (FLINK-2851) Merge Language-Binding into Python API and move to flink-libraries

2015-11-12 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-2851. --- Resolution: Fixed > Merge Language-Binding into Python API and move to flink-libraries >

  1   2   3   4   5   6   7   8   9   10   >