[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

[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=15462090#comment-15462090 ] ASF GitHub Bot commented on FLINK-4559: --- Github user tzulitai commented on the issue:

[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-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=15461833#comment-15461833 ] Neelesh Srinivas Salian commented on FLINK-4513: Shall I work on this? Need to change all

[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

[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=15461654#comment-15461654 ] ASF GitHub Bot commented on FLINK-4559: --- Github user greghogan commented on the issue:

[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?

[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=15461528#comment-15461528 ] ASF GitHub Bot commented on FLINK-4559: --- GitHub user tzulitai opened a pull request:

[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] [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

[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=15461269#comment-15461269 ] Tzu-Li (Gordon) Tai commented on FLINK-4194: On second thought, I think we ought to discuss

[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

[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

[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:

[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=15461121#comment-15461121 ] ASF GitHub Bot commented on FLINK-4572: --- GitHub user greghogan opened a pull request:

[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.

[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=15460619#comment-15460619 ] ASF GitHub Bot commented on FLINK-4561: --- Github user shijinkui commented on the issue:

[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

[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=15460594#comment-15460594 ] ASF GitHub Bot commented on FLINK-3580: --- GitHub user twalthr opened a pull request:

[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