[jira] [Closed] (FLINK-32890) Flink app rolled back with old savepoints (3 hours back in time) while some checkpoints have been taken in between

2023-08-22 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32890. -- Fix Version/s: kubernetes-operator-1.7.0 Resolution: Fixed merged to main 301b179c1e38904124fbf

[jira] [Commented] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

2023-08-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758362#comment-17758362 ] Gyula Fora commented on FLINK-30680: Sure [~wangm92] , I will assign this to you. I

[jira] [Assigned] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

2023-08-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30680: -- Assignee: Matt Wang > Consider using the autoscaler to detect slow taskmanagers > ---

[jira] [Assigned] (FLINK-31406) Do not delete jobgraph on scale only last-state upgrades

2023-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-31406: -- Assignee: Nicholas Jiang > Do not delete jobgraph on scale only last-state upgrades > ---

[jira] [Commented] (FLINK-30407) Better encapsulate error handling logic in controllers

2023-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758412#comment-17758412 ] Gyula Fora commented on FLINK-30407: [~spencerx] are you working on this? Otherwise

[jira] [Commented] (FLINK-30843) Add Notifier For Autoscaler

2023-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758413#comment-17758413 ] Gyula Fora commented on FLINK-30843: [~gaurav726] are you still working on this? If

[jira] [Closed] (FLINK-29110) Support to mount a dynamically-created pvc for JM and TM in standalone mode with StatefulSet.

2023-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29110. -- Resolution: Later I am closing this for now [~kevin_123] please feel free to reopen the ticket if you

[jira] [Closed] (FLINK-30843) Add Notifier For Autoscaler

2023-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30843. -- Resolution: Later > Add Notifier For Autoscaler > --- > > Key:

[jira] [Commented] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

2023-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758640#comment-17758640 ] Gyula Fora commented on FLINK-30680: done [~wangm92]  > Consider using the autoscal

[jira] [Closed] (FLINK-30407) Better encapsulate error handling logic in controllers

2023-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30407. -- Resolution: Won't Fix > Better encapsulate error handling logic in controllers > -

[jira] [Commented] (FLINK-32890) Flink app rolled back with old savepoints (3 hours back in time) while some checkpoints have been taken in between

2023-08-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17758871#comment-17758871 ] Gyula Fora commented on FLINK-32890: release-1.6: 25cadc34bb3b4b2cbbffbffeadaeb9e337

[jira] [Commented] (FLINK-32959) Operator standalone mode throws NoClassDefFoundError

2023-08-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759102#comment-17759102 ] Gyula Fora commented on FLINK-32959: But still this error should surface in the e2e,

[jira] [Assigned] (FLINK-32973) Documentation for kubernetes.operator.job.savepoint-on-deletion indicate that it can be set on per resource level while it can't

2023-08-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-32973: -- Assignee: Nicolas Fraison > Documentation for kubernetes.operator.job.savepoint-on-deletion i

[jira] [Commented] (FLINK-32973) Documentation for kubernetes.operator.job.savepoint-on-deletion indicate that it can be set on per resource level while it can't

2023-08-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759510#comment-17759510 ] Gyula Fora commented on FLINK-32973: Ah yes, this should not be part of the operator

[jira] [Closed] (FLINK-32973) Documentation for kubernetes.operator.job.savepoint-on-deletion indicate that it can be set on per resource level while it can't

2023-08-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32973. -- Resolution: Fixed merged to main 61ff9f59c14e012ea0237da0c1cc2f7297483293 > Documentation for kuberne

[jira] [Commented] (FLINK-32992) Recommended parallelism metric is a duplicate of Parallelism metric

2023-08-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760403#comment-17760403 ] Gyula Fora commented on FLINK-32992: cc [~morhidi]  > Recommended parallelism metri

[jira] [Commented] (FLINK-32992) Recommended parallelism metric is a duplicate of Parallelism metric

