[jira] [Commented] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

[ https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888650#comment-17888650 ] Edward Rojas commented on FLINK-28897: -- Hi [~lsy] any news on this issue or a possi

[jira] [Commented] (FLINK-11419) StreamingFileSink fails to recover after taskmanager failure

[ https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16756394#comment-16756394 ] Edward Rojas commented on FLINK-11419: -- [~kkl0u] Travis build is failing but it's n

[jira] [Commented] (FLINK-11419) StreamingFileSink fails to recover after taskmanager failure

[ https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755180#comment-16755180 ] Edward Rojas commented on FLINK-11419: -- [~kkl0u] I created the PR, you can review i

[jira] [Commented] (FLINK-11419) StreamingFileSink fails to recover after taskmanager failure

[ https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16754066#comment-16754066 ] Edward Rojas commented on FLINK-11419: -- I performed more tests now by doing the mod

[jira] [Commented] (FLINK-11419) StreamingFileSink fails to recover after taskmanager failure

[ https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16753965#comment-16753965 ] Edward Rojas commented on FLINK-11419: -- Hi [~kkl0u], I performed several tests and

[jira] [Updated] (FLINK-11419) StreamingFileSink fails to recover after taskmanager failure

[ https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edward Rojas updated FLINK-11419: - Description: If a job with a StreamingFileSink sending data to HDFS is running in a cluster wit

[jira] [Updated] (FLINK-11419) StreamingFileSink fails to recover after taskmanager failure

[ https://issues.apache.org/jira/browse/FLINK-11419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edward Rojas updated FLINK-11419: - Description: If a job with a StreamingFileSink sending data to HDFS is running in a cluster wit

[jira] [Created] (FLINK-11419) StreamingFileSink fails to recover after taskmanager failure

Edward Rojas created FLINK-11419: Summary: StreamingFileSink fails to recover after taskmanager failure Key: FLINK-11419 URL: https://issues.apache.org/jira/browse/FLINK-11419 Project: Flink

[jira] [Commented] (FLINK-11318) [Regression] StreamingFileSink can overwrite existing files

[ https://issues.apache.org/jira/browse/FLINK-11318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743811#comment-16743811 ] Edward Rojas commented on FLINK-11318: -- Yes, that's what I had in mind. Thanks for

[jira] [Commented] (FLINK-11337) Incorrect watermark in StreaminFileSink BucketAssigner.Context when used in connected stream

[ https://issues.apache.org/jira/browse/FLINK-11337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743044#comment-16743044 ] Edward Rojas commented on FLINK-11337: -- Hi [~kkl0u], sorry, I created the issue too

[jira] [Created] (FLINK-11337) Incorrect watermark in StreaminFileSink BucketAssigner.Context when used in connected stream

Edward Rojas created FLINK-11337: Summary: Incorrect watermark in StreaminFileSink BucketAssigner.Context when used in connected stream Key: FLINK-11337 URL: https://issues.apache.org/jira/browse/FLINK-11337

[jira] [Commented] (FLINK-11318) [Regression] StreamingFileSink can overwrite existing files

[ https://issues.apache.org/jira/browse/FLINK-11318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742965#comment-16742965 ] Edward Rojas commented on FLINK-11318: -- Yes [~kkl0u], I did verify that this could

[jira] [Updated] (FLINK-11318) [Regression] StreamingFileSink can overwrite existing files

[ https://issues.apache.org/jira/browse/FLINK-11318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edward Rojas updated FLINK-11318: - Affects Version/s: 1.6.3 > [Regression] StreamingFileSink can overwrite existing files > ---

[jira] [Created] (FLINK-11318) [Regression] StreamingFileSink can overwrite existing files

Edward Rojas created FLINK-11318: Summary: [Regression] StreamingFileSink can overwrite existing files Key: FLINK-11318 URL: https://issues.apache.org/jira/browse/FLINK-11318 Project: Flink

[jira] [Commented] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16711469#comment-16711469 ] Edward Rojas commented on FLINK-11087: -- I just tried out, 1.5.3 to 1.6.2. I get a

[jira] [Created] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

Edward Rojas created FLINK-11087: Summary: Broadcast state migration Incompatibility from 1.5.3 to 1.7.0 Key: FLINK-11087 URL: https://issues.apache.org/jira/browse/FLINK-11087 Project: Flink

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16471833#comment-16471833 ] Edward Rojas commented on FLINK-9303: - you are right, I'll update my code and create a

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16465996#comment-16465996 ] Edward Rojas commented on FLINK-9303: - Hello,  I reported the issue on the mailing lis

[jira] [Commented] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled

[ https://issues.apache.org/jira/browse/FLINK-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16462124#comment-16462124 ] Edward Rojas commented on FLINK-9261: - I just want to point out that even with *web.ss

[jira] [Commented] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working

[ https://issues.apache.org/jira/browse/FLINK-9255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16456371#comment-16456371 ] Edward Rojas commented on FLINK-9255: - I was not aware of that change. Effectively usi

[jira] [Updated] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled

[ https://issues.apache.org/jira/browse/FLINK-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edward Rojas updated FLINK-9261: Labels: regression (was: ) > Regression - Flink CLI and Web UI not working when SSL is enabled > --

[jira] [Created] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled

Edward Rojas created FLINK-9261: --- Summary: Regression - Flink CLI and Web UI not working when SSL is enabled Key: FLINK-9261 URL: https://issues.apache.org/jira/browse/FLINK-9261 Project: Flink

[jira] [Updated] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working

[ https://issues.apache.org/jira/browse/FLINK-9255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edward Rojas updated FLINK-9255: Description: Every time the flink CLI is called with the -m option to specify the jobmanager addres

[jira] [Created] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working

Edward Rojas created FLINK-9255: --- Summary: Regression - Flink CLI -m,--jobmanager option not working Key: FLINK-9255 URL: https://issues.apache.org/jira/browse/FLINK-9255 Project: Flink Issue

[jira] [Created] (FLINK-9103) SSL verification on TaskManager when parallelism > 1

Edward Rojas created FLINK-9103: --- Summary: SSL verification on TaskManager when parallelism > 1 Key: FLINK-9103 URL: https://issues.apache.org/jira/browse/FLINK-9103 Project: Flink Issue Type: