[jira] [Assigned] (FLINK-5336) Make Path immutable

2016-12-15 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5336: Assignee: Anton Solovev > Make Path immutable > --- > > Key

[jira] [Updated] (FLINK-5336) Make Path immutable

2016-12-15 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5336: - Assignee: (was: Anton Solovev) > Make Path immutable > --- > >

[GitHub] flink pull request #3009: [FLINK-5255] Improve single row check in DataSetSi...

2016-12-15 Thread AlexanderShoshin
GitHub user AlexanderShoshin opened a pull request: https://github.com/apache/flink/pull/3009 [FLINK-5255] Improve single row check in DataSetSingleRowJoinRule DataSetSingleRowJoinRule now supports not only `LogicalAggregate` as single row input, but also `LogicalCalc`, `LogicalProj

[jira] [Commented] (FLINK-5255) Improve single row check in DataSetSingleRowJoinRule

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750737#comment-15750737 ] ASF GitHub Bot commented on FLINK-5255: --- GitHub user AlexanderShoshin opened a pull

[GitHub] flink issue #2629: [FLINK-4391] Provide support for asynchronous operations ...

2016-12-15 Thread bjlovegithub
Github user bjlovegithub commented on the issue: https://github.com/apache/flink/pull/2629 hi @tillrohrmann @mproch I have updated the PR, including a wrapper class for `RuntimeContext` specialized for `RichAsyncFunction`. --- If your project is set up for it, you can reply to this e

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750741#comment-15750741 ] ASF GitHub Bot commented on FLINK-4391: --- Github user bjlovegithub commented on the i

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750749#comment-15750749 ] ASF GitHub Bot commented on FLINK-4391: --- Github user mproch commented on the issue:

[GitHub] flink issue #2629: [FLINK-4391] Provide support for asynchronous operations ...

2016-12-15 Thread mproch
Github user mproch commented on the issue: https://github.com/apache/flink/pull/2629 @bjlovegithub @tillrohrmann thanks for quick reply :+1: I really appreciate your work! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[GitHub] flink issue #2914: [FLINK-4611] [kinesis] Make "AUTO" credential provider as...

2016-12-15 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2914 I've tested the `AUTO` config behaviour, and it works as expected in EMR / EC2 environments, so the Kinesis API part should be working fine. Let me summarize the new behaviour after the prop

[jira] [Commented] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750759#comment-15750759 ] ASF GitHub Bot commented on FLINK-4611: --- Github user tzulitai commented on the issue

[jira] [Assigned] (FLINK-5186) Move Row and RowTypeInfo into Flink core

2016-12-15 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-5186: Assignee: Anton Solovev > Move Row and RowTypeInfo into Flink core > --

[jira] [Updated] (FLINK-5186) Move Row and RowTypeInfo into Flink core

2016-12-15 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5186: - Assignee: (was: Anton Solovev) > Move Row and RowTypeInfo into Flink core > --

[jira] [Assigned] (FLINK-3109) Join two streams with two different buffer time

2016-12-15 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-3109: Assignee: Anton Solovev > Join two streams with two different buffer time > ---

[GitHub] flink issue #2925: [FLINK-4574] [kinesis] Strengthen fetch interval implemen...

2016-12-15 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2925 Thanks for working on this @tony810430! I'd like to discuss a bit on the design before a more detailed review for this PR. If I'm correct, with this PR we will be creating a separate shard

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750804#comment-15750804 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tzulitai commented on the issue

[GitHub] flink issue #2914: [FLINK-4611] [kinesis] Make "AUTO" credential provider as...

2016-12-15 Thread tony810430
Github user tony810430 commented on the issue: https://github.com/apache/flink/pull/2914 The new behavior is as what you have said. The second behavior is for letting configuration in previous version work like before, otherwise job will fail in this version if it couldn't get the aws

[jira] [Commented] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750839#comment-15750839 ] ASF GitHub Bot commented on FLINK-4611: --- Github user tony810430 commented on the iss

[jira] [Created] (FLINK-5343) Add option to CsvTableSink to overwrite files

2016-12-15 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-5343: Summary: Add option to CsvTableSink to overwrite files Key: FLINK-5343 URL: https://issues.apache.org/jira/browse/FLINK-5343 Project: Flink Issue Type: Impro

[jira] [Commented] (FLINK-5247) Setting allowedLateness to a non-zero value should throw exception for processing-time windows

