[
https://issues.apache.org/jira/browse/FLINK-13609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921675#comment-16921675
]
Joao Boto commented on FLINK-13609:
---
[~kkl0u] I think this could be closed as we agree
[
https://issues.apache.org/jira/browse/FLINK-13609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921068#comment-16921068
]
Joao Boto commented on FLINK-13609:
---
[~kkl0u] I understand what you say about timestam
[
https://issues.apache.org/jira/browse/FLINK-13609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916537#comment-16916537
]
Joao Boto commented on FLINK-13609:
---
And we could not use the max counter for that buc
[
https://issues.apache.org/jira/browse/FLINK-13850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916474#comment-16916474
]
Joao Boto edited comment on FLINK-13850 at 8/27/19 7:35 AM:
[
https://issues.apache.org/jira/browse/FLINK-13850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916474#comment-16916474
]
Joao Boto commented on FLINK-13850:
---
this make sense to me, maybe FileConfig make more
[
https://issues.apache.org/jira/browse/FLINK-13860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joao Boto updated FLINK-13860:
--
Description:
Hi..
I'm the contributor and maintainer of this connector on Bahir-Flink project
[https
Joao Boto created FLINK-13860:
-
Summary: Flink Apache Kudu Connector
Key: FLINK-13860
URL: https://issues.apache.org/jira/browse/FLINK-13860
Project: Flink
Issue Type: New Feature
Rep
[
https://issues.apache.org/jira/browse/FLINK-13609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16915578#comment-16915578
]
Joao Boto commented on FLINK-13609:
---
[~gyfora] maybe this can be address on
https://i
[
https://issues.apache.org/jira/browse/FLINK-13428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16915573#comment-16915573
]
Joao Boto commented on FLINK-13428:
---
[~gyfora] i will do the fix and doc on that issue
[
https://issues.apache.org/jira/browse/FLINK-13634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joao Boto updated FLINK-13634:
--
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
> StreamingFileSink - allow bulkwriter t
Joao Boto created FLINK-13634:
-
Summary: StreamingFileSink - allow bulkwriter to compress data
Key: FLINK-13634
URL: https://issues.apache.org/jira/browse/FLINK-13634
Project: Flink
Issue Type: I
Joao Boto created FLINK-13609:
-
Summary: StreamingFileSink - reset part counter on bucket change
Key: FLINK-13609
URL: https://issues.apache.org/jira/browse/FLINK-13609
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-13428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joao Boto updated FLINK-13428:
--
Component/s: (was: Connectors / FileSystem)
> StreamingFileSink allow part file name to be configu
[
https://issues.apache.org/jira/browse/FLINK-13428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joao Boto updated FLINK-13428:
--
Description:
Allow that part file name could be configurable:
* partPrefix and partSuffix can be pass
Joao Boto created FLINK-13428:
-
Summary: StreamingFileSink allow part file name to be configurable
Key: FLINK-13428
URL: https://issues.apache.org/jira/browse/FLINK-13428
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joao Boto updated FLINK-8424:
-
Component/s: Cassandra Connector
> [Cassandra Connector] Update Cassandra version to last one
> --
[
https://issues.apache.org/jira/browse/FLINK-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joao Boto updated FLINK-8424:
-
Description:
Cassandra connector are using a version outdated
This is to upgrade the cassandra version to
[
https://issues.apache.org/jira/browse/FLINK-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joao Boto updated FLINK-8424:
-
Priority: Major (was: Critical)
> [Cassandra Connector] Update Cassandra version to last one
> --
Joao Boto created FLINK-8424:
Summary: [Cassandra Connector] Update Cassandra version to last one
Key: FLINK-8424
URL: https://issues.apache.org/jira/browse/FLINK-8424
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joao Boto updated FLINK-8249:
-
Description:
Hi,
setting this configurations to FlinkKinesisProducer:
{code}
properties.put(AWSConfigCons
[
https://issues.apache.org/jira/browse/FLINK-8249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joao Boto updated FLINK-8249:
-
Description:
Hi,
setting this configurations to FlinkKinesisProducer:
{code}
properties.put(AWSConfigCons
[
https://issues.apache.org/jira/browse/FLINK-8249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joao Boto updated FLINK-8249:
-
Description:
Hi,
setting this configurations to FlinkKinesisProducer:
{code}
properties.put(AWSConfigCons
[
https://issues.apache.org/jira/browse/FLINK-8249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joao Boto updated FLINK-8249:
-
Description:
Hi,
setting this configurations to FlinkKinesisProducer:
properties.put(AWSConfigConstants.A
[
https://issues.apache.org/jira/browse/FLINK-8249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joao Boto updated FLINK-8249:
-
Description:
Hi,
setting this configurations to FlinkKinesisProducer:
properties.put(AWSConfigConstants.A
Joao Boto created FLINK-8249:
Summary: Kinesis Producer dont cpnfigure region
Key: FLINK-8249
URL: https://issues.apache.org/jira/browse/FLINK-8249
Project: Flink
Issue Type: Bug
Compon
[
https://issues.apache.org/jira/browse/FLINK-8249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joao Boto updated FLINK-8249:
-
Summary: Kinesis Producer didnt configure region (was: Kinesis Producer
dont cpnfigure region)
> Kinesis
26 matches
Mail list logo
