[jira] [Comment Edited] (FLINK-13517) Restructure Hive Catalog documentation

[ https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16901353#comment-16901353 ] Seth Wiesman edited comment on FLINK-13517 at 8/6/19 6:36 PM: --

[jira] [Commented] (FLINK-13517) Restructure Hive Catalog documentation

[ https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16901353#comment-16901353 ] Seth Wiesman commented on FLINK-13517: -- [~phoenixjiangnan] I definitely understand the concern.

[jira] [Comment Edited] (FLINK-13517) Restructure Hive Catalog documentation

[ https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16900431#comment-16900431 ] Seth Wiesman edited comment on FLINK-13517 at 8/5/19 9:59 PM: -- Copying

[jira] [Commented] (FLINK-13517) Restructure Hive Catalog documentation

[ https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16900431#comment-16900431 ] Seth Wiesman commented on FLINK-13517: -- Copying [~phoenixjiangnan] 's comment from github  

[jira] [Commented] (FLINK-13558) Include table examples in flink-dist

[ https://issues.apache.org/jira/browse/FLINK-13558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16900343#comment-16900343 ] Seth Wiesman commented on FLINK-13558: -- Sounds good, thanks for the clarification. > Include table

[jira] [Commented] (FLINK-13558) Include table examples in flink-dist

[ https://issues.apache.org/jira/browse/FLINK-13558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898974#comment-16898974 ] Seth Wiesman commented on FLINK-13558: -- [~dawidwys] are these just code examples in

[jira] [Created] (FLINK-13541) State Processor Api sets the wrong key selector when writing savepoints

Seth Wiesman created FLINK-13541: Summary: State Processor Api sets the wrong key selector when writing savepoints Key: FLINK-13541 URL: https://issues.apache.org/jira/browse/FLINK-13541 Project:

[jira] [Created] (FLINK-13517) Restructure Hive Catalog documentation

Seth Wiesman created FLINK-13517: Summary: Restructure Hive Catalog documentation Key: FLINK-13517 URL: https://issues.apache.org/jira/browse/FLINK-13517 Project: Flink Issue Type:

[jira] [Commented] (FLINK-13415) Document how to use hive connector in scala shell

[ https://issues.apache.org/jira/browse/FLINK-13415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896175#comment-16896175 ] Seth Wiesman commented on FLINK-13415: -- I think that is more approriate, document how to use

[jira] [Commented] (FLINK-13179) Add document on how to run examples.

[ https://issues.apache.org/jira/browse/FLINK-13179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895442#comment-16895442 ] Seth Wiesman commented on FLINK-13179: -- FLINK-12746 is different than the ask of this ticket. It is

[jira] [Commented] (FLINK-13415) Document how to use hive connector in scala shell

[ https://issues.apache.org/jira/browse/FLINK-13415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895386#comment-16895386 ] Seth Wiesman commented on FLINK-13415: -- Hi [~zjffdu] It's not clear to me that this change makes

[jira] [Commented] (FLINK-12746) Getting Started - Project Setup and DataStream Example Walkthrough

[ https://issues.apache.org/jira/browse/FLINK-12746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890472#comment-16890472 ] Seth Wiesman commented on FLINK-12746: -- I'm moving the restructuring into a different ticket:

[jira] [Updated] (FLINK-12746) Getting Started - DataStream Example Walkthrough

[ https://issues.apache.org/jira/browse/FLINK-12746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-12746: - Summary: Getting Started - DataStream Example Walkthrough (was: Getting Started - Project

[jira] [Updated] (FLINK-13373) Restructure Getting Started Documentation

[ https://issues.apache.org/jira/browse/FLINK-13373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-13373: - Description: The planned structure for the new Getting Started Guide is Flink Overview (~

[jira] [Updated] (FLINK-13373) Restructure Getting Started Documentation

[ https://issues.apache.org/jira/browse/FLINK-13373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-13373: - Description: The planned structure for the new Getting Started Guide is * Flink Overview (~

[jira] [Updated] (FLINK-13373) Restructure Getting Started Documentation

[ https://issues.apache.org/jira/browse/FLINK-13373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-13373: - Summary: Restructure Getting Started Documentation (was: DataStream API Walkthrough) >

[jira] [Created] (FLINK-13373) DataStream API Walkthrough

Seth Wiesman created FLINK-13373: Summary: DataStream API Walkthrough Key: FLINK-13373 URL: https://issues.apache.org/jira/browse/FLINK-13373 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13293) Add state processor api to opt/ directory in flink-dist

Seth Wiesman created FLINK-13293: Summary: Add state processor api to opt/ directory in flink-dist Key: FLINK-13293 URL: https://issues.apache.org/jira/browse/FLINK-13293 Project: Flink

[jira] [Commented] (FLINK-13251) Add bandwidth throttling for checkpoint uploading/downloading

[ https://issues.apache.org/jira/browse/FLINK-13251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885265#comment-16885265 ] Seth Wiesman commented on FLINK-13251: -- Not identical to what this ticket is describing but there

[jira] [Updated] (FLINK-13094) Provide an easy way to read timers using the State Processor API

[ https://issues.apache.org/jira/browse/FLINK-13094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-13094: - Summary: Provide an easy way to read timers using the State Processor API (was: Provide an

[jira] [Commented] (FLINK-12749) Getting Started - Docker Playgrounds - Flink Cluster Playground

[ https://issues.apache.org/jira/browse/FLINK-12749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882446#comment-16882446 ] Seth Wiesman commented on FLINK-12749: -- +1 for option 2. It will be the best user experience. >

[jira] [Created] (FLINK-13064) Add Python Table API to Table Api Walkthrough

Seth Wiesman created FLINK-13064: Summary: Add Python Table API to Table Api Walkthrough Key: FLINK-13064 URL: https://issues.apache.org/jira/browse/FLINK-13064 Project: Flink Issue Type:

[jira] [Created] (FLINK-12963) Add savepoint writer for bootstrapping new savepoints

Seth Wiesman created FLINK-12963: Summary: Add savepoint writer for bootstrapping new savepoints Key: FLINK-12963 URL: https://issues.apache.org/jira/browse/FLINK-12963 Project: Flink Issue

[jira] [Created] (FLINK-12928) Remove old Flink ML docs

Seth Wiesman created FLINK-12928: Summary: Remove old Flink ML docs Key: FLINK-12928 URL: https://issues.apache.org/jira/browse/FLINK-12928 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-12747) Getting Started - Table API Example Walkthrough

[ https://issues.apache.org/jira/browse/FLINK-12747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-12747: Assignee: Seth Wiesman > Getting Started - Table API Example Walkthrough >

[jira] [Assigned] (FLINK-12746) Getting Started - Project Setup and DataStream Example Walkthrough

[ https://issues.apache.org/jira/browse/FLINK-12746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-12746: Assignee: Seth Wiesman > Getting Started - Project Setup and DataStream Example

[jira] [Commented] (FLINK-12650) Redirect Users to Documentation Homepage if Requested Resource Does Not Exist

[ https://issues.apache.org/jira/browse/FLINK-12650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856796#comment-16856796 ] Seth Wiesman commented on FLINK-12650: -- [~Zentol] Even though we now issue a redirect the header

[jira] [Created] (FLINK-12732) Add savepoint reader for consuming partitioned operator state

Seth Wiesman created FLINK-12732: Summary: Add savepoint reader for consuming partitioned operator state Key: FLINK-12732 URL: https://issues.apache.org/jira/browse/FLINK-12732 Project: Flink

[jira] [Created] (FLINK-12729) Add savepoint reader for consuming non-partitioned operator state

Seth Wiesman created FLINK-12729: Summary: Add savepoint reader for consuming non-partitioned operator state Key: FLINK-12729 URL: https://issues.apache.org/jira/browse/FLINK-12729 Project: Flink

[jira] [Commented] (FLINK-12650) Redirect Users to Documentation Homepage if Requested Resource Does Not Exist

[ https://issues.apache.org/jira/browse/FLINK-12650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16849781#comment-16849781 ] Seth Wiesman commented on FLINK-12650: -- Relevant documentation:

[jira] [Assigned] (FLINK-12650) Redirect Users to Documentation Homepage if Requested Resource Does Not Exist

[ https://issues.apache.org/jira/browse/FLINK-12650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-12650: Assignee: Seth Wiesman > Redirect Users to Documentation Homepage if Requested Resource

[jira] [Created] (FLINK-12560) Documentation language build flags

Seth Wiesman created FLINK-12560: Summary: Documentation language build flags Key: FLINK-12560 URL: https://issues.apache.org/jira/browse/FLINK-12560 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-12537) Improve Documentation Build Time

[ https://issues.apache.org/jira/browse/FLINK-12537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842151#comment-16842151 ] Seth Wiesman commented on FLINK-12537: -- [~alpinegizmo] Yes > Improve Documentation Build Time >

[jira] [Commented] (FLINK-12537) Improve Documentation Build Time

[ https://issues.apache.org/jira/browse/FLINK-12537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841495#comment-16841495 ] Seth Wiesman commented on FLINK-12537: -- [~jark] I profiled the build and 99% of the time is spent

[jira] [Created] (FLINK-12537) Improve Documentation Build Time

Seth Wiesman created FLINK-12537: Summary: Improve Documentation Build Time Key: FLINK-12537 URL: https://issues.apache.org/jira/browse/FLINK-12537 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-12388) Update the production readiness checklist

[ https://issues.apache.org/jira/browse/FLINK-12388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-12388: - Summary: Update the production readiness checklist (was: Update the production readyness

[jira] [Created] (FLINK-12388) Update the production readyness checklist

Seth Wiesman created FLINK-12388: Summary: Update the production readyness checklist Key: FLINK-12388 URL: https://issues.apache.org/jira/browse/FLINK-12388 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8513) Add documentation for connecting to non-AWS S3 endpoints

[ https://issues.apache.org/jira/browse/FLINK-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830731#comment-16830731 ] Seth Wiesman commented on FLINK-8513: - Included as part of

[jira] [Created] (FLINK-12378) Consolidate FileSystem Documentation

Seth Wiesman created FLINK-12378: Summary: Consolidate FileSystem Documentation Key: FLINK-12378 URL: https://issues.apache.org/jira/browse/FLINK-12378 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-8513) Add documentation for connecting to non-AWS S3 endpoints

[ https://issues.apache.org/jira/browse/FLINK-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-8513: --- Assignee: Seth Wiesman > Add documentation for connecting to non-AWS S3 endpoints >

[jira] [Assigned] (FLINK-10249) Document hadoop/presto s3 file system configuration forwarding

[ https://issues.apache.org/jira/browse/FLINK-10249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-10249: Assignee: Seth Wiesman > Document hadoop/presto s3 file system configuration forwarding

[jira] [Commented] (FLINK-10900) Mark Kafka 2.0 connector as beta feature

[ https://issues.apache.org/jira/browse/FLINK-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829381#comment-16829381 ] Seth Wiesman commented on FLINK-10900: -- [~till.rohrmann] Is the universal Kafka connector still

[jira] [Comment Edited] (FLINK-10967) Update kafka dependency to 2.1.0

[ https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773486#comment-16773486 ] Seth Wiesman edited comment on FLINK-10967 at 2/20/19 11:16 PM:

[jira] [Commented] (FLINK-10967) Update kafka dependency to 2.1.0

[ https://issues.apache.org/jira/browse/FLINK-10967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16773486#comment-16773486 ] Seth Wiesman commented on FLINK-10967: -- [~aljoscha] There is a bug in the kafka client version

[jira] [Updated] (FLINK-11653) Add configuration to enforce custom UID's on datastream

[ https://issues.apache.org/jira/browse/FLINK-11653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-11653: - Component/s: (was: Job-Submission) DataStream API > Add configuration to

[jira] [Updated] (FLINK-11653) Add configuration to enforce custom UID's on datastream

[ https://issues.apache.org/jira/browse/FLINK-11653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-11653: - Component/s: (was: DataStream API) Job-Submission > Add configuration to

[jira] [Created] (FLINK-11653) Add configuration to enforce custom UID's on datastream

Seth Wiesman created FLINK-11653: Summary: Add configuration to enforce custom UID's on datastream Key: FLINK-11653 URL: https://issues.apache.org/jira/browse/FLINK-11653 Project: Flink

[jira] [Updated] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policy's

[ https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-11499: - Component/s: Streaming Connectors filesystem-connector > Extend

[jira] [Created] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policy's

Seth Wiesman created FLINK-11499: Summary: Extend StreamingFileSink BulkFormats to support arbitrary roll policy's Key: FLINK-11499 URL: https://issues.apache.org/jira/browse/FLINK-11499 Project:

[jira] [Updated] (FLINK-10964) sql-client throws exception when paging through finished batch query

[ https://issues.apache.org/jira/browse/FLINK-10964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-10964: - Summary: sql-client throws exception when paging through finished batch query (was:

[jira] [Updated] (FLINK-10964) sql-client throws exception when pagin through finished batch query

[ https://issues.apache.org/jira/browse/FLINK-10964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-10964: - Description: When paging through a batch query in state 'Finished' the sql client throws the

[jira] [Created] (FLINK-10964) sql-client throws exception when pagin through finished batch query

Seth Wiesman created FLINK-10964: Summary: sql-client throws exception when pagin through finished batch query Key: FLINK-10964 URL: https://issues.apache.org/jira/browse/FLINK-10964 Project: Flink

[jira] [Comment Edited] (FLINK-10423) Forward RocksDB native metrics to Flink metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629155#comment-16629155 ] Seth Wiesman edited comment on FLINK-10423 at 10/9/18 7:34 PM: --- -I have a

[jira] [Updated] (FLINK-10423) Forward RocksDB native metrics to Flink metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-10423: - Summary: Forward RocksDB native metrics to Flink metrics reporter (was: Forward RocksDB

[jira] [Commented] (FLINK-10423) Forward RocksDB memory metrics to Flink metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629155#comment-16629155 ] Seth Wiesman commented on FLINK-10423: -- [~srichter] I have a question about the best way to handle

[jira] [Created] (FLINK-10423) Forward RocksDB memory metrics to Flink metrics reporter

Seth Wiesman created FLINK-10423: Summary: Forward RocksDB memory metrics to Flink metrics reporter Key: FLINK-10423 URL: https://issues.apache.org/jira/browse/FLINK-10423 Project: Flink

[jira] [Closed] (FLINK-6306) Sink for eventually consistent file systems

[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-6306. --- Resolution: Won't Do Instead of having multiple filesystem sink, improvements will be made to the

[jira] [Commented] (FLINK-3655) Allow comma-separated or multiple directories to be specified for FileInputFormat

[ https://issues.apache.org/jira/browse/FLINK-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16305745#comment-16305745 ] Seth Wiesman commented on FLINK-3655: - [~fhueske] I have been looking for this feature, is there

[jira] [Comment Edited] (FLINK-7999) Variable Join Window Boundaries

[ https://issues.apache.org/jira/browse/FLINK-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247674#comment-16247674 ] Seth Wiesman edited comment on FLINK-7999 at 11/10/17 3:47 PM: --- Sure, I will

[jira] [Commented] (FLINK-7999) Variable Join Window Boundaries

[ https://issues.apache.org/jira/browse/FLINK-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247674#comment-16247674 ] Seth Wiesman commented on FLINK-7999: - Sure, I will use the example of my use case. I am using Flink

[jira] [Created] (FLINK-7999) Variable Join Window Boundaries

Seth Wiesman created FLINK-7999: --- Summary: Variable Join Window Boundaries Key: FLINK-7999 URL: https://issues.apache.org/jira/browse/FLINK-7999 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-6315) Notify on checkpoint timeout

[ https://issues.apache.org/jira/browse/FLINK-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-6315. --- Resolution: Won't Do > Notify on checkpoint timeout > - > >

[jira] [Commented] (FLINK-6315) Notify on checkpoint timeout

[ https://issues.apache.org/jira/browse/FLINK-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15976688#comment-15976688 ] Seth Wiesman commented on FLINK-6315: - Thank you for talking this through with me, I'm going to close

[jira] [Commented] (FLINK-6315) Notify on checkpoint timeout

[ https://issues.apache.org/jira/browse/FLINK-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15975434#comment-15975434 ] Seth Wiesman commented on FLINK-6315: - [~StephanEwen] So I guess this is the crux of the real issue,

[jira] [Comment Edited] (FLINK-6315) Notify on checkpoint timeout

[ https://issues.apache.org/jira/browse/FLINK-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974984#comment-15974984 ] Seth Wiesman edited comment on FLINK-6315 at 4/19/17 4:20 PM: -- [~StephanEwen]

[jira] [Commented] (FLINK-6315) Notify on checkpoint timeout

[ https://issues.apache.org/jira/browse/FLINK-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974984#comment-15974984 ] Seth Wiesman commented on FLINK-6315: - [~StephanEwen] Regarding the first two points, that makes a

[jira] [Commented] (FLINK-6315) Notify on checkpoint timeout

[ https://issues.apache.org/jira/browse/FLINK-6315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15974811#comment-15974811 ] Seth Wiesman commented on FLINK-6315: - [~aljoscha] Apologies, didn't see this comment. Might have

[jira] [Comment Edited] (FLINK-6306) Sink for eventually consistent file systems

[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15971397#comment-15971397 ] Seth Wiesman edited comment on FLINK-6306 at 4/18/17 3:16 PM: -- The idea is

[jira] [Commented] (FLINK-6306) Sink for eventually consistent file systems

[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15971397#comment-15971397 ] Seth Wiesman commented on FLINK-6306: - The idea is that data is buffered on local disk until

[jira] [Updated] (FLINK-6306) Sink for eventually consistent file systems

[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-6306: Attachment: eventually-consistent-sink > Sink for eventually consistent file systems >

[jira] [Created] (FLINK-6315) Notify on checkpoint timeout

Seth Wiesman created FLINK-6315: --- Summary: Notify on checkpoint timeout Key: FLINK-6315 URL: https://issues.apache.org/jira/browse/FLINK-6315 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-6306) Sink for eventually consistent file systems

[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-6306: Description: Currently Flink provides the BucketingSink as an exactly once method for writing out

[jira] [Updated] (FLINK-6306) Sink for eventually consistent file systems

[ https://issues.apache.org/jira/browse/FLINK-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-6306: Description: Currently Flink provides the BucketingSink as an exactly once method for writing out

[jira] [Created] (FLINK-6306) Sink for eventually consistent file systems

Seth Wiesman created FLINK-6306: --- Summary: Sink for eventually consistent file systems Key: FLINK-6306 URL: https://issues.apache.org/jira/browse/FLINK-6306 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15892398#comment-15892398 ] Seth Wiesman commented on FLINK-5929: - [~aljoscha] I have a version of this that I feel pretty good,

[jira] [Comment Edited] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15892362#comment-15892362 ] Seth Wiesman edited comment on FLINK-5929 at 3/2/17 3:00 PM: - [~aljoscha] That

[jira] [Commented] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15892362#comment-15892362 ] Seth Wiesman commented on FLINK-5929: - [~aljoscha] That seems like a reasonable first step. For now

[jira] [Commented] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15888357#comment-15888357 ] Seth Wiesman commented on FLINK-5929: - [~aljoscha] Curioius, why is ProcessWindowFunction wrapped in a

[jira] [Closed] (FLINK-5930) Allow Access to Job Id from Runtime Context

[ https://issues.apache.org/jira/browse/FLINK-5930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-5930. --- Resolution: Duplicate > Allow Access to Job Id from Runtime Context >

[jira] [Commented] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886446#comment-15886446 ] Seth Wiesman commented on FLINK-5929: - [~aljoscha] Yes this does look like what we were discussing.

[jira] [Commented] (FLINK-5929) Allow Access to Per-Window State in ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-5929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886450#comment-15886450 ] Seth Wiesman commented on FLINK-5929: - [~rehevkor5] Yes, state for individual window panes. > Allow

[jira] [Commented] (FLINK-5706) Implement Flink's own S3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15886417#comment-15886417 ] Seth Wiesman commented on FLINK-5706: - [~StephanEwen] To expand on our conversation from the mailing

[jira] [Updated] (FLINK-5930) Allow Access to Job Id from Runtime Context

[ https://issues.apache.org/jira/browse/FLINK-5930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-5930: Affects Version/s: (was: 1.2.1) (was: 1.3.0) > Allow Access to Job

[jira] [Created] (FLINK-5930) Allow Access to Job Id from Runtime Context

Seth Wiesman created FLINK-5930: --- Summary: Allow Access to Job Id from Runtime Context Key: FLINK-5930 URL: https://issues.apache.org/jira/browse/FLINK-5930 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15687124#comment-15687124 ] Seth Wiesman commented on FLINK-3869: - [~aljoscha] Yes, this is more or less what I did. Very excited

[jira] [Commented] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15671614#comment-15671614 ] Seth Wiesman commented on FLINK-3869: - [~aljoscha] [~ymarzougui] This is an issue I have been

[jira] [Comment Edited] (FLINK-3869) WindowedStream.apply with FoldFunction is too restrictive

[ https://issues.apache.org/jira/browse/FLINK-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15671614#comment-15671614 ] Seth Wiesman edited comment on FLINK-3869 at 11/16/16 9:05 PM: --- [~aljoscha]

<    3   4   5   6   7   8