[jira] [Comment Edited] (FLINK-22968) Improve exception message when using toAppendStream[String]

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361421#comment-17361421 ] DaChun edited comment on FLINK-22968 at 6/11/21, 5:55 AM: -- thanks you very much

[jira] [Commented] (FLINK-22968) Improve exception message when using toAppendStream[String]

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361421#comment-17361421 ] DaChun commented on FLINK-22968: thanks you very much Jark Wu,love you. > Improve exception message

[jira] [Closed] (FLINK-22952) docs_404_check fail on azure due to ruby version not available

[ https://issues.apache.org/jira/browse/FLINK-22952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-22952. Resolution: Fixed > docs_404_check fail on azure due to ruby version not available >

[jira] [Comment Edited] (FLINK-22952) docs_404_check fail on azure due to ruby version not available

[ https://issues.apache.org/jira/browse/FLINK-22952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360927#comment-17360927 ] Chesnay Schepler edited comment on FLINK-22952 at 6/11/21, 5:47 AM:

[jira] [Updated] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

[ https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei-Che Wei updated FLINK-22970: Description: According to this ML discussion

[jira] [Created] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

Wei-Che Wei created FLINK-22970: --- Summary: The documentation for `TO_TIMESTAMP` UDF has an incorrect description Key: FLINK-22970 URL: https://issues.apache.org/jira/browse/FLINK-22970 Project: Flink

[jira] [Assigned] (FLINK-22968) Improve exception message when using toAppendStream[String]

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22968: --- Assignee: Nicholas Jiang > Improve exception message when using toAppendStream[String] >

[jira] [Comment Edited] (FLINK-15526) Add RollingPolicy to PartitionWriters

[ https://issues.apache.org/jira/browse/FLINK-15526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361380#comment-17361380 ] luoyuxia edited comment on FLINK-15526 at 6/11/21, 3:59 AM: [~lzljs3620320] 

[jira] [Commented] (FLINK-15526) Add RollingPolicy to PartitionWriters

[ https://issues.apache.org/jira/browse/FLINK-15526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361380#comment-17361380 ] luoyuxia commented on FLINK-15526: -- [~lzljs3620320] I see DefaultRollingPolicy.shouldRollOnEvent

[jira] [Commented] (FLINK-22968) Improve exception message when using toAppendStream[String]

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361378#comment-17361378 ] Nicholas Jiang commented on FLINK-22968: [~jark], I would like to take this issue. Could you

[jira] [Closed] (FLINK-22907) SQL Client queries fails on select statement

[ https://issues.apache.org/jira/browse/FLINK-22907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22907. --- Resolution: Not A Problem > SQL Client queries fails on select statement >

[jira] [Comment Edited] (FLINK-22907) SQL Client queries fails on select statement

[ https://issues.apache.org/jira/browse/FLINK-22907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361376#comment-17361376 ] Jark Wu edited comment on FLINK-22907 at 6/11/21, 3:52 AM: --- [~rdarling],

[jira] [Commented] (FLINK-22907) SQL Client queries fails on select statement

[ https://issues.apache.org/jira/browse/FLINK-22907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361376#comment-17361376 ] Jark Wu commented on FLINK-22907: - [~rdarling], please do not use {{--jar}} to load jars which are

[jira] [Updated] (FLINK-22968) String type cannot be used when creating Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22968: Priority: Major (was: Blocker) > String type cannot be used when creating Flink SQL >

[jira] [Updated] (FLINK-22968) Improve exception message when using toAppendStream[String]

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22968: Summary: Improve exception message when using toAppendStream[String] (was: String type cannot be used

[jira] [Updated] (FLINK-22968) String type cannot be used when creating Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22968: Description: {code:scala} package com.bytedance.one import

[jira] [Updated] (FLINK-22968) String type cannot be used when creating Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22968: Description: {code:scala} package com.bytedance.one import

[jira] [Updated] (FLINK-22968) String type cannot be used when creating Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22968: Docs Text: (was: package com.bytedance.one import org.apache.flink.streaming.api.scala.{DataStream,

[jira] [Commented] (FLINK-22968) String type cannot be used when creating Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361373#comment-17361373 ] Jark Wu commented on FLINK-22968: - But I have to admit we should improve the exception message a bit.

[jira] [Commented] (FLINK-22968) String type cannot be used when creating Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361370#comment-17361370 ] Jark Wu commented on FLINK-22968: - Hi [~DaChun777], thanks for reporting this, but this is not a bug.

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22969: Component/s: Table SQL / Ecosystem Connectors / Kafka > Validate the topic is not null

[jira] [Comment Edited] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out

[ https://issues.apache.org/jira/browse/FLINK-22735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361360#comment-17361360 ] frank wang edited comment on FLINK-22735 at 6/11/21, 3:19 AM: -- [~lirui] i

[jira] [Commented] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out

[ https://issues.apache.org/jira/browse/FLINK-22735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361360#comment-17361360 ] frank wang commented on FLINK-22735: [~lirui] i check the code , and find 

[jira] [Commented] (FLINK-22952) docs_404_check fail on azure due to ruby version not available

[ https://issues.apache.org/jira/browse/FLINK-22952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361358#comment-17361358 ] Xintong Song commented on FLINK-22952: --

[jira] [Commented] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361357#comment-17361357 ] Xintong Song commented on FLINK-22457: --

[jira] [Commented] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361355#comment-17361355 ] Xintong Song commented on FLINK-22387: --

[jira] [Commented] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361354#comment-17361354 ] Xintong Song commented on FLINK-22963: -- [~jasonlee1017], thanks for reporting this issue and

[jira] [Assigned] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-22963: Assignee: JasonLee > The description of taskmanager.memory.task.heap.size in the

[jira] [Created] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

Shengkai Fang created FLINK-22969: - Summary: Validate the topic is not null or empty string when create kafka source/sink function Key: FLINK-22969 URL: https://issues.apache.org/jira/browse/FLINK-22969

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22969: -- Issue Type: Improvement (was: Bug) > Validate the topic is not null or empty string when

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-22969: -- Affects Version/s: 1.14.0 > Validate the topic is not null or empty string when create kafka

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361350#comment-17361350 ] Xintong Song commented on FLINK-20329: -- Thanks [~karmagyz]. I cannot come up with any other better

[jira] [Assigned] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20329: Assignee: Yangze Guo > Elasticsearch7DynamicSinkITCase hangs >

[jira] [Updated] (FLINK-22627) Remove SlotManagerImpl

[ https://issues.apache.org/jira/browse/FLINK-22627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-22627: --- Labels: pull-request-available (was: pull-request-available stale-assigned) > Remove

[jira] [Commented] (FLINK-22625) FileSinkMigrationITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361349#comment-17361349 ] Xintong Song commented on FLINK-22625: -- Thank, [~gaoyunhaii]. I've assigned you to the ticket. >

[jira] [Assigned] (FLINK-22625) FileSinkMigrationITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-22625: Assignee: Yun Gao > FileSinkMigrationITCase unstable >

[jira] [Issue Comment Deleted] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee updated FLINK-22963: - Comment: was deleted (was: [~xintongsong]  Thank you for your confirmation and changes to the issue.

[jira] [Commented] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361346#comment-17361346 ] JasonLee commented on FLINK-22963: -- [~xintongsong]  Thank you for your confirmation and changes to the

[jira] [Commented] (FLINK-22933) Upgrade the Flink Fabric8io/kubernetes-client version to >=5.4.0 to be FIPS compliant

[ https://issues.apache.org/jira/browse/FLINK-22933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361345#comment-17361345 ] Yang Wang commented on FLINK-22933: --- [~Fuyao Li] Maybe I do not make myself clear. IIRC, we could not

[jira] [Commented] (FLINK-22625) FileSinkMigrationITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361343#comment-17361343 ] Yun Gao commented on FLINK-22625: - [~xintongsong] sure, I'll have a look. > FileSinkMigrationITCase

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361342#comment-17361342 ] Yangze Guo commented on FLINK-20329: Maybe we can temporarily change the logger devel temporarily to

[jira] [Commented] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361341#comment-17361341 ] JasonLee commented on FLINK-22963: -- Hi Xintong Thank you for your confirmation and changes to the

[jira] [Updated] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22946: -- Description: We recently encountered deadlock when using unaligned checkpoint. Below are two

[jira] [Updated] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guokuai Huang updated FLINK-22946: -- Priority: Blocker (was: Critical) > Network buffer deadlock introduced by unaligned

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361338#comment-17361338 ] Xintong Song commented on FLINK-20329: --

[jira] [Updated] (FLINK-22419) testScheduleRunAsync fail

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

[jira] [Reopened] (FLINK-22419) testScheduleRunAsync fail

[ https://issues.apache.org/jira/browse/FLINK-22419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-22419: -- Reopen to port the fix to 1.12. Instance on 1.12:

[jira] [Commented] (FLINK-22625) FileSinkMigrationITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361333#comment-17361333 ] Xintong Song commented on FLINK-22625: -- [~gaoyunhaii], could you please take a look into this test

[jira] [Commented] (FLINK-22625) FileSinkMigrationITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-22625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361332#comment-17361332 ] Xintong Song commented on FLINK-22625: --

[jira] [Commented] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361331#comment-17361331 ] Xintong Song commented on FLINK-22908: --

[jira] [Reopened] (FLINK-22952) docs_404_check fail on azure due to ruby version not available

[ https://issues.apache.org/jira/browse/FLINK-22952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-22952: -- Happens again on master, after the PR is merged.

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361329#comment-17361329 ] Xintong Song commented on FLINK-19863: -- [~Leonard Xu], this is happening again. Would you like to

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361328#comment-17361328 ] Xintong Song commented on FLINK-19863: --

[jira] [Updated] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22963: - Labels: documentation starter (was: documentation) > The description of

[jira] [Updated] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22963: - Affects Version/s: (was: 1.13.0) (was: 1.12.0)

[jira] [Updated] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22963: - Priority: Major (was: Minor) > The description of taskmanager.memory.task.heap.size in the

[jira] [Updated] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22963: - Issue Type: Bug (was: Improvement) > The description of taskmanager.memory.task.heap.size in

[jira] [Updated] (FLINK-20988) Various resource allocation improvements for active resource managers

[ https://issues.apache.org/jira/browse/FLINK-20988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20988: - Labels: Umbrella (was: Umbrella stale-assigned) > Various resource allocation improvements for

[jira] [Updated] (FLINK-22968) String type cannot be used when creating Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] DaChun updated FLINK-22968: --- Docs Text: package com.bytedance.one import org.apache.flink.streaming.api.scala.{DataStream,

[jira] [Updated] (FLINK-22968) String type cannot be used when creating Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] DaChun updated FLINK-22968: --- Environment: {color:#FF}*Flink-1.13.1 and Flink-1.12.1*{color} (was:

[jira] [Created] (FLINK-22968) String type cannot be used when creating Flink SQL

DaChun created FLINK-22968: -- Summary: String type cannot be used when creating Flink SQL Key: FLINK-22968 URL: https://issues.apache.org/jira/browse/FLINK-22968 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-19550) StreamingFileSink can't be interrupted when writing to S3

[ https://issues.apache.org/jira/browse/FLINK-19550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot closed FLINK-19550. -- Resolution: Auto Closed This issue was labeled "stale-minor" 7 ago and has not received any

[jira] [Updated] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22593: --- Labels: stale-blocker stale-critical test-stability (was: stale-critical test-stability)

[jira] [Updated] (FLINK-22443) can not be execute an extreme long sql under batch mode

[ https://issues.apache.org/jira/browse/FLINK-22443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22443: --- I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community

[jira] [Updated] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

[ https://issues.apache.org/jira/browse/FLINK-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10794: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-2491) Support Checkpoints After Tasks Finished

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2491: -- Labels: auto-deprioritized-critical (was: stale-critical) Priority: Major (was:

[jira] [Updated] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10806: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-10834) TableAPI flatten() calculated value error

[ https://issues.apache.org/jira/browse/FLINK-10834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10834: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-10855) CheckpointCoordinator does not delete checkpoint directory of late/failed checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10855: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-19380) Add support for a gRPC transport for the RequestReply protocol.

[ https://issues.apache.org/jira/browse/FLINK-19380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19380: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-10882) Misleading job/task state for scheduled jobs

[ https://issues.apache.org/jira/browse/FLINK-10882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10882: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-20574) Throttle number of remote invocation requests on startup or restores with large backlogs

[ https://issues.apache.org/jira/browse/FLINK-20574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20574: --- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned

[jira] [Updated] (FLINK-21308) Cancel "sendAfter"

[ https://issues.apache.org/jira/browse/FLINK-21308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21308: --- Labels: auto-deprioritized-major stale-major (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-11070) Add stream-stream non-window cross join

[ https://issues.apache.org/jira/browse/FLINK-11070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11070: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-11141) Key generation for RocksDBMapState can theoretically be ambiguous

[ https://issues.apache.org/jira/browse/FLINK-11141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11141: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am

[jira] [Updated] (FLINK-10873) Remove tableEnv in DataSetConversions#toTable and DataStreamConversions#toTable

[ https://issues.apache.org/jira/browse/FLINK-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10873: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-11060) Unable to set number of task manager and slot per task manager in scala shell local mode

[ https://issues.apache.org/jira/browse/FLINK-11060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11060: --- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned

[jira] [Updated] (FLINK-22626) KafkaITCase.testTimestamps fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-22626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22626: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-11102) Enable check for previous data in SpanningRecordSerializer

[ https://issues.apache.org/jira/browse/FLINK-11102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11102: --- Labels: auto-unassigned stale-major (was: auto-unassigned) I am the [Flink Jira

[jira] [Updated] (FLINK-22441) In Flink v1.11.3 contains netty(version:3.10.6) netty(version:4.1.60) . There are many vulnerabilities, like CVE-2021-21409 etc. please confirm these version and fix. th

[ https://issues.apache.org/jira/browse/FLINK-22441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22441: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-22532) Improve the support for remote functions in the DataStream integration

[ https://issues.apache.org/jira/browse/FLINK-22532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22532: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-16627) Support only generate non-null values when serializing into JSON

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16627: --- Labels: auto-deprioritized-major auto-unassigned sprint (was: auto-unassigned sprint

[jira] [Updated] (FLINK-16609) Promotes the column name representation of SQL-CLI

[ https://issues.apache.org/jira/browse/FLINK-16609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16609: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-16688) Hive-connector should set SessionState for hive

[ https://issues.apache.org/jira/browse/FLINK-16688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16688: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-20217) More fine-grained timer processing

[ https://issues.apache.org/jira/browse/FLINK-20217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20217: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16765) Replace all BatchTableEnvironment to StreamTableEnvironment in the document of PyFlink

[ https://issues.apache.org/jira/browse/FLINK-16765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16765: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-16708) When a JDBC connection has been closed, the retry policy of the JDBCUpsertOutputFormat cannot take effect

[ https://issues.apache.org/jira/browse/FLINK-16708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16708: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-22465) KafkaSourceITCase.testValueOnlyDeserializer hangs

[ https://issues.apache.org/jira/browse/FLINK-22465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22465: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22068: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-16735) FlinkKafkaProducer should check that it is not null before sending a record

[ https://issues.apache.org/jira/browse/FLINK-16735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16735: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-16762) Relocation Beam dependency of PyFlink

[ https://issues.apache.org/jira/browse/FLINK-16762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16762: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-22466) KafkaSourceLegacyITCase.testOneToOneSources fail because the OperatorEvent lost

[ https://issues.apache.org/jira/browse/FLINK-22466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22466: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-16716) Update Roadmap after Flink 1.10 release

[ https://issues.apache.org/jira/browse/FLINK-16716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16716: --- Labels: auto-deprioritized-critical auto-deprioritized-major (was:

[jira] [Updated] (FLINK-21142) Flink guava Dependence problem

[ https://issues.apache.org/jira/browse/FLINK-21142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21142: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-16799) add hive partition limit when read from hive

[ https://issues.apache.org/jira/browse/FLINK-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16799: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-16800) TypeMappingUtils#checkIfCompatible didn't deal with nested types

[ https://issues.apache.org/jira/browse/FLINK-16800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16800: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-16883) No support for log4j2 configuration formats besides properties

[ https://issues.apache.org/jira/browse/FLINK-16883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16883: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-22627) Remove SlotManagerImpl

[ https://issues.apache.org/jira/browse/FLINK-22627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22627: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-21345) NullPointerException LogicalCorrelateToJoinFromTemporalTableFunctionRule.scala:157

[ https://issues.apache.org/jira/browse/FLINK-21345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21345: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Closed] (FLINK-20208) Remove outdated in-progress files in StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-20208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot closed FLINK-20208. -- Resolution: Auto Closed This issue was labeled "stale-minor" 7 ago and has not received any

  1   2   3   4   >