2023-08-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760431#comment-17760431 ] Gyula Fora commented on FLINK-32992: I think they are not the same when scaling is t

[jira] [Commented] (FLINK-31064) Error while retrieving the leader gateway

2023-08-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760726#comment-17760726 ] Gyula Fora commented on FLINK-31064: [~tshofer] is still still an issue? > Error wh

[jira] [Resolved] (FLINK-31203) Application upgrade rollbacks failed in Flink Kubernetes Operator

2023-08-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-31203. Resolution: Fixed I think this is fixed in 1.6.0 > Application upgrade rollbacks failed in Flink

[jira] [Closed] (FLINK-31613) Some default operator config values are overwritten by values.yaml

2023-08-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-31613. -- Resolution: Won't Fix > Some default operator config values are overwritten by values.yaml > -

[jira] [Closed] (FLINK-31850) Fix args in JobSpec not being passed through to Flink in Standalone mode - 1.4.0

2023-08-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-31850. -- Resolution: Not A Problem > Fix args in JobSpec not being passed through to Flink in Standalone mode -

[jira] [Resolved] (FLINK-31964) Improve the document of Autoscaler as 1.17.0 is released

2023-08-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-31964. Resolution: Fixed > Improve the document of Autoscaler as 1.17.0 is released > ---

[jira] [Closed] (FLINK-31941) Not backwards compatible naming for some kubernetes resources

2023-08-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-31941. -- Resolution: Not A Problem > Not backwards compatible naming for some kubernetes resources > --

[jira] [Commented] (FLINK-31998) Flink Operator Deadlock on run job Failure

2023-08-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760730#comment-17760730 ] Gyula Fora commented on FLINK-31998: [~chalixar] is this still an issue? > Flink Op

[jira] [Closed] (FLINK-32531) "Recovery of missing job deployments" feature not working as described

2023-08-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32531. -- Resolution: Not A Problem > "Recovery of missing job deployments" feature not working as described > -

[jira] [Closed] (FLINK-32423) Flink-sql-runner-example application fails if multiple execute() called in one sql file

2023-08-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32423. -- Resolution: Won't Fix The SQL runner is intended to be an example and not really a proper all encompa

[jira] [Closed] (FLINK-32318) [flink-operator] missing s3 plugin in folder plugins

2023-08-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-32318. -- Resolution: Not A Problem > [flink-operator] missing s3 plugin in folder plugins > ---

[jira] [Resolved] (FLINK-23356) HBase delegation token expired after 7 days

2021-07-13 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-23356. Resolution: Fixed Fixed for master via 657df14677a8f4e500efdc79627f095e32e8c4b4 > HBase delegatio

[jira] [Commented] (FLINK-17998) Support limiting job history size

2021-01-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17261117#comment-17261117 ] Gyula Fora commented on FLINK-17998: Wait here [~jiechen] we are doing it right now

[jira] [Assigned] (FLINK-22469) HistoryServer starts with NoSuchFileException

2021-04-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-22469: -- Assignee: Gabor Somogyi > HistoryServer starts with NoSuchFileException > ---

[jira] [Resolved] (FLINK-22469) HistoryServer starts with NoSuchFileException

2021-04-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-22469. Resolution: Fixed Merged to master: fa19ba2acbe878b0c454f1ad93d0c412ab6ed380 > HistoryServer star

[jira] [Created] (FLINK-13171) Add withParameters(Configuration) method to DataStream operators

2019-07-09 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-13171: -- Summary: Add withParameters(Configuration) method to DataStream operators Key: FLINK-13171 URL: https://issues.apache.org/jira/browse/FLINK-13171 Project: Flink

[jira] [Commented] (FLINK-13171) Add withParameters(Configuration) method to DataStream operators

2019-07-10 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881927#comment-16881927 ] Gyula Fora commented on FLINK-13171: Each rich function comes with an open(Configura

[jira] [Commented] (FLINK-13171) Add withParameters(Configuration) method to DataStream operators

