[jira] [Commented] (FLINK-19519) Add support for port range in taskmanager.data.port

2021-04-21 Thread Truong Duc Kien (Jira)
[ 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

[jira] [Updated] (FLINK-19519) Add support for port range in taskmanager.data.port

2021-04-21 Thread Truong Duc Kien (Jira)
[ 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

[jira] [Commented] (FLINK-19519) Add support for port range in taskmanager.data.port

2021-01-15 Thread Truong Duc Kien (Jira)
[ 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

[jira] [Commented] (FLINK-19901) Unable to exclude metrics variables for the last metrics reporter.

2020-10-30 Thread Truong Duc Kien (Jira)
[ 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

[jira] [Created] (FLINK-19901) Unable to exclude metrics variables for the last metrics reporter.

2020-10-30 Thread Truong Duc Kien (Jira)
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:

[jira] [Created] (FLINK-19519) Add support for port range in taskmanager.data.port

2020-10-07 Thread Truong Duc Kien (Jira)
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

[jira] [Commented] (FLINK-5919) port range support for config taskmanager.data.port

2020-10-07 Thread Truong Duc Kien (Jira)
[ 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

[jira] [Commented] (FLINK-18527) Task Managers fail to start on HDP 2.6.5 due to commons-cli conflict

2020-09-21 Thread Truong Duc Kien (Jira)
[ 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

[jira] [Closed] (FLINK-18527) Task Managers fail to start on HDP 2.6.5 due to commons-cli conflict

2020-09-21 Thread Truong Duc Kien (Jira)
[ 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

[jira] [Commented] (FLINK-18527) Task Managers fail to start on HDP 2.6.5 due to commons-cli conflict

2020-09-16 Thread Truong Duc Kien (Jira)
[ 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

[jira] [Commented] (FLINK-18934) Idle stream does not advance watermark in connected stream

2020-08-24 Thread Truong Duc Kien (Jira)
[ 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

[jira] [Created] (FLINK-18934) Idle stream does not advance watermark in connected stream

2020-08-13 Thread Truong Duc Kien (Jira)
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

[jira] [Created] (FLINK-18740) Support rate limiter in the universal kafka connector

2020-07-28 Thread Truong Duc Kien (Jira)
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

[jira] [Commented] (FLINK-18554) Memory exceeds taskmanager.memory.process.size when enabling mmap_read for RocksDB

2020-07-14 Thread Truong Duc Kien (Jira)
[ 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

[jira] [Created] (FLINK-18554) Memory exceeds taskmanager.memory.process.size when enabling mmap_read for RocksDB

2020-07-10 Thread Truong Duc Kien (Jira)
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

[jira] [Commented] (FLINK-18554) Memory exceeds taskmanager.memory.process.size when enabling mmap_read for RocksDB

2020-07-10 Thread Truong Duc Kien (Jira)
[ 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

[jira] [Comment Edited] (FLINK-18554) Memory exceeds taskmanager.memory.process.size when enabling mmap_read for RocksDB

2020-07-10 Thread Truong Duc Kien (Jira)
[ 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: ---

[jira] [Created] (FLINK-18527) Task Managers fail to start on HDP 2.6.5 due to commons-cli conflict

2020-07-08 Thread Truong Duc Kien (Jira)
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:

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

2019-09-18 Thread Truong Duc Kien (Jira)
[ 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

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

2019-08-09 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Commented] (FLINK-9465) Separate timeout for savepoint and checkpoint

2019-05-28 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Commented] (FLINK-6263) Leader error in Kafka producer on leader change (broker restart/failrue)

2019-05-18 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Commented] (FLINK-8033) Build Flink with JDK 9

2019-04-20 Thread Truong Duc Kien (JIRA)
[ 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. 

[jira] [Closed] (FLINK-9459) Maven enforcer plugin prevents compilation with HDP's Hadoop

2019-03-03 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Commented] (FLINK-9459) Maven enforcer plugin prevents compilation with HDP's Hadoop

2019-03-03 Thread Truong Duc Kien (JIRA)
[ 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. >

[jira] [Created] (FLINK-11283) Accessing the key when processing connected keyed stream

2019-01-08 Thread Truong Duc Kien (JIRA)
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

[jira] [Commented] (FLINK-10848) Flink's Yarn ResourceManager can allocate too many excess containers

2019-01-07 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Created] (FLINK-11148) Rescaling operator regression in Flink 1.7

2018-12-13 Thread Truong Duc Kien (JIRA)
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:

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

2018-11-30 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Commented] (FLINK-10857) Conflict between JMX and Prometheus Metrics reporter

2018-11-14 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Commented] (FLINK-10857) Conflict between JMX and Prometheus Metrics reporter

2018-11-14 Thread Truong Duc Kien (JIRA)
[ 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}}

[jira] [Updated] (FLINK-10857) Conflict between JMX and Prometheus Metrics reporter

2018-11-12 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Created] (FLINK-10857) Conflict between JMX and Prometheus Metrics reporter

2018-11-12 Thread Truong Duc Kien (JIRA)
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

[jira] [Created] (FLINK-9628) Options to tolerate truncate failure in BucketingSink

2018-06-20 Thread Truong Duc Kien (JIRA)
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

[jira] [Commented] (FLINK-9552) NPE in SpanningRecordSerializer during checkpoint with iterations

2018-06-15 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Created] (FLINK-9583) Wrong number of TaskManagers' slots after recovery.

2018-06-13 Thread Truong Duc Kien (JIRA)
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

[jira] [Created] (FLINK-9552) NPE in SpanningRecordSerializer during checkpoint

2018-06-07 Thread Truong Duc Kien (JIRA)
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

[jira] [Commented] (FLINK-9459) Maven enforcer plugin prevents compilation with HDP's Hadoop

2018-05-29 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Created] (FLINK-9467) No Watermark display on Web UI

2018-05-29 Thread Truong Duc Kien (JIRA)
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

[jira] [Created] (FLINK-9465) Separate timeout for savepoint and checkpoint

2018-05-29 Thread Truong Duc Kien (JIRA)
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:

[jira] [Updated] (FLINK-9459) Maven enforcer plugin prevents compilation with HDP's Hadoop

2018-05-28 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Created] (FLINK-9459) Maven enforcer plugin prevents compilation with HDP's Hadoop

2018-05-28 Thread Truong Duc Kien (JIRA)
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

[jira] [Updated] (FLINK-9458) Unable to recover from job failure on YARN with NPE

2018-05-28 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Updated] (FLINK-9458) Unable to recover from job failure on YARN with NPE

2018-05-28 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Created] (FLINK-9458) Unable to recover from job failure on YARN with NPE

2018-05-28 Thread Truong Duc Kien (JIRA)
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

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

2018-04-10 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

2018-04-09 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

2018-03-27 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

2018-03-26 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Created] (FLINK-9070) Improve performance of RocksDBMapState.clear()

2018-03-25 Thread Truong Duc Kien (JIRA)
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:

[jira] [Commented] (FLINK-9052) Flink complains when scala.Option is used inside POJO

2018-03-22 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Updated] (FLINK-9052) Flink complains when scala.Option is used inside POJO

2018-03-22 Thread Truong Duc Kien (JIRA)
[ 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

[jira] [Created] (FLINK-9052) Flink complains when scala.Option is used inside POJO

2018-03-21 Thread Truong Duc Kien (JIRA)
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

[jira] [Commented] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-03-19 Thread Truong Duc Kien (JIRA)
[ 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. >

[jira] [Commented] (FLINK-8297) RocksDBListState stores whole list in single byte[]

2018-03-15 Thread Truong Duc Kien (JIRA)
[ 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 

[jira] [Created] (FLINK-8949) Rest API failure with long URL

2018-03-15 Thread Truong Duc Kien (JIRA)
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

[jira] [Created] (FLINK-8946) TaskManager stop sending metrics after JobManager failover

2018-03-14 Thread Truong Duc Kien (JIRA)
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

[jira] [Commented] (FLINK-7921) Flink downloads link redirect to spark downloads page

2017-10-26 Thread Truong Duc Kien (JIRA)
[ 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