[GitHub] flink pull request #2468: [FLINK-3580] [table] Add OVERLAPS function

2016-09-03 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2468 [FLINK-3580] [table] Add OVERLAPS function Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes ta

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

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

[GitHub] flink issue #2459: [FLINK-4561] replace all the scala version as a `scala.bi...

2016-09-03 Thread shijinkui
Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/2459 @chiwanpark @StephanEwen thanks for the reply. dependency's version which contain scala 2.10 replace as property? --- If your project is set up for it, you can reply to this email and have your r

[jira] [Commented] (FLINK-4561) replace all the scala version as a `scala.binary.version` property

2016-09-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15460619#comment-15460619 ] ASF GitHub Bot commented on FLINK-4561: --- Github user shijinkui commented on the issu

[GitHub] flink pull request #2469: [FLINK-4572] [gelly] Convert to negative in LongVa...

2016-09-03 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2469 [FLINK-4572] [gelly] Convert to negative in LongValueToIntValue The Gelly drivers expect that scale 32 edges, represented by the lower 32 bits of long values, can be converted to int values. Value

[jira] [Commented] (FLINK-4572) Convert to negative in LongValueToIntValue

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

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

2016-09-03 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-4574: -- Summary: Strengthen fetch interval implementation in Kinesis consumer Key: FLINK-4574 URL: https://issues.apache.org/jira/browse/FLINK-4574 Project: Flink

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

2016-09-03 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4574: --- Description: As pointed out by [~rmetzger], right now the fetch interval implementatio

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

2016-09-03 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4574: --- Description: As pointed out by [~rmetzger], right now the fetch interval implementatio

[jira] [Commented] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema

2016-09-03 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15461269#comment-15461269 ] Tzu-Li (Gordon) Tai commented on FLINK-4194: On second thought, I think we oug

[jira] [Assigned] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO"

2016-09-03 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-4559: -- Assignee: Tzu-Li (Gordon) Tai > Kinesis Producer not setting credentials provid

[GitHub] flink pull request #2470: [FLINK-4559][kinesis-connector] Fix AWSUtil.getCre...

2016-09-03 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/2470 [FLINK-4559][kinesis-connector] Fix AWSUtil.getCredentialsProvider() to not return null Let `AWSUtil#getCredentialsProvider` return a `DefaultAWSCredentialsProviderChain` instead of `null` when

[jira] [Commented] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO"

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

[GitHub] flink issue #2470: [FLINK-4559][kinesis-connector] Fix AWSUtil.getCredential...

2016-09-03 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2470 Looks good to me. Should we also create a ticket to make AUTO the default as this checks for credentials in multiple places? http://docs.aws.amazon.com/java-sdk/latest/developer-guid

[jira] [Commented] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO"

2016-09-03 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15461654#comment-15461654 ] ASF GitHub Bot commented on FLINK-4559: --- Github user greghogan commented on the issu

[GitHub] flink pull request #2471: Broken links on website

2016-09-03 Thread apivovarov
GitHub user apivovarov opened a pull request: https://github.com/apache/flink/pull/2471 Broken links on website Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your changes take all of the it

[jira] [Commented] (FLINK-4513) Kafka connector documentation refers to Flink 1.1-SNAPSHOT

2016-09-03 Thread Neelesh Srinivas Salian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15461833#comment-15461833 ] Neelesh Srinivas Salian commented on FLINK-4513: Shall I work on this? Nee

[GitHub] flink issue #2470: [FLINK-4559][kinesis-connector] Fix AWSUtil.getCredential...

2016-09-03 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2470 Thanks for the review @greghogan. I think it makes sense to let `AUTO` be the default, as the usual use case for most AWS users is to auto-detect the credentials delivered to instances by AWS's

[jira] [Commented] (FLINK-4559) Kinesis Producer not setting credentials provider properly when AWS_CREDENTIALS_PROVIDER is "AUTO"

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

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

2016-09-03 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4574: --- Description: As pointed out by [~rmetzger], right now the fetch interval implementatio