[jira] [Commented] (FLINK-19538) Support more complex routers in remote ingress definitions

2020-10-19 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216726#comment-17216726 ] Seth Wiesman commented on FLINK-19538: -- I've gone back and forth since opening this ticket and I'm

[jira] [Commented] (FLINK-19508) Add collect() operation on DataStream

2020-10-15 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214737#comment-17214737 ] Seth Wiesman commented on FLINK-19508: -- Hi [~xuannan], I plan on working on this next week. I'll be

[jira] [Commented] (FLINK-19508) Add collect() operation on DataStream

2020-10-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214105#comment-17214105 ] Seth Wiesman commented on FLINK-19508: -- I'm going to pick up this ticket. > Add collect()

[jira] [Assigned] (FLINK-19508) Add collect() operation on DataStream

2020-10-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-19508: Assignee: Seth Wiesman > Add collect() operation on DataStream >

[jira] [Commented] (FLINK-19525) Update Table API Overview page

2020-10-12 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17212369#comment-17212369 ] Seth Wiesman commented on FLINK-19525: -- Assgined > Update Table API Overview page >

[jira] [Assigned] (FLINK-19525) Update Table API Overview page

2020-10-12 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-19525: Assignee: M Haseeb Asif > Update Table API Overview page >

[jira] [Assigned] (FLINK-19530) Table Concepts Page

2020-10-09 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-19530: Assignee: Kartik Khare > Table Concepts Page > --- > >

[jira] [Updated] (FLINK-19538) Support more complex routers in remote ingress definitions

2020-10-08 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-19538: - Description: Ingresses defined via Yaml route messages with an implicit key pulled via the

[jira] [Created] (FLINK-19538) Support more complex routers in remote ingress definitions

2020-10-08 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19538: Summary: Support more complex routers in remote ingress definitions Key: FLINK-19538 URL: https://issues.apache.org/jira/browse/FLINK-19538 Project: Flink

[jira] [Created] (FLINK-19527) Update SQL Pages

2020-10-07 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19527: Summary: Update SQL Pages Key: FLINK-19527 URL: https://issues.apache.org/jira/browse/FLINK-19527 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-19529) Table connectors docs

2020-10-07 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19529: Summary: Table connectors docs Key: FLINK-19529 URL: https://issues.apache.org/jira/browse/FLINK-19529 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19530) Table Concepts Page

2020-10-07 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19530: Summary: Table Concepts Page Key: FLINK-19530 URL: https://issues.apache.org/jira/browse/FLINK-19530 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19526) Update Table API specific section

2020-10-07 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19526: Summary: Update Table API specific section Key: FLINK-19526 URL: https://issues.apache.org/jira/browse/FLINK-19526 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19528) Setup and SQL execution

2020-10-07 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19528: Summary: Setup and SQL execution Key: FLINK-19528 URL: https://issues.apache.org/jira/browse/FLINK-19528 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19525) Update Table API Overview page

2020-10-07 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19525: Summary: Update Table API Overview page Key: FLINK-19525 URL: https://issues.apache.org/jira/browse/FLINK-19525 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-19524) Google Season of Docs - FLIP 60

2020-10-07 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-19524: - Issue Type: Improvement (was: Bug) > Google Season of Docs - FLIP 60 >

[jira] [Updated] (FLINK-19524) Google Season of Docs - FLIP 60

2020-10-07 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-19524: - Description: This is an umbrella ticket to track the implementation of FLIP-60 that will occur

[jira] [Created] (FLINK-19524) Google Season of Docs - FLIP 60

2020-10-07 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19524: Summary: Google Season of Docs - FLIP 60 Key: FLINK-19524 URL: https://issues.apache.org/jira/browse/FLINK-19524 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-17259) Have scala 2.12 support

2020-10-06 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208857#comment-17208857 ] Seth Wiesman commented on FLINK-17259: -- StateFun 2.2 dropped scala 2.11 support in favor of 2.12.

