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

2022-03-03 Thread Seth Wiesman (Jira)
[ 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 **

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

2022-02-25 Thread Seth Wiesman (Jira)
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

2022-02-24 Thread Seth Wiesman (Jira)
[ 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

2022-02-24 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497743#comment-17497743 ] Seth Wiesman commented on FLINK-26340: -- resolved in: 725202cd69b78442d1287deec000ae2d52da4bda >

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

2022-02-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493547#comment-17493547 ] Seth Wiesman commented on FLINK-26200: -- resolved in 5a8b85bd6c449ce4edebacf332568cd4b6845837 >

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

2022-02-16 Thread Seth Wiesman (Jira)
[ 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

2022-02-16 Thread Seth Wiesman (Jira)
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

2022-02-02 Thread Seth Wiesman (Jira)
[ 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

2022-02-02 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17485909#comment-17485909 ] Seth Wiesman commented on FLINK-25423: -- fixed in master: 8069a0f0b8c2172a90aa509de08df865884ff815

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

2022-01-05 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17469379#comment-17469379 ] Seth Wiesman commented on FLINK-25528: -- The state processor api only takes a single snapshot at end

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

2021-12-28 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466227#comment-17466227 ] Seth Wiesman commented on FLINK-25423: -- [~ym] I've opened a PR for this change. It would be great

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

2021-12-28 Thread Seth Wiesman (Jira)
[ 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

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

2021-12-28 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466158#comment-17466158 ] Seth Wiesman commented on FLINK-24912: -- Resolved in 3b54d27b5174c588b80525e04a9af37613730681 >

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

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

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

2021-12-24 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465074#comment-17465074 ] Seth Wiesman commented on FLINK-25423: -- Hi Yuan,    we can get this into 1.15 without any

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

2021-12-23 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464800#comment-17464800 ] Seth Wiesman commented on FLINK-25026: --

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

2021-12-23 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464577#comment-17464577 ] Seth Wiesman commented on FLINK-25423: -- This sounds reasonable. I’m actively working on porting the

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

2021-12-23 Thread Seth Wiesman (Jira)
[ 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

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

2021-12-22 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464028#comment-17464028 ] Seth Wiesman commented on FLINK-25360: -- [~yunta] there isn't any way to do this with the state

[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.

2021-12-20 Thread Seth Wiesman (Jira)
[ 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

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

2021-12-15 Thread Seth Wiesman (Jira)
[ 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

2021-12-15 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460257#comment-17460257 ] Seth Wiesman commented on FLINK-25333: -- resolved in flink-statefun-docker:

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

2021-12-15 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460256#comment-17460256 ] Seth Wiesman commented on FLINK-25333: -- [~keremulutas] yes, that log line was actually the clue to

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

2021-12-15 Thread Seth Wiesman (Jira)
[ 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

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

2021-12-15 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460213#comment-17460213 ] Seth Wiesman commented on FLINK-25267: -- Apologies for not seeing this ticket earlier. For those

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

2021-12-15 Thread Seth Wiesman (Jira)
[ 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

2021-12-15 Thread Seth Wiesman (Jira)
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

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

2021-12-13 Thread Seth Wiesman (Jira)
[ 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

2021-12-10 Thread Seth Wiesman (Jira)
[ 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

2021-12-10 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457235#comment-17457235 ] Seth Wiesman commented on FLINK-25238: -- The Iceberg Sink is maintained by the Apache Iceberg

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

2021-12-09 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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

2021-12-09 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456700#comment-17456700 ] Seth Wiesman commented on FLINK-25236: -- Unfortunately, this is not so simple to do. The method you

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

2021-11-16 Thread Seth Wiesman (Jira)
[ 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:

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

2021-11-16 Thread Seth Wiesman (Jira)
[ 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

2021-11-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444836#comment-17444836 ] Seth Wiesman commented on FLINK-24635: -- fixed in b00bfaa66db90df7797be6c2003ceaf257e0309f > Clean

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

2021-11-16 Thread Seth Wiesman (Jira)
[ 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

2021-11-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444834#comment-17444834 ] Seth Wiesman commented on FLINK-24833: -- fixed in ef5fb7a15cb3964d0d59434798549bfa26adabe9 >

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

2021-11-16 Thread Seth Wiesman (Jira)
[ 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] [Commented] (FLINK-24831) Upgrade DataStream Window examples

2021-11-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444835#comment-17444835 ] Seth Wiesman commented on FLINK-24831: -- fixed in 443b7121373a7f7c4b7a25660a50b06cbee8cb01 >

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

2021-11-15 Thread Seth Wiesman (Jira)
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:

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

2021-11-15 Thread Seth Wiesman (Jira)
[ 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

2021-11-15 Thread Seth Wiesman (Jira)
[ 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

2021-11-15 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444114#comment-17444114 ] Seth Wiesman commented on FLINK-24830: -- fixed in 83a2541475228a4ff9e9a9def4049fb742353549 > Update

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

2021-11-15 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17444113#comment-17444113 ] Seth Wiesman commented on FLINK-24833: -- [~RocMarshal] Thank you for the initiative, but I'm going

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

2021-11-15 Thread Seth Wiesman (Jira)
[ 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

2021-11-10 Thread Seth Wiesman (Jira)
[ 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

2021-11-10 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441946#comment-17441946 ] Seth Wiesman commented on FLINK-24782: -- fixed in: 0b1c83b16065484200564402bef2ca10ef19cb30 >

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

2021-11-10 Thread Seth Wiesman (Jira)
[ 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

2021-11-10 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441880#comment-17441880 ] Seth Wiesman commented on FLINK-24834: -- fixed in 059c00f4f6bbf0b868d4d8e0971e29d0168894f9 > Add

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

2021-11-08 Thread Seth Wiesman (Jira)
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:

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

2021-11-08 Thread Seth Wiesman (Jira)
[ 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

2021-11-08 Thread Seth Wiesman (Jira)
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

2021-11-08 Thread Seth Wiesman (Jira)
[ 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

2021-11-08 Thread Seth Wiesman (Jira)
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

2021-11-08 Thread Seth Wiesman (Jira)
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

2021-11-08 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440563#comment-17440563 ] Seth Wiesman commented on FLINK-24829: -- We might want to look at just dropping dataset examples in

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

2021-11-08 Thread Seth Wiesman (Jira)
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

2021-11-05 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439346#comment-17439346 ] Seth Wiesman commented on FLINK-24783: -- [~yunta]   These improvements all look really good! 

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

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

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

2021-11-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438953#comment-17438953 ] Seth Wiesman commented on FLINK-24767: -- When executing a `keyBy` under batch execution, the

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

2021-11-04 Thread Seth Wiesman (Jira)
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:

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

2021-11-02 Thread Seth Wiesman (Jira)
[ 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

2021-11-02 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437400#comment-17437400 ] Seth Wiesman commented on FLINK-24723: -- fixed in master: ea484357b222d850f8df4d7b6ae8dacb110b19b7

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

2021-11-01 Thread Seth Wiesman (Jira)
[ 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

2021-11-01 Thread Seth Wiesman (Jira)
[ 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

2021-10-25 Thread Seth Wiesman (Jira)
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

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

2021-10-19 Thread Seth Wiesman (Jira)
[ 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

2021-10-19 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430545#comment-17430545 ] Seth Wiesman commented on FLINK-24516: -- fixed in: d8112a721329e7d276fff97ceaccf91fc90391a2 >

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

2021-10-19 Thread Seth Wiesman (Jira)
[ 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

2021-10-19 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17430541#comment-17430541 ] Seth Wiesman commented on FLINK-24516: -- [~MartijnVisser] I agree, I think that is follow-up work.

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

2021-10-19 Thread Seth Wiesman (Jira)
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

2021-10-14 Thread Seth Wiesman (Jira)
[ 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

2021-10-12 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17427811#comment-17427811 ] Seth Wiesman commented on FLINK-24516: -- [~MartijnVisser] maybe you have some ideas about what this

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

2021-10-12 Thread Seth Wiesman (Jira)
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

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

2021-10-07 Thread Seth Wiesman (Jira)
[ 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

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

2021-10-07 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17425600#comment-17425600 ] Seth Wiesman commented on FLINK-24464: -- resolved in master: 

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

2021-10-06 Thread Seth Wiesman (Jira)
[ 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

2021-10-06 Thread Seth Wiesman (Jira)
[ 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

2021-10-06 Thread Seth Wiesman (Jira)
[ 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

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

2021-10-06 Thread Seth Wiesman (Jira)
[ 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

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

2021-10-06 Thread Seth Wiesman (Jira)
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:

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

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

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

2021-09-30 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17423039#comment-17423039 ] Seth Wiesman commented on FLINK-24427: -- Hi [~eloisant],    The goal is to hide the planner from

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

2021-09-29 Thread Seth Wiesman (Jira)
[ 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

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

2021-09-29 Thread Seth Wiesman (Jira)
[ 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

2021-09-29 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422407#comment-17422407 ] Seth Wiesman commented on FLINK-23313: -- resolved in release-1.14: 

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

2021-09-28 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421630#comment-17421630 ] Seth Wiesman commented on FLINK-24392: -- Potentially as follow up, I think its worth investigating

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

2021-09-27 Thread Seth Wiesman (Jira)
[ 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

2021-09-27 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420780#comment-17420780 ] Seth Wiesman commented on FLINK-24373: -- resolved in 1.14: 81d676ff72a553d546a2fad25d71d47467e76f95

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

2021-09-27 Thread Seth Wiesman (Jira)
[ 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

2021-09-24 Thread Seth Wiesman (Jira)
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:

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

2021-09-22 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418765#comment-17418765 ] Seth Wiesman commented on FLINK-23976: -- [~thw] interesting. Similar to the linked ticket we'll need

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

2021-09-21 Thread Seth Wiesman (Jira)
[ 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

2021-09-21 Thread Seth Wiesman (Jira)
[ 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

2021-09-21 Thread Seth Wiesman (Jira)
[ 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

2021-09-21 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17418112#comment-17418112 ] Seth Wiesman commented on FLINK-24253: -- resolved in master: 

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

2021-09-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416329#comment-17416329 ] Seth Wiesman commented on FLINK-24301: -- fixed in dev: dffc59428a91853332a038e9d13970108d2302e9

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

2021-09-16 Thread Seth Wiesman (Jira)
[ 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

2021-09-16 Thread Seth Wiesman (Jira)
[ 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

2021-09-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17416327#comment-17416327 ] Seth Wiesman commented on FLINK-24284: -- fixed in dev: 3b52dfc554540c03dbd4b2acfa4440ceb8914e38 >

  1   2   3   4   5   6   7   8   >