[jira] [Resolved] (FLINK-35525) HDFS delegation token fetched by custom DelegationTokenProvider is not passed to Yarn AM

[ https://issues.apache.org/jira/browse/FLINK-35525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-35525. --- Fix Version/s: 1.20.0 Resolution: Fixed 74b100b on master > HDFS delegation token f

[jira] [Closed] (FLINK-35525) HDFS delegation token fetched by custom DelegationTokenProvider is not passed to Yarn AM

[ https://issues.apache.org/jira/browse/FLINK-35525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-35525. - > HDFS delegation token fetched by custom DelegationTokenProvider is not > passed to Yarn AM > ---

[jira] [Resolved] (FLINK-35371) Allow the keystore and truststore type to configured for SSL

[ https://issues.apache.org/jira/browse/FLINK-35371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-35371. --- Fix Version/s: 1.20.0 Resolution: Fixed 0919ff2 on master > Allow the keystore and t

[jira] [Closed] (FLINK-35371) Allow the keystore and truststore type to configured for SSL

[ https://issues.apache.org/jira/browse/FLINK-35371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-35371. - > Allow the keystore and truststore type to configured for SSL > ---

[jira] [Resolved] (FLINK-35625) FLIP-464: Merge "flink run" and "flink run-application"

[ https://issues.apache.org/jira/browse/FLINK-35625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-35625. --- Fix Version/s: 2.0.0 (was: 1.20.0) Resolution: Fixed e56b54d o

[jira] [Closed] (FLINK-35625) FLIP-464: Merge "flink run" and "flink run-application"

[ https://issues.apache.org/jira/browse/FLINK-35625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-35625. - > FLIP-464: Merge "flink run" and "flink run-application" >

[jira] [Assigned] (FLINK-35625) FLIP-464: Merge "flink run" and "flink run-application"

[ https://issues.apache.org/jira/browse/FLINK-35625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-35625: - Assignee: Ferenc Csaky > FLIP-464: Merge "flink run" and "flink run-application" >

[jira] [Resolved] (FLINK-34267) Python connector test fails when running on MacBook with m1 processor

[ https://issues.apache.org/jira/browse/FLINK-34267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-34267. --- Resolution: Fixed [{{e6e1426}}|https://github.com/apache/flink-connector-shared-utils/commit

[jira] [Assigned] (FLINK-34267) Python connector test fails when running on MacBook with m1 processor

[ https://issues.apache.org/jira/browse/FLINK-34267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-34267: - Assignee: Aleksandr Pilipenko > Python connector test fails when running on MacBook wit

[jira] [Closed] (FLINK-34267) Python connector test fails when running on MacBook with m1 processor

[ https://issues.apache.org/jira/browse/FLINK-34267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-34267. - > Python connector test fails when running on MacBook with m1 processor > --

[jira] [Assigned] (FLINK-20090) Expose SlotId / SlotSharingGroup in Rest API

[ https://issues.apache.org/jira/browse/FLINK-20090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-20090: - Assignee: Gabor Somogyi > Expose SlotId / SlotSharingGroup in Rest API > -

[jira] [Commented] (FLINK-20090) Expose SlotId / SlotSharingGroup in Rest API

[ https://issues.apache.org/jira/browse/FLINK-20090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17820034#comment-17820034 ] Gabor Somogyi commented on FLINK-20090: --- I'm working on this and planning to open

[jira] [Resolved] (FLINK-20090) Expose SlotId / SlotSharingGroup in Rest API

[ https://issues.apache.org/jira/browse/FLINK-20090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-20090. --- Resolution: Fixed [{{34a7734}}|https://github.com/apache/flink/commit/34a7734c489b080d34ff21

[jira] [Updated] (FLINK-20090) Expose SlotId / SlotSharingGroup in Rest API

[ https://issues.apache.org/jira/browse/FLINK-20090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-20090: -- Fix Version/s: 1.20.0 > Expose SlotId / SlotSharingGroup in Rest API > --

[jira] [Closed] (FLINK-20090) Expose SlotId / SlotSharingGroup in Rest API

[ https://issues.apache.org/jira/browse/FLINK-20090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-20090. - > Expose SlotId / SlotSharingGroup in Rest API > - > >

[jira] [Created] (FLINK-34574) Add CPU and memory size autoscaler quota

Gabor Somogyi created FLINK-34574: - Summary: Add CPU and memory size autoscaler quota Key: FLINK-34574 URL: https://issues.apache.org/jira/browse/FLINK-34574 Project: Flink Issue Type: New Fe

[jira] [Assigned] (FLINK-34574) Add CPU and memory size autoscaler quota

[ https://issues.apache.org/jira/browse/FLINK-34574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-34574: - Assignee: Gabor Somogyi > Add CPU and memory size autoscaler quota > --

[jira] [Assigned] (FLINK-33515) PythonDriver need to stream python process output to log instead of collecting it in memory

[ https://issues.apache.org/jira/browse/FLINK-33515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-33515: - Assignee: Gabor Somogyi > PythonDriver need to stream python process output to log inst

[jira] [Created] (FLINK-33515) PythonDriver need to stream python process output to log instead of collecting it in memory

Gabor Somogyi created FLINK-33515: - Summary: PythonDriver need to stream python process output to log instead of collecting it in memory Key: FLINK-33515 URL: https://issues.apache.org/jira/browse/FLINK-33515

[jira] [Commented] (FLINK-33513) Metastore delegation-token can be cached?

[ https://issues.apache.org/jira/browse/FLINK-33513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784739#comment-17784739 ] Gabor Somogyi commented on FLINK-33513: --- If that hurts the solution is not caching

[jira] [Resolved] (FLINK-33515) PythonDriver need to stream python process output to log instead of collecting it in memory

[ https://issues.apache.org/jira/browse/FLINK-33515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-33515. --- Fix Version/s: 1.19.0 Resolution: Fixed caa324a on master > PythonDriver need to str

[jira] [Closed] (FLINK-33515) PythonDriver need to stream python process output to log instead of collecting it in memory

[ https://issues.apache.org/jira/browse/FLINK-33515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-33515. - > PythonDriver need to stream python process output to log instead of > collecting it in memory > -

[jira] [Commented] (FLINK-33531) Nightly Python fails with NPE at metadataHandlerProvider on AZP

[ https://issues.apache.org/jira/browse/FLINK-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785515#comment-17785515 ] Gabor Somogyi commented on FLINK-33531: --- Since I've added python 3.11 lately I've

[jira] [Resolved] (FLINK-33268) Flink REST API response parsing throws exception on new fields

[ https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-33268. --- Resolution: Fixed [{{19cb9de}}|https://github.com/apache/flink/commit/19cb9de5c54b9535be15ca

[jira] [Closed] (FLINK-33268) Flink REST API response parsing throws exception on new fields

[ https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-33268. - > Flink REST API response parsing throws exception on new fields > -

[jira] [Updated] (FLINK-33268) Flink REST API response parsing throws exception on new fields

[ https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-33268: -- Fix Version/s: 1.19.0 > Flink REST API response parsing throws exception on new fields > -

[jira] [Commented] (FLINK-30310) Re-enable e2e test error check

[ https://issues.apache.org/jira/browse/FLINK-30310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17809448#comment-17809448 ] Gabor Somogyi commented on FLINK-30310: --- There are too many false positives becaus

[jira] [Resolved] (FLINK-30310) Re-enable e2e test error check

[ https://issues.apache.org/jira/browse/FLINK-30310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-30310. --- Resolution: Won't Fix > Re-enable e2e test error check > -- > >

[jira] [Closed] (FLINK-30310) Re-enable e2e test error check

[ https://issues.apache.org/jira/browse/FLINK-30310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-30310. - > Re-enable e2e test error check > -- > > Key: FLINK-303

[jira] [Resolved] (FLINK-30147) Evaluate operator error log whitelist entry: Failed to submit a listener notification task

[ https://issues.apache.org/jira/browse/FLINK-30147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-30147. --- Resolution: Won't Fix See comment in FLINK-30310. > Evaluate operator error log whitelist e

[jira] [Closed] (FLINK-30148) Evaluate operator error log whitelist entry: Failed to submit job to session cluster

[ https://issues.apache.org/jira/browse/FLINK-30148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-30148. - > Evaluate operator error log whitelist entry: Failed to submit job to session > cluster >

[jira] [Resolved] (FLINK-30148) Evaluate operator error log whitelist entry: Failed to submit job to session cluster

[ https://issues.apache.org/jira/browse/FLINK-30148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-30148. --- Resolution: Won't Fix See comment in FLINK-30310. > Evaluate operator error log whitelist e

[jira] [Closed] (FLINK-30147) Evaluate operator error log whitelist entry: Failed to submit a listener notification task

[ https://issues.apache.org/jira/browse/FLINK-30147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-30147. - > Evaluate operator error log whitelist entry: Failed to submit a listener > notification task > --

[jira] [Closed] (FLINK-30149) Evaluate operator error log whitelist entry: Error during event processing

[ https://issues.apache.org/jira/browse/FLINK-30149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-30149. - > Evaluate operator error log whitelist entry: Error during event processing > -

[jira] [Resolved] (FLINK-30149) Evaluate operator error log whitelist entry: Error during event processing

[ https://issues.apache.org/jira/browse/FLINK-30149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-30149. --- Resolution: Won't Fix See comment in FLINK-30310. > Evaluate operator error log whitelist e

[jira] [Closed] (FLINK-30117) Evaluate operator error log whitelist entries added in FLINK-29475

[ https://issues.apache.org/jira/browse/FLINK-30117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-30117. - > Evaluate operator error log whitelist entries added in FLINK-29475 > -

[jira] [Resolved] (FLINK-30311) CI error: Back-off pulling image "flink:1.14"

[ https://issues.apache.org/jira/browse/FLINK-30311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-30311. --- Resolution: Won't Fix See comment in FLINK-30310. > CI error: Back-off pulling image "flink

[jira] [Closed] (FLINK-30283) Evaluate operator error log entry: Error while patching status

[ https://issues.apache.org/jira/browse/FLINK-30283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-30283. - > Evaluate operator error log entry: Error while patching status > -

[jira] [Resolved] (FLINK-30283) Evaluate operator error log entry: Error while patching status

[ https://issues.apache.org/jira/browse/FLINK-30283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-30283. --- Resolution: Won't Fix See comment in FLINK-30310. > Evaluate operator error log entry: Erro

[jira] [Closed] (FLINK-30311) CI error: Back-off pulling image "flink:1.14"

[ https://issues.apache.org/jira/browse/FLINK-30311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-30311. - > CI error: Back-off pulling image "flink:1.14" > - > >

[jira] [Resolved] (FLINK-30117) Evaluate operator error log whitelist entries added in FLINK-29475

[ https://issues.apache.org/jira/browse/FLINK-30117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-30117. --- Resolution: Won't Fix See comment in FLINK-30310. > Evaluate operator error log whitelist e

[jira] [Created] (FLINK-34198) Remove e2e test operator log error check

Gabor Somogyi created FLINK-34198: - Summary: Remove e2e test operator log error check Key: FLINK-34198 URL: https://issues.apache.org/jira/browse/FLINK-34198 Project: Flink Issue Type: Improv

[jira] [Assigned] (FLINK-34198) Remove e2e test operator log error check

[ https://issues.apache.org/jira/browse/FLINK-34198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-34198: - Assignee: Gabor Somogyi > Remove e2e test operator log error check > --

[jira] [Resolved] (FLINK-34198) Remove e2e test operator log error check

[ https://issues.apache.org/jira/browse/FLINK-34198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-34198. --- Fix Version/s: 1.8.0 Resolution: Fixed [{{31d01f2}}|https://github.com/apache/flink-k

[jira] [Updated] (FLINK-34198) Remove e2e test operator log error check

[ https://issues.apache.org/jira/browse/FLINK-34198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-34198: -- Affects Version/s: 1.8.0 (was: 1.8.4) > Remove e2e test operator lo

[jira] [Closed] (FLINK-34198) Remove e2e test operator log error check

[ https://issues.apache.org/jira/browse/FLINK-34198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-34198. - > Remove e2e test operator log error check > > >

[jira] [Updated] (FLINK-33268) Flink REST API response parsing should support backward compatible changes like new fields

[ https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-33268: -- Description: At the moment Flink is not ignoring unknown fields when parsing REST responses.

[jira] [Updated] (FLINK-33268) Flink REST API response parsing should support backward compatible changes like new fields

[ https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-33268: -- Description: At the moment Flink is not ignoring unknown fields when parsing REST responses.

[jira] [Updated] (FLINK-33268) Flink REST API response parsing should support backward compatible changes like new fields

[ https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-33268: -- Description: At the moment Flink is not ignoring unknown fields when parsing REST responses.

[jira] [Updated] (FLINK-33268) Flink REST API response parsing throws exception on new fields

[ https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-33268: -- Summary: Flink REST API response parsing throws exception on new fields (was: Flink REST API

[jira] [Commented] (FLINK-33556) Test infrastructure for externalized python code

[ https://issues.apache.org/jira/browse/FLINK-33556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794087#comment-17794087 ] Gabor Somogyi commented on FLINK-33556: --- e4f3898 on master > Test infrastructure

[jira] [Resolved] (FLINK-33556) Test infrastructure for externalized python code

[ https://issues.apache.org/jira/browse/FLINK-33556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-33556. --- Resolution: Fixed > Test infrastructure for externalized python code > -

[jira] [Commented] (FLINK-33556) Test infrastructure for externalized python code

[ https://issues.apache.org/jira/browse/FLINK-33556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17794102#comment-17794102 ] Gabor Somogyi commented on FLINK-33556: --- 7691962 on ci_utils > Test infrastructur

[jira] [Closed] (FLINK-33556) Test infrastructure for externalized python code

[ https://issues.apache.org/jira/browse/FLINK-33556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-33556. - > Test infrastructure for externalized python code > ---

[jira] [Commented] (FLINK-33559) Externalize Kafka Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17795239#comment-17795239 ] Gabor Somogyi commented on FLINK-33559: --- c38a040 on main > Externalize Kafka Pyth

[jira] [Closed] (FLINK-33559) Externalize Kafka Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-33559. - > Externalize Kafka Python connector code > --- > >

[jira] [Resolved] (FLINK-33559) Externalize Kafka Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-33559. --- Resolution: Fixed > Externalize Kafka Python connector code > --

[jira] [Assigned] (FLINK-33268) Flink REST API response parsing throws exception on new fields

[ https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-33268: - Assignee: Gabor Somogyi > Flink REST API response parsing throws exception on new field

[jira] [Assigned] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

[ https://issues.apache.org/jira/browse/FLINK-22059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-22059: - Assignee: zhongyou.lee (was: xiaogang zhou) > add a new option is rocksdb statebackend

[jira] [Created] (FLINK-35969) Remove deprecated dataset based API from State Processor API

Gabor Somogyi created FLINK-35969: - Summary: Remove deprecated dataset based API from State Processor API Key: FLINK-35969 URL: https://issues.apache.org/jira/browse/FLINK-35969 Project: Flink

[jira] [Assigned] (FLINK-35969) Remove deprecated dataset based API from State Processor API

[ https://issues.apache.org/jira/browse/FLINK-35969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-35969: - Assignee: Gabor Somogyi > Remove deprecated dataset based API from State Processor API

[jira] [Created] (FLINK-36001) Store operator name and UID in state metadata

Gabor Somogyi created FLINK-36001: - Summary: Store operator name and UID in state metadata Key: FLINK-36001 URL: https://issues.apache.org/jira/browse/FLINK-36001 Project: Flink Issue Type: I

[jira] [Assigned] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-36001: - Assignee: Gabor Somogyi > Store operator name and UID in state metadata > -

[jira] [Resolved] (FLINK-35969) Remove deprecated dataset based API from State Processor API

[ https://issues.apache.org/jira/browse/FLINK-35969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-35969. --- Fix Version/s: 2.0.0 Resolution: Fixed > Remove deprecated dataset based API from Sta

[jira] [Commented] (FLINK-35969) Remove deprecated dataset based API from State Processor API

[ https://issues.apache.org/jira/browse/FLINK-35969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871663#comment-17871663 ] Gabor Somogyi commented on FLINK-35969: --- 2c48175 on master > Remove deprecated da

[jira] [Closed] (FLINK-35969) Remove deprecated dataset based API from State Processor API

[ https://issues.apache.org/jira/browse/FLINK-35969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-35969. - > Remove deprecated dataset based API from State Processor API > ---

[jira] [Commented] (FLINK-36058) OperatorTestHarness is always using checkpointId=0 for state recovery

[ https://issues.apache.org/jira/browse/FLINK-36058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873727#comment-17873727 ] Gabor Somogyi commented on FLINK-36058: --- If I understand correctly this has no Fli

[jira] [Created] (FLINK-36124) S3RecoverableFsDataOutputStream.sync closes the stream and further write operation throw exception

Gabor Somogyi created FLINK-36124: - Summary: S3RecoverableFsDataOutputStream.sync closes the stream and further write operation throw exception Key: FLINK-36124 URL: https://issues.apache.org/jira/browse/FLINK-361

[jira] [Assigned] (FLINK-36124) S3RecoverableFsDataOutputStream.sync closes the stream and further write operation throw exception

[ https://issues.apache.org/jira/browse/FLINK-36124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-36124: - Assignee: Gabor Somogyi > S3RecoverableFsDataOutputStream.sync closes the stream and fu

[jira] [Assigned] (FLINK-36124) S3RecoverableFsDataOutputStream.sync closes the stream and further write operation throw exception

[ https://issues.apache.org/jira/browse/FLINK-36124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-36124: - Assignee: (was: Gabor Somogyi) > S3RecoverableFsDataOutputStream.sync closes the st

[jira] [Assigned] (FLINK-36124) S3RecoverableFsDataOutputStream.sync closes the stream and further write operation throw exception

[ https://issues.apache.org/jira/browse/FLINK-36124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-36124: - Assignee: Gabor Somogyi > S3RecoverableFsDataOutputStream.sync closes the stream and fu

[jira] [Updated] (FLINK-36124) S3RecoverableFsDataOutputStream.sync closes the stream and further write operations throw exception

[ https://issues.apache.org/jira/browse/FLINK-36124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-36124: -- Summary: S3RecoverableFsDataOutputStream.sync closes the stream and further write operations t

[jira] [Assigned] (FLINK-36140) Log a warning when pods are terminated by kubernetes

[ https://issues.apache.org/jira/browse/FLINK-36140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-36140: - Assignee: Clara Xiong > Log a warning when pods are terminated by kubernetes >

[jira] [Resolved] (FLINK-36140) Log a warning when pods are terminated by kubernetes

[ https://issues.apache.org/jira/browse/FLINK-36140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-36140. --- Fix Version/s: 2.0.0 Resolution: Fixed 9bcd8f4 on master > Log a warning when pods a

[jira] [Closed] (FLINK-36140) Log a warning when pods are terminated by kubernetes

[ https://issues.apache.org/jira/browse/FLINK-36140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-36140. - > Log a warning when pods are terminated by kubernetes > ---

[jira] [Created] (FLINK-36173) Invalid link in checkpoint documentation

Gabor Somogyi created FLINK-36173: - Summary: Invalid link in checkpoint documentation Key: FLINK-36173 URL: https://issues.apache.org/jira/browse/FLINK-36173 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-36173) Invalid link in checkpoint documentation

[ https://issues.apache.org/jira/browse/FLINK-36173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-36173: - Assignee: Gabor Somogyi > Invalid link in checkpoint documentation > --

[jira] [Resolved] (FLINK-36173) Invalid link in checkpoint documentation

[ https://issues.apache.org/jira/browse/FLINK-36173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-36173. --- Resolution: Fixed [{{26ce997}}|https://github.com/apache/flink/commit/26ce997052b5b3a4f3e06e

[jira] [Updated] (FLINK-36173) Invalid link in checkpoint documentation

[ https://issues.apache.org/jira/browse/FLINK-36173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-36173: -- Fix Version/s: 2.0.0 1.20.1 > Invalid link in checkpoint documentation > --

[jira] [Updated] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-36001: -- Fix Version/s: 2.0.0 > Store operator name and UID in state metadata > ---

[jira] [Resolved] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-36001. --- Release Note: 02110ce on master Resolution: Fixed > Store operator name and UID in sta

[jira] [Closed] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-36001. - > Store operator name and UID in state metadata > - > >

[jira] [Reopened] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reopened FLINK-36001: --- > Store operator name and UID in state metadata > -

[jira] [Updated] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-36001: -- Release Note: (was: 02110ce on master) > Store operator name and UID in state metadata > ---

[jira] [Closed] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-36001. - Resolution: Fixed > Store operator name and UID in state metadata >

[jira] [Commented] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881700#comment-17881700 ] Gabor Somogyi commented on FLINK-36001: --- 02110ce on master > Store operator name

[jira] [Commented] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881701#comment-17881701 ] Gabor Somogyi commented on FLINK-36001: --- 60beed9 on master > Store operator name

[jira] [Commented] (FLINK-33268) Flink REST API response parsing throws exception on new fields

[ https://issues.apache.org/jira/browse/FLINK-33268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17843657#comment-17843657 ] Gabor Somogyi commented on FLINK-33268: --- > I assume that there can still be a prob

[jira] [Closed] (FLINK-35302) Flink REST server throws exception on unknown fields in RequestBody

[ https://issues.apache.org/jira/browse/FLINK-35302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-35302. - > Flink REST server throws exception on unknown fields in RequestBody >

[jira] [Resolved] (FLINK-35302) Flink REST server throws exception on unknown fields in RequestBody

[ https://issues.apache.org/jira/browse/FLINK-35302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-35302. --- Resolution: Fixed 36b1d2a on master > Flink REST server throws exception on unknown fields

[jira] [Commented] (FLINK-35371) Allow the keystore and truststore type to configured for SSL

[ https://issues.apache.org/jira/browse/FLINK-35371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846935#comment-17846935 ] Gabor Somogyi commented on FLINK-35371: --- That makes sense. Started to have a look.

[jira] [Assigned] (FLINK-35371) Allow the keystore and truststore type to configured for SSL

[ https://issues.apache.org/jira/browse/FLINK-35371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-35371: - Assignee: Gabor Somogyi > Allow the keystore and truststore type to configured for SSL

[jira] [Updated] (FLINK-35371) Allow the keystore and truststore type to configured for SSL

[ https://issues.apache.org/jira/browse/FLINK-35371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-35371: -- Affects Version/s: 1.19.0 > Allow the keystore and truststore type to configured for SSL > ---

[jira] [Assigned] (FLINK-35371) Allow the keystore and truststore type to configured for SSL

[ https://issues.apache.org/jira/browse/FLINK-35371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-35371: - Assignee: Ammar Master (was: Gabor Somogyi) > Allow the keystore and truststore type t

[jira] [Commented] (FLINK-35192) Kubernetes operator oom

[ https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848060#comment-17848060 ] Gabor Somogyi commented on FLINK-35192: --- 8b789ee on main > Kubernetes operator oo

[jira] [Commented] (FLINK-35192) Kubernetes operator oom

[ https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848066#comment-17848066 ] Gabor Somogyi commented on FLINK-35192: --- [~stupid_pig] I've read through the whole

[jira] [Closed] (FLINK-35192) Kubernetes operator oom

[ https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-35192. - > Kubernetes operator oom > --- > > Key: FLINK-35192 >

[jira] [Resolved] (FLINK-35192) Kubernetes operator oom

[ https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-35192. --- Resolution: Fixed > Kubernetes operator oom > --- > > Ke

[jira] [Assigned] (FLINK-35525) HDFS delegation token fetched by custom DelegationTokenProvider is not passed to Yarn AM

[ https://issues.apache.org/jira/browse/FLINK-35525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-35525: - Assignee: Zhen Wang > HDFS delegation token fetched by custom DelegationTokenProvider

[jira] [Commented] (FLINK-35371) Allow the keystore and truststore type to configured for SSL

[ https://issues.apache.org/jira/browse/FLINK-35371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852689#comment-17852689 ] Gabor Somogyi commented on FLINK-35371: --- [~ammarm] any news on this? > Allow the

  1   2   3   4   5   6   7   >