[jira] [Closed] (FLINK-17259) Have scala 2.12 support

2020-10-06 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-17259. Resolution: Duplicate > Have scala 2.12 support > --- > >

[jira] [Created] (FLINK-19496) DataGen source DECIMAL always returns null

2020-10-02 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19496: Summary: DataGen source DECIMAL always returns null Key: FLINK-19496 URL: https://issues.apache.org/jira/browse/FLINK-19496 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-19496) DataGen source DECIMAL always returns null

2020-10-02 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-19496: - Fix Version/s: 1.12.0 > DataGen source DECIMAL always returns null >

[jira] [Updated] (FLINK-19496) DataGen source DECIMAL always returns null

2020-10-02 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-19496: - Component/s: Table SQL / Runtime > DataGen source DECIMAL always returns null >

[jira] [Updated] (FLINK-19464) Rename CheckpointStorage interface to CheckpointStorageAccess

2020-09-29 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-19464: - Component/s: Runtime / State Backends > Rename CheckpointStorage interface to

[jira] [Updated] (FLINK-19467) Implement HashMapStateBackend and EmbeddedRocksDBStateBackend

2020-09-29 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-19467: - Component/s: Runtime / State Backends > Implement HashMapStateBackend and

[jira] [Updated] (FLINK-19465) Add CheckpointStorage interface

2020-09-29 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-19465: - Component/s: Runtime / State Backends > Add CheckpointStorage interface >

[jira] [Updated] (FLINK-19466) Implement JobManagerCheckpointStorage and FileSystemCheckpointStorage

2020-09-29 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-19466: - Component/s: Runtime / State Backends > Implement JobManagerCheckpointStorage and

[jira] [Created] (FLINK-19467) Implement HashMapStateBackend and EmbeddedRocksDBStateBackend

2020-09-29 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19467: Summary: Implement HashMapStateBackend and EmbeddedRocksDBStateBackend Key: FLINK-19467 URL: https://issues.apache.org/jira/browse/FLINK-19467 Project: Flink

[jira] [Assigned] (FLINK-19467) Implement HashMapStateBackend and EmbeddedRocksDBStateBackend

2020-09-29 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-19467: Assignee: Seth Wiesman > Implement HashMapStateBackend and EmbeddedRocksDBStateBackend >

[jira] [Created] (FLINK-19466) Implement JobManagerCheckpointStorage and FileSystemCheckpointStorage

2020-09-29 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19466: Summary: Implement JobManagerCheckpointStorage and FileSystemCheckpointStorage Key: FLINK-19466 URL: https://issues.apache.org/jira/browse/FLINK-19466 Project: Flink

[jira] [Created] (FLINK-19464) Rename CheckpointStorage interface to CheckpointStorageAccess

2020-09-29 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19464: Summary: Rename CheckpointStorage interface to CheckpointStorageAccess Key: FLINK-19464 URL: https://issues.apache.org/jira/browse/FLINK-19464 Project: Flink

[jira] [Created] (FLINK-19465) Add CheckpointStorage interface

2020-09-29 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19465: Summary: Add CheckpointStorage interface Key: FLINK-19465 URL: https://issues.apache.org/jira/browse/FLINK-19465 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19463) Disentangle StateBackends from Checkpointing

2020-09-29 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19463: Summary: Disentangle StateBackends from Checkpointing Key: FLINK-19463 URL: https://issues.apache.org/jira/browse/FLINK-19463 Project: Flink Issue Type:

[jira] [Commented] (FLINK-18810) Golang remote functions SDK

2020-09-24 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201544#comment-17201544 ] Seth Wiesman commented on FLINK-18810: -- Great to hear [~galenwarren], the goal is to eventually

[jira] [Updated] (FLINK-19331) State processor api has native resouce leak when working with RocksDB

2020-09-21 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-19331: - Affects Version/s: 1.11.3 1.12.0 > State processor api has native

[jira] [Updated] (FLINK-19331) State processor api has native resouce leak when working with RocksDB

2020-09-21 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-19331: - Affects Version/s: (was: 1.11.3) > State processor api has native resouce leak when working

[jira] [Created] (FLINK-19331) State processor api has native resouce leak when working with RocksDB

2020-09-21 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19331: Summary: State processor api has native resouce leak when working with RocksDB Key: FLINK-19331 URL: https://issues.apache.org/jira/browse/FLINK-19331 Project: Flink

[jira] [Closed] (FLINK-19224) Provide an easy way to read window state

2020-09-18 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-19224. Resolution: Fixed > Provide an easy way to read window state >

[jira] [Commented] (FLINK-19224) Provide an easy way to read window state

2020-09-18 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17198498#comment-17198498 ] Seth Wiesman commented on FLINK-19224: -- fixed in master: 3a133b1d21c67c15bd21b70cdf0d59898e86ebcc

[jira] [Created] (FLINK-19224) Provide an easy way to read window state

2020-09-14 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19224: Summary: Provide an easy way to read window state Key: FLINK-19224 URL: https://issues.apache.org/jira/browse/FLINK-19224 Project: Flink Issue Type:

[jira] [Updated] (FLINK-19209) Single bucket

2020-09-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-19209: - Priority: Minor (was: Major) > Single bucket > - > > Key:

[jira] [Commented] (FLINK-19209) Single bucket

2020-09-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195732#comment-17195732 ] Seth Wiesman commented on FLINK-19209: -- thanks for catching this! > Single bucket > -

[jira] [Assigned] (FLINK-19209) Single bucket

2020-09-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-19209: Assignee: Seth Wiesman > Single bucket > - > > Key:

[jira] [Closed] (FLINK-18978) Support full table scan of key and namespace from statebackend

2020-09-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-18978. Resolution: Fixed > Support full table scan of key and namespace from statebackend >

[jira] [Commented] (FLINK-18978) Support full table scan of key and namespace from statebackend

2020-09-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195728#comment-17195728 ] Seth Wiesman commented on FLINK-18978: -- fixed in cd81e9bbbd7456e6aedbff31054700cc4da70fa3 >

[jira] [Closed] (FLINK-18735) Enhance DataGen source to support more types

2020-09-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-18735. Resolution: Fixed > Enhance DataGen source to support more types >

[jira] [Commented] (FLINK-18735) Enhance DataGen source to support more types

2020-09-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195653#comment-17195653 ] Seth Wiesman commented on FLINK-18735: -- fixed in master: ef01fec2a632f65556e0b30faad7399120b62e95

[jira] [Commented] (FLINK-19222) Elevate external SDKs

2020-09-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17195645#comment-17195645 ] Seth Wiesman commented on FLINK-19222: -- fixed in 13cbda4a60f7223d17389c05d3e193c541d59cf0 >

[jira] [Closed] (FLINK-19222) Elevate external SDKs

2020-09-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-19222. Resolution: Fixed > Elevate external SDKs > - > > Key:

[jira] [Created] (FLINK-19222) Elevate external SDKs

2020-09-14 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-19222: Summary: Elevate external SDKs Key: FLINK-19222 URL: https://issues.apache.org/jira/browse/FLINK-19222 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-19203) Use Flink-*-scala2.12 variants for StateFun

2020-09-11 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman resolved FLINK-19203. -- Resolution: Fixed > Use Flink-*-scala2.12 variants for StateFun >

[jira] [Commented] (FLINK-19203) Use Flink-*-scala2.12 variants for StateFun

2020-09-11 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17194347#comment-17194347 ] Seth Wiesman commented on FLINK-19203: -- fixed in 038560a3c88718137544dc014528e41112714efd > Use

[jira] [Commented] (FLINK-14942) State Processing API: add an option to make deep copy

