[jira] [Updated] (FLINK-26446) Update Feature Radar in Apache Flink Roadmap

[ https://issues.apache.org/jira/browse/FLINK-26446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-26446: - Description: Deployment/Coordination: * Java 8 -> Deprecation * Add Deployment Modes ** Appli

[jira] [Created] (FLINK-26374) JSON_OBJECT may throw NullPointerException on nullable column

Seth Wiesman created FLINK-26374: Summary: JSON_OBJECT may throw NullPointerException on nullable column Key: FLINK-26374 URL: https://issues.apache.org/jira/browse/FLINK-26374 Project: Flink

[jira] [Closed] (FLINK-26340) Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context

[ https://issues.apache.org/jira/browse/FLINK-26340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-26340. Resolution: Fixed > Add ability in Golang SDK to create new statefun.Context from existing one, >

[jira] [Commented] (FLINK-26340) Add ability in Golang SDK to create new statefun.Context from existing one, but with a new underlying context.Context

[ https://issues.apache.org/jira/browse/FLINK-26340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497743#comment-17497743 ] Seth Wiesman commented on FLINK-26340: -- resolved in: 725202cd69b78442d1287deec000ae

[jira] [Commented] (FLINK-26200) Redirect statefun directly to docs

[ https://issues.apache.org/jira/browse/FLINK-26200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17493547#comment-17493547 ] Seth Wiesman commented on FLINK-26200: -- resolved in 5a8b85bd6c449ce4edebacf332568cd

[jira] [Closed] (FLINK-26200) Redirect statefun directly to docs

[ https://issues.apache.org/jira/browse/FLINK-26200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-26200. Resolution: Fixed > Redirect statefun directly to docs > -- > >

[jira] [Created] (FLINK-26200) Redirect statefun directly to docs

Seth Wiesman created FLINK-26200: Summary: Redirect statefun directly to docs Key: FLINK-26200 URL: https://issues.apache.org/jira/browse/FLINK-26200 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-25423) Enable loading state backend via configuration in state processor api

[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-25423. Resolution: Fixed > Enable loading state backend via configuration in state processor api > --

[jira] [Commented] (FLINK-25423) Enable loading state backend via configuration in state processor api

[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17485909#comment-17485909 ] Seth Wiesman commented on FLINK-25423: -- fixed in master: 8069a0f0b8c2172a90aa509de0

[jira] [Commented] (FLINK-25528) state processor api do not support increment checkpoint

[ https://issues.apache.org/jira/browse/FLINK-25528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17469379#comment-17469379 ] Seth Wiesman commented on FLINK-25528: -- The state processor api only takes a single

[jira] [Commented] (FLINK-25423) Enable loading state backend via configuration in state processor api

[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466227#comment-17466227 ] Seth Wiesman commented on FLINK-25423: -- [~ym] I've opened a PR for this change. It

[jira] [Closed] (FLINK-24912) Migrate state processor API to DataStream API

[ https://issues.apache.org/jira/browse/FLINK-24912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24912. Fix Version/s: 1.15.0 Release Note: The State Processor API has been migrated from Flinks lega

[jira] [Commented] (FLINK-24912) Migrate state processor API to DataStream API

[ https://issues.apache.org/jira/browse/FLINK-24912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17466158#comment-17466158 ] Seth Wiesman commented on FLINK-24912: -- Resolved in 3b54d27b5174c588b80525e04a9af37

[jira] [Comment Edited] (FLINK-25423) Enable loading state backend via configuration in state processor api

[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465074#comment-17465074 ] Seth Wiesman edited comment on FLINK-25423 at 12/24/21, 7:52 PM: -

[jira] [Commented] (FLINK-25423) Enable loading state backend via configuration in state processor api

[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465074#comment-17465074 ] Seth Wiesman commented on FLINK-25423: -- Hi Yuan,    we can get this into 1.15 wit

[jira] [Commented] (FLINK-25026) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17464800#comment-17464800 ] Seth Wiesman commented on FLINK-25026: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-25423) Enable loading state backend via configuration in state processor api

[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17464577#comment-17464577 ] Seth Wiesman commented on FLINK-25423: -- This sounds reasonable. I’m actively workin

[jira] [Assigned] (FLINK-25423) Enable loading state backend via configuration in state processor api

[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-25423: Assignee: Seth Wiesman > Enable loading state backend via configuration in state processo

[jira] [Commented] (FLINK-25360) Add State Desc to CheckpointMetadata

[ https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17464028#comment-17464028 ] Seth Wiesman commented on FLINK-25360: -- [~yunta] there isn't any way to do this wit

[jira] [Assigned] (FLINK-25197) Using Statefun RequestReplyFunctionBuilder fails with Java 8 date/time type `java.time.Duration` not supported by default: add Module "org.apache.flink.shaded.jackson2.

[ https://issues.apache.org/jira/browse/FLINK-25197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-25197: Assignee: Galen Warren > Using Statefun RequestReplyFunctionBuilder fails with Java 8 dat

[jira] [Closed] (FLINK-25333) Harden UID management when constructing statefun universe

[ https://issues.apache.org/jira/browse/FLINK-25333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-25333. Resolution: Fixed > Harden UID management when constructing statefun universe > --

[jira] [Commented] (FLINK-25333) Harden UID management when constructing statefun universe

[ https://issues.apache.org/jira/browse/FLINK-25333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460257#comment-17460257 ] Seth Wiesman commented on FLINK-25333: -- resolved in flink-statefun-docker: 7f8a9b29

[jira] [Commented] (FLINK-25333) Harden UID management when constructing statefun universe

[ https://issues.apache.org/jira/browse/FLINK-25333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460256#comment-17460256 ] Seth Wiesman commented on FLINK-25333: -- [~keremulutas] yes, that log line was actua

[jira] [Closed] (FLINK-25267) Unable to (always) recover using checkpoint in HA setup (both Zookeeper and Kubernetes)

[ https://issues.apache.org/jira/browse/FLINK-25267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-25267. Resolution: Duplicate > Unable to (always) recover using checkpoint in HA setup (both Zookeeper an

[jira] [Commented] (FLINK-25267) Unable to (always) recover using checkpoint in HA setup (both Zookeeper and Kubernetes)

[ https://issues.apache.org/jira/browse/FLINK-25267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17460213#comment-17460213 ] Seth Wiesman commented on FLINK-25267: -- Apologies for not seeing this ticket earlie

[jira] [Updated] (FLINK-25333) Harden UID management when constructing statefun universe

[ https://issues.apache.org/jira/browse/FLINK-25333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-25333: - Issue Type: Bug (was: Improvement) > Harden UID management when constructing statefun universe

[jira] [Created] (FLINK-25333) Harden UID management when constructing statefun universe

Seth Wiesman created FLINK-25333: Summary: Harden UID management when constructing statefun universe Key: FLINK-25333 URL: https://issues.apache.org/jira/browse/FLINK-25333 Project: Flink Iss

[jira] [Closed] (FLINK-21341) Update state reader to return InputFormat

[ https://issues.apache.org/jira/browse/FLINK-21341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-21341. Resolution: Won't Do > Update state reader to return InputFormat > ---

[jira] [Closed] (FLINK-25238) flink iceberg source reading array types fail with Cast Exception

[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-25238. Resolution: Won't Fix > flink iceberg source reading array types fail with Cast Exception > --

[jira] [Commented] (FLINK-25238) flink iceberg source reading array types fail with Cast Exception

[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17457235#comment-17457235 ] Seth Wiesman commented on FLINK-25238: -- The Iceberg Sink is maintained by the Apach

[jira] [Comment Edited] (FLINK-25236) Add a mechanism to generate and validate a jobgraph with a checkpoint before submission

[ https://issues.apache.org/jira/browse/FLINK-25236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456700#comment-17456700 ] Seth Wiesman edited comment on FLINK-25236 at 12/9/21, 9:31 PM: --

[jira] [Commented] (FLINK-25236) Add a mechanism to generate and validate a jobgraph with a checkpoint before submission

[ https://issues.apache.org/jira/browse/FLINK-25236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456700#comment-17456700 ] Seth Wiesman commented on FLINK-25236: -- Unfortunately, this is not so simple to do.

[jira] [Closed] (FLINK-24635) Clean up flink-examples

[ https://issues.apache.org/jira/browse/FLINK-24635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24635. Resolution: Fixed > Clean up flink-examples > --- > > Key: FLI

[jira] [Closed] (FLINK-24829) Rename example directories based on API

[ https://issues.apache.org/jira/browse/FLINK-24829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24829. Resolution: Won't Fix > Rename example directories based on API >

[jira] [Commented] (FLINK-24635) Clean up flink-examples

[ https://issues.apache.org/jira/browse/FLINK-24635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444836#comment-17444836 ] Seth Wiesman commented on FLINK-24635: -- fixed in b00bfaa66db90df7797be6c2003ceaf257

[jira] [Closed] (FLINK-24831) Upgrade DataStream Window examples

[ https://issues.apache.org/jira/browse/FLINK-24831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24831. Fix Version/s: 1.15.0 Resolution: Fixed > Upgrade DataStream Window examples >

[jira] [Commented] (FLINK-24833) Prevent use of deprecated APIs in flink-examples

[ https://issues.apache.org/jira/browse/FLINK-24833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444834#comment-17444834 ] Seth Wiesman commented on FLINK-24833: -- fixed in ef5fb7a15cb3964d0d59434798549bfa26

[jira] [Commented] (FLINK-24831) Upgrade DataStream Window examples

[ https://issues.apache.org/jira/browse/FLINK-24831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444835#comment-17444835 ] Seth Wiesman commented on FLINK-24831: -- fixed in 443b7121373a7f7c4b7a25660a50b06cbe

[jira] [Closed] (FLINK-24833) Prevent use of deprecated APIs in flink-examples

[ https://issues.apache.org/jira/browse/FLINK-24833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24833. Fix Version/s: 1.15.0 Resolution: Fixed > Prevent use of deprecated APIs in flink-examples

[jira] [Created] (FLINK-24912) Migrate state processor API to DataStream API

Seth Wiesman created FLINK-24912: Summary: Migrate state processor API to DataStream API Key: FLINK-24912 URL: https://issues.apache.org/jira/browse/FLINK-24912 Project: Flink Issue Type: Imp

[jira] [Closed] (FLINK-24830) Update DataStream WordCount example

[ https://issues.apache.org/jira/browse/FLINK-24830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24830. Fix Version/s: 1.15.0 Resolution: Fixed > Update DataStream WordCount example > ---

[jira] [Assigned] (FLINK-24831) Upgrade DataStream Window examples

[ https://issues.apache.org/jira/browse/FLINK-24831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-24831: Assignee: Seth Wiesman > Upgrade DataStream Window examples > ---

[jira] [Commented] (FLINK-24830) Update DataStream WordCount example

[ https://issues.apache.org/jira/browse/FLINK-24830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444114#comment-17444114 ] Seth Wiesman commented on FLINK-24830: -- fixed in 83a2541475228a4ff9e9a9def4049fb742

[jira] [Commented] (FLINK-24833) Prevent use of deprecated APIs in flink-examples

[ https://issues.apache.org/jira/browse/FLINK-24833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444113#comment-17444113 ] Seth Wiesman commented on FLINK-24833: -- [~RocMarshal] Thank you for the initiative,

[jira] [Assigned] (FLINK-24833) Prevent use of deprecated APIs in flink-examples

[ https://issues.apache.org/jira/browse/FLINK-24833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-24833: Assignee: Seth Wiesman > Prevent use of deprecated APIs in flink-examples > -

[jira] [Closed] (FLINK-24782) Create 1.14 release branch for training repo

[ https://issues.apache.org/jira/browse/FLINK-24782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24782. Resolution: Fixed > Create 1.14 release branch for training repo > ---

[jira] [Commented] (FLINK-24782) Create 1.14 release branch for training repo

[ https://issues.apache.org/jira/browse/FLINK-24782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441946#comment-17441946 ] Seth Wiesman commented on FLINK-24782: -- fixed in: 0b1c83b16065484200564402bef2ca10e

[jira] [Closed] (FLINK-24834) Add typed builders to DefaultRollingPolicy

[ https://issues.apache.org/jira/browse/FLINK-24834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24834. Resolution: Fixed > Add typed builders to DefaultRollingPolicy > -

[jira] [Commented] (FLINK-24834) Add typed builders to DefaultRollingPolicy

[ https://issues.apache.org/jira/browse/FLINK-24834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441880#comment-17441880 ] Seth Wiesman commented on FLINK-24834: -- fixed in 059c00f4f6bbf0b868d4d8e0971e29d016

[jira] [Created] (FLINK-24834) Add typed builders to DefaultRollingPolicy

Seth Wiesman created FLINK-24834: Summary: Add typed builders to DefaultRollingPolicy Key: FLINK-24834 URL: https://issues.apache.org/jira/browse/FLINK-24834 Project: Flink Issue Type: Improv

[jira] [Assigned] (FLINK-24830) Update DataStream WordCount example

[ https://issues.apache.org/jira/browse/FLINK-24830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-24830: Assignee: Seth Wiesman > Update DataStream WordCount example > --

[jira] [Created] (FLINK-24833) Prevent use of deprecated APIs in flink-examples

Seth Wiesman created FLINK-24833: Summary: Prevent use of deprecated APIs in flink-examples Key: FLINK-24833 URL: https://issues.apache.org/jira/browse/FLINK-24833 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-24829) Rename example directories based on API

[ https://issues.apache.org/jira/browse/FLINK-24829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-24829: Assignee: Seth Wiesman > Rename example directories based on API > --

[jira] [Created] (FLINK-24831) Upgrade DataStream Window examples

Seth Wiesman created FLINK-24831: Summary: Upgrade DataStream Window examples Key: FLINK-24831 URL: https://issues.apache.org/jira/browse/FLINK-24831 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-24830) Update DataStream WordCount example

Seth Wiesman created FLINK-24830: Summary: Update DataStream WordCount example Key: FLINK-24830 URL: https://issues.apache.org/jira/browse/FLINK-24830 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-24829) Rename example directories based on API

[ https://issues.apache.org/jira/browse/FLINK-24829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440563#comment-17440563 ] Seth Wiesman commented on FLINK-24829: -- We might want to look at just dropping data

[jira] [Created] (FLINK-24829) Rename example directories based on API

Seth Wiesman created FLINK-24829: Summary: Rename example directories based on API Key: FLINK-24829 URL: https://issues.apache.org/jira/browse/FLINK-24829 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-24783) Improve monitoring experience and usability of state backend

[ https://issues.apache.org/jira/browse/FLINK-24783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17439346#comment-17439346 ] Seth Wiesman commented on FLINK-24783: -- [~yunta]   These improvements all look re

[jira] [Comment Edited] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438953#comment-17438953 ] Seth Wiesman edited comment on FLINK-24767 at 11/4/21, 10:19 PM: -

[jira] [Commented] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438953#comment-17438953 ] Seth Wiesman commented on FLINK-24767: -- When executing a `keyBy` under batch execut

[jira] [Created] (FLINK-24782) Create 1.14 release branch for training repo

Seth Wiesman created FLINK-24782: Summary: Create 1.14 release branch for training repo Key: FLINK-24782 URL: https://issues.apache.org/jira/browse/FLINK-24782 Project: Flink Issue Type: Impr

[jira] [Closed] (FLINK-24723) Add ServicesResourceTransformer to the quickstart project

[ https://issues.apache.org/jira/browse/FLINK-24723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24723. Resolution: Fixed > Add ServicesResourceTransformer to the quickstart project > --

[jira] [Commented] (FLINK-24723) Add ServicesResourceTransformer to the quickstart project

[ https://issues.apache.org/jira/browse/FLINK-24723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17437400#comment-17437400 ] Seth Wiesman commented on FLINK-24723: -- fixed in master: ea484357b222d850f8df4d7b6a

[jira] [Updated] (FLINK-24723) Add ServicesResourceTransformer to the quickstart project

[ https://issues.apache.org/jira/browse/FLINK-24723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-24723: - Fix Version/s: 1.15.0 > Add ServicesResourceTransformer to the quickstart project >

[jira] [Assigned] (FLINK-24723) Add ServicesResourceTransformer to the quickstart project

[ https://issues.apache.org/jira/browse/FLINK-24723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-24723: Assignee: Ali Bahadir Zeybek > Add ServicesResourceTransformer to the quickstart project

[jira] [Created] (FLINK-24635) Clean up flink-examples

Seth Wiesman created FLINK-24635: Summary: Clean up flink-examples Key: FLINK-24635 URL: https://issues.apache.org/jira/browse/FLINK-24635 Project: Flink Issue Type: Improvement Com

[jira] [Closed] (FLINK-24516) Modernize Maven Archetype

[ https://issues.apache.org/jira/browse/FLINK-24516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24516. Fix Version/s: 1.15.0 Resolution: Fixed > Modernize Maven Archetype > -

[jira] [Commented] (FLINK-24516) Modernize Maven Archetype

[ https://issues.apache.org/jira/browse/FLINK-24516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17430545#comment-17430545 ] Seth Wiesman commented on FLINK-24516: -- fixed in: d8112a721329e7d276fff97ceaccf91fc

[jira] [Assigned] (FLINK-24593) Create Table API Quickstart

[ https://issues.apache.org/jira/browse/FLINK-24593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-24593: Assignee: (was: Seth Wiesman) > Create Table API Quickstart > ---

[jira] [Commented] (FLINK-24516) Modernize Maven Archetype

[ https://issues.apache.org/jira/browse/FLINK-24516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17430541#comment-17430541 ] Seth Wiesman commented on FLINK-24516: -- [~MartijnVisser] I agree, I think that is f

[jira] [Created] (FLINK-24593) Create Table API Quickstart

Seth Wiesman created FLINK-24593: Summary: Create Table API Quickstart Key: FLINK-24593 URL: https://issues.apache.org/jira/browse/FLINK-24593 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-24516) Modernize Maven Archetype

[ https://issues.apache.org/jira/browse/FLINK-24516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-24516: Assignee: Seth Wiesman > Modernize Maven Archetype > - > >

[jira] [Commented] (FLINK-24516) Modernize Maven Archetype

[ https://issues.apache.org/jira/browse/FLINK-24516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17427811#comment-17427811 ] Seth Wiesman commented on FLINK-24516: -- [~MartijnVisser] maybe you have some ideas

[jira] [Created] (FLINK-24516) Modernize Maven Archetype

Seth Wiesman created FLINK-24516: Summary: Modernize Maven Archetype Key: FLINK-24516 URL: https://issues.apache.org/jira/browse/FLINK-24516 Project: Flink Issue Type: Improvement C

[jira] [Closed] (FLINK-24464) Metrics sometimes report negative backlog

[ https://issues.apache.org/jira/browse/FLINK-24464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24464. Fix Version/s: statefun-3.2.0 Resolution: Fixed > Metrics sometimes report negative backlog

[jira] [Commented] (FLINK-24464) Metrics sometimes report negative backlog

[ https://issues.apache.org/jira/browse/FLINK-24464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425600#comment-17425600 ] Seth Wiesman commented on FLINK-24464: -- resolved in master: 461cdde1b92c8f285e425c4

[jira] [Assigned] (FLINK-24464) Metrics sometimes report negative backlog

[ https://issues.apache.org/jira/browse/FLINK-24464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-24464: Assignee: Seth Wiesman > Metrics sometimes report negative backlog >

[jira] [Updated] (FLINK-24464) Metrics sometimes report negative backlog

[ https://issues.apache.org/jira/browse/FLINK-24464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-24464: - Affects Version/s: statefun-3.1.0 > Metrics sometimes report negative backlog >

[jira] [Updated] (FLINK-24464) Metrics sometimes report negative backlog

[ https://issues.apache.org/jira/browse/FLINK-24464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-24464: - Description: As reported [here|https://stackoverflow.com/questions/69441309/negative-backlog-in

[jira] [Updated] (FLINK-24464) Metrics sometimes report negative backlog

[ https://issues.apache.org/jira/browse/FLINK-24464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-24464: - Description: As report [here|[https://stackoverflow.com/questions/69441309/negative-backlog-in-

[jira] [Created] (FLINK-24464) Metrics sometimes report negative backlog

Seth Wiesman created FLINK-24464: Summary: Metrics sometimes report negative backlog Key: FLINK-24464 URL: https://issues.apache.org/jira/browse/FLINK-24464 Project: Flink Issue Type: Improve

[jira] [Comment Edited] (FLINK-24427) Hide Scala in flink-table-planner from API

[ https://issues.apache.org/jira/browse/FLINK-24427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423039#comment-17423039 ] Seth Wiesman edited comment on FLINK-24427 at 9/30/21, 11:01 PM: -

[jira] [Commented] (FLINK-24427) Hide Scala in flink-table-planner from API

[ https://issues.apache.org/jira/browse/FLINK-24427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17423039#comment-17423039 ] Seth Wiesman commented on FLINK-24427: -- Hi [~eloisant],    The goal is to hide th

[jira] [Updated] (FLINK-23313) Reintroduce temporal table function documentation

[ https://issues.apache.org/jira/browse/FLINK-23313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-23313: - Fix Version/s: 1.14.0 1.15.0 > Reintroduce temporal table function documentat

[jira] [Closed] (FLINK-23313) Reintroduce temporal table function documentation

[ https://issues.apache.org/jira/browse/FLINK-23313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-23313. Resolution: Fixed > Reintroduce temporal table function documentation > --

[jira] [Commented] (FLINK-23313) Reintroduce temporal table function documentation

[ https://issues.apache.org/jira/browse/FLINK-23313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17422407#comment-17422407 ] Seth Wiesman commented on FLINK-23313: -- resolved in release-1.14: fc8e269e9415a75fe

[jira] [Commented] (FLINK-24392) Upgrade presto s3 fs implementation to Trino >= 348

[ https://issues.apache.org/jira/browse/FLINK-24392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17421630#comment-17421630 ] Seth Wiesman commented on FLINK-24392: -- Potentially as follow up, I think its worth

[jira] [Closed] (FLINK-24373) Remove BETA Tag from FLIP-27 Source Docs

[ https://issues.apache.org/jira/browse/FLINK-24373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24373. Resolution: Fixed > Remove BETA Tag from FLIP-27 Source Docs > ---

[jira] [Commented] (FLINK-24373) Remove BETA Tag from FLIP-27 Source Docs

[ https://issues.apache.org/jira/browse/FLINK-24373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17420780#comment-17420780 ] Seth Wiesman commented on FLINK-24373: -- resolved in 1.14: 81d676ff72a553d546a2fad25

[jira] [Updated] (FLINK-24373) Remove BETA Tag from FLIP-27 Source Docs

[ https://issues.apache.org/jira/browse/FLINK-24373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-24373: - Fix Version/s: 1.15.0 1.14.0 > Remove BETA Tag from FLIP-27 Source Docs > ---

[jira] [Created] (FLINK-24373) Remove BETA Tag from FLIP-27 Source Docs

Seth Wiesman created FLINK-24373: Summary: Remove BETA Tag from FLIP-27 Source Docs Key: FLINK-24373 URL: https://issues.apache.org/jira/browse/FLINK-24373 Project: Flink Issue Type: Improvem

[jira] [Commented] (FLINK-23976) Add additional availability timing metrics to Job lifecycle events

[ https://issues.apache.org/jira/browse/FLINK-23976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418765#comment-17418765 ] Seth Wiesman commented on FLINK-23976: -- [~thw] interesting. Similar to the linked t

[jira] [Updated] (FLINK-24253) Load JdbcDialects via Service Loaders

[ https://issues.apache.org/jira/browse/FLINK-24253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-24253: - Affects Version/s: 1.15.0 > Load JdbcDialects via Service Loaders >

[jira] [Updated] (FLINK-24253) Load JdbcDialects via Service Loaders

[ https://issues.apache.org/jira/browse/FLINK-24253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-24253: - Fix Version/s: 1.15.0 > Load JdbcDialects via Service Loaders >

[jira] [Closed] (FLINK-24253) Load JdbcDialects via Service Loaders

[ https://issues.apache.org/jira/browse/FLINK-24253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24253. Resolution: Fixed > Load JdbcDialects via Service Loaders > -

[jira] [Commented] (FLINK-24253) Load JdbcDialects via Service Loaders

[ https://issues.apache.org/jira/browse/FLINK-24253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418112#comment-17418112 ] Seth Wiesman commented on FLINK-24253: -- resolved in master: 412b49a0fa4756bc6a66378

[jira] [Commented] (FLINK-24301) use Async transport on all statefun playground examples

[ https://issues.apache.org/jira/browse/FLINK-24301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17416329#comment-17416329 ] Seth Wiesman commented on FLINK-24301: -- fixed in dev: dffc59428a91853332a038e9d1397

[jira] [Closed] (FLINK-24301) use Async transport on all statefun playground examples

[ https://issues.apache.org/jira/browse/FLINK-24301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24301. Resolution: Fixed > use Async transport on all statefun playground examples >

[jira] [Closed] (FLINK-24284) Add a greeter and a showcase for the JavaScript SDK

[ https://issues.apache.org/jira/browse/FLINK-24284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-24284. Resolution: Done > Add a greeter and a showcase for the JavaScript SDK > -

[jira] [Commented] (FLINK-24284) Add a greeter and a showcase for the JavaScript SDK

[ https://issues.apache.org/jira/browse/FLINK-24284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17416327#comment-17416327 ] Seth Wiesman commented on FLINK-24284: -- fixed in dev: 3b52dfc554540c03dbd4b2acfa444

  1   2   3   4   5   6   7   8   >