2019-07-10 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882021#comment-16882021 ] Gyula Fora commented on FLINK-13171: there are no other variants that do not accept

[jira] [Commented] (FLINK-14577) Hortonworks schema registry support for avro deserialization

2019-10-30 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963706#comment-16963706 ] Gyula Fora commented on FLINK-14577: Thanks for bringing up the discussion. We have

[jira] [Commented] (FLINK-14531) Add Kafka Metrics Reporter

2019-10-31 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963709#comment-16963709 ] Gyula Fora commented on FLINK-14531: I think the first step here would be to draft u

[jira] [Commented] (FLINK-14577) Hortonworks schema registry support for avro deserialization

2019-10-31 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16963714#comment-16963714 ] Gyula Fora commented on FLINK-14577: [~nickRyan], we can draft a proposal with our c

[jira] [Assigned] (FLINK-14577) Hortonworks schema registry support for avro deserialization

2019-11-01 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-14577: -- Assignee: Gyula Fora > Hortonworks schema registry support for avro deserialization > ---

[jira] [Commented] (FLINK-14577) Hortonworks schema registry support for avro deserialization

2019-11-01 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16964730#comment-16964730 ] Gyula Fora commented on FLINK-14577: Alright, I will start a discussion thread on mo

[jira] [Commented] (FLINK-14531) Add Kafka Metrics Reporter

2019-11-12 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16972267#comment-16972267 ] Gyula Fora commented on FLINK-14531: hi [~yong_chen], have you made any progress on

[jira] [Closed] (FLINK-13850) Refactor part file configuration into a single method

2019-11-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-13850. -- Release Note: Implemented in 22b2a8856307c310b4c75b32eeed33ba66c0206e Resolution: Fixed > Refact

[jira] [Commented] (FLINK-13850) Refactor part file configuration into a single method

2019-11-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975113#comment-16975113 ] Gyula Fora commented on FLINK-13850: Ah, sorry this is completely my bad, for some r

[jira] [Updated] (FLINK-13850) Refactor part file configuration into a single method

2019-11-15 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-13850: --- Release Note: (was: Implemented in 22b2a8856307c310b4c75b32eeed33ba66c0206e) > Refactor part file

[jira] [Closed] (FLINK-14832) Support kafka metrics reporter

2019-11-17 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-14832. -- Resolution: Duplicate This is a duplicate of https://issues.apache.org/jira/browse/FLINK-14531 > Supp

[jira] [Closed] (FLINK-13850) Refactor part file configuration into a single method

2019-11-17 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-13850. -- Resolution: Fixed Merged to master 901438b65bfbf3874cec60ea17b0c3b05bdd8477 > Refactor part file conf

[jira] [Commented] (FLINK-14531) Add Kafka Metrics Reporter

2019-11-17 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16976014#comment-16976014 ] Gyula Fora commented on FLINK-14531: I have just started a discussion thread on the

[jira] [Commented] (FLINK-13566) Support checkpoint configuration through flink-conf.yaml

2019-08-05 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16900098#comment-16900098 ] Gyula Fora commented on FLINK-13566: Thanks for the feedback [~uce] . I am planning

[jira] [Created] (FLINK-13685) YARN deployment hangs when requested container is above the maximum vcore size

2019-08-11 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-13685: -- Summary: YARN deployment hangs when requested container is above the maximum vcore size Key: FLINK-13685 URL: https://issues.apache.org/jira/browse/FLINK-13685 Project: F

[jira] [Commented] (FLINK-13685) YARN deployment hangs when requested container is above the maximum vcore size

2019-08-12 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16904931#comment-16904931 ] Gyula Fora commented on FLINK-13685: Yes we will start working on this today! > YAR

[jira] [Assigned] (FLINK-13685) YARN deployment hangs when requested container is above the maximum vcore size

2019-08-12 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-13685: -- Assignee: Matyas Orhidi > YARN deployment hangs when requested container is above the maximum

