[jira] [Commented] (FLINK-36162) Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference

2024-08-27 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877194#comment-17877194 ] Thomas Weise commented on FLINK-36162: -- [~gyfora] I was surprised when you closed y

[jira] [Commented] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference

2024-08-25 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876534#comment-17876534 ] Thomas Weise commented on FLINK-36145: -- `snapshotReference` sounds a bit misleading

[jira] [Commented] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

2024-07-09 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864421#comment-17864421 ] Thomas Weise commented on FLINK-33545: -- I agree that even if we fix the underlying

[jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

2024-05-17 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847467#comment-17847467 ] Thomas Weise commented on FLINK-16686: -- Flink 1.17: {code:java} Exception in thread

[jira] [Updated] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

2024-05-17 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-16686: - Affects Version/s: 1.17.0 > [State TTL] Make user class loader available in native RocksDB compa

[jira] [Resolved] (FLINK-28048) Introduce Source API alternative to FiniteTestSource

2024-04-20 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-28048. -- Fix Version/s: 1.20.0 Resolution: Implemented > Introduce Source API alternative to Fin

[jira] [Updated] (FLINK-25565) Write and Read Parquet INT64 Timestamp

2023-12-08 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-25565: - Fix Version/s: 1.18.1 > Write and Read Parquet INT64 Timestamp > ---

[jira] [Commented] (FLINK-25565) Write and Read Parquet INT64 Timestamp

2023-12-07 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794287#comment-17794287 ] Thomas Weise commented on FLINK-25565: -- [~martijnvisser] the default behavior did n

[jira] [Commented] (FLINK-25565) Write and Read Parquet INT64 Timestamp

2023-12-07 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794237#comment-17794237 ] Thomas Weise commented on FLINK-25565: -- It turns out that without this option, tabl

[jira] [Resolved] (FLINK-25565) Write and Read Parquet INT64 Timestamp

2023-12-06 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-25565. -- Fix Version/s: 1.19.0 Resolution: Fixed > Write and Read Parquet INT64 Timestamp >

[jira] [Resolved] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex using error Integer check

2023-12-04 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-27529. -- Resolution: Fixed > HybridSourceSplitEnumerator sourceIndex using error Integer check > --

[jira] [Updated] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex using error Integer check

2023-12-04 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-27529: - Fix Version/s: 1.19.0 > HybridSourceSplitEnumerator sourceIndex using error Integer check >

[jira] [Commented] (FLINK-33402) Hybrid Source Concurrency Race Condition Fixes and Related Bugs Results in Data Loss

2023-11-13 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785549#comment-17785549 ] Thomas Weise commented on FLINK-33402: -- [~varun1729dd] thanks for investigating thi

[jira] [Assigned] (FLINK-33402) Hybrid Source Concurrency Race Condition Fixes and Related Bugs Results in Data Loss

2023-11-13 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-33402: Assignee: Varun Narayanan Chakravarthy > Hybrid Source Concurrency Race Condition Fixes a

[jira] [Resolved] (FLINK-32884) PyFlink remote execution should support URLs with paths and https scheme

2023-09-26 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-32884. -- Resolution: Fixed > PyFlink remote execution should support URLs with paths and https scheme >

[jira] [Closed] (FLINK-32884) PyFlink remote execution should support URLs with paths and https scheme

2023-09-21 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise closed FLINK-32884. Resolution: Fixed > PyFlink remote execution should support URLs with paths and https scheme > ---

[jira] [Assigned] (FLINK-32885) Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for PyFlink remote execution

2023-08-16 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-32885: Assignee: Elkhan Dadashov > Refactoring: Moving UrlPrefixDecorator into flink-clients so

[jira] [Assigned] (FLINK-32884) PyFlink remote execution should support URLs with paths and https scheme

2023-08-16 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-32884: Assignee: Elkhan Dadashov > PyFlink remote execution should support URLs with paths and h

[jira] [Resolved] (FLINK-32035) SQL Client should support HTTPS with built-in JDK certificates

2023-07-07 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-32035. -- Fix Version/s: 1.18.0 Resolution: Implemented > SQL Client should support HTTPS with bu

[jira] [Resolved] (FLINK-32373) Support passing headers with SQL Client gateway requests

2023-07-06 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-32373. -- Fix Version/s: 1.18.0 Resolution: Fixed > Support passing headers with SQL Client gatew

[jira] [Assigned] (FLINK-32137) Flame graph is hard to use with many task managers

2023-06-16 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-32137: Assignee: Vladimir Matveev > Flame graph is hard to use with many task managers > ---

[jira] [Commented] (FLINK-32109) Operator doesn't recognize JobManager stuck on volumeMount startup errors

2023-05-16 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723208#comment-17723208 ] Thomas Weise commented on FLINK-32109: -- [~gyfora] if the issue can be corrected ext

[jira] [Updated] (FLINK-32030) SQL Client gateway mode should accept URLs

2023-05-16 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-32030: - Fix Version/s: 1.18.0 > SQL Client gateway mode should accept URLs > ---

[jira] [Resolved] (FLINK-32030) SQL Client gateway mode should accept URLs

2023-05-16 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-32030. -- Resolution: Fixed > SQL Client gateway mode should accept URLs > -

[jira] [Commented] (FLINK-31997) Update to Fabric8 6.5.1+ in flink-kubernetes

2023-05-07 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720364#comment-17720364 ] Thomas Weise commented on FLINK-31997: -- [~gyfora] would it be possible to also shad

[jira] [Commented] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

2023-05-04 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719355#comment-17719355 ] Thomas Weise commented on FLINK-31974: -- There are many cases where errors are trans

[jira] [Commented] (FLINK-30859) Remove flink-connector-kafka from master branch

2023-03-23 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704157#comment-17704157 ] Thomas Weise commented on FLINK-30859: -- The examples would lead to a chicken and eg

[jira] [Updated] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

2023-03-02 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-31305: - Issue Type: Bug (was: Improvement) > KafkaWriter doesn't wait for errors for in-flight records

[jira] [Assigned] (FLINK-31305) KafkaWriter doesn't wait for errors for in-flight records before completing flush

2023-03-02 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-31305: Assignee: Mason Chen > KafkaWriter doesn't wait for errors for in-flight records before c

[jira] [Commented] (FLINK-22793) HybridSource Table Implementation

2023-02-24 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693339#comment-17693339 ] Thomas Weise commented on FLINK-22793: -- [~nicholasjiang] thanks for the confirmatio

[jira] [Assigned] (FLINK-22793) HybridSource Table Implementation

2023-02-24 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-22793: Assignee: Ran Tao (was: Nicholas Jiang) > HybridSource Table Implementation > --

[jira] [Commented] (FLINK-22793) HybridSource Table Implementation

2023-02-09 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686606#comment-17686606 ] Thomas Weise commented on FLINK-22793: -- [~lemonjing] given the long time that has p

[jira] [Commented] (FLINK-30858) Kubernetes operator does not update reconciled generation

2023-01-31 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682798#comment-17682798 ] Thomas Weise commented on FLINK-30858: -- https://lists.apache.org/thread/8y1zp4ogssy

[jira] [Created] (FLINK-30858) Kubernetes operator does not update reconciled generation

2023-01-31 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-30858: Summary: Kubernetes operator does not update reconciled generation Key: FLINK-30858 URL: https://issues.apache.org/jira/browse/FLINK-30858 Project: Flink Iss

[jira] [Resolved] (FLINK-29109) Checkpoint path conflict with stateless upgrade mode

2022-12-04 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-29109. -- Resolution: Fixed > Checkpoint path conflict with stateless upgrade mode > ---

[jira] [Updated] (FLINK-29109) Checkpoint path conflict with stateless upgrade mode

2022-12-04 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-29109: - Fix Version/s: kubernetes-operator-1.3.0 > Checkpoint path conflict with stateless upgrade mode

[jira] [Commented] (FLINK-29109) Checkpoint path conflict with stateless upgrade mode

2022-12-03 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642849#comment-17642849 ] Thomas Weise commented on FLINK-29109: -- [~gyfora] thanks for catching this. Because

[jira] [Commented] (FLINK-30266) Recovery reconciliation loop fails if no checkpoint has been created yet

2022-12-01 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642133#comment-17642133 ] Thomas Weise commented on FLINK-30266: -- I believe this was discussed before and the

[jira] [Commented] (FLINK-29634) Support periodic checkpoint triggering

2022-11-30 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641610#comment-17641610 ] Thomas Weise commented on FLINK-29634: -- [~pnowojski] please note that this ticket a

[jira] [Commented] (FLINK-29099) Deadlock for Single Subtask in Kinesis Consumer

2022-11-28 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17640298#comment-17640298 ] Thomas Weise commented on FLINK-29099: -- [~sethsaperstein] thanks for the thorough i

[jira] [Resolved] (FLINK-29099) Deadlock for Single Subtask in Kinesis Consumer

2022-11-28 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-29099. -- Fix Version/s: 1.17.0 Resolution: Fixed > Deadlock for Single Subtask in Kinesis Consum

[jira] [Assigned] (FLINK-29099) Deadlock for Single Subtask in Kinesis Consumer

2022-11-28 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-29099: Assignee: seth saperstein > Deadlock for Single Subtask in Kinesis Consumer > ---

[jira] [Resolved] (FLINK-12675) Event time synchronization in Kafka consumer

2022-11-25 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-12675. -- Resolution: Won't Fix > Event time synchronization in Kafka consumer > ---

[jira] [Resolved] (FLINK-10886) Event time synchronization across sources

2022-11-25 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-10886. -- Resolution: Done > Event time synchronization across sources > ---

[jira] [Commented] (FLINK-12675) Event time synchronization in Kafka consumer

2022-11-25 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638662#comment-17638662 ] Thomas Weise commented on FLINK-12675: -- Partition/split level alignment is supporte

[jira] [Resolved] (FLINK-30004) Cannot resume deployment after suspend with savepoint due to leftover configmaps

2022-11-15 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-30004. -- Fix Version/s: kubernetes-operator-1.3.0 Resolution: Fixed > Cannot resume deployment a

[jira] [Updated] (FLINK-30004) Cannot resume deployment after suspend with savepoint due to leftover configmaps

2022-11-15 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-30004: - Summary: Cannot resume deployment after suspend with savepoint due to leftover configmaps (was:

[jira] [Created] (FLINK-30004) Cannot resume deployment after suspend with savepoint due to leftover confgmaps

2022-11-12 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-30004: Summary: Cannot resume deployment after suspend with savepoint due to leftover confgmaps Key: FLINK-30004 URL: https://issues.apache.org/jira/browse/FLINK-30004 Proje

[jira] [Commented] (FLINK-29871) Upgrade operator Flink version and examples to 1.16

2022-11-04 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629128#comment-17629128 ] Thomas Weise commented on FLINK-29871: -- +1 > Upgrade operator Flink version and ex

[jira] [Commented] (FLINK-29871) Upgrade operator Flink version and examples to 1.16

2022-11-04 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629085#comment-17629085 ] Thomas Weise commented on FLINK-29871: -- X.Y.0 releases are not vetted and prone to

[jira] [Commented] (FLINK-29634) Support periodic checkpoint triggering

2022-10-14 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617676#comment-17617676 ] Thomas Weise commented on FLINK-29634: -- [~Jiale] that PR it the right place to look

[jira] [Assigned] (FLINK-29634) Support periodic checkpoint triggering

2022-10-13 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-29634: Assignee: Jiale Tan > Support periodic checkpoint triggering > --

[jira] [Created] (FLINK-29634) Support periodic checkpoint triggering

2022-10-13 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-29634: Summary: Support periodic checkpoint triggering Key: FLINK-29634 URL: https://issues.apache.org/jira/browse/FLINK-29634 Project: Flink Issue Type: New Featur

[jira] [Commented] (FLINK-29497) Provide an option to publish the flink-dist jar file artifact

2022-10-09 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614743#comment-17614743 ] Thomas Weise commented on FLINK-29497: -- Hi [~chesnay] , at the moment we are using

[jira] [Resolved] (FLINK-27479) HybridSource refreshes availability future

2022-10-09 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-27479. -- Resolution: Fixed > HybridSource refreshes availability future > -

[jira] [Updated] (FLINK-27479) HybridSource refreshes availability future

2022-10-09 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-27479: - Fix Version/s: (was: 1.15.3) > HybridSource refreshes availability future >

[jira] [Created] (FLINK-29497) Provide an option to publish the flink-dist jar file artifact

2022-10-03 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-29497: Summary: Provide an option to publish the flink-dist jar file artifact Key: FLINK-29497 URL: https://issues.apache.org/jira/browse/FLINK-29497 Project: Flink

[jira] [Commented] (FLINK-29413) Make it possible to associate triggered and completed savepoints

2022-09-26 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17609561#comment-17609561 ] Thomas Weise commented on FLINK-29413: -- +1 for tracking the triggering nonce Would

[jira] [Closed] (FLINK-29251) Send CREATED status and Cancel event via FlinkResourceListener

2022-09-14 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise closed FLINK-29251. Resolution: Fixed > Send CREATED status and Cancel event via FlinkResourceListener > -

[jira] [Closed] (FLINK-29100) Deployment with last-state upgrade mode stuck after initial error

2022-08-31 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise closed FLINK-29100. Resolution: Fixed > Deployment with last-state upgrade mode stuck after initial error > --

[jira] [Updated] (FLINK-29100) Deployment with last-state upgrade mode stuck after initial error

2022-08-31 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-29100: - Fix Version/s: kubernetes-operator-1.2.0 > Deployment with last-state upgrade mode stuck after i

[jira] [Created] (FLINK-29159) Revisit/harden initial deployment logic

2022-08-31 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-29159: Summary: Revisit/harden initial deployment logic Key: FLINK-29159 URL: https://issues.apache.org/jira/browse/FLINK-29159 Project: Flink Issue Type: Technical

[jira] [Commented] (FLINK-29144) Enable multiple jar entries for jarURI

2022-08-30 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17598040#comment-17598040 ] Thomas Weise commented on FLINK-29144: -- Please note that the operator is not in the

[jira] [Commented] (FLINK-29144) Enable multiple jar entries for jarURI

2022-08-30 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17597903#comment-17597903 ] Thomas Weise commented on FLINK-29144: -- [~gyfora] since this isn't a common require

[jira] [Created] (FLINK-29109) Checkpoint path conflict with stateless upgrade mode

2022-08-25 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-29109: Summary: Checkpoint path conflict with stateless upgrade mode Key: FLINK-29109 URL: https://issues.apache.org/jira/browse/FLINK-29109 Project: Flink Issue Ty

[jira] [Created] (FLINK-29100) Deployment with last-state upgrade mode stuck after initial error

2022-08-24 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-29100: Summary: Deployment with last-state upgrade mode stuck after initial error Key: FLINK-29100 URL: https://issues.apache.org/jira/browse/FLINK-29100 Project: Flink

[jira] [Resolved] (FLINK-28977) NullPointerException in HybridSourceSplitEnumerator.close

2022-08-23 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-28977. -- Resolution: Fixed > NullPointerException in HybridSourceSplitEnumerator.close > --

[jira] [Updated] (FLINK-28977) NullPointerException in HybridSourceSplitEnumerator.close

2022-08-23 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-28977: - Fix Version/s: 1.17.0 > NullPointerException in HybridSourceSplitEnumerator.close >

[jira] [Updated] (FLINK-21126) Reconsider FLINK_PROPERTIES

2022-08-22 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-21126: - Fix Version/s: (was: 1.17.0) > Reconsider FLINK_PROPERTIES > --- > >

[jira] [Assigned] (FLINK-28977) NullPointerException in HybridSourceSplitEnumerator.close

2022-08-15 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-28977: Assignee: Michael > NullPointerException in HybridSourceSplitEnumerator.close > -

[jira] [Updated] (FLINK-28817) NullPointerException in HybridSource when restoring from checkpoint

2022-08-13 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-28817: - Fix Version/s: 1.15.2 > NullPointerException in HybridSource when restoring from checkpoint > --

[jira] [Commented] (FLINK-28817) NullPointerException in HybridSource when restoring from checkpoint

2022-08-12 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579192#comment-17579192 ] Thomas Weise commented on FLINK-28817: -- [~Benenson] thank you for the thorough inve

[jira] [Assigned] (FLINK-28817) NullPointerException in HybridSource when restoring from checkpoint

2022-08-12 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-28817: Assignee: Qishang Zhong > NullPointerException in HybridSource when restoring from checkp

[jira] [Updated] (FLINK-28817) NullPointerException in HybridSource when restoring from checkpoint

2022-08-12 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-28817: - Fix Version/s: 1.16.0 > NullPointerException in HybridSource when restoring from checkpoint > --

[jira] [Resolved] (FLINK-28817) NullPointerException in HybridSource when restoring from checkpoint

2022-08-12 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-28817. -- Resolution: Fixed > NullPointerException in HybridSource when restoring from checkpoint >

[jira] [Commented] (FLINK-28817) NullPointerException in HybridSource when restoring from checkpoint

2022-08-12 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579190#comment-17579190 ] Thomas Weise commented on FLINK-28817: -- [~nicholasjiang] I believe it does. Can you

[jira] [Comment Edited] (FLINK-28817) NullPointerException in HybridSource when restoring from checkpoint

2022-08-11 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578507#comment-17578507 ] Thomas Weise edited comment on FLINK-28817 at 8/11/22 2:29 PM: ---

[jira] [Commented] (FLINK-28817) NullPointerException in HybridSource when restoring from checkpoint

2022-08-11 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578507#comment-17578507 ] Thomas Weise commented on FLINK-28817: -- [~Benenson] thanks for investigating this i

[jira] [Commented] (FLINK-28722) Hybrid Source should use .equals() for Integer comparison

2022-07-27 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572148#comment-17572148 ] Thomas Weise commented on FLINK-28722: -- [~mason6345] please take a look at the PR i

[jira] [Closed] (FLINK-28722) Hybrid Source should use .equals() for Integer comparison

2022-07-27 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise closed FLINK-28722. Resolution: Duplicate > Hybrid Source should use .equals() for Integer comparison > --

[jira] [Updated] (FLINK-27650) First environment variable of top level pod template is lost

2022-07-20 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-27650: - Fix Version/s: (was: kubernetes-operator-1.1.0) > First environment variable of top level po

[jira] [Commented] (FLINK-28541) Add OwnerReferences to FlinkDeployment CR in jobmanager Deployment

2022-07-13 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566505#comment-17566505 ] Thomas Weise commented on FLINK-28541: -- See https://issues.apache.org/jira/browse/F

[jira] [Commented] (FLINK-28364) Python Job support for Kubernetes Operator

2022-07-06 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563304#comment-17563304 ] Thomas Weise commented on FLINK-28364: -- Thanks for the ping [~gyfora]. This is some

[jira] [Commented] (FLINK-27009) Support SQL job submission in flink kubernetes opeartor

2022-07-05 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562716#comment-17562716 ] Thomas Weise commented on FLINK-27009: -- I would prefer if any sql processing logic

[jira] [Comment Edited] (FLINK-26891) Emit events for important Deployment / Job changes

2022-06-23 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558113#comment-17558113 ] Thomas Weise edited comment on FLINK-26891 at 6/23/22 2:33 PM: ---

[jira] [Commented] (FLINK-26891) Emit events for important Deployment / Job changes

2022-06-23 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17558113#comment-17558113 ] Thomas Weise commented on FLINK-26891: -- This will add events that will provide more

[jira] [Assigned] (FLINK-26891) Emit events for important Deployment / Job changes

2022-06-22 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-26891: Assignee: Thomas Weise (was: Matyas Orhidi) > Emit events for important Deployment / Job

[jira] [Assigned] (FLINK-27101) Periodically break the chain of incremental checkpoint

2022-06-10 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-27101: Assignee: Jiale Tan > Periodically break the chain of incremental checkpoint > --

[jira] [Assigned] (FLINK-27788) Adding annotation to k8 operator Pod

2022-05-25 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-27788: Assignee: Jaganathan Asokan > Adding annotation to k8 operator Pod >

[jira] [Updated] (FLINK-27788) Adding annotation to k8 operator Pod

2022-05-25 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-27788: - Fix Version/s: (was: kubernetes-operator-0.1.0) (was: kubernetes-opera

[jira] [Commented] (FLINK-27650) First environment variable of top level pod template is lost

2022-05-16 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17537773#comment-17537773 ] Thomas Weise commented on FLINK-27650: -- That's as per [https://github.com/apache/f

[jira] [Updated] (FLINK-27650) First environment variable of top level pod template is lost

2022-05-16 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-27650: - Priority: Major (was: Blocker) > First environment variable of top level pod template is lost >

[jira] [Updated] (FLINK-27465) AvroRowDeserializationSchema.convertToTimestamp fails with negative nano seconds

2022-05-13 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-27465: - Fix Version/s: 1.15.1 > AvroRowDeserializationSchema.convertToTimestamp fails with negative nano

[jira] [Updated] (FLINK-27255) Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters

2022-05-13 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-27255: - Fix Version/s: 1.15.1 > Flink-avro does not support serialization and deserialization of avro sc

[jira] [Commented] (FLINK-27594) Only recover JM deployment if HA metadata available

2022-05-12 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17536266#comment-17536266 ] Thomas Weise commented on FLINK-27594: -- [~gyfora] are you saying that when no HA me

[jira] [Commented] (FLINK-27255) Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters

2022-05-12 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17536222#comment-17536222 ] Thomas Weise commented on FLINK-27255: -- [~Keathalin21] please also open a PR for 1.

[jira] [Updated] (FLINK-27255) Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters

2022-05-12 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-27255: - Fix Version/s: 1.14.5 > Flink-avro does not support serialization and deserialization of avro sc

[jira] [Resolved] (FLINK-27255) Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters

2022-05-10 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-27255. -- Resolution: Fixed > Flink-avro does not support serialization and deserialization of avro sche

[jira] [Updated] (FLINK-27255) Flink-avro does not support serialization and deserialization of avro schema longer than 65535 characters

2022-05-10 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-27255: - Fix Version/s: 1.16.0 > Flink-avro does not support serialization and deserialization of avro sc

[jira] [Commented] (FLINK-27435) Kubernetes Operator keeps savepoint history

2022-05-10 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17534609#comment-17534609 ] Thomas Weise commented on FLINK-27435: -- [~gyfora] [~wangyang0918] I'm considering a

  1   2   3   4   5   6   >