[jira] [Closed] (FLINK-20906) Update copyright year to 2021 for NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-20906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20906. Resolution: Fixed Fixed for `flink-shaded` via * master: 022d3f84965399189ba32c84ef196e8a2ab127ce

[jira] [Commented] (FLINK-20258) Configured memory sizes on the JM metrics page should be displayed with proper units.

[ https://issues.apache.org/jira/browse/FLINK-20258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239628#comment-17239628 ] Xintong Song commented on FLINK-20258: -- Bytes are used for passing the configuration values for 

[jira] [Commented] (FLINK-20259) Add explanation that "configured values" for JM/TM memory sizes include automatically derived values

[ https://issues.apache.org/jira/browse/FLINK-20259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239491#comment-17239491 ] Xintong Song commented on FLINK-20259: -- Thanks [~vthinkxie]. I've assigned you. Please go ahead. >

[jira] [Assigned] (FLINK-20259) Add explanation that "configured values" for JM/TM memory sizes include automatically derived values

[ https://issues.apache.org/jira/browse/FLINK-20259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20259: Assignee: Yadong Xie > Add explanation that "configured values" for JM/TM memory sizes

[jira] [Commented] (FLINK-20249) Rethink the necessity of the k8s internal Service even in non-HA mode

[ https://issues.apache.org/jira/browse/FLINK-20249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237906#comment-17237906 ] Xintong Song commented on FLINK-20249: -- Thanks for the discussion and pulling me in. I think it

[jira] [Assigned] (FLINK-20282) Make invalid managed memory fraction errors more advisory in MemoryManager

[ https://issues.apache.org/jira/browse/FLINK-20282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20282: Assignee: Xintong Song > Make invalid managed memory fraction errors more advisory in

[jira] [Closed] (FLINK-20282) Make invalid managed memory fraction errors more advisory in MemoryManager

[ https://issues.apache.org/jira/browse/FLINK-20282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20282. Resolution: Fixed Fixed via * master: dee76cd47278b664c66fefd0a44e17356358454a > Make invalid

[jira] [Closed] (FLINK-20073) Add kerberos setup documentation for native k8s integration

[ https://issues.apache.org/jira/browse/FLINK-20073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20073. Resolution: Done Merged via * master: 7a7c87096ab76f416cd7c393240faa8454db36f0 * 1.12: 

[jira] [Created] (FLINK-20505) Yarn provided lib does not work with http paths.

Xintong Song created FLINK-20505: Summary: Yarn provided lib does not work with http paths. Key: FLINK-20505 URL: https://issues.apache.org/jira/browse/FLINK-20505 Project: Flink Issue Type:

[jira] [Created] (FLINK-20503) Internal cpu configuration option is leaked in logs

Xintong Song created FLINK-20503: Summary: Internal cpu configuration option is leaked in logs Key: FLINK-20503 URL: https://issues.apache.org/jira/browse/FLINK-20503 Project: Flink Issue

[jira] [Assigned] (FLINK-20503) Internal cpu configuration option is leaked in logs

[ https://issues.apache.org/jira/browse/FLINK-20503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20503: Assignee: Xintong Song > Internal cpu configuration option is leaked in logs >

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244999#comment-17244999 ] Xintong Song commented on FLINK-20505: -- Thanks for the replies, [~ZhenqiuHuang] and [~zoucao].

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245011#comment-17245011 ] Xintong Song commented on FLINK-20505: -- [~zoucao], BTW, I've assigned myself to this ticket,

[jira] [Commented] (FLINK-20503) Internal cpu configuration option is leaked in logs

[ https://issues.apache.org/jira/browse/FLINK-20503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17244926#comment-17244926 ] Xintong Song commented on FLINK-20503: -- cc: [~karmagyz], [~azagrebin], [~mapohl] > Internal cpu

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use maximum-failed-containers as limit of resource acquirement

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245067#comment-17245067 ] Xintong Song commented on FLINK-10868: -- Hi [~hpeter], I've gone through the previous discussions

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245071#comment-17245071 ] Xintong Song commented on FLINK-20505: -- [~zoucao], I don't think it requires a FLIP for this

[jira] [Created] (FLINK-20332) Add workers recovered from previous attempt to pending resources

Xintong Song created FLINK-20332: Summary: Add workers recovered from previous attempt to pending resources Key: FLINK-20332 URL: https://issues.apache.org/jira/browse/FLINK-20332 Project: Flink

[jira] [Commented] (FLINK-20249) Rethink the necessity of the k8s internal Service even in non-HA mode

[ https://issues.apache.org/jira/browse/FLINK-20249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238488#comment-17238488 ] Xintong Song commented on FLINK-20249: -- [~jiang7chengzitc], Your understanding is correct. Fixing

[jira] [Commented] (FLINK-20249) Rethink the necessity of the k8s internal Service even in non-HA mode

[ https://issues.apache.org/jira/browse/FLINK-20249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238633#comment-17238633 ] Xintong Song commented on FLINK-20249: -- [~trohrmann], Ok, I think I see your point. {quote}whether

[jira] [Commented] (FLINK-20259) Add explanation that "configured values" for JM/TM memory sizes include automatically derived values

[ https://issues.apache.org/jira/browse/FLINK-20259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247134#comment-17247134 ] Xintong Song commented on FLINK-20259: -- [~mapohl], I think "Effective Configuration" is a really

[jira] [Commented] (FLINK-20451) Taskmanager can't apply resources when submit job with configs `env.java.opts.taskmanager: -javaagent:`

[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242872#comment-17242872 ] Xintong Song commented on FLINK-20451: -- Hi [~xiaozilong], I don't understand the problem. What do

[jira] [Commented] (FLINK-20451) Taskmanager can't allocate resources when submit job with configs `env.java.opts.taskmanager: -javaagent:`

[ https://issues.apache.org/jira/browse/FLINK-20451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242957#comment-17242957 ] Xintong Song commented on FLINK-20451: -- For public visibility: [~xiaozilong] reached out to me

[jira] [Commented] (FLINK-15906) physical memory exceeded causing being killed by yarn

[ https://issues.apache.org/jira/browse/FLINK-15906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242974#comment-17242974 ] Xintong Song commented on FLINK-15906: -- The exception suggests that the task manager is consuming

[jira] [Closed] (FLINK-20214) Unnecessary warning log when starting a k8s session cluster

[ https://issues.apache.org/jira/browse/FLINK-20214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20214. Resolution: Fixed Fixed via: * master: 00ee23b4ee78e9c41229bc16fa0bc49d9c20ba05 > Unnecessary

[jira] [Commented] (FLINK-20258) Configured memory sizes on the JM metrics page should be displayed with proper units.

[ https://issues.apache.org/jira/browse/FLINK-20258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241205#comment-17241205 ] Xintong Song commented on FLINK-20258: -- Sounds good to me. Thanks for the explanation, [~mapohl].

[jira] [Commented] (FLINK-12884) FLIP-144: Native Kubernetes HA Service

[ https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242124#comment-17242124 ] Xintong Song commented on FLINK-12884: -- [~shravan.adharapurapu], K8s HA service will be released

[jira] [Comment Edited] (FLINK-20646) ReduceTransformation does not work with RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-20646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250920#comment-17250920 ] Xintong Song edited comment on FLINK-20646 at 12/17/20, 9:39 AM: - I

[jira] [Assigned] (FLINK-20646) ReduceTransformation does not work with RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-20646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20646: Assignee: Aljoscha Krettek (was: Xintong Song) > ReduceTransformation does not work

[jira] [Assigned] (FLINK-20646) ReduceTransformation does not work with RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-20646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20646: Assignee: Xintong Song > ReduceTransformation does not work with RocksDBStateBackend >

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 release

[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251005#comment-17251005 ] Xintong Song commented on FLINK-20632: -- bq. As a meta comment: Should we wait with release

[jira] [Updated] (FLINK-20379) New Kafka Connector does not support DeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-20379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20379: - Affects Version/s: 1.12.0 > New Kafka Connector does not support DeserializationSchema >

[jira] [Updated] (FLINK-20379) New Kafka Connector does not support DeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-20379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20379: - Fix Version/s: 1.12.1 > New Kafka Connector does not support DeserializationSchema >

[jira] [Commented] (FLINK-20646) ReduceTransformation does not work with RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-20646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250962#comment-17250962 ] Xintong Song commented on FLINK-20646: -- [~aljoscha], I think they are just playing with 1.12.0.

[jira] [Commented] (FLINK-20646) ReduceTransformation does not work with RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-20646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250920#comment-17250920 ] Xintong Song commented on FLINK-20646: -- I think this but reveals two problems. * Absence of common

[jira] [Updated] (FLINK-20646) ReduceTransformation does not work with RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-20646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20646: - Description: The intra-slot managed memory sharing (FLIP-141) requires transformations to

[jira] [Updated] (FLINK-20114) Test Kafka Source based on the new Source API 

[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20114: - Fix Version/s: 1.12.1 > Test Kafka Source based on the new Source API  >

[jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20431: - Fix Version/s: 1.12.1 >

[jira] [Updated] (FLINK-19743) Add Source metrics definitions

[ https://issues.apache.org/jira/browse/FLINK-19743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19743: - Fix Version/s: 1.12.1 1.13.0 > Add Source metrics definitions >

[jira] [Commented] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251444#comment-17251444 ] Xintong Song commented on FLINK-20648: -- [~fly_in_gis], could you help look into this? > Unable to

[jira] [Assigned] (FLINK-20664) Support setting service account for TaskManager pod

[ https://issues.apache.org/jira/browse/FLINK-20664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20664: Assignee: Yang Wang > Support setting service account for TaskManager pod >

[jira] [Updated] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20648: - Fix Version/s: 1.12.1 > Unable to restore job from savepoint when using Kubernetes based HA

[jira] [Assigned] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20648: Assignee: Yang Wang > Unable to restore job from savepoint when using Kubernetes based

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use maximum-failed-containers as limit of resource acquirement

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251576#comment-17251576 ] Xintong Song commented on FLINK-10868: -- [~ZhenqiuHuang], I think adding counting metrics for

[jira] [Updated] (FLINK-20630) [Kinesis][DynamoDB] DynamoDB Streams Consumer fails to consume from Latest

[ https://issues.apache.org/jira/browse/FLINK-20630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20630: - Fix Version/s: 1.13.0 > [Kinesis][DynamoDB] DynamoDB Streams Consumer fails to consume from

[jira] [Updated] (FLINK-20629) [Kinesis][EFO] Migrate from DescribeStream to DescribeStreamSummary

[ https://issues.apache.org/jira/browse/FLINK-20629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20629: - Fix Version/s: 1.13.0 > [Kinesis][EFO] Migrate from DescribeStream to DescribeStreamSummary >

[jira] [Updated] (FLINK-18906) Support checkpointing with multiple input operator chained with sources

[ https://issues.apache.org/jira/browse/FLINK-18906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18906: - Fix Version/s: 1.11.3 > Support checkpointing with multiple input operator chained with sources

[jira] [Updated] (FLINK-20396) Add "OperatorCoordinator.resetSubtask()" to fix order problems of "subtaskFailed()"

[ https://issues.apache.org/jira/browse/FLINK-20396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20396: - Fix Version/s: 1.11.3 > Add "OperatorCoordinator.resetSubtask()" to fix order problems of >

[jira] [Updated] (FLINK-20397) Pass checkpointId to OperatorCoordinator.resetToCheckpoint().

[ https://issues.apache.org/jira/browse/FLINK-20397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20397: - Fix Version/s: 1.11.3 > Pass checkpointId to OperatorCoordinator.resetToCheckpoint(). >

[jira] [Updated] (FLINK-20266) New Sources prevent JVM shutdown when running a job

[ https://issues.apache.org/jira/browse/FLINK-20266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20266: - Fix Version/s: 1.11.3 > New Sources prevent JVM shutdown when running a job >

[jira] [Updated] (FLINK-20223) The RecreateOnResetOperatorCoordinator and SourceCoordinator executor thread should use the user class loader.

[ https://issues.apache.org/jira/browse/FLINK-20223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20223: - Fix Version/s: 1.11.3 > The RecreateOnResetOperatorCoordinator and SourceCoordinator executor

[jira] [Updated] (FLINK-20222) The CheckpointCoordinator should reset the OperatorCoordinators when fail before the first checkpoint.

[ https://issues.apache.org/jira/browse/FLINK-20222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20222: - Fix Version/s: 1.11.3 > The CheckpointCoordinator should reset the OperatorCoordinators when

[jira] [Updated] (FLINK-19338) New source interface cannot unregister unregistered source

[ https://issues.apache.org/jira/browse/FLINK-19338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19338: - Fix Version/s: 1.11.3 > New source interface cannot unregister unregistered source >

[jira] [Updated] (FLINK-19535) SourceCoordinator should avoid fail job multiple times.

[ https://issues.apache.org/jira/browse/FLINK-19535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19535: - Fix Version/s: (was: 1.11.4) 1.11.3 > SourceCoordinator should avoid

[jira] [Updated] (FLINK-20193) SourceCoordinator should catch exception thrown from SplitEnumerator.start()

[ https://issues.apache.org/jira/browse/FLINK-20193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20193: - Fix Version/s: 1.11.3 > SourceCoordinator should catch exception thrown from

[jira] [Updated] (FLINK-20049) Simplify handling of "request split".

[ https://issues.apache.org/jira/browse/FLINK-20049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20049: - Fix Version/s: 1.11.3 > Simplify handling of "request split". >

[jira] [Updated] (FLINK-20418) NPE in IteratorSourceReader

[ https://issues.apache.org/jira/browse/FLINK-20418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20418: - Fix Version/s: 1.11.3 > NPE in IteratorSourceReader > --- > >

[jira] [Updated] (FLINK-19934) [FLIP-27 source] add new API: SplitEnumeratorContext.runInCoordinatorThread(Runnable)

[ https://issues.apache.org/jira/browse/FLINK-19934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19934: - Fix Version/s: 1.11.3 > [FLIP-27 source] add new API: >

[jira] [Updated] (FLINK-20050) SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20050: - Fix Version/s: 1.11.3 > SourceCoordinatorProviderTest.testCheckpointAndReset failed with >

[jira] [Updated] (FLINK-20063) File Source requests an additional split on every restore.

[ https://issues.apache.org/jira/browse/FLINK-20063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20063: - Fix Version/s: 1.11.3 > File Source requests an additional split on every restore. >

[jira] [Updated] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20492: - Fix Version/s: 1.11.3 > The SourceOperatorStreamTask should implement cancelTask() and

[jira] [Updated] (FLINK-20413) Sources should add splits back in "resetSubtask()", rather than in "subtaskFailed()".

[ https://issues.apache.org/jira/browse/FLINK-20413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20413: - Fix Version/s: 1.11.3 > Sources should add splits back in "resetSubtask()", rather than in >

[jira] [Updated] (FLINK-20270) Fix the regression of missing ExternallyInducedSource support in FLIP-27 Source.

[ https://issues.apache.org/jira/browse/FLINK-20270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20270: - Fix Version/s: 1.11.3 > Fix the regression of missing ExternallyInducedSource support in

[jira] [Updated] (FLINK-19265) Simplify handling of 'NoMoreSplitsEvent'

[ https://issues.apache.org/jira/browse/FLINK-19265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19265: - Fix Version/s: 1.11.3 > Simplify handling of 'NoMoreSplitsEvent' >

[jira] [Updated] (FLINK-20169) Move emitting MAX_WATERMARK out of SourceOperator processing loop

[ https://issues.apache.org/jira/browse/FLINK-20169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20169: - Fix Version/s: 1.11.3 > Move emitting MAX_WATERMARK out of SourceOperator processing loop >

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247630#comment-17247630 ] Xintong Song commented on FLINK-20505: -- [~ZhenqiuHuang], Yes, I think that's what we are planning

[jira] [Updated] (FLINK-20213) Partition commit is delayed when records keep coming

[ https://issues.apache.org/jira/browse/FLINK-20213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20213: - Fix Version/s: 1.11.3 > Partition commit is delayed when records keep coming >

[jira] [Assigned] (FLINK-20505) Yarn provided lib does not work with http paths.

[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20505: Assignee: zoucao (was: Xintong Song) > Yarn provided lib does not work with http paths.

[jira] [Updated] (FLINK-20455) Add check to LicenseChecker for top level /LICENSE files in shaded jars

[ https://issues.apache.org/jira/browse/FLINK-20455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20455: - Fix Version/s: 1.11.3 > Add check to LicenseChecker for top level /LICENSE files in shaded jars

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17247619#comment-17247619 ] Xintong Song commented on FLINK-20505: -- [~ZhenqiuHuang], It there any further comments/concerns

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254376#comment-17254376 ] Xintong Song commented on FLINK-20505: -- [~zoucao], Could you share some more details about the use

[jira] [Commented] (FLINK-20505) Yarn provided lib does not work with http paths.

[ https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254403#comment-17254403 ] Xintong Song commented on FLINK-20505: -- I'm not sure whether we should support individual files for

[jira] [Closed] (FLINK-20650) Mark "native-k8s" as deprecated in docker-entrypoint.sh

[ https://issues.apache.org/jira/browse/FLINK-20650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20650. Resolution: Fixed Fixed *flink-docker* via * dev-master **

[jira] [Closed] (FLINK-20173) CoordinatedSourceITCase.testEnumeratorReaderCommunication fails with IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-20173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20173. Resolution: Fixed Thanks [~kezhuw]. Closing this ticket. Fixed by FLINK-19448. >

[jira] [Updated] (FLINK-20173) CoordinatedSourceITCase.testEnumeratorReaderCommunication fails with IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-20173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20173: - Fix Version/s: (was: 1.11.4) > CoordinatedSourceITCase.testEnumeratorReaderCommunication

[jira] [Closed] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20648. Resolution: Fixed Fixed on release-1.12 via: * 368b204d82ea274be9a47d7f1b9d24c7365c3b2d Fixed

[jira] [Commented] (FLINK-20476) New File Sink end-to-end test Failed

[ https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252558#comment-17252558 ] Xintong Song commented on FLINK-20476: -- [~gaoyunhaii] [~hxbks2ks], Thanks for reporting and

[jira] [Created] (FLINK-20688) New File Sink end-to-end test failed repeating "Received resource declaration"

Xintong Song created FLINK-20688: Summary: New File Sink end-to-end test failed repeating "Received resource declaration" Key: FLINK-20688 URL: https://issues.apache.org/jira/browse/FLINK-20688

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use maximum-failed-containers as limit of resource acquirement

[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252640#comment-17252640 ] Xintong Song commented on FLINK-10868: -- Thanks for the updates. I'll try to take a look asap. >

[jira] [Updated] (FLINK-20476) New File Sink end-to-end test Failed

[ https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20476: - Affects Version/s: (was: 1.12.1) 1.12.0 > New File Sink end-to-end

[jira] [Updated] (FLINK-20476) New File Sink end-to-end test Failed

[ https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20476: - Priority: Critical (was: Blocker) > New File Sink end-to-end test Failed >

[jira] [Comment Edited] (FLINK-20476) New File Sink end-to-end test Failed

[ https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252558#comment-17252558 ] Xintong Song edited comment on FLINK-20476 at 12/21/20, 2:07 AM: -

[jira] [Updated] (FLINK-20688) New File Sink end-to-end test failed repeating "Received resource declaration"

[ https://issues.apache.org/jira/browse/FLINK-20688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20688: - Priority: Blocker (was: Major) > New File Sink end-to-end test failed repeating "Received

[jira] [Updated] (FLINK-20688) New File Sink end-to-end test failed repeating "Received resource declaration"

[ https://issues.apache.org/jira/browse/FLINK-20688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20688: - Fix Version/s: 1.13.0 > New File Sink end-to-end test failed repeating "Received resource

[jira] [Commented] (FLINK-20688) New File Sink end-to-end test failed repeating "Received resource declaration"

[ https://issues.apache.org/jira/browse/FLINK-20688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252570#comment-17252570 ] Xintong Song commented on FLINK-20688: -- cc [~hxbks2ks], [~gaoyunhaii], [~chesnay] > New File Sink

[jira] [Closed] (FLINK-20646) ReduceTransformation does not work with RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-20646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20646. Release Note: Fixed via: * master (1.13): cf71008984dd68b25db3612a9ca39f197b7e09c8 *

[jira] [Updated] (FLINK-20646) ReduceTransformation does not work with RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-20646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20646: - Fix Version/s: 1.13.0 > ReduceTransformation does not work with RocksDBStateBackend >

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 releas

[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17250736#comment-17250736 ] Xintong Song commented on FLINK-20632: -- Hi [~peperg], Docker Hub requires all official images to

[jira] [Updated] (FLINK-20664) Support setting service account for TaskManager pod

[ https://issues.apache.org/jira/browse/FLINK-20664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20664: - Priority: Blocker (was: Critical) > Support setting service account for TaskManager pod >

[jira] [Commented] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253302#comment-17253302 ] Xintong Song commented on FLINK-20648: -- Just to add my two cents. IIUC, the reason we convert a

[jira] [Assigned] (FLINK-20664) Support setting service account for TaskManager pod

[ https://issues.apache.org/jira/browse/FLINK-20664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20664: Assignee: Boris Lublinsky (was: Yang Wang) > Support setting service account for

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253373#comment-17253373 ] Xintong Song commented on FLINK-20654: -- [~pnowojski], Thanks for the reply. Among all the 1.12.1

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17253303#comment-17253303 ] Xintong Song commented on FLINK-20654: -- Hi [~roman_khachatryan], How are things going with this

[jira] [Updated] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20648: - Priority: Blocker (was: Critical) > Unable to restore job from savepoint when using Kubernetes

[jira] [Closed] (FLINK-20519) Extend HBase notice with transitively bundled dependencies

[ https://issues.apache.org/jira/browse/FLINK-20519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20519. Resolution: Fixed Fixed via: * master (1.13): a5576587a4a92049d53cd2ec9dc310763a0c461d *

[jira] [Assigned] (FLINK-20519) Extend HBase notice with transitively bundled dependencies

[ https://issues.apache.org/jira/browse/FLINK-20519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20519: Assignee: Xintong Song > Extend HBase notice with transitively bundled dependencies >

[jira] [Commented] (FLINK-18906) Support checkpointing with multiple input operator chained with sources

[ https://issues.apache.org/jira/browse/FLINK-18906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17249428#comment-17249428 ] Xintong Song commented on FLINK-18906: -- True, thank you [~pnowojski]. > Support checkpointing with

[jira] [Updated] (FLINK-20537) Failed to call Hive UDF with string literal arguments

[ https://issues.apache.org/jira/browse/FLINK-20537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20537: - Fix Version/s: (was: 1.11.3) 1.11.4 > Failed to call Hive UDF with

[jira] [Updated] (FLINK-20412) Collect Result Fetching occasionally fails after a JobManager Failover

[ https://issues.apache.org/jira/browse/FLINK-20412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20412: - Fix Version/s: (was: 1.11.3) 1.11.4 > Collect Result Fetching

[jira] [Updated] (FLINK-18775) Rework PyFlink Documentation

[ https://issues.apache.org/jira/browse/FLINK-18775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18775: - Fix Version/s: (was: 1.11.3) 1.11.4 > Rework PyFlink Documentation >

[jira] [Updated] (FLINK-15018) Add event time page to Concepts

[ https://issues.apache.org/jira/browse/FLINK-15018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15018: - Fix Version/s: (was: 1.11.3) 1.11.4 > Add event time page to Concepts >

<    3   4   5   6   7   8   9   10   11   12   >