[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068281#comment-17068281 ] Sivaprasanna Sethuraman commented on FLINK-10114: - [~kkl0u] [~gaoyunhaii

[jira] [Commented] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policies

[ https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17069306#comment-17069306 ] Sivaprasanna Sethuraman commented on FLINK-11499: - [~pnowojski] Regardi

[jira] [Commented] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policies

[ https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073381#comment-17073381 ] Sivaprasanna Sethuraman commented on FLINK-11499: - [~pnowojski] That cla

[jira] [Commented] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policies

[ https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17075847#comment-17075847 ] Sivaprasanna Sethuraman commented on FLINK-11499: - [~pnowojski] Yes, tha

[jira] [Commented] (FLINK-16968) Convert StatsD reporter to plugin

[ https://issues.apache.org/jira/browse/FLINK-16968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083144#comment-17083144 ] Sivaprasanna Sethuraman commented on FLINK-16968: - [~chesnay] Can you a

[jira] [Commented] (FLINK-17042) Jackson version conflict for Flink 1.9

[ https://issues.apache.org/jira/browse/FLINK-17042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083162#comment-17083162 ] Sivaprasanna Sethuraman commented on FLINK-17042: - If the conflict is co

[jira] [Created] (FLINK-17142) Bump ORC version

Sivaprasanna Sethuraman created FLINK-17142: --- Summary: Bump ORC version Key: FLINK-17142 URL: https://issues.apache.org/jira/browse/FLINK-17142 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-17221) Flink on YARN fails with NoClassDefFoundError: com/sun/jersey/core/util/FeaturesAndProperties

Sivaprasanna Sethuraman created FLINK-17221: --- Summary: Flink on YARN fails with NoClassDefFoundError: com/sun/jersey/core/util/FeaturesAndProperties Key: FLINK-17221 URL: https://issues.apache.org/jira/b

[jira] [Commented] (FLINK-17221) Flink on YARN fails with NoClassDefFoundError: com/sun/jersey/core/util/FeaturesAndProperties

[ https://issues.apache.org/jira/browse/FLINK-17221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085761#comment-17085761 ] Sivaprasanna Sethuraman commented on FLINK-17221: - Oopsie. Dint realise

[jira] [Comment Edited] (FLINK-16499) Flink shaded hadoop could not work when Yarn timeline service is enabled

[ https://issues.apache.org/jira/browse/FLINK-16499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085768#comment-17085768 ] Sivaprasanna Sethuraman edited comment on FLINK-16499 at 4/17/20, 1:48 PM: ---

[jira] [Commented] (FLINK-16499) Flink shaded hadoop could not work when Yarn timeline service is enabled

[ https://issues.apache.org/jira/browse/FLINK-16499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085768#comment-17085768 ] Sivaprasanna Sethuraman commented on FLINK-16499: - [~fly_in_gis] [~sewen

[jira] [Created] (FLINK-16371) HadoopCompressionBulkWriter fails with 'java.io.NotSerializableException'

Sivaprasanna Sethuraman created FLINK-16371: --- Summary: HadoopCompressionBulkWriter fails with 'java.io.NotSerializableException' Key: FLINK-16371 URL: https://issues.apache.org/jira/browse/FLINK-16371

[jira] [Commented] (FLINK-16371) HadoopCompressionBulkWriter fails with 'java.io.NotSerializableException'

[ https://issues.apache.org/jira/browse/FLINK-16371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17049004#comment-17049004 ] Sivaprasanna Sethuraman commented on FLINK-16371: - Can someone please gr

[jira] [Comment Edited] (FLINK-16371) HadoopCompressionBulkWriter fails with 'java.io.NotSerializableException'

[ https://issues.apache.org/jira/browse/FLINK-16371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17049004#comment-17049004 ] Sivaprasanna Sethuraman edited comment on FLINK-16371 at 3/2/20 10:22 AM:

[jira] [Updated] (FLINK-16371) HadoopCompressionBulkWriter fails with 'java.io.NotSerializableException'

[ https://issues.apache.org/jira/browse/FLINK-16371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sivaprasanna Sethuraman updated FLINK-16371: Description: When using CompressWriterFactory with Hadoop compression code

[jira] [Issue Comment Deleted] (FLINK-16371) HadoopCompressionBulkWriter fails with 'java.io.NotSerializableException'

[ https://issues.apache.org/jira/browse/FLINK-16371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sivaprasanna Sethuraman updated FLINK-16371: Comment: was deleted (was: Can someone please grant me access to Flink's J

[jira] [Commented] (FLINK-16447) Non serializable field on CompressWriterFactory

[ https://issues.apache.org/jira/browse/FLINK-16447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17053067#comment-17053067 ] Sivaprasanna Sethuraman commented on FLINK-16447: - Hi [~eskabetxe] I do

[jira] [Commented] (FLINK-17438) Flink StreamingFileSink chinese garbled

[ https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094434#comment-17094434 ] Sivaprasanna Sethuraman commented on FLINK-17438: - I think this is an en

[jira] [Commented] (FLINK-17325) Integrate orc to file system connector

[ https://issues.apache.org/jira/browse/FLINK-17325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095060#comment-17095060 ] Sivaprasanna Sethuraman commented on FLINK-17325: - [~lzljs3620320] If y

[jira] [Commented] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095071#comment-17095071 ] Sivaprasanna Sethuraman commented on FLINK-17444: - Yes, exclusion of the

[jira] [Comment Edited] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095071#comment-17095071 ] Sivaprasanna Sethuraman edited comment on FLINK-17444 at 4/29/20, 5:08 AM: ---

[jira] [Commented] (FLINK-17438) Flink StreamingFileSink chinese garbled

[ https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095076#comment-17095076 ] Sivaprasanna Sethuraman commented on FLINK-17438: - [~why198852] I agree

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095078#comment-17095078 ] Sivaprasanna Sethuraman commented on FLINK-10114: - Thank you so much, [~

[jira] [Commented] (FLINK-17438) Flink StreamingFileSink chinese garbled

[ https://issues.apache.org/jira/browse/FLINK-17438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097163#comment-17097163 ] Sivaprasanna Sethuraman commented on FLINK-17438: - If the StringExtracto

[jira] [Commented] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17103632#comment-17103632 ] Sivaprasanna Sethuraman commented on FLINK-17444: - [~trohrm...@apache.or

[jira] [Commented] (FLINK-17486) ClassCastException when checkpointing AVRO SpecificRecord with decimal fields

[ https://issues.apache.org/jira/browse/FLINK-17486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17103754#comment-17103754 ] Sivaprasanna Sethuraman commented on FLINK-17486: - This seems to be beca

[jira] [Updated] (FLINK-17486) ClassCastException when checkpointing AVRO SpecificRecord with decimal fields

[ https://issues.apache.org/jira/browse/FLINK-17486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sivaprasanna Sethuraman updated FLINK-17486: Attachment: 0001-FLINK-17486-Fix-ClassCastException-for-decimal-field.patch

[jira] [Commented] (FLINK-16491) Add compression support for ParquetAvroWriters

[ https://issues.apache.org/jira/browse/FLINK-16491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17054779#comment-17054779 ] Sivaprasanna Sethuraman commented on FLINK-16491: - Was wondering whether

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055609#comment-17055609 ] Sivaprasanna Sethuraman commented on FLINK-10114: - [~gaoyunhaii] I beli

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059378#comment-17059378 ] Sivaprasanna Sethuraman commented on FLINK-10114: - [~kkl0u] [~yanghua]

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060796#comment-17060796 ] Sivaprasanna Sethuraman commented on FLINK-10114: - Hi [~gaoyunhaii] and

[jira] [Comment Edited] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060796#comment-17060796 ] Sivaprasanna Sethuraman edited comment on FLINK-10114 at 3/17/20, 10:18 AM: --

[jira] [Comment Edited] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060796#comment-17060796 ] Sivaprasanna Sethuraman edited comment on FLINK-10114 at 3/17/20, 10:19 AM: --

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060802#comment-17060802 ] Sivaprasanna Sethuraman commented on FLINK-10114: - If needed, along with

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17062344#comment-17062344 ] Sivaprasanna Sethuraman commented on FLINK-10114: - Thanks [~kkl0u] I'll

[jira] [Comment Edited] (FLINK-18013) Refactor Hadoop Utility classes/functions into a common Maven module

[ https://issues.apache.org/jira/browse/FLINK-18013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151619#comment-17151619 ] Sivaprasanna Sethuraman edited comment on FLINK-18013 at 7/5/20, 4:47 PM:

[jira] [Commented] (FLINK-18013) Refactor Hadoop Utility classes/functions into a common Maven module

[ https://issues.apache.org/jira/browse/FLINK-18013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151619#comment-17151619 ] Sivaprasanna Sethuraman commented on FLINK-18013: - [~rmetzger] Hi, sorry

[jira] [Commented] (FLINK-17968) Hadoop Configuration is not properly serialized in HBaseRowInputFormat

[ https://issues.apache.org/jira/browse/FLINK-17968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117954#comment-17117954 ] Sivaprasanna Sethuraman commented on FLINK-17968: - [~rmetzger] I have c

[jira] [Created] (FLINK-18013) Refactor Hadoop Utility classes/functions into a common Maven module

Sivaprasanna Sethuraman created FLINK-18013: --- Summary: Refactor Hadoop Utility classes/functions into a common Maven module Key: FLINK-18013 URL: https://issues.apache.org/jira/browse/FLINK-18013

[jira] [Commented] (FLINK-18013) Refactor Hadoop Utility classes/functions into a common Maven module

[ https://issues.apache.org/jira/browse/FLINK-18013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118781#comment-17118781 ] Sivaprasanna Sethuraman commented on FLINK-18013: - [~rmetzger] FYI. >

[jira] [Comment Edited] (FLINK-18013) Refactor Hadoop Utility classes/functions into a common Maven module

[ https://issues.apache.org/jira/browse/FLINK-18013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118781#comment-17118781 ] Sivaprasanna Sethuraman edited comment on FLINK-18013 at 5/28/20, 3:00 PM: ---

[jira] [Commented] (FLINK-18013) Refactor Hadoop Utility classes/functions into a common Maven module

[ https://issues.apache.org/jira/browse/FLINK-18013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17129541#comment-17129541 ] Sivaprasanna Sethuraman commented on FLINK-18013: - [~rmetzger] I am sor