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

[ https://issues.apache.org/jira/browse/FLINK-19519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17326437#comment-17326437 ] Truong Duc Kien commented on FLINK-19519: - Sorry, I completely forgot about this

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

[ 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 support

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

[ https://issues.apache.org/jira/browse/FLINK-19519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266472#comment-17266472 ] Truong Duc Kien commented on FLINK-19519: - Sure. I'll do it. > Add support for

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

[ https://issues.apache.org/jira/browse/FLINK-19901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17223565#comment-17223565 ] Truong Duc Kien commented on FLINK-19901: - [~chesnay] Can you take look ? Thanks

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

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: Fli

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

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 Iss

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

[ https://issues.apache.org/jira/browse/FLINK-5919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17209403#comment-17209403 ] Truong Duc Kien commented on FLINK-5919: [~trohrmann] Can you clarify why this is

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

[ https://issues.apache.org/jira/browse/FLINK-18527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17199266#comment-17199266 ] Truong Duc Kien commented on FLINK-18527: - It turns out that it was our uber-jar

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

[ 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 conflict

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

[ https://issues.apache.org/jira/browse/FLINK-18527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196932#comment-17196932 ] Truong Duc Kien commented on FLINK-18527: - I don't think we do anything special

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

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183311#comment-17183311 ] Truong Duc Kien commented on FLINK-18934: - Sorry, I've forgotten about this issu

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

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

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 I

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

[ https://issues.apache.org/jira/browse/FLINK-18554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17157258#comment-17157258 ] Truong Duc Kien commented on FLINK-18554: - We investigated and came to the concl

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

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

[ https://issues.apache.org/jira/browse/FLINK-18554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17155242#comment-17155242 ] Truong Duc Kien commented on FLINK-18554: - According to this issues, mmaping SST

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

[ https://issues.apache.org/jira/browse/FLINK-18554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

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

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16932200#comment-16932200 ] Truong Duc Kien commented on FLINK-7289: In my experience, using jemalloc can red

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

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16903760#comment-16903760 ] Truong Duc Kien commented on FLINK-10114: - Hi, [~hiliuxg] I take a look at your

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

[ https://issues.apache.org/jira/browse/FLINK-9465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849867#comment-16849867 ] Truong Duc Kien commented on FLINK-9465: We optimized our jobs so that they check

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

[ https://issues.apache.org/jira/browse/FLINK-6263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843135#comment-16843135 ] Truong Duc Kien commented on FLINK-6263: I think this is a duplicate of https://i

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

[ https://issues.apache.org/jira/browse/FLINK-8033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16822402#comment-16822402 ] Truong Duc Kien commented on FLINK-8033: I also think that Flink should target Ja

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

[ 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 with

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

[ https://issues.apache.org/jira/browse/FLINK-9459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16782727#comment-16782727 ] Truong Duc Kien commented on FLINK-9459: This doesn't seem to happens anymore wit

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

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

[ https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16736636#comment-16736636 ] Truong Duc Kien commented on FLINK-10848: - Yarn can return more containers than

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

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

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16705572#comment-16705572 ] Truong Duc Kien commented on FLINK-10114: - Maybe we can let the ORC's writer wri

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

[ https://issues.apache.org/jira/browse/FLINK-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686275#comment-16686275 ] Truong Duc Kien commented on FLINK-10857: - This is due to `AbstractMetricGroup.l

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

[ https://issues.apache.org/jira/browse/FLINK-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16686264#comment-16686264 ] Truong Duc Kien commented on FLINK-10857: - I've updated my code, even when {{Fro

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

[ 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 re

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

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 Is

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

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 Issue

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

[ https://issues.apache.org/jira/browse/FLINK-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514674#comment-16514674 ] Truong Duc Kien commented on FLINK-9552: Hi [~till.rohrmann] , FLINK-3257 seems t

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

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 T

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

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 Typ

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

[ https://issues.apache.org/jira/browse/FLINK-9459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16493464#comment-16493464 ] Truong Duc Kien commented on FLINK-9459: Yes, it seems the root cause is the same

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

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

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: I

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

[ 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 unsuccessf

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

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

[ 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 w

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

[ 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 w

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

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 T

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

[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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()

[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16430525#comment-16430525 ] Truong Duc Kien commented on FLINK-9070: This is definitely a safer way than my id

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

[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16415609#comment-16415609 ] Truong Duc Kien commented on FLINK-9070: So here's my idea for RocksDBMapState.cle

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

[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16413567#comment-16413567 ] Truong Duc Kien commented on FLINK-9070: Yeah, that bug with DeleteRange was fixed

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

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

[ https://issues.apache.org/jira/browse/FLINK-9052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16409135#comment-16409135 ] Truong Duc Kien commented on FLINK-9052: Turn out this issue is due to Java API's

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

[ 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

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 Issue

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

[ https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16405692#comment-16405692 ] Truong Duc Kien commented on FLINK-8946: Sorry, we haven't had time to test with F

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

[ https://issues.apache.org/jira/browse/FLINK-8297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16400215#comment-16400215 ] Truong Duc Kien commented on FLINK-8297: Isn't this also related to https://issues

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

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 Co

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

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

[ https://issues.apache.org/jira/browse/FLINK-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16220383#comment-16220383 ] Truong Duc Kien commented on FLINK-7921: It works fine for me. Maybe there's some