[
https://issues.apache.org/jira/browse/FLINK-19519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326437#comment-17326437
]
Truong Duc Kien commented on FLINK-19519:
-
Sorry, I completely forgot about this issue. Please
[
https://issues.apache.org/jira/browse/FLINK-19519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Truong Duc Kien updated FLINK-19519:
Labels: pull-request-available (was: pull-request-available stale-assigned)
> Add
[
https://issues.apache.org/jira/browse/FLINK-19519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17266472#comment-17266472
]
Truong Duc Kien commented on FLINK-19519:
-
Sure. I'll do it.
> Add support for port range in
[
https://issues.apache.org/jira/browse/FLINK-19901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223565#comment-17223565
]
Truong Duc Kien commented on FLINK-19901:
-
[~chesnay] Can you take look ? Thanks.
> Unable to
Truong Duc Kien created FLINK-19901:
---
Summary: Unable to exclude metrics variables for the last metrics
reporter.
Key: FLINK-19901
URL: https://issues.apache.org/jira/browse/FLINK-19901
Project:
Truong Duc Kien created FLINK-19519:
---
Summary: Add support for port range in taskmanager.data.port
Key: FLINK-19519
URL: https://issues.apache.org/jira/browse/FLINK-19519
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17209403#comment-17209403
]
Truong Duc Kien commented on FLINK-5919:
[~trohrmann] Can you clarify why this is no longer
[
https://issues.apache.org/jira/browse/FLINK-18527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199266#comment-17199266
]
Truong Duc Kien commented on FLINK-18527:
-
It turns out that it was our uber-jar that was
[
https://issues.apache.org/jira/browse/FLINK-18527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Truong Duc Kien closed FLINK-18527.
---
Resolution: Not A Bug
> Task Managers fail to start on HDP 2.6.5 due to commons-cli
[
https://issues.apache.org/jira/browse/FLINK-18527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196932#comment-17196932
]
Truong Duc Kien commented on FLINK-18527:
-
I don't think we do anything special apart from
[
https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183311#comment-17183311
]
Truong Duc Kien commented on FLINK-18934:
-
Sorry, I've forgotten about this issue so I've only
Truong Duc Kien created FLINK-18934:
---
Summary: Idle stream does not advance watermark in connected stream
Key: FLINK-18934
URL: https://issues.apache.org/jira/browse/FLINK-18934
Project: Flink
Truong Duc Kien created FLINK-18740:
---
Summary: Support rate limiter in the universal kafka connector
Key: FLINK-18740
URL: https://issues.apache.org/jira/browse/FLINK-18740
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-18554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157258#comment-17157258
]
Truong Duc Kien commented on FLINK-18554:
-
We investigated and came to the conclusion that it's
Truong Duc Kien created FLINK-18554:
---
Summary: Memory exceeds taskmanager.memory.process.size when
enabling mmap_read for RocksDB
Key: FLINK-18554
URL: https://issues.apache.org/jira/browse/FLINK-18554
[
https://issues.apache.org/jira/browse/FLINK-18554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155242#comment-17155242
]
Truong Duc Kien commented on FLINK-18554:
-
According to this issues, mmaping SST files can be a
[
https://issues.apache.org/jira/browse/FLINK-18554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155242#comment-17155242
]
Truong Duc Kien edited comment on FLINK-18554 at 7/10/20, 7:40 AM:
---
Truong Duc Kien created FLINK-18527:
---
Summary: Task Managers fail to start on HDP 2.6.5 due to
commons-cli conflict
Key: FLINK-18527
URL: https://issues.apache.org/jira/browse/FLINK-18527
Project:
[
https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932200#comment-16932200
]
Truong Duc Kien commented on FLINK-7289:
In my experience, using jemalloc can reduce RocksDB
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16903760#comment-16903760
]
Truong Duc Kien commented on FLINK-10114:
-
Hi, [~hiliuxg] I take a look at your project.
It's
[
https://issues.apache.org/jira/browse/FLINK-9465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849867#comment-16849867
]
Truong Duc Kien commented on FLINK-9465:
We optimized our jobs so that they checkpoint much
[
https://issues.apache.org/jira/browse/FLINK-6263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16843135#comment-16843135
]
Truong Duc Kien commented on FLINK-6263:
I think this is a duplicate of
[
https://issues.apache.org/jira/browse/FLINK-8033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822402#comment-16822402
]
Truong Duc Kien commented on FLINK-8033:
I also think that Flink should target Java 11 directly.
[
https://issues.apache.org/jira/browse/FLINK-9459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Truong Duc Kien closed FLINK-9459.
--
Resolution: Fixed
Fix Version/s: 1.7.3
> Maven enforcer plugin prevents compilation
[
https://issues.apache.org/jira/browse/FLINK-9459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16782727#comment-16782727
]
Truong Duc Kien commented on FLINK-9459:
This doesn't seem to happens anymore with Flink 1.7.
>
Truong Duc Kien created FLINK-11283:
---
Summary: Accessing the key when processing connected keyed stream
Key: FLINK-11283
URL: https://issues.apache.org/jira/browse/FLINK-11283
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16736636#comment-16736636
]
Truong Duc Kien commented on FLINK-10848:
-
Yarn can return more containers than the number of
Truong Duc Kien created FLINK-11148:
---
Summary: Rescaling operator regression in Flink 1.7
Key: FLINK-11148
URL: https://issues.apache.org/jira/browse/FLINK-11148
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705572#comment-16705572
]
Truong Duc Kien commented on FLINK-10114:
-
Maybe we can let the ORC's writer write to a path on
[
https://issues.apache.org/jira/browse/FLINK-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686275#comment-16686275
]
Truong Duc Kien commented on FLINK-10857:
-
This is due to
[
https://issues.apache.org/jira/browse/FLINK-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16686264#comment-16686264
]
Truong Duc Kien commented on FLINK-10857:
-
I've updated my code, even when {{FrontMetricGroup}}
[
https://issues.apache.org/jira/browse/FLINK-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Truong Duc Kien updated FLINK-10857:
Description:
When registering both JMX and Prometheus metrics reporter, the Prometheus
Truong Duc Kien created FLINK-10857:
---
Summary: Conflict between JMX and Prometheus Metrics reporter
Key: FLINK-10857
URL: https://issues.apache.org/jira/browse/FLINK-10857
Project: Flink
Truong Duc Kien created FLINK-9628:
--
Summary: Options to tolerate truncate failure in BucketingSink
Key: FLINK-9628
URL: https://issues.apache.org/jira/browse/FLINK-9628
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514674#comment-16514674
]
Truong Duc Kien commented on FLINK-9552:
Hi [~till.rohrmann] , FLINK-3257 seems to stall, is
Truong Duc Kien created FLINK-9583:
--
Summary: Wrong number of TaskManagers' slots after recovery.
Key: FLINK-9583
URL: https://issues.apache.org/jira/browse/FLINK-9583
Project: Flink
Issue
Truong Duc Kien created FLINK-9552:
--
Summary: NPE in SpanningRecordSerializer during checkpoint
Key: FLINK-9552
URL: https://issues.apache.org/jira/browse/FLINK-9552
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16493464#comment-16493464
]
Truong Duc Kien commented on FLINK-9459:
Yes, it seems the root cause is the same. Solving for
Truong Duc Kien created FLINK-9467:
--
Summary: No Watermark display on Web UI
Key: FLINK-9467
URL: https://issues.apache.org/jira/browse/FLINK-9467
Project: Flink
Issue Type: Bug
Affects
Truong Duc Kien created FLINK-9465:
--
Summary: Separate timeout for savepoint and checkpoint
Key: FLINK-9465
URL: https://issues.apache.org/jira/browse/FLINK-9465
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Truong Duc Kien updated FLINK-9459:
---
Description:
Compiling Flink with Hortonwork HDP's version of Hadoop is currently
Truong Duc Kien created FLINK-9459:
--
Summary: Maven enforcer plugin prevents compilation with HDP's
Hadoop
Key: FLINK-9459
URL: https://issues.apache.org/jira/browse/FLINK-9459
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Truong Duc Kien updated FLINK-9458:
---
Description:
After upgrading our job to Flink 1.5, they are unable to recover from failure
[
https://issues.apache.org/jira/browse/FLINK-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Truong Duc Kien updated FLINK-9458:
---
Description:
After upgrading our job to Flink 1.5, they are unable to recover from failure
Truong Duc Kien created FLINK-9458:
--
Summary: Unable to recover from job failure on YARN with NPE
Key: FLINK-9458
URL: https://issues.apache.org/jira/browse/FLINK-9458
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432213#comment-16432213
]
Truong Duc Kien commented on FLINK-9070:
Sure. Go ahead.
> Improve performance of
[
https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16430525#comment-16430525
]
Truong Duc Kien commented on FLINK-9070:
This is definitely a safer way than my idea and should
[
https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16415609#comment-16415609
]
Truong Duc Kien commented on FLINK-9070:
So here's my idea for RocksDBMapState.clear() with
[
https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16413567#comment-16413567
]
Truong Duc Kien commented on FLINK-9070:
Yeah, that bug with DeleteRange was fixed, I'm just
Truong Duc Kien created FLINK-9070:
--
Summary: Improve performance of RocksDBMapState.clear()
Key: FLINK-9070
URL: https://issues.apache.org/jira/browse/FLINK-9070
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16409135#comment-16409135
]
Truong Duc Kien commented on FLINK-9052:
Turn out this issue is due to Java API's inability to
[
https://issues.apache.org/jira/browse/FLINK-9052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Truong Duc Kien updated FLINK-9052:
---
Attachment: TypeInfomationTest.scala
> Flink complains when scala.Option is used inside POJO
Truong Duc Kien created FLINK-9052:
--
Summary: Flink complains when scala.Option is used inside POJO
Key: FLINK-9052
URL: https://issues.apache.org/jira/browse/FLINK-9052
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16405692#comment-16405692
]
Truong Duc Kien commented on FLINK-8946:
Sorry, we haven't had time to test with Flip-6 yet.
>
[
https://issues.apache.org/jira/browse/FLINK-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16400215#comment-16400215
]
Truong Duc Kien commented on FLINK-8297:
Isn't this also related to
Truong Duc Kien created FLINK-8949:
--
Summary: Rest API failure with long URL
Key: FLINK-8949
URL: https://issues.apache.org/jira/browse/FLINK-8949
Project: Flink
Issue Type: Bug
Truong Duc Kien created FLINK-8946:
--
Summary: TaskManager stop sending metrics after JobManager failover
Key: FLINK-8946
URL: https://issues.apache.org/jira/browse/FLINK-8946
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16220383#comment-16220383
]
Truong Duc Kien commented on FLINK-7921:
It works fine for me. Maybe there's some problems with
58 matches
Mail list logo