[jira] [Closed] (FLINK-6263) Leader error in Kafka producer on leader change (broker restart/failrue)

2019-08-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-6263. - Resolution: Not A Problem > Leader error in Kafka producer on leader change (broker restart/failrue) > --

[jira] [Closed] (FLINK-3168) Make checkpointing properties configurable from flink-conf.yaml

2019-08-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-3168. - Resolution: Duplicate > Make checkpointing properties configurable from flink-conf.yaml > ---

[jira] [Closed] (FLINK-2917) Make non-copying behaviour default for stream operator

2019-08-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-2917. - Resolution: Won't Fix > Make non-copying behaviour default for stream operator >

[jira] [Closed] (FLINK-3018) Job state discarded from web interface for restarting jobs

2019-08-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-3018. - Resolution: Won't Fix > Job state discarded from web interface for restarting jobs >

[jira] [Closed] (FLINK-6262) UnknownTopicOrPartitionException Kafka consumer error on broker restart/failure

2019-08-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-6262. - Resolution: Won't Fix > UnknownTopicOrPartitionException Kafka consumer error on broker > restart/failur

[jira] [Closed] (FLINK-6264) Kafka consumer fails if can't find leader for partition

2019-08-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-6264. - Resolution: Won't Fix > Kafka consumer fails if can't find leader for partition > ---

[jira] [Closed] (FLINK-13171) Add withParameters(Configuration) method to DataStream operators

2019-08-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-13171. -- Resolution: Won't Fix > Add withParameters(Configuration) method to DataStream operators > ---

[jira] [Closed] (FLINK-6754) Savepoints don't respect client timeout config

2019-08-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-6754. - Resolution: Not A Problem > Savepoints don't respect client timeout config >

[jira] [Created] (FLINK-13832) DefaultRollingPolicy create() method should be renamed to builder()

2019-08-23 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-13832: -- Summary: DefaultRollingPolicy create() method should be renamed to builder() Key: FLINK-13832 URL: https://issues.apache.org/jira/browse/FLINK-13832 Project: Flink

[jira] [Assigned] (FLINK-13832) DefaultRollingPolicy create() method should be renamed to builder()

2019-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-13832: -- Assignee: Gyula Fora > DefaultRollingPolicy create() method should be renamed to builder() >

[jira] [Created] (FLINK-13842) Improve Javadocs and web documentation of the StreamingFileSink

2019-08-24 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-13842: -- Summary: Improve Javadocs and web documentation of the StreamingFileSink Key: FLINK-13842 URL: https://issues.apache.org/jira/browse/FLINK-13842 Project: Flink

[jira] [Commented] (FLINK-11395) Support for Avro StreamingFileSink

2019-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914982#comment-16914982 ] Gyula Fora commented on FLINK-11395: Wouldn't the Avro format be a Row based format

[jira] [Commented] (FLINK-11931) Avro Bulk Writer Factory for StreamingFileSink Bulk Format

2019-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914983#comment-16914983 ] Gyula Fora commented on FLINK-11931: This is a duplicate of https://issues.apache.or

[jira] [Closed] (FLINK-11931) Avro Bulk Writer Factory for StreamingFileSink Bulk Format

2019-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-11931. -- Resolution: Duplicate > Avro Bulk Writer Factory for StreamingFileSink Bulk Format > -

[jira] [Commented] (FLINK-13832) DefaultRollingPolicy create() method should be renamed to builder()

2019-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16914999#comment-16914999 ] Gyula Fora commented on FLINK-13832: Do you mean the eventual removal of the method

[jira] [Commented] (FLINK-13832) DefaultRollingPolicy create() method should be renamed to builder()

2019-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16915040#comment-16915040 ] Gyula Fora commented on FLINK-13832: I don't mind opening a quick discussion about d

[jira] [Comment Edited] (FLINK-13832) DefaultRollingPolicy create() method should be renamed to builder()

