[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654760#comment-14654760 ] ASF GitHub Bot commented on FLINK-1901: --- Github user ChengXiangLi commented on a dif

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-08-04 Thread ChengXiangLi
Github user ChengXiangLi commented on a diff in the pull request: https://github.com/apache/flink/pull/949#discussion_r36267541 --- Diff: pom.xml --- @@ -224,6 +224,12 @@ under the License. 3.2.1 +

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654757#comment-14654757 ] ASF GitHub Bot commented on FLINK-1901: --- Github user ChengXiangLi commented on a dif

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-08-04 Thread ChengXiangLi
Github user ChengXiangLi commented on a diff in the pull request: https://github.com/apache/flink/pull/949#discussion_r36267430 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/util/ReservoirSamplerWithReplacement.java --- @@ -0,0 +1,122 @@ +/* + *

[jira] [Commented] (FLINK-1901) Create sample operator for Dataset

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654751#comment-14654751 ] ASF GitHub Bot commented on FLINK-1901: --- Github user ChengXiangLi commented on the p

[GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for...

2015-08-04 Thread ChengXiangLi
Github user ChengXiangLi commented on the pull request: https://github.com/apache/flink/pull/949#issuecomment-127835084 Thanks for the review, Till. For your last suggestion, I'm aware of this issue before, but i didn't know the exist of RichMapPartitionFunction, thanks for reminding

[jira] [Commented] (FLINK-2480) Improving tests coverage for org.apache.flink.streaming.api

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654749#comment-14654749 ] ASF GitHub Bot commented on FLINK-2480: --- Github user HuangWHWHW commented on the pul

[GitHub] flink pull request: [FLINK-2480][test]Add tests for PrintSinkFunct...

2015-08-04 Thread HuangWHWHW
Github user HuangWHWHW commented on the pull request: https://github.com/apache/flink/pull/991#issuecomment-127834382 I still cannot see the CI. Does any one can help to support this CI info?? --- If your project is set up for it, you can reply to this email and have your reply ap

[GitHub] flink pull request: [FLINK-2477][Add]Add tests for SocketClientSin...

2015-08-04 Thread HuangWHWHW
Github user HuangWHWHW commented on the pull request: https://github.com/apache/flink/pull/977#issuecomment-127832555 @rmetzger Hi, Thank you very much. So,any progress lately? --- If your project is set up for it, you can reply to this email and have your reply appear on Gi

[jira] [Commented] (FLINK-2477) Add test for SocketClientSink

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654740#comment-14654740 ] ASF GitHub Bot commented on FLINK-2477: --- Github user HuangWHWHW commented on the pul

[jira] [Commented] (FLINK-2480) Improving tests coverage for org.apache.flink.streaming.api

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654734#comment-14654734 ] ASF GitHub Bot commented on FLINK-2480: --- GitHub user HuangWHWHW opened a pull reques

[GitHub] flink pull request: [FLINK-2480][TEST]Add test for PrintSinkFuncti...

2015-08-04 Thread HuangWHWHW
Github user HuangWHWHW closed the pull request at: https://github.com/apache/flink/pull/990 --- 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 e

[jira] [Commented] (FLINK-2480) Improving tests coverage for org.apache.flink.streaming.api

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654735#comment-14654735 ] ASF GitHub Bot commented on FLINK-2480: --- Github user HuangWHWHW closed the pull requ

[GitHub] flink pull request: [FLINK-2480][test]Add tests for PrintSinkFunct...

2015-08-04 Thread HuangWHWHW
GitHub user HuangWHWHW opened a pull request: https://github.com/apache/flink/pull/991 [FLINK-2480][test]Add tests for PrintSinkFunction Test PrintSinkFunction: set number of subtasks with 0 in runtime ctx to make prefix null. 1.set STD.OUT and test print system.out 2.set

[jira] [Commented] (FLINK-2480) Improving tests coverage for org.apache.flink.streaming.api

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654726#comment-14654726 ] ASF GitHub Bot commented on FLINK-2480: --- GitHub user HuangWHWHW opened a pull reques

[GitHub] flink pull request: [FLINK-2480][TEST]Add test for PrintSinkFuncti...

2015-08-04 Thread HuangWHWHW
GitHub user HuangWHWHW opened a pull request: https://github.com/apache/flink/pull/990 [FLINK-2480][TEST]Add test for PrintSinkFunction Test PrintSinkFunction: set number of subtasks with 0 in runtime ctx to make prefix null. 1.set STD.OUT and test print system.out 2.set

[jira] [Commented] (FLINK-2486) Remove unwanted null check in removeInstance function

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654713#comment-14654713 ] ASF GitHub Bot commented on FLINK-2486: --- Github user HuangWHWHW commented on the pul

[GitHub] flink pull request: [FLINK-2486]Remove unwanted null check in remo...

2015-08-04 Thread HuangWHWHW
Github user HuangWHWHW commented on the pull request: https://github.com/apache/flink/pull/989#issuecomment-127822096 The Instance in removeInstance() is always not null. Test cannot cover these lines. Look good to merge. --- If your project is set up for it, you can reply to

[jira] [Commented] (FLINK-2486) Remove unwanted null check in removeInstance function

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654709#comment-14654709 ] ASF GitHub Bot commented on FLINK-2486: --- GitHub user ffbin opened a pull request:

[GitHub] flink pull request: [FLINK-2486]Remove unwanted null check in remo...

2015-08-04 Thread ffbin
GitHub user ffbin opened a pull request: https://github.com/apache/flink/pull/989 [FLINK-2486]Remove unwanted null check in removeInstance function removeInstance() is called in getFreeSlotForTask()/getNewSlotForSharingGroup()/handleNewSlot()/instanceDied()/newInstanceAvailable().

[jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent

2015-08-04 Thread Sheetal Parade (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654674#comment-14654674 ] Sheetal Parade commented on FLINK-2314: --- Thanks Stephan, snapshot number of records

[jira] [Created] (FLINK-2486) Remove unwanted null check in removeInstance function

2015-08-04 Thread fangfengbin (JIRA)
fangfengbin created FLINK-2486: -- Summary: Remove unwanted null check in removeInstance function Key: FLINK-2486 URL: https://issues.apache.org/jira/browse/FLINK-2486 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654530#comment-14654530 ] ASF GitHub Bot commented on FLINK-2131: --- Github user sachingoel0101 commented on the

[GitHub] flink pull request: [FLINK-2131][ml]: Initialization schemes for k...

2015-08-04 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/757#issuecomment-127796214 This now implements the complete KMeans clustering algorithm along-with four initialization strategies, namely, from given centroids, random, kmeans++ and kmeans||

[jira] [Created] (FLINK-2485) Handle removal of Java Unsafe in Java9

2015-08-04 Thread Henry Saputra (JIRA)
Henry Saputra created FLINK-2485: Summary: Handle removal of Java Unsafe in Java9 Key: FLINK-2485 URL: https://issues.apache.org/jira/browse/FLINK-2485 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654489#comment-14654489 ] ASF GitHub Bot commented on FLINK-2105: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-08-04 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/907#issuecomment-127782760 Thanks for the excellent work! The PR is merged :-) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[jira] [Closed] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

2015-08-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2105. Resolution: Fixed Fix Version/s: (was: pre-apache) 0.10 Implemented wi

[jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654484#comment-14654484 ] ASF GitHub Bot commented on FLINK-2105: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-08-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/907 --- 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 enabl

[jira] [Commented] (FLINK-2106) Add outer joins to API, Optimizer, and Runtime

2015-08-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654445#comment-14654445 ] Fabian Hueske commented on FLINK-2106: -- Hi [~jkovacs] and [~r-pogalz], As I said be

[jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654388#comment-14654388 ] ASF GitHub Bot commented on FLINK-2105: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a...

2015-08-04 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/907#issuecomment-127770092 Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Commented] (FLINK-2457) Integrate Tuple0

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654357#comment-14654357 ] ASF GitHub Bot commented on FLINK-2457: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

2015-08-04 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/983#issuecomment-127764809 I tried to write a DataSet program that processes Tuple0 records and fails during execution. However, this is surprisingly hard. In fact, I didn't manage to break the sys

[jira] [Commented] (FLINK-2478) The page “FlinkML - Machine Learning for Flink“ https://ci.apache.org/projects/flink/flink-docs-master/libs/ml/ contains a dead link

2015-08-04 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654119#comment-14654119 ] Theodore Vasiloudis commented on FLINK-2478: Small typo remains in the section

[jira] [Closed] (FLINK-2205) Confusing entries in JM Webfrontend Job Configuration section

2015-08-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2205. Resolution: Fixed Fix Version/s: 0.9.1 0.10 Fixed for 0.9.1 with 8797890d2

[jira] [Closed] (FLINK-2442) PojoType fields not supported by field position keys

2015-08-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2442. Resolution: Fixed Fixed for 0.9.1 with 80d3478c0be6c346c0d33d966385c3db4eb06769 Fixed for 0.10 with

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

2015-08-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske resolved FLINK-2005. -- Resolution: Fixed Fix Version/s: 0.10 Fixed by 06b37bf550315bd1d5be7dc3ed6638fd21768e1a

[jira] [Reopened] (FLINK-2478) The page “FlinkML - Machine Learning for Flink“ https://ci.apache.org/projects/flink/flink-docs-master/libs/ml/ contains a dead link

2015-08-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reopened FLINK-2478: -- Thanks [~tvas]. Reopened to fix minor typos. > The page “FlinkML - Machine Learning for Flink“ >

[GitHub] flink pull request: [FLINK-2205] Fix confusing entries in JM UI Jo...

2015-08-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/927 --- 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 enabl

[jira] [Commented] (FLINK-2205) Confusing entries in JM Webfrontend Job Configuration section

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654159#comment-14654159 ] ASF GitHub Bot commented on FLINK-2205: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-1681) Remove the old Record API

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654160#comment-14654160 ] ASF GitHub Bot commented on FLINK-1681: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-2442) PojoType fields not supported by field position keys

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654158#comment-14654158 ] ASF GitHub Bot commented on FLINK-2442: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-1681] Remove Record API from jdbc modul...

2015-08-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/982 --- 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 enabl

[GitHub] flink pull request: [FLINK-2442] [fix] FieldPositionKeys support P...

2015-08-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/963 --- 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 enabl

[jira] [Comment Edited] (FLINK-2478) The page “FlinkML - Machine Learning for Flink“ https://ci.apache.org/projects/flink/flink-docs-master/libs/ml/ contains a dead link

2015-08-04 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654119#comment-14654119 ] Theodore Vasiloudis edited comment on FLINK-2478 at 8/4/15 6:41 PM:

[jira] [Commented] (FLINK-2457) Integrate Tuple0

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654056#comment-14654056 ] ASF GitHub Bot commented on FLINK-2457: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

2015-08-04 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/983#issuecomment-127693034 The empty file is exactly the problem. What happens if you read that file with a TypeSerializerInpitFormat typed for Tuple0? It will not return the same amount of Tup

[GitHub] flink pull request: [FLINK-2447] [java api] TypeExtractor returns ...

2015-08-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/986#issuecomment-127689216 I'm not a type extractor expert but since its fixing a bug and it has tests: +1 --- If your project is set up for it, you can reply to this email and have your reply ap

[jira] [Commented] (FLINK-2447) TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14654029#comment-14654029 ] ASF GitHub Bot commented on FLINK-2447: --- Github user rmetzger commented on the pull

[jira] [Commented] (FLINK-2457) Integrate Tuple0

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653998#comment-14653998 ] ASF GitHub Bot commented on FLINK-2457: --- Github user mjsax commented on the pull req

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

2015-08-04 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/983#issuecomment-127680821 I just tried using `TypeSerializerOutputFormat` for a DataSet sink. There is no error. The system only creates an empty file. How can I force the usage of a file-channel (i

[jira] [Commented] (FLINK-2398) Decouple StreamGraph Building from the API

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653942#comment-14653942 ] ASF GitHub Bot commented on FLINK-2398: --- GitHub user aljoscha opened a pull request:

[GitHub] flink pull request: [FLINK-2398][api-breaking] Introduce StreamGra...

2015-08-04 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/988 [FLINK-2398][api-breaking] Introduce StreamGraphGenerator This decouples the building of the StreamGraph from the API methods. Before, the methods would build the StreamGraph as they go. Now the

[jira] [Commented] (FLINK-2205) Confusing entries in JM Webfrontend Job Configuration section

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653883#comment-14653883 ] ASF GitHub Bot commented on FLINK-2205: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2205] Fix confusing entries in JM UI Jo...

2015-08-04 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/927#issuecomment-127661715 Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Commented] (FLINK-2442) PojoType fields not supported by field position keys

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653882#comment-14653882 ] ASF GitHub Bot commented on FLINK-2442: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-2442] [fix] FieldPositionKeys support P...

2015-08-04 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/963#issuecomment-127661514 Merging --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Commented] (FLINK-1681) Remove the old Record API

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653878#comment-14653878 ] ASF GitHub Bot commented on FLINK-1681: --- Github user fhueske commented on the pull r

[GitHub] flink pull request: [FLINK-1681] Remove Record API from jdbc modul...

2015-08-04 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/982#issuecomment-127661442 Merging (with updated commit message) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Assigned] (FLINK-2394) HadoopOutFormat OutputCommitter is default to FileOutputCommiter

2015-08-04 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-2394: Assignee: Fabian Hueske > HadoopOutFormat OutputCommitter is default to FileOutputCommiter

[jira] [Commented] (FLINK-2393) Add a "stateless at-least-once" mode for streaming

2015-08-04 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653842#comment-14653842 ] Henry Saputra commented on FLINK-2393: -- Thanks, Robert. This needs additional sub-ta

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

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653818#comment-14653818 ] ASF GitHub Bot commented on FLINK-2166: --- Github user jamescao commented on the pull

[GitHub] flink pull request: FLINK-2166. Add fromCsvFile() method to TableE...

2015-08-04 Thread jamescao
Github user jamescao commented on the pull request: https://github.com/apache/flink/pull/939#issuecomment-127654532 @twalthr Great! I will hold my work on this issue. I think FLINK-2167 will set a good reference for other fromXXX issues. --- If your project is set up for it, you

[jira] [Reopened] (FLINK-2393) Add a "stateless at-least-once" mode for streaming

2015-08-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-2393: --- I'm reopening the issue because the documentation hasn't been updated. According to our rules [1]:

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

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653777#comment-14653777 ] ASF GitHub Bot commented on FLINK-1882: --- Github user hsaputra commented on the pull

[GitHub] flink pull request: [FLINK-1882] Removed RemotedCollector

2015-08-04 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/985#issuecomment-127643465 +1 LGTM --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature en

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

2015-08-04 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653769#comment-14653769 ] Henry Saputra commented on FLINK-2005: -- No worries, just misunderstanding. > Remove

[jira] [Commented] (FLINK-2457) Integrate Tuple0

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653734#comment-14653734 ] ASF GitHub Bot commented on FLINK-2457: --- Github user mjsax commented on a diff in th

[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-tabpanel&focusedCommentId=14653760#comment-14653760 ] Chesnay Schepler commented on FLINK-2005: - Guess it's my fault you confused the is

[jira] [Commented] (FLINK-1681) Remove the old Record API

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653759#comment-14653759 ] ASF GitHub Bot commented on FLINK-1681: --- Github user hsaputra commented on the pull

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

2015-08-04 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653758#comment-14653758 ] Henry Saputra commented on FLINK-2005: -- PR: https://github.com/apache/flink/pull/982

[GitHub] flink pull request: [FLINK-1681] Remove Record API from jdbc modul...

2015-08-04 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/982#issuecomment-127639909 To be more precise, this addresses: FLINK-2005 --- 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 pr

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

2015-08-04 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653752#comment-14653752 ] Henry Saputra commented on FLINK-2005: -- Ah, my bad, I thought it was assigned to some

[GitHub] flink pull request: [FLINk-1680] Remove Tachyon test, rename maven...

2015-08-04 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/987#issuecomment-127636475 The problem is that we can only include this module for the hadoop2 builds. Therefore, I can not add the code to a module which is always present (`flink-tests`) --- I

[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-tabpanel&focusedCommentId=14653743#comment-14653743 ] Chesnay Schepler commented on FLINK-2005: - if you check the history you will see t

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

2015-08-04 Thread mjsax
Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/983#discussion_r36195314 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java --- @@ -391,6 +392,10 @@ protected TypeExtractor() {

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

2015-08-04 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653733#comment-14653733 ] Henry Saputra commented on FLINK-2005: -- [~Zentol], thanks for taking over this JIRA a

[GitHub] flink pull request: [FLINk-1680] Remove Tachyon test, rename maven...

2015-08-04 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/987#issuecomment-127634823 +1 --- 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 an

[jira] [Commented] (FLINK-2457) Integrate Tuple0

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653728#comment-14653728 ] ASF GitHub Bot commented on FLINK-2457: --- Github user twalthr commented on the pull r

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

2015-08-04 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/983#issuecomment-127633696 Sorry, I was just thinking loadly. You are right ;) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If you

[jira] [Commented] (FLINK-2457) Integrate Tuple0

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653711#comment-14653711 ] ASF GitHub Bot commented on FLINK-2457: --- Github user twalthr commented on a diff in

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

2015-08-04 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/983#discussion_r36193152 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java --- @@ -391,6 +392,10 @@ protected TypeExtractor() {

[GitHub] flink pull request: [FLINk-1680] Remove Tachyon test, rename maven...

2015-08-04 Thread StephanEwen
Github user StephanEwen commented on the pull request: https://github.com/apache/flink/pull/987#issuecomment-127629178 Looks good in general. Any reason that the tests cannot be part of `flink-tests`? Just thinking that we may reduce our maven project sprawl a bit ;-) --- If

[GitHub] flink pull request: [FLINK-1819][core]Allow access to RuntimeConte...

2015-08-04 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/966#issuecomment-127627512 Build failure is on unrelated tests. The recent error on `PartitionedStateCheckpointingITCase` and the other on `KafkaITCase`. --- If your project is set up for i

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

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653699#comment-14653699 ] ASF GitHub Bot commented on FLINK-1819: --- Github user sachingoel0101 commented on the

[jira] [Commented] (FLINK-2457) Integrate Tuple0

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653685#comment-14653685 ] ASF GitHub Bot commented on FLINK-2457: --- Github user mjsax commented on the pull req

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

2015-08-04 Thread mjsax
Github user mjsax commented on the pull request: https://github.com/apache/flink/pull/983#issuecomment-127623565 @twalthr thanks for the hint to `TypeInfoParser`. I will have a lock. But your statement about "introduce multiple bugs", seems to be a little bit to general... I did not b

[jira] [Commented] (FLINK-2457) Integrate Tuple0

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653681#comment-14653681 ] ASF GitHub Bot commented on FLINK-2457: --- Github user mjsax commented on a diff in th

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

2015-08-04 Thread mjsax
Github user mjsax commented on a diff in the pull request: https://github.com/apache/flink/pull/983#discussion_r36190666 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java --- @@ -391,6 +392,10 @@ protected TypeExtractor() {

[jira] [Commented] (FLINK-2457) Integrate Tuple0

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653670#comment-14653670 ] ASF GitHub Bot commented on FLINK-2457: --- Github user twalthr commented on a diff in

[GitHub] flink pull request: [FLINk-1680] Remove Tachyon test, rename maven...

2015-08-04 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/987 [FLINk-1680] Remove Tachyon test, rename maven module I removed our dependencies to Tachyon. The Tachyon test cluster (version 0.5) seemed to be unstable. Upgrading to Tachyon 0.7 was causing

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

2015-08-04 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/983#discussion_r36189782 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java --- @@ -391,6 +392,10 @@ protected TypeExtractor() {

[GitHub] flink pull request: [FLINK-2457] Integrate Tuple0

2015-08-04 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/983#issuecomment-127620260 I think this PR will introduce multiple bugs. @mjsax please also have a look into the `TypeInfoParser`. --- If your project is set up for it, you can reply to this em

[jira] [Commented] (FLINK-2457) Integrate Tuple0

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653666#comment-14653666 ] ASF GitHub Bot commented on FLINK-2457: --- Github user twalthr commented on the pull r

[GitHub] flink pull request: [FLINK-2472]Make JobClientActor poll JobManage...

2015-08-04 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/979#discussion_r36189042 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java --- @@ -59,11 +87,50 @@ public JobClientActor(

[jira] [Commented] (FLINK-2472) Make the JobClientActor check periodically if the submitted Job is still running and if the JobManager is still alive

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653662#comment-14653662 ] ASF GitHub Bot commented on FLINK-2472: --- Github user sachingoel0101 commented on a d

[GitHub] flink pull request: [FLINK-2472]Make JobClientActor poll JobManage...

2015-08-04 Thread sachingoel0101
Github user sachingoel0101 commented on a diff in the pull request: https://github.com/apache/flink/pull/979#discussion_r36188838 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java --- @@ -59,11 +87,50 @@ public JobClientActor(

[jira] [Commented] (FLINK-2472) Make the JobClientActor check periodically if the submitted Job is still running and if the JobManager is still alive

2015-08-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14653660#comment-14653660 ] ASF GitHub Bot commented on FLINK-2472: --- Github user sachingoel0101 commented on a d

  1   2   3   >