[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park updated FLINK-7398:
--
Attachment: Example.png
[~wheat9] Why not follow Apache Spark's example for this problem?
https://gith
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135534#comment-16135534
]
Jacob Park edited comment on FLINK-7398 at 8/21/17 6:17 PM:
[~
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135534#comment-16135534
]
Jacob Park edited comment on FLINK-7398 at 8/21/17 6:17 PM:
[~
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park updated FLINK-7398:
--
Attachment: (was: Example.png)
> Table API operators/UDFs must not store Logger
> --
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park updated FLINK-7398:
--
Attachment: Example.png
> Table API operators/UDFs must not store Logger
> -
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135534#comment-16135534
]
Jacob Park edited comment on FLINK-7398 at 8/21/17 6:28 PM:
[~
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137250#comment-16137250
]
Jacob Park commented on FLINK-7398:
---
+1 for the checkstyle rule.
> Table API operators/
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16137601#comment-16137601
]
Jacob Park commented on FLINK-7465:
---
[~sunjincheng121] [~fhueske] May I recommend referr
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141856#comment-16141856
]
Jacob Park commented on FLINK-7465:
---
[~sunzhenya] When you say you want to process the r
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16143844#comment-16143844
]
Jacob Park commented on FLINK-7465:
---
[~fhueske] [~sunjincheng121] Thanks for the context
[
https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16633170#comment-16633170
]
Jacob Park commented on FLINK-9083:
---
Hi [~bmeriaux],
I've been so busy with personal s
[
https://issues.apache.org/jira/browse/FLINK-9084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park updated FLINK-9084:
--
Summary: Upgrade cassandra-driver-core to 3.6.0 to introduce
BusyPoolException retries to Cassandra Con
Jacob Park created FLINK-9069:
-
Summary: Fix some double semi-colons to single semi-colons, and
update checkstyle
Key: FLINK-9069
URL: https://issues.apache.org/jira/browse/FLINK-9069
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16412690#comment-16412690
]
Jacob Park commented on FLINK-9069:
---
Can I be assigned to this ticket? I want to use it
[
https://issues.apache.org/jira/browse/FLINK-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park updated FLINK-9069:
--
Summary: Fix some double semicolons to single semicolons, and update
checkstyle (was: Fix some double s
[
https://issues.apache.org/jira/browse/FLINK-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park updated FLINK-9069:
--
Description:
As I was reading through the source code, I noticed that there were some double
semicolons
Jacob Park created FLINK-9083:
-
Summary: Add async backpressure support to Cassandra Connector
Key: FLINK-9083
URL: https://issues.apache.org/jira/browse/FLINK-9083
Project: Flink
Issue Type: Imp
Jacob Park created FLINK-9084:
-
Summary: Upgrade cassandra-driver-core to 3.4.0 to introduce
BusyPoolException retries
Key: FLINK-9084
URL: https://issues.apache.org/jira/browse/FLINK-9084
Project: Flink
Jacob Park created FLINK-9085:
-
Summary: Add a rate limiter to the Cassandra Connector
Key: FLINK-9085
URL: https://issues.apache.org/jira/browse/FLINK-9085
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park updated FLINK-9085:
--
Description:
The spark-cassandra-connector uses a rate limiter. In production, this allows
our Cassandr
[
https://issues.apache.org/jira/browse/FLINK-9084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park updated FLINK-9084:
--
Description:
As per [https://datastax-oss.atlassian.net/browse/SPARKC-503,] that exception
will be thro
[
https://issues.apache.org/jira/browse/FLINK-9084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park updated FLINK-9084:
--
Summary: Upgrade cassandra-driver-core to 3.4.0 to introduce
BusyPoolException retries to Cassandra Conn
[
https://issues.apache.org/jira/browse/FLINK-9085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park reassigned FLINK-9085:
-
Assignee: Jacob Park
> Add a rate limiter to the Cassandra Connector
> --
[
https://issues.apache.org/jira/browse/FLINK-9083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park reassigned FLINK-9083:
-
Assignee: Jacob Park
> Add async backpressure support to Cassandra Connector
> --
[
https://issues.apache.org/jira/browse/FLINK-9084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park reassigned FLINK-9084:
-
Assignee: Jacob Park
> Upgrade cassandra-driver-core to 3.4.0 to introduce BusyPoolException retr
[
https://issues.apache.org/jira/browse/FLINK-9095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park reassigned FLINK-9095:
-
Assignee: Jacob Park
> Add metrics for Cassandra Connector
> ---
Jacob Park created FLINK-9095:
-
Summary: Add metrics for Cassandra Connector
Key: FLINK-9095
URL: https://issues.apache.org/jira/browse/FLINK-9095
Project: Flink
Issue Type: Improvement
Jacob Park created FLINK-9114:
-
Summary: Enable user-provided, custom CheckpointRecoveryFactory
for non-HA deployments
Key: FLINK-9114
URL: https://issues.apache.org/jira/browse/FLINK-9114
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16419992#comment-16419992
]
Jacob Park commented on FLINK-9114:
---
[~ecanzonieri] FYI.
> Enable user-provided, custom
[
https://issues.apache.org/jira/browse/FLINK-9114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16428587#comment-16428587
]
Jacob Park commented on FLINK-9114:
---
I was thinking of creating a ConfigurableCheckpoint
[
https://issues.apache.org/jira/browse/FLINK-9114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Park updated FLINK-9114:
--
Description:
When you operate a Flink application that uses externalized checkpoints to S3,
it becomes
31 matches
Mail list logo