2019-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16915040#comment-16915040 ] Gyula Fora edited comment on FLINK-13832 at 8/24/19 4:46 PM: -

[jira] [Commented] (FLINK-13832) DefaultRollingPolicy create() method should be renamed to builder()

2019-08-24 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16915049#comment-16915049 ] Gyula Fora commented on FLINK-13832: To be precise I am not suggesting to remove the

[jira] [Created] (FLINK-13843) Unify and clean up StreamingFileSink format builders

2019-08-25 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-13843: -- Summary: Unify and clean up StreamingFileSink format builders Key: FLINK-13843 URL: https://issues.apache.org/jira/browse/FLINK-13843 Project: Flink Issue Type:

[jira] [Commented] (FLINK-13428) StreamingFileSink allow part file name to be configurable

2019-08-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16915220#comment-16915220 ] Gyula Fora commented on FLINK-13428: I just checked the implementation and it contai

[jira] [Commented] (FLINK-13843) Unify and clean up StreamingFileSink format builders

2019-08-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16915224#comment-16915224 ] Gyula Fora commented on FLINK-13843: In that case [~kkl0u] the RowFormatBuilder.with

[jira] [Created] (FLINK-13850) Refactor part file configuration into a single method

2019-08-26 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-13850: -- Summary: Refactor part file configuration into a single method Key: FLINK-13850 URL: https://issues.apache.org/jira/browse/FLINK-13850 Project: Flink Issue Type:

[jira] [Commented] (FLINK-13428) StreamingFileSink allow part file name to be configurable

2019-08-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16915552#comment-16915552 ] Gyula Fora commented on FLINK-13428: Maybe fixing the docs can be combined with  htt

[jira] [Created] (FLINK-13852) Support storing in-progress/pending files in different directories (StreamingFileSink)

2019-08-26 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-13852: -- Summary: Support storing in-progress/pending files in different directories (StreamingFileSink) Key: FLINK-13852 URL: https://issues.apache.org/jira/browse/FLINK-13852 Pr

[jira] [Commented] (FLINK-13609) StreamingFileSink - reset part counter on bucket change

2019-08-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16915582#comment-16915582 ] Gyula Fora commented on FLINK-13609: I have also noticed this behavior myself but I

[jira] [Commented] (FLINK-13850) Refactor part file configuration into a single method

2019-08-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916054#comment-16916054 ] Gyula Fora commented on FLINK-13850: I think having clear and well structured code f

[jira] [Commented] (FLINK-13850) Refactor part file configuration into a single method

2019-08-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916082#comment-16916082 ] Gyula Fora commented on FLINK-13850: Maybe we should come up with a better name like

[jira] [Commented] (FLINK-13609) StreamingFileSink - reset part counter on bucket change

2019-08-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916531#comment-16916531 ] Gyula Fora commented on FLINK-13609: Thanks for the explanation of the mechanism [~k

[jira] [Resolved] (FLINK-13832) DefaultRollingPolicy create() method should be renamed to builder()

2019-08-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-13832. Resolution: Fixed > DefaultRollingPolicy create() method should be renamed to builder() >

[jira] [Closed] (FLINK-13832) DefaultRollingPolicy create() method should be renamed to builder()

2019-08-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-13832. -- > DefaultRollingPolicy create() method should be renamed to builder() > --

[jira] [Created] (FLINK-13874) StreamingFileSink fails to recover (truncate) properly

2019-08-27 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-13874: -- Summary: StreamingFileSink fails to recover (truncate) properly Key: FLINK-13874 URL: https://issues.apache.org/jira/browse/FLINK-13874 Project: Flink Issue Type

[jira] [Updated] (FLINK-13874) StreamingFileSink fails to recover (truncate) properly

2019-08-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-13874: --- Description: It seems that there might be some problem with the truncate / recovery logic for the H

[jira] [Updated] (FLINK-13874) StreamingFileSink fails to recover (truncate) properly

