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
[
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:
[
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 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
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
[
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
[
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
[
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
[
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
[
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 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
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:
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
13 matches
Mail list logo