2016-12-15 Thread Rohit Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750858#comment-15750858 ] Rohit Agarwal commented on FLINK-5247: -- Sorry, I am a bit busy these days. I will try

[GitHub] flink pull request #3010: [minor] Fix String formats in FlinkDistributionOve...

2016-12-15 Thread BorisOsipov
GitHub user BorisOsipov opened a pull request: https://github.com/apache/flink/pull/3010 [minor] Fix String formats in FlinkDistributionOverlay and Task Fix a couple mistakes in String.format(..) You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] flink issue #2925: [FLINK-4574] [kinesis] Strengthen fetch interval implemen...

2016-12-15 Thread tony810430
Github user tony810430 commented on the issue: https://github.com/apache/flink/pull/2925 I think it would not be sub-optimal, because it still need to separate consuming thread and ingesting thread, which emits records to next operator. The reason for this implementation is because `T

[jira] [Commented] (FLINK-4574) Strengthen fetch interval implementation in Kinesis consumer

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750873#comment-15750873 ] ASF GitHub Bot commented on FLINK-4574: --- Github user tony810430 commented on the iss

[jira] [Commented] (FLINK-3109) Join two streams with two different buffer time

2016-12-15 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750880#comment-15750880 ] Anton Solovev commented on FLINK-3109: -- Hi [~yangjunpro], [~StephanEwen] has this iss

[jira] [Updated] (FLINK-3109) Join two streams with two different buffer time

2016-12-15 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-3109: - Assignee: (was: Anton Solovev) > Join two streams with two different buffer time > ---

[jira] [Closed] (FLINK-4610) Replace keySet/getValue with entrySet in UdfAnalyzerUtils

2016-12-15 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev closed FLINK-4610. Resolution: Fixed Assignee: Alexander Pivovarov > Replace keySet/getValue with entrySet in Udf

[GitHub] flink issue #3003: [FLINK-5188] Create analog of RowCsvInputFormat in java a...

2016-12-15 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3003 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 and wishes so, or if the fea

[GitHub] flink issue #2961: [FLINK-5266] [table] eagerly project unused fields when s...

2016-12-15 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2961 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 and wishes so, or if the fea

[GitHub] flink issue #2968: [FLINK-5187] [core] Create analog of Row and RowTypeInfo ...

2016-12-15 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2968 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 and wishes so, or if the fea

[jira] [Commented] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750977#comment-15750977 ] ASF GitHub Bot commented on FLINK-5266: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-5187) Create analog of Row in core

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750978#comment-15750978 ] ASF GitHub Bot commented on FLINK-5187: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-5188) Adjust all the imports referencing types.Row and move RowCsvInputFormat

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750979#comment-15750979 ] ASF GitHub Bot commented on FLINK-5188: --- Github user fhueske commented on the issue:

[GitHub] flink issue #3004: [FLINK-5189] Delete Row and its related classes from tabl...

2016-12-15 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/3004 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 and wishes so, or if the fea

[jira] [Commented] (FLINK-5189) Delete Row in table api

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750981#comment-15750981 ] ASF GitHub Bot commented on FLINK-5189: --- Github user fhueske commented on the issue:

[GitHub] flink issue #2914: [FLINK-4611] [kinesis] Make "AUTO" credential provider as...

2016-12-15 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2914 Thanks for the clarification. > If the user has provided AWS_SECRET_ACCESS_KEY and AWS_ACCESS_KEY_ID, regardless of the credential provider type provided (i.e. even if it's set to AUTO

[jira] [Commented] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750999#comment-15750999 ] ASF GitHub Bot commented on FLINK-4611: --- Github user tzulitai commented on the issue

[GitHub] flink pull request #:

2016-12-15 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/commit/79d7e3017efe7c96e449e6f339fd7184ef3d1ba2#commitcomment-20198048 This commit accidentally removed the newly added docs about Externalized Checkpoints (in `setup/fault_tolerance.md`. @alpinegizmo @Step

[GitHub] flink issue #3005: [FLINK-5335] Allow ListCheckpointed user functions to ret...

2016-12-15 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/3005 Thanks for your work! 😃 I merged. Could you please close this PR and the Jira issue? --- If your project is set up for it, you can reply to this email and have your reply appear on GitH

[jira] [Commented] (FLINK-5335) Allow ListCheckpointed user functions to return null

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751006#comment-15751006 ] ASF GitHub Bot commented on FLINK-5335: --- Github user aljoscha commented on the issue

[GitHub] flink pull request #:

2016-12-15 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/commit/79d7e3017efe7c96e449e6f339fd7184ef3d1ba2#commitcomment-20198072 OK, just found it in `setup/checkpoints.md`. Perfect place for it 👍 --- If your project is set up for it, you can reply to this em

[GitHub] flink pull request #3005: [FLINK-5335] Allow ListCheckpointed user functions...

2016-12-15 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/3005 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Commented] (FLINK-5335) Allow ListCheckpointed user functions to return null

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751010#comment-15751010 ] ASF GitHub Bot commented on FLINK-5335: --- Github user StefanRRichter closed the pull

