[GitHub] flink issue #2060: [FLINK-3921] StringParser encoding

2016-06-04 Thread rekhajoshm
Github user rekhajoshm commented on the issue: https://github.com/apache/flink/pull/2060 Thanks @greghogan for your inputs. updated. Please have a look. Please note though the configurable Charset will have no impact on StringValueParser(or other parsers) except StringParser.In

[jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use

2016-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15315704#comment-15315704 ] ASF GitHub Bot commented on FLINK-3921: --- Github user rekhajoshm commented on the issue:

[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

2016-06-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15315569#comment-15315569 ] ASF GitHub Bot commented on FLINK-3650: --- Github user ramkrish86 commented on the issue:

[GitHub] flink issue #1856: FLINK-3650 Add maxBy/minBy to Scala DataSet API

2016-06-04 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/1856 This time the build seems to pass except one and there is no long lines now. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[jira] [Created] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection

2016-06-04 Thread Zhijiang Wang (JIRA)
Zhijiang Wang created FLINK-4021: Summary: Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection Key: FLINK-4021 URL: https://issues.apache.org/jira/browse/FLINK-4021

[jira] [Comment Edited] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

2016-06-04 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15315494#comment-15315494 ] Tzu-Li (Gordon) Tai edited comment on FLINK-3231 at 6/4/16 1:04 PM: Hi

[jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

2016-06-04 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15315494#comment-15315494 ] Tzu-Li (Gordon) Tai commented on FLINK-3231: Hi Stephan, Finally reached the point where we

[jira] [Updated] (FLINK-4020) Remove shard list querying from Kinesis consumer constructor

2016-06-04 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4020: --- Description: Currently FlinkKinesisConsumer is querying for the whole list of shards

[jira] [Updated] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

2016-06-04 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-3231: --- Affects Version/s: (was: 1.0.0) 1.1.0 > Handle

[jira] [Commented] (FLINK-3948) EventTimeWindowCheckpointingITCase Fails with Core Dump

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

[GitHub] flink pull request #2072: [FLINK-3948] Protect RocksDB cleanup by cleanup lo...

2016-06-04 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/2072 [FLINK-3948] Protect RocksDB cleanup by cleanup lock Before, it could happen that an asynchronous checkpoint was going on when trying to do cleanup. Now we protect cleanup and asynchronous

[jira] [Created] (FLINK-4020) Remove shard list querying from Kinesis consumer constructor

2016-06-04 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-4020: -- Summary: Remove shard list querying from Kinesis consumer constructor Key: FLINK-4020 URL: https://issues.apache.org/jira/browse/FLINK-4020 Project:

[jira] [Created] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface

2016-06-04 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-4019: -- Summary: Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface Key: FLINK-4019 URL: https://issues.apache.org/jira/browse/FLINK-4019