2020-09-08 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192368#comment-17192368 ] Seth Wiesman commented on FLINK-14942: -- merged in master: 597f5027c5b0277a80448f988c11f314449d270f

[jira] [Closed] (FLINK-14942) State Processing API: add an option to make deep copy

2020-09-08 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-14942. Resolution: Fixed > State Processing API: add an option to make deep copy >

[jira] [Commented] (FLINK-14942) State Processing API: add an option to make deep copy

2020-09-08 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17192239#comment-17192239 ] Seth Wiesman commented on FLINK-14942: -- I agree, will only merge this into 1.12. > State

[jira] [Commented] (FLINK-15719) Exceptions when using scala types directly with the State Process API

2020-09-02 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189637#comment-17189637 ] Seth Wiesman commented on FLINK-15719: -- fixed in 367dce2898e5f3a828cd30c6b322dcf76cf4dc8a >

[jira] [Closed] (FLINK-18977) Extract WindowOperator construction into a builder class

2020-08-31 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-18977. Resolution: Fixed > Extract WindowOperator construction into a builder class >

[jira] [Commented] (FLINK-18977) Extract WindowOperator construction into a builder class

2020-08-31 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17187920#comment-17187920 ] Seth Wiesman commented on FLINK-18977: -- fixed in master: fe867a6f55e84aad803a12e5df31074a1404a9e8

[jira] [Created] (FLINK-18979) Update statefun docs to better emphasize remote modules

2020-08-17 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18979: Summary: Update statefun docs to better emphasize remote modules Key: FLINK-18979 URL: https://issues.apache.org/jira/browse/FLINK-18979 Project: Flink

[jira] [Updated] (FLINK-18979) Update statefun docs to better emphasize remote modules

2020-08-17 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-18979: - Fix Version/s: statefun-2.2.0 > Update statefun docs to better emphasize remote modules >

[jira] [Created] (FLINK-18978) Support full table scan of key and namespace from statebackend

2020-08-17 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18978: Summary: Support full table scan of key and namespace from statebackend Key: FLINK-18978 URL: https://issues.apache.org/jira/browse/FLINK-18978 Project: Flink

[jira] [Assigned] (FLINK-18977) Extract WindowOperator construction into a builder class

2020-08-17 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-18977: Assignee: Seth Wiesman > Extract WindowOperator construction into a builder class >

[jira] [Created] (FLINK-18977) Extract WindowOperator construction into a builder class

2020-08-17 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18977: Summary: Extract WindowOperator construction into a builder class Key: FLINK-18977 URL: https://issues.apache.org/jira/browse/FLINK-18977 Project: Flink

[jira] [Commented] (FLINK-13095) Provide an easy way to read / bootstrap window state using the State Processor API

2020-08-17 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17179036#comment-17179036 ] Seth Wiesman commented on FLINK-13095: -- This turned out to be more work than expected, I'm going to

[jira] [Commented] (FLINK-18849) Improve the code tabs of the Flink documents

2020-08-14 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177824#comment-17177824 ] Seth Wiesman commented on FLINK-18849: -- release-1.11: 0e2a7cc30a14c6338b4447cedb3383474b0a0d71 >

[jira] [Resolved] (FLINK-18849) Improve the code tabs of the Flink documents

2020-08-13 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman resolved FLINK-18849. -- Resolution: Fixed > Improve the code tabs of the Flink documents >

[jira] [Commented] (FLINK-18849) Improve the code tabs of the Flink documents

2020-08-13 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177016#comment-17177016 ] Seth Wiesman commented on FLINK-18849: -- Fixed in master: 2c527fb9c8645b1da4a893577ad2eae3bbab179e

[jira] [Updated] (FLINK-18908) Ensure max parallelism is at least 128 when bootstrapping savepoints

2020-08-12 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-18908: - Summary: Ensure max parallelism is at least 128 when bootstrapping savepoints (was: Ensure max

[jira] [Created] (FLINK-18908) Ensure max parallelism is at least 128

2020-08-12 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18908: Summary: Ensure max parallelism is at least 128 Key: FLINK-18908 URL: https://issues.apache.org/jira/browse/FLINK-18908 Project: Flink Issue Type:

[jira] [Updated] (FLINK-18894) StateFun job stalls on stop-with-savepoint

2020-08-11 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-18894: - Description: Stateful Function jobs stall when performing a stop with savepoint. The

[jira] [Updated] (FLINK-18894) StateFun job stalls on stop-with-savepoint

2020-08-11 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-18894: - Issue Type: Bug (was: Improvement) > StateFun job stalls on stop-with-savepoint >

[jira] [Updated] (FLINK-18894) StateFun job stalls on stop-with-savepoint

2020-08-11 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-18894: - Environment: (was: {noformat} *no* further _formatting_ is done here {noformat} ) >

[jira] [Created] (FLINK-18894) StateFun job stalls on stop-with-savepoint

2020-08-11 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18894: Summary: StateFun job stalls on stop-with-savepoint Key: FLINK-18894 URL: https://issues.apache.org/jira/browse/FLINK-18894 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-18812) Upgrade StateFun to Flink 1.11.1

2020-08-11 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman resolved FLINK-18812. -- Resolution: Fixed > Upgrade StateFun to Flink 1.11.1 > > >

[jira] [Commented] (FLINK-18812) Upgrade StateFun to Flink 1.11.1

2020-08-11 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175793#comment-17175793 ] Seth Wiesman commented on FLINK-18812: -- fixed in master: 56ef7e5bec2c20e11c518d406a0b4c2290c50c64

[jira] [Commented] (FLINK-14942) State Processing API: add an option to make deep copy

2020-08-11 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175636#comment-17175636 ] Seth Wiesman commented on FLINK-14942: -- It's not a question of enabling it, the feature hasn't been

[jira] [Commented] (FLINK-18810) Golang remote functions SDK

2020-08-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170974#comment-17170974 ] Seth Wiesman commented on FLINK-18810: -- [~slinkydeveloper] I've pushed the code here. I'll try to

[jira] [Commented] (FLINK-18810) Golang remote functions SDK

2020-08-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170861#comment-17170861 ] Seth Wiesman commented on FLINK-18810: -- Hi [~slinkydeveloper], I have a very rough golang sdk

[jira] [Created] (FLINK-18812) Upgrade StateFun to Flink 1.11.1

2020-08-04 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18812: Summary: Upgrade StateFun to Flink 1.11.1 Key: FLINK-18812 URL: https://issues.apache.org/jira/browse/FLINK-18812 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-18735) Enhance DataGen source to support more types

2020-07-27 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-18735: - Description: DataGen connector is should support most types natively so it can be used in

[jira] [Created] (FLINK-18735) Enhance DataGen source to support more types

2020-07-27 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18735: Summary: Enhance DataGen source to support more types Key: FLINK-18735 URL: https://issues.apache.org/jira/browse/FLINK-18735 Project: Flink Issue Type:

[jira] [Closed] (FLINK-18341) Building Flink Walkthrough Table Java 0.1 COMPILATION ERROR

2020-07-24 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-18341. Resolution: Fixed > Building Flink Walkthrough Table Java 0.1 COMPILATION ERROR >

[jira] [Updated] (FLINK-18341) Building Flink Walkthrough Table Java 0.1 COMPILATION ERROR

2020-07-24 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-18341: - Fix Version/s: 1.12.0 > Building Flink Walkthrough Table Java 0.1 COMPILATION ERROR >

[jira] [Commented] (FLINK-18341) Building Flink Walkthrough Table Java 0.1 COMPILATION ERROR

2020-07-24 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164552#comment-17164552 ] Seth Wiesman commented on FLINK-18341: -- Fixed in master: d88f9b1f9577291b32b472387f6981059522d9e2

[jira] [Commented] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger

2020-07-24 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164456#comment-17164456 ] Seth Wiesman commented on FLINK-18478: -- [~georg.kf.hei...@gmail.com] I'm not sure you will find a

[jira] [Comment Edited] (FLINK-18478) AvroDeserializationSchema does not work with types generated by avrohugger

2020-07-24 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164456#comment-17164456 ] Seth Wiesman edited comment on FLINK-18478 at 7/24/20, 1:50 PM:

[jira] [Commented] (FLINK-16048) Support read/write confluent schema registry avro data from Kafka

2020-07-23 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164003#comment-17164003 ] Seth Wiesman commented on FLINK-16048: -- I honestly don’t have a strong preference here. I

[jira] [Commented] (FLINK-18341) Building Flink Walkthrough Table Java 0.1 COMPILATION ERROR

2020-07-23 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163778#comment-17163778 ] Seth Wiesman commented on FLINK-18341: -- It was slightly more than just a cherry pick so I have

[jira] [Commented] (FLINK-18341) Building Flink Walkthrough Table Java 0.1 COMPILATION ERROR

2020-07-23 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163710#comment-17163710 ] Seth Wiesman commented on FLINK-18341: -- HI [~dian.fu] You are absolutly correct. I will do that

[jira] [Commented] (FLINK-18627) Get unmatch filter method records to side output

2020-07-20 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161366#comment-17161366 ] Seth Wiesman commented on FLINK-18627: -- Hi [~roeyshemtov], Thank you for opening this ticket. Can

[jira] [Commented] (FLINK-18619) Update training to use WatermarkStrategy

2020-07-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159321#comment-17159321 ] Seth Wiesman commented on FLINK-18619: -- master: d34d36c235c20bf6c648a3af961919dd29fd7332

[jira] [Closed] (FLINK-18619) Update training to use WatermarkStrategy

2020-07-16 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-18619. Resolution: Fixed > Update training to use WatermarkStrategy >

[jira] [Created] (FLINK-18619) Update training to use WatermarkStrategy

2020-07-16 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18619: Summary: Update training to use WatermarkStrategy Key: FLINK-18619 URL: https://issues.apache.org/jira/browse/FLINK-18619 Project: Flink Issue Type:

[jira] [Created] (FLINK-18610) Clean up Table connector docs grammar

2020-07-15 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-18610: Summary: Clean up Table connector docs grammar Key: FLINK-18610 URL: https://issues.apache.org/jira/browse/FLINK-18610 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-18606) Remove generic parameter from SinkFunction.Context

2020-07-15 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-18606: Assignee: Niels Basjes > Remove generic parameter from SinkFunction.Context >

[jira] [Commented] (FLINK-18532) Remove Beta tag from MATCH_RECOGNIZE docs

2020-07-13 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17156833#comment-17156833 ] Seth Wiesman commented on FLINK-18532: -- Fixed in master: ae3c79033a682c9fd090052bfc3ba76adadfb94c

[jira] [Resolved] (FLINK-18532) Remove Beta tag from MATCH_RECOGNIZE docs

2020-07-13 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman resolved FLINK-18532. -- Fix Version/s: 1.11.1 1.12.0 Resolution: Fixed > Remove Beta tag

[jira] [Commented] (FLINK-18482) Replace flink-training datasets with data generators

2020-07-12 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17156375#comment-17156375 ] Seth Wiesman commented on FLINK-18482: -- fixed in master: 4f95a443cca0d13fc41ca9bc819cd8aacb6c8372

[jira] [Closed] (FLINK-18482) Replace flink-training datasets with data generators

2020-07-12 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-18482. Resolution: Fixed > Replace flink-training datasets with data generators >

[jira] [Closed] (FLINK-18499) Update Flink Exercises to 1.11

2020-07-09 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-18499. Resolution: Fixed > Update Flink Exercises to 1.11 > -- > >

<    1   2   3   4   5   6   7   8   >