[jira] [Closed] (FLINK-5335) Allow ListCheckpointed user functions to return null

2016-12-15 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-5335. - Resolution: Implemented Fix Version/s: 1.2.0 > Allow ListCheckpointed user functions to ret

[GitHub] flink issue #2729: [FLINK-4883]Prevent UDFs implementations through Scala si...

2016-12-15 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2729 it should just be a warning in the Javadoc/Scaladoc, probably in bold. That's what I meant. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751028#comment-15751028 ] ASF GitHub Bot commented on FLINK-4883: --- Github user aljoscha commented on the issue

[jira] [Commented] (FLINK-5342) Setting the parallelism automatically for operators base on cost model

2016-12-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751031#comment-15751031 ] Fabian Hueske commented on FLINK-5342: -- The cost model we are using for optimizing re

[jira] [Updated] (FLINK-5338) Make printing sinks non-parallel

2016-12-15 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5338: - Description: This is a suggestion, up for discussion. I suggest to make the {{DataStream::print()

[GitHub] flink pull request #2968: [FLINK-5187] [core] Create analog of Row and RowTy...

2016-12-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2968 --- 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 enab

[GitHub] flink pull request #3003: [FLINK-5188] Create analog of RowCsvInputFormat in...

2016-12-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3003 --- 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 enab

[GitHub] flink pull request #3004: [FLINK-5189] Delete Row and its related classes fr...

2016-12-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3004 --- 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 enab

[GitHub] flink pull request #2961: [FLINK-5266] [table] eagerly project unused fields...

2016-12-15 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2961 --- 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 enab

[jira] [Commented] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields

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

[jira] [Commented] (FLINK-5188) Adjust all the imports referencing types.Row and move RowCsvInputFormat

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

[jira] [Commented] (FLINK-5189) Delete Row in table api

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

[jira] [Resolved] (FLINK-4446) Move Flume Sink from Flink to Bahir

2016-12-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4446. --- Resolution: Fixed Fix Version/s: 1.2.0 Resolved for Flink in http://git-wip-us.apache.

[jira] [Commented] (FLINK-5343) Add option to CsvTableSink to overwrite files

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751091#comment-15751091 ] ASF GitHub Bot commented on FLINK-5343: --- GitHub user fhueske opened a pull request:

[GitHub] flink pull request #3011: [FLINK-5343] [table] Add support to overwrite file...

2016-12-15 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/3011 [FLINK-5343] [table] Add support to overwrite files with CsvTableSink. Adds a `WriteMode` parameter to the `CsvTableSink` to allow overwriting existing files. You can merge this pull request into a

[GitHub] flink pull request #2723: [FLINK-3617] Fix for OptionSerializer.

2016-12-15 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2723#discussion_r92588685 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/typeutils/SerializerTestBase.java --- @@ -409,9 +402,26 @@ else if (should instanceof Thro

[jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751099#comment-15751099 ] ASF GitHub Bot commented on FLINK-3617: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #2723: [FLINK-3617] Fix for OptionSerializer.

2016-12-15 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2723#discussion_r92588478 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/typeutils/SerializerTestBase.java --- @@ -409,9 +402,26 @@ else if (should instanceof Thro

[jira] [Commented] (FLINK-3617) NPE from CaseClassSerializer when dealing with null Option field

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751098#comment-15751098 ] ASF GitHub Bot commented on FLINK-3617: --- Github user StephanEwen commented on a diff

[jira] [Closed] (FLINK-5189) Delete Row in table api

2016-12-15 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev closed FLINK-5189. > Delete Row in table api > --- > > Key: FLINK-5189 >

[jira] [Resolved] (FLINK-5189) Delete Row in table api

2016-12-15 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev resolved FLINK-5189. -- Resolution: Fixed > Delete Row in table api > --- > > Key: F

[jira] [Closed] (FLINK-5188) Adjust all the imports referencing types.Row and move RowCsvInputFormat

2016-12-15 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev closed FLINK-5188. Resolution: Fixed > Adjust all the imports referencing types.Row and move RowCsvInputFormat > --

[jira] [Closed] (FLINK-5186) Move Row and RowTypeInfo into Flink core

2016-12-15 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev closed FLINK-5186. Resolution: Fixed > Move Row and RowTypeInfo into Flink core > -

[jira] [Closed] (FLINK-5187) Create analog of Row in core

2016-12-15 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev closed FLINK-5187. Resolution: Fixed > Create analog of Row in core > > >

[GitHub] flink pull request #3012: [FLINK-2186] Add readCsvAsRow methods to CsvReader...

2016-12-15 Thread tonycox
GitHub user tonycox opened a pull request: https://github.com/apache/flink/pull/3012 [FLINK-2186] Add readCsvAsRow methods to CsvReader and scala ExecutionEnv Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consid

[jira] [Commented] (FLINK-2186) Rework CSV import to support very wide files

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751122#comment-15751122 ] ASF GitHub Bot commented on FLINK-2186: --- GitHub user tonycox opened a pull request:

[GitHub] flink issue #2995: [FLINK-5320] Fix result TypeInformation in WindowedStream...

2016-12-15 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2995 I have some work in the window translation tests that should make testing this more easy: https://issues.apache.org/jira/browse/FLINK-5237 @StephanEwen what do you think about merging this i

[jira] [Commented] (FLINK-5320) Fix result TypeInformation in WindowedStream.fold(ACC, FoldFunction, WindowFunction)

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751130#comment-15751130 ] ASF GitHub Bot commented on FLINK-5320: --- Github user aljoscha commented on the issue

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751145#comment-15751145 ] ASF GitHub Bot commented on FLINK-3848: --- Github user tonycox commented on the issue:

[GitHub] flink issue #2810: [FLINK-3848] Add ProjectableTableSource interface and tra...

2016-12-15 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/2810 @fhueske I update this PR according to last changes in master --- 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

[jira] [Commented] (FLINK-4905) Kafka test instability IllegalStateException: Client is not started

2016-12-15 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751146#comment-15751146 ] Stephan Ewen commented on FLINK-4905: - I saw the issue happening again: https://api.t

[jira] [Commented] (FLINK-5338) Make printing sinks non-parallel

2016-12-15 Thread David Anderson (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751151#comment-15751151 ] David Anderson commented on FLINK-5338: --- When doing training, I like that DataStream

[jira] [Commented] (FLINK-5108) Remove ClientShutdownHook during job execution

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751162#comment-15751162 ] ASF GitHub Bot commented on FLINK-5108: --- Github user mxm commented on the issue:

[GitHub] flink issue #2928: [FLINK-5108] Remove ClientShutdownHook during job executi...

2016-12-15 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2928 Thanks for your understanding :) Could you please close this PR? --- 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 h

[jira] [Updated] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

2016-12-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3398: -- Priority: Critical (was: Blocker) > Flink Kafka consumer should support auto-commit opt-outs >

[jira] [Closed] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields

2016-12-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5266. Resolution: Fixed Fix Version/s: 1.2.0 Fixed with 15e7f0a8c7fd161d5847e7b2afae35b212ea23f0 >

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-15 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751212#comment-15751212 ] Ivan Mushketyk commented on FLINK-5280: --- Hi [~jark], thank you for your reply. I se

[jira] [Commented] (FLINK-5108) Remove ClientShutdownHook during job execution

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751233#comment-15751233 ] ASF GitHub Bot commented on FLINK-5108: --- Github user Renkai closed the pull request

[GitHub] flink pull request #2928: [FLINK-5108] Remove ClientShutdownHook during job ...

2016-12-15 Thread Renkai
Github user Renkai closed the pull request at: https://github.com/apache/flink/pull/2928 --- 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 enab

[GitHub] flink issue #2999: [FLINK-5332] [core] Synchronize FileSystem::initOutPathLo...

2016-12-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2999 Manually merged in 2f3ad58b7b73463aa1827baef0eb2e9d87fdb882 --- 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 no

[jira] [Commented] (FLINK-5332) Non-thread safe FileSystem::initOutPathLocalFS() can cause lost files/directories in local execution

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751246#comment-15751246 ] ASF GitHub Bot commented on FLINK-5332: --- Github user StephanEwen commented on the is

[GitHub] flink pull request #2999: [FLINK-5332] [core] Synchronize FileSystem::initOu...

2016-12-15 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/2999 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-5332) Non-thread safe FileSystem::initOutPathLocalFS() can cause lost files/directories in local execution

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751247#comment-15751247 ] ASF GitHub Bot commented on FLINK-5332: --- Github user StephanEwen closed the pull req

[jira] [Commented] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751281#comment-15751281 ] ASF GitHub Bot commented on FLINK-4973: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3008: [FLINK-4973] Let LatencyMarksEmitter use StreamTask's Pro...

2016-12-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3008 Looks good to me, +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 and wishes

[GitHub] flink issue #3008: [FLINK-4973] Let LatencyMarksEmitter use StreamTask's Pro...

2016-12-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3008 Just for curiosity: I think that could have been solved also without extending the ProcessingTimeService for periodic tasks - each task could simply schedule its successor. --- If your project

[jira] [Commented] (FLINK-4973) Flakey Yarn tests due to recently added latency marker

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751279#comment-15751279 ] ASF GitHub Bot commented on FLINK-4973: --- Github user StephanEwen commented on the is

[jira] [Commented] (FLINK-4927) Implement FLI-6 YARN Resource Manager

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751288#comment-15751288 ] ASF GitHub Bot commented on FLINK-4927: --- Github user StephanEwen commented on the is

[GitHub] flink issue #2936: [FLINK-4927] [yarn] refine YARN Resource manager accordin...

2016-12-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2936 This has already been merged to the flip-6 branch, so this pull request can be closed. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as w

[GitHub] flink issue #2877: [FLINK-5141] Implement Flip6LocalStreamEnvironment to run...

2016-12-15 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2877 This has already been merged to the flip-6 branch, so this pull request can be closed. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as w

[jira] [Commented] (FLINK-5141) Implement Flip6LocalStreamEnvironment to run new mini cluster in flip-6 branch

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751286#comment-15751286 ] ASF GitHub Bot commented on FLINK-5141: --- Github user StephanEwen commented on the is

[jira] [Updated] (FLINK-5343) Add more option to CsvTableSink

2016-12-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5343: - Summary: Add more option to CsvTableSink (was: Add option to CsvTableSink to overwrite files) >

[jira] [Updated] (FLINK-5343) Add more option to CsvTableSink

2016-12-15 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5343: - Description: The {{CsvTableSink}} does currently only offer very few configuration options. We sh

[jira] [Commented] (FLINK-5280) Extend TableSource to support nested data

2016-12-15 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751325#comment-15751325 ] Jark Wu commented on FLINK-5280: Hi [~ivan.mushketyk], Yes, you are right. In your case,

[GitHub] flink pull request #2914: [FLINK-4611] [kinesis] Make "AUTO" credential prov...

2016-12-15 Thread tony810430
Github user tony810430 commented on a diff in the pull request: https://github.com/apache/flink/pull/2914#discussion_r92583846 --- Diff: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerTest.java --- @@ -87,18

[jira] [Commented] (FLINK-4611) Make "AUTO" credential provider as default for Kinesis Connector

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751341#comment-15751341 ] ASF GitHub Bot commented on FLINK-4611: --- Github user tony810430 commented on a diff

[jira] [Commented] (FLINK-5008) Update quickstart documentation

2016-12-15 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751370#comment-15751370 ] ASF GitHub Bot commented on FLINK-5008: --- Github user NicoK commented on a diff in th

[GitHub] flink pull request #2764: [FLINK-5008] Update quickstart documentation

2016-12-15 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/2764#discussion_r92608383 --- Diff: docs/quickstart/java_api_quickstart.md --- @@ -46,39 +46,79 @@ Use one of the following commands to __create a project__: {% highlight bash %

[GitHub] flink pull request #2764: [FLINK-5008] Update quickstart documentation

2016-12-15 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/2764#discussion_r92608012 --- Diff: docs/quickstart/run_example_quickstart.md --- @@ -90,23 +92,23 @@ use it in our program. Edit the `dependencies` section so that it looks like thi

  1   2   3   >