2019-08-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-13874: --- Issue Type: Bug (was: New Feature) > StreamingFileSink fails to recover (truncate) properly > -

[jira] [Commented] (FLINK-13874) StreamingFileSink fails to recover (truncate) properly

2019-08-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16916795#comment-16916795 ] Gyula Fora commented on FLINK-13874: Seems like it:  [https://github.com/apache/hado

[jira] [Commented] (FLINK-14483) Build and supply frocksdb version to support WriteBufferManager

2019-11-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16982361#comment-16982361 ] Gyula Fora commented on FLINK-14483: could we try to release this frocksdb version t

[jira] [Commented] (FLINK-14482) Bump up rocksdb version

2019-11-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16982362#comment-16982362 ] Gyula Fora commented on FLINK-14482: since the PR with the 5.17.2 improvements have

[jira] [Commented] (FLINK-14483) Build and supply frocksdb version to support WriteBufferManager

2019-11-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16982542#comment-16982542 ] Gyula Fora commented on FLINK-14483: Haha, sorry [~yunta] that I am constantly naggi

[jira] [Commented] (FLINK-14048) Flink client hangs after trying to kill Yarn Job during deployment

2019-10-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16957670#comment-16957670 ] Gyula Fora commented on FLINK-14048: [~tison] I think your patch doesn't fix the pro

[jira] [Closed] (FLINK-14528) Add a constructor for FlinkKafkaProducer

2019-10-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-14528. -- Resolution: Duplicate This is a duplicate of https://issues.apache.org/jira/browse/FLINK-14002 > Add

[jira] [Commented] (FLINK-10435) Client sporadically hangs after Ctrl + C

2019-10-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16959570#comment-16959570 ] Gyula Fora commented on FLINK-10435: You might have to wait until the yarn job is ac

[jira] [Commented] (FLINK-14531) Add Kafka Metrics Reporter

2019-10-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16960856#comment-16960856 ] Gyula Fora commented on FLINK-14531: Hi! Thanks for starting the discussion, we have

[jira] [Commented] (FLINK-10435) Client sporadically hangs after Ctrl + C

2019-10-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16962030#comment-16962030 ] Gyula Fora commented on FLINK-10435: I would also only add it for the current 1.9 an

[jira] [Commented] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

2020-03-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057620#comment-17057620 ] Gyula Fora commented on FLINK-16441: I have a quick fix that sets the contents of th

[jira] [Assigned] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

2020-03-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-16441: -- Assignee: Gyula Fora > Allow users to override flink-conf parameters from SQL CLI environment

[jira] [Commented] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

2020-03-16 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060079#comment-17060079 ] Gyula Fora commented on FLINK-16441: There are a large class of configs that take ef

[jira] [Commented] (FLINK-16421) Changing default catalog to hive without changing default database fails

2020-03-23 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17064611#comment-17064611 ] Gyula Fora commented on FLINK-16421: my point is that defualt_database should switch

[jira] [Commented] (FLINK-16775) expose FlinkKafkaConsumer/FlinkKafkaProducer Properties for other system

2020-03-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066604#comment-17066604 ] Gyula Fora commented on FLINK-16775: We should also expose the TopicsDescriptor > e

[jira] [Commented] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

2020-03-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066608#comment-17066608 ] Gyula Fora commented on FLINK-16774: Also probably the hbase configuration > expose

[jira] [Assigned] (FLINK-23693) Add principal creation possibilities to SecureTestEnvironment

2021-08-10 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-23693: -- Assignee: Gyula Fora > Add principal creation possibilities to SecureTestEnvironment > --

[jira] [Assigned] (FLINK-23688) Make JaasModule.getAppConfigurationEntries public

2021-08-10 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-23688: -- Assignee: Gyula Fora > Make JaasModule.getAppConfigurationEntries public > --

<    11   12   13   14   15   16   17   18   19   20   >