[
https://issues.apache.org/jira/browse/FLINK-6133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li resolved FLINK-6133.
-
Resolution: Fixed
> fix build status in README.md
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15928381#comment-15928381
]
Bowen Li commented on FLINK-6053:
-
Thank you!
> Gauge should only take subclasses of Number, rather than
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-6013:
---
Assignee: Bowen Li
> Add Datadog HTTP metrics reporter
> -
>
>
Bowen Li created FLINK-6121:
---
Summary: Include TravisCI build status to README.md
Key: FLINK-6121
URL: https://issues.apache.org/jira/browse/FLINK-6121
Project: Flink
Issue Type: Improvement
Bowen Li created FLINK-6122:
---
Summary: Include TravisCI build status to README.md
Key: FLINK-6122
URL: https://issues.apache.org/jira/browse/FLINK-6122
Project: Flink
Issue Type: Improvement
Bowen Li created FLINK-6053:
---
Summary: Gauge should only take subclasses of Number, rather
than everything
Key: FLINK-6053
URL: https://issues.apache.org/jira/browse/FLINK-6053
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6053:
Description:
Currently, Flink's Gauge is defined as
```java
public interface Gauge extends Metric {
[
https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6053:
Description:
Currently, Flink's Gauge is defined as
```java
/**
* A Gauge is a {@link Metric} that
[
https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15926514#comment-15926514
]
Bowen Li commented on FLINK-6053:
-
I see. I can do a hack in FLINK-6013 to check if a Gauge is typed as
[
https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6053:
Fix Version/s: (was: 1.3.0)
2.0.0
> Gauge should only take subclasses of Number,
[
https://issues.apache.org/jira/browse/FLINK-6121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-6121:
---
Assignee: Bowen Li
> Include TravisCI build status to README.md
>
Bowen Li created FLINK-6133:
---
Summary: fix build status in README.md
Key: FLINK-6133
URL: https://issues.apache.org/jira/browse/FLINK-6133
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15926665#comment-15926665
]
Bowen Li commented on FLINK-6053:
-
Cool. Adding a NumberGauge or NumericGauge was my first impression when
[
https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15926684#comment-15926684
]
Bowen Li commented on FLINK-5095:
-
Agree that MetricReporter interface is not extendable and scalable, and
[
https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925257#comment-15925257
]
Bowen Li commented on FLINK-6053:
-
hm I found in Flink's Gauge class is used like this in
[
https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977893#comment-15977893
]
Bowen Li commented on FLINK-5095:
-
What's the main disadvantage of having counter, meters, and gauge
Bowen Li created FLINK-6350:
---
Summary: Flink: Windowing does not work with streams from
collections and the local execution environment
Key: FLINK-6350
URL: https://issues.apache.org/jira/browse/FLINK-6350
[
https://issues.apache.org/jira/browse/FLINK-6350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6350:
Component/s: Streaming
> Flink: Windowing does not work with streams from collections and the local
>
[
https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15977893#comment-15977893
]
Bowen Li edited comment on FLINK-5095 at 4/21/17 1:02 AM:
--
What's the main
Bowen Li created FLINK-6010:
---
Summary: Documentation: correct IntelliJ IDEA Plugins path in
'Installing the Scala plugin' section
Key: FLINK-6010
URL: https://issues.apache.org/jira/browse/FLINK-6010
Bowen Li created FLINK-6013:
---
Summary: Add Datadog HTTP metrics reporter
Key: FLINK-6013
URL: https://issues.apache.org/jira/browse/FLINK-6013
Project: Flink
Issue Type: Improvement
Bowen Li created FLINK-6002:
---
Summary: Setup: Download and Start Flink/MacOS X in Quickstart
page is not rendered correctly
Key: FLINK-6002
URL: https://issues.apache.org/jira/browse/FLINK-6002
Project:
[
https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6002:
Description:
On
[
https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6002:
Affects Version/s: 1.2.0
Priority: Trivial (was: Major)
Fix Version/s: 1.2.1
[
https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6002:
Description:
On
[
https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6002:
Description:
On
[
https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6002:
Summary: Documentation: 'MacOS X' under 'Download and Start Flink' in
Quickstart page is not rendered
[
https://issues.apache.org/jira/browse/FLINK-6002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901831#comment-15901831
]
Bowen Li commented on FLINK-6002:
-
Hi guys, how to assign this issue to myself?
> Documentation: 'MacOS
[
https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974103#comment-15974103
]
Bowen Li commented on FLINK-5095:
-
I'll spend time in the following few days to see how other projects
[
https://issues.apache.org/jira/browse/FLINK-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16106325#comment-16106325
]
Bowen Li commented on FLINK-7223:
-
What do you guys think 3min or 1min?
I strongly believe that this
Bowen Li created FLINK-7356:
---
Summary: misleading s3 file uri in configuration file
Key: FLINK-7356
URL: https://issues.apache.org/jira/browse/FLINK-7356
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-5462.
---
Resolution: Not A Bug
> Flink job fails due to java.util.concurrent.CancellationException while
>
[
https://issues.apache.org/jira/browse/FLINK-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7365:
Affects Version/s: 1.3.0
Component/s: Configuration
> warning of attempt to override final
Bowen Li created FLINK-7365:
---
Summary: warning of attempt to override final parameter:
fs.s3.buffer.dir
Key: FLINK-7365
URL: https://issues.apache.org/jira/browse/FLINK-7365
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7367:
Description:
Right now, FlinkKinesisProducer only expose two configs for the underlying
KinesisProducer:
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7367:
Description:
Right now, FlinkKinesisProducer only expose two configs for the underlying
KinesisProducer:
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7367:
Summary: Parameterize more configs for FlinkKinesisProducer
(RecordMaxBufferedTime, MaxConnections,
Bowen Li created FLINK-7366:
---
Summary: Upgrade kinesis-producer-library in
flink-connector-kinesis from 0.10.2 to 0.12.5
Key: FLINK-7366
URL: https://issues.apache.org/jira/browse/FLINK-7366
Project: Flink
Bowen Li created FLINK-7367:
---
Summary: Parameterize FlinkKinesisProducer on
RecordMaxBufferedTime, MaxConnections, RequestTimeout, and more
Key: FLINK-7367
URL: https://issues.apache.org/jira/browse/FLINK-7367
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7366:
Description:
flink-connector-kinesis currently uses kinesis-producer-library 0.10.2, which
is released in
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7366:
Summary: Upgrade kinesis producer library in flink-connector-kinesis (was:
Upgrade kinesis producer
[
https://issues.apache.org/jira/browse/FLINK-7453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128301#comment-16128301
]
Bowen Li commented on FLINK-7453:
-
There are lots of this line in my taskmanager.log. Looks like
[
https://issues.apache.org/jira/browse/FLINK-7453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128366#comment-16128366
]
Bowen Li commented on FLINK-7453:
-
ohho, my bad in https://github.com/apache/flink/pull/4473, I
[
https://issues.apache.org/jira/browse/FLINK-7453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128359#comment-16128359
]
Bowen Li commented on FLINK-7453:
-
Is it returning 'null' or just an empty string?
So looks like it still
Bowen Li created FLINK-7454:
---
Summary: update 'Monitoring Current Event Time' section of Flink
doc
Key: FLINK-7454
URL: https://issues.apache.org/jira/browse/FLINK-7454
Project: Flink
Issue Type:
Bowen Li created FLINK-7453:
---
Summary: FlinkKinesisProducer logs empty aws region
Key: FLINK-7453
URL: https://issues.apache.org/jira/browse/FLINK-7453
Project: Flink
Issue Type: Bug
Affects
[
https://issues.apache.org/jira/browse/FLINK-7453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-7453.
---
Resolution: Fixed
false alarm...
> FlinkKinesisProducer logs empty aws region
>
Bowen Li created FLINK-7422:
---
Summary: Upgrade Kinesis Client Library (KCL) in
flink-connector-kinesis from 1.6.2 to 1.8.1
Key: FLINK-7422
URL: https://issues.apache.org/jira/browse/FLINK-7422
Project:
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7366:
Description:
flink-connector-kinesis currently uses kinesis-producer-library 0.10.2, which
is released in
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7366:
Affects Version/s: 1.3.2
> Upgrade kinesis-producer-library in flink-connector-kinesis from 0.10.2 to
>
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7366:
Fix Version/s: 1.3.3
> Upgrade kinesis-producer-library in flink-connector-kinesis from 0.10.2 to
> 0.12.5
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7366:
Summary: Upgrade kinesis producer library, kinesis client library, and AWS
SDK in flink-connector-kinesis
[
https://issues.apache.org/jira/browse/FLINK-7422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-7422.
---
Resolution: Fixed
> Upgrade Kinesis Client Library (KCL) in flink-connector-kinesis from 1.6.2 to
> 1.8.1
>
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7366:
Description:
# KPL:
flink-connector-kinesis currently uses kinesis-producer-library 0.10.2, which
is
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7366:
Description:
*KPL: *
flink-connector-kinesis currently uses kinesis-producer-library 0.10.2, which
is
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7366:
Description:
*KPL:*
flink-connector-kinesis currently uses kinesis-producer-library 0.10.2, which
is
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7366:
Description:
We need to upgrade KPL and KCL to pick up the enhanced performance and
stability for Flink
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7366:
Issue Type: Bug (was: Improvement)
> Upgrade kinesis producer library, kinesis client library, and AWS SDK
[
https://issues.apache.org/jira/browse/FLINK-7366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7366:
Description:
We need to upgrade KPL and KCL to pick up the enhanced performance and
stability for Flink to
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7367:
Fix Version/s: 1.4.0
> Parameterize more configs for FlinkKinesisProducer (RecordMaxBufferedTime,
>
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7367:
Issue Type: Bug (was: Improvement)
> Parameterize more configs for FlinkKinesisProducer
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7367:
Description:
Right now, FlinkKinesisProducer only expose two configs for the underlying
KinesisProducer:
Bowen Li created FLINK-7215:
---
Summary: Typo in FAQ page
Key: FLINK-7215
URL: https://issues.apache.org/jira/browse/FLINK-7215
Project: Flink
Issue Type: Bug
Components: Documentation
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6951:
Fix Version/s: 1.3.2
> Incompatible versions of httpcomponents jars for Flink kinesis connector
>
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6951:
Fix Version/s: (was: 1.3.2)
1.4.0
> Incompatible versions of httpcomponents jars for
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6951:
Flags: Important
Fix Version/s: 1.3.2
> Incompatible versions of httpcomponents jars for Flink
[
https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-6365:
Fix Version/s: 1.3.2
1.4.0
> Adapt default values of the Kinesis connector
>
[
https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-6365:
---
Assignee: Bowen Li
> Adapt default values of the Kinesis connector
>
[
https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16088020#comment-16088020
]
Bowen Li commented on FLINK-6365:
-
We ran into this issue, too. 100 is too small for SHARD_GETRECORDS_MAX,
[
https://issues.apache.org/jira/browse/FLINK-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16093498#comment-16093498
]
Bowen Li commented on FLINK-7223:
-
I believe what Gordon and I proposed are complementary. We need to do
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16092661#comment-16092661
]
Bowen Li commented on FLINK-6951:
-
This is similar to https://issues.apache.org/jira/browse/FLINK-6125
>
Bowen Li created FLINK-7223:
---
Summary: Increase DEFAULT_SHARD_DISCOVERY_INTERVAL_MILLIS for
Flink-kinesis-connector
Key: FLINK-7223
URL: https://issues.apache.org/jira/browse/FLINK-7223
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16095837#comment-16095837
]
Bowen Li commented on FLINK-7198:
-
Sounds good to me. We can change title of this ticket to match what we
[
https://issues.apache.org/jira/browse/FLINK-6125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16092660#comment-16092660
]
Bowen Li commented on FLINK-6125:
-
This is similar to https://issues.apache.org/jira/browse/FLINK-6951
>
[
https://issues.apache.org/jira/browse/FLINK-7198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16092679#comment-16092679
]
Bowen Li commented on FLINK-7198:
-
Datadog Metric Reporter gets host name from MetricGroup, Flink's metric
[
https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16094156#comment-16094156
]
Bowen Li commented on FLINK-6365:
-
Ok. For {{SHARD_GETRECORDS_MAX}}, {{10,000}} it is, since we all agree
[
https://issues.apache.org/jira/browse/FLINK-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16093498#comment-16093498
]
Bowen Li edited comment on FLINK-7223 at 7/20/17 4:24 AM:
--
I believe what Gordon
[
https://issues.apache.org/jira/browse/FLINK-6365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16094169#comment-16094169
]
Bowen Li commented on FLINK-6365:
-
Cool! Glad we reached a consensus, and I can proceed with code change.
[
https://issues.apache.org/jira/browse/FLINK-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16094173#comment-16094173
]
Bowen Li commented on FLINK-7223:
-
[~sthm] can we also get your insights here?
> Increase
[
https://issues.apache.org/jira/browse/FLINK-7198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16094190#comment-16094190
]
Bowen Li commented on FLINK-7198:
-
[~Zentol] I don't really understand Scala. So when
[
https://issues.apache.org/jira/browse/FLINK-6350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15983852#comment-15983852
]
Bowen Li commented on FLINK-6350:
-
I'll take a look first. Thanks!
> Flink: Windowing does not work with
Bowen Li created FLINK-6386:
---
Summary: Missing bracket in 'Compiler Limitation' section
Key: FLINK-6386
URL: https://issues.apache.org/jira/browse/FLINK-6386
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15989181#comment-15989181
]
Bowen Li commented on FLINK-6013:
-
[~StephanEwen] [~Zentol] While testing the reporter, I found Datadog
Bowen Li created FLINK-6405:
---
Summary: Flink should be able to load a jar from s3
Key: FLINK-6405
URL: https://issues.apache.org/jira/browse/FLINK-6405
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119222#comment-16119222
]
Bowen Li commented on FLINK-7223:
-
I'm actually fine with the default value, since we are already aware of
Bowen Li created FLINK-7393:
---
Summary: Refactor FlinkKinesisConsumerTest
Key: FLINK-7393
URL: https://issues.apache.org/jira/browse/FLINK-7393
Project: Flink
Issue Type: Test
Components:
Bowen Li created FLINK-7405:
---
Summary: Reduce excessive warning logging from DatadogHttpReporter
Key: FLINK-7405
URL: https://issues.apache.org/jira/browse/FLINK-7405
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7405:
Summary: Reduce spamming warning logging from DatadogHttpReporter (was:
Reduce excessive warning logging
[
https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7405:
Component/s: Metrics
> Reduce excessive warning logging from DatadogHttpReporter
>
[
https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7405:
Description:
DatadogHttpReporter is logging too much when there's a connection timeout, and
we need to
[
https://issues.apache.org/jira/browse/FLINK-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16117498#comment-16117498
]
Bowen Li commented on FLINK-7365:
-
How about turning off Hadoop logging by default? Is it harmful in any
[
https://issues.apache.org/jira/browse/FLINK-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7365:
Description:
I'm seeing hundreds of line of the following log in my JobManager log file:
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7365:
Summary: excessive warning logs of attempt to override final parameter:
fs.s3.buffer.dir (was: warning of
[
https://issues.apache.org/jira/browse/FLINK-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16114629#comment-16114629
]
Bowen Li commented on FLINK-7365:
-
[~StephanEwen] Yes, you are right. It's logging too often and too much.
[
https://issues.apache.org/jira/browse/FLINK-4319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16137064#comment-16137064
]
Bowen Li commented on FLINK-4319:
-
Hi guys, what's the schedule for this task? When are we starting, and
[
https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008430#comment-16008430
]
Bowen Li commented on FLINK-5095:
-
[~Zentol] Can you list your proposed interfaces here? Want to make sure
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16056442#comment-16056442
]
Bowen Li commented on FLINK-6951:
-
Original email thread:
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-6951:
---
Assignee: Bowen Li
> Incompatible versions of httpcomponents jars for Flink kinesis connector
>
Bowen Li created FLINK-6806:
---
Summary: rocksdb is not listed as state backend in doc
Key: FLINK-6806
URL: https://issues.apache.org/jira/browse/FLINK-6806
Project: Flink
Issue Type: Bug
Bowen Li created FLINK-6940:
---
Summary: Clarify the effect of configuring per-job state backend
Key: FLINK-6940
URL: https://issues.apache.org/jira/browse/FLINK-6940
Project: Flink
Issue Type:
1 - 100 of 1720 matches
Mail list logo
