[jira] [Assigned] (FLINK-19135) (Stream)ExecutionEnvironment.execute() should not throw ExecutionException

[ https://issues.apache.org/jira/browse/FLINK-19135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19135: Assignee: Aljoscha Krettek > (Stream)ExecutionEnvironment.execute() should not

[jira] [Assigned] (FLINK-19123) TestStreamEnvironment does not use shared MiniCluster for executeAsync()

[ https://issues.apache.org/jira/browse/FLINK-19123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-19123: Assignee: Aljoscha Krettek > TestStreamEnvironment does not use shared

[jira] [Commented] (FLINK-19124) Some JobClient methods are not ergonomic, require ClassLoader argument

[ https://issues.apache.org/jira/browse/FLINK-19124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17189153#comment-17189153 ] Aljoscha Krettek commented on FLINK-19124: -- I'd be very happy to work in this with a

[jira] [Updated] (FLINK-19123) TestStreamEnvironment does not use shared MiniCluster for executeAsync()

[ https://issues.apache.org/jira/browse/FLINK-19123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19123: - Fix Version/s: 1.12.0 > TestStreamEnvironment does not use shared MiniCluster for

[jira] [Created] (FLINK-19124) Some JobClient methods are not ergonomic, require ClassLoader argument

Aljoscha Krettek created FLINK-19124: Summary: Some JobClient methods are not ergonomic, require ClassLoader argument Key: FLINK-19124 URL: https://issues.apache.org/jira/browse/FLINK-19124

[jira] [Created] (FLINK-19123) TestStreamEnvironment does not use shared MiniCluster for executeAsync()

Aljoscha Krettek created FLINK-19123: Summary: TestStreamEnvironment does not use shared MiniCluster for executeAsync() Key: FLINK-19123 URL: https://issues.apache.org/jira/browse/FLINK-19123

[jira] [Commented] (FLINK-19065) java.lang.IllegalStateException: Auto generated UIDs have been disabled on join

[ https://issues.apache.org/jira/browse/FLINK-19065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188427#comment-17188427 ] Aljoscha Krettek commented on FLINK-19065: -- Thanks! I found the culprit:

[jira] [Closed] (FLINK-19099) consume kafka message repeat

[ https://issues.apache.org/jira/browse/FLINK-19099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19099. Resolution: Not A Problem I'm closing this for now since I don't think it's a problem

[jira] [Commented] (FLINK-19099) consume kafka message repeat

[ https://issues.apache.org/jira/browse/FLINK-19099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188410#comment-17188410 ] Aljoscha Krettek commented on FLINK-19099: -- Did you completely cancel your job and start it

[jira] [Commented] (FLINK-19083) Remove deprecated DataStream#split

[ https://issues.apache.org/jira/browse/FLINK-19083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188362#comment-17188362 ] Aljoscha Krettek commented on FLINK-19083: -- Suggested release note: "The DataStream#split()

[jira] [Updated] (FLINK-19083) Remove deprecated DataStream#split

[ https://issues.apache.org/jira/browse/FLINK-19083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19083: - Description: {{DataStream#split()}} has been deprecated in favour of using Side Outputs

[jira] [Updated] (FLINK-19083) Remove deprecated DataStream#split

[ https://issues.apache.org/jira/browse/FLINK-19083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-19083: - Description: {{DataStream#split()}} has been deprecated in favour of using Side Outputs

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17188277#comment-17188277 ] Aljoscha Krettek commented on FLINK-18959: -- Agreed on everything. But that's a new Jira issue,

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186453#comment-17186453 ] Aljoscha Krettek commented on FLINK-18959: -- I think for this issue we would just change the

[jira] [Commented] (FLINK-19065) java.lang.IllegalStateException: Auto generated UIDs have been disabled on join

[ https://issues.apache.org/jira/browse/FLINK-19065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186351#comment-17186351 ] Aljoscha Krettek commented on FLINK-19065: -- Could you quickly try and run that on a cluster

[jira] [Commented] (FLINK-19069) finalizeOnMaster takes too much time and client timeouts

[ https://issues.apache.org/jira/browse/FLINK-19069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186344#comment-17186344 ] Aljoscha Krettek commented on FLINK-19069: -- Does this really only affect Flink 1.9 or should we

[jira] [Commented] (FLINK-19060) Checkpoint not triggered when use broadcast stream

[ https://issues.apache.org/jira/browse/FLINK-19060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185740#comment-17185740 ] Aljoscha Krettek commented on FLINK-19060: -- Hi, would you mind also trying this with an earlier

[jira] [Commented] (FLINK-19006) project transformation does not support conversion to Tuple25 type

[ https://issues.apache.org/jira/browse/FLINK-19006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185727#comment-17185727 ] Aljoscha Krettek commented on FLINK-19006: -- This code is more than 6 years old by now.  We can

[jira] [Closed] (FLINK-19052) Performance issue with PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-19052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19052. Fix Version/s: 1.12.0 Assignee: Roman Grebennikov Resolution: Fixed

[jira] [Commented] (FLINK-19053) Flink Kafka Connector Dependency Error

[ https://issues.apache.org/jira/browse/FLINK-19053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185721#comment-17185721 ] Aljoscha Krettek commented on FLINK-19053: -- Yes, we should fix that! > Flink Kafka Connector

[jira] [Closed] (FLINK-17159) ES6 ElasticsearchSinkITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-17159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17159. Fix Version/s: 1.11.2 1.12.0 Resolution: Fixed Fix on

[jira] [Commented] (FLINK-17159) ES6 ElasticsearchSinkITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-17159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17184125#comment-17184125 ] Aljoscha Krettek commented on FLINK-17159: -- Potential fix on master:

[jira] [Commented] (FLINK-18830) JoinCoGroupFunction and FlatJoinCoGroupFunction work incorrectly for outer join when one side of coGroup is empty

[ https://issues.apache.org/jira/browse/FLINK-18830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183991#comment-17183991 ] Aljoscha Krettek commented on FLINK-18830: -- The documentation describes {{DataStream.join()}}

[jira] [Assigned] (FLINK-17159) ES6 ElasticsearchSinkITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-17159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17159: Assignee: Aljoscha Krettek > ES6 ElasticsearchSinkITCase unstable >

[jira] [Commented] (FLINK-12130) Apply command line options to configuration before installing security modules

[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183825#comment-17183825 ] Aljoscha Krettek commented on FLINK-12130: -- Sure, that would be good! > Apply command line

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183821#comment-17183821 ] Aljoscha Krettek commented on FLINK-18959: -- Yes, exactly. The cluster should shut down in both

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183342#comment-17183342 ] Aljoscha Krettek commented on FLINK-18959: -- If that means the cluster still shuts down by

[jira] [Commented] (FLINK-17260) StreamingKafkaITCase failure on Azure

[ https://issues.apache.org/jira/browse/FLINK-17260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183306#comment-17183306 ] Aljoscha Krettek commented on FLINK-17260: -- I believe you're right: KAFKA-4815. We should

[jira] [Reopened] (FLINK-12130) Apply command line options to configuration before installing security modules

[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-12130: -- > Apply command line options to configuration before installing security modules >

[jira] [Commented] (FLINK-12130) Apply command line options to configuration before installing security modules

[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183260#comment-17183260 ] Aljoscha Krettek commented on FLINK-12130: -- I think this still needs work then. > Apply

[jira] [Closed] (FLINK-14054) Enable checkpointing via job configuration

[ https://issues.apache.org/jira/browse/FLINK-14054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-14054. Fix Version/s: 1.10.0 Resolution: Fixed This should be fixed by FLINK-14788.

[jira] [Commented] (FLINK-11779) CLI ignores -m parameter if high-availability is ZOOKEEPER

[ https://issues.apache.org/jira/browse/FLINK-11779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183250#comment-17183250 ] Aljoscha Krettek commented on FLINK-11779: -- Agreed, I think we need to make this more prominent

[jira] [Comment Edited] (FLINK-18960) flink sideoutput union

[ https://issues.apache.org/jira/browse/FLINK-18960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181004#comment-17181004 ] Aljoscha Krettek edited comment on FLINK-18960 at 8/24/20, 12:43 PM: -

[jira] [Commented] (FLINK-18934) Idle stream does not advance watermark in connected stream

[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183225#comment-17183225 ] Aljoscha Krettek commented on FLINK-18934: -- Is there any update on this? > Idle stream does

[jira] [Commented] (FLINK-18909) SequenceGenerator doesn't work as expected

[ https://issues.apache.org/jira/browse/FLINK-18909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183221#comment-17183221 ] Aljoscha Krettek commented on FLINK-18909: -- [~lzljs3620320] Could you please take a look? >

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183202#comment-17183202 ] Aljoscha Krettek commented on FLINK-18959: -- Yes, this is an unintended side effect of

[jira] [Commented] (FLINK-18770) Emitting element fails in KryoSerializer

[ https://issues.apache.org/jira/browse/FLINK-18770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17169849#comment-17169849 ] Aljoscha Krettek commented on FLINK-18770: -- Thanks for the analysis! Regarding object reuse:

[jira] [Updated] (FLINK-18800) Avro serialization schema doesn't support Kafka key/value serialization

[ https://issues.apache.org/jira/browse/FLINK-18800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18800: - Component/s: (was: API / Type Serialization System) > Avro serialization schema

[jira] [Commented] (FLINK-18770) Emitting element fails in KryoSerializer

[ https://issues.apache.org/jira/browse/FLINK-18770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17168004#comment-17168004 ] Aljoscha Krettek commented on FLINK-18770: -- So it seems that the {{KryoSerializer}} just

[jira] [Commented] (FLINK-18770) Emitting element fails in KryoSerializer

[ https://issues.apache.org/jira/browse/FLINK-18770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167864#comment-17167864 ] Aljoscha Krettek commented on FLINK-18770: -- Could you please post the code for the Flink

[jira] [Updated] (FLINK-18770) Emitting element fails in KryoSerializer

[ https://issues.apache.org/jira/browse/FLINK-18770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18770: - Component/s: API / Type Serialization System > Emitting element fails in KryoSerializer

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

[ https://issues.apache.org/jira/browse/FLINK-18606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18606. Fix Version/s: 1.12.0 Resolution: Fixed master:

[jira] [Commented] (FLINK-18752) Yarn ship logic should support files

[ https://issues.apache.org/jira/browse/FLINK-18752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167288#comment-17167288 ] Aljoscha Krettek commented on FLINK-18752: -- That sounds sensible! [~tison] [~fly_in_gis]

[jira] [Assigned] (FLINK-18749) Correct dependencies in Kubernetes pom

[ https://issues.apache.org/jira/browse/FLINK-18749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-18749: Assignee: Yang Wang (was: Aljoscha Krettek) > Correct dependencies in

[jira] [Assigned] (FLINK-18749) Correct dependencies in Kubernetes pom

[ https://issues.apache.org/jira/browse/FLINK-18749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-18749: Assignee: Aljoscha Krettek (was: Yang Wang) > Correct dependencies in

[jira] [Commented] (FLINK-18741) ProcessWindowFunction's process function exception

[ https://issues.apache.org/jira/browse/FLINK-18741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167276#comment-17167276 ] Aljoscha Krettek commented on FLINK-18741: -- I don't quite get what's wrong. Is it throwing an

[jira] [Commented] (FLINK-18742) Some configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167118#comment-17167118 ] Aljoscha Krettek commented on FLINK-18742: -- [~fly_in_gis] is right, please open a PR [~wangm92]

[jira] [Assigned] (FLINK-18742) Some configuration args do not take effect at client

[ https://issues.apache.org/jira/browse/FLINK-18742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-18742: Assignee: Matt Wang > Some configuration args do not take effect at client >

[jira] [Closed] (FLINK-18746) WindowStaggerTest.testWindowStagger failed

[ https://issues.apache.org/jira/browse/FLINK-18746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18746. Fix Version/s: 1.12.0 Resolution: Fixed The problem was that WindowStagger.RANDOM

[jira] [Assigned] (FLINK-18746) WindowStaggerTest.testWindowStagger failed

[ https://issues.apache.org/jira/browse/FLINK-18746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-18746: Assignee: Aljoscha Krettek > WindowStaggerTest.testWindowStagger failed >

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

[ https://issues.apache.org/jira/browse/FLINK-18627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166445#comment-17166445 ] Aljoscha Krettek commented on FLINK-18627: -- That will not produce the desired output,

[jira] [Closed] (FLINK-18281) Add WindowStagger into all Tumbling and Sliding Windows

[ https://issues.apache.org/jira/browse/FLINK-18281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18281. Fix Version/s: 1.12.0 Assignee: Teng Hu Resolution: Fixed master:

[jira] [Closed] (FLINK-1140) Add a flatmap that returns an Iterable instead of aggregation to a collector

[ https://issues.apache.org/jira/browse/FLINK-1140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1140. --- Resolution: Abandoned I'm closing this as "Abandoned", since there is no more activity and

[jira] [Closed] (FLINK-3613) Add standard deviation, mean, variance to list of Aggregations

[ https://issues.apache.org/jira/browse/FLINK-3613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-3613. --- Resolution: Abandoned I'm closing this as "Abandoned", since there is no more activity and

[jira] [Closed] (FLINK-7561) Add support for pre-aggregation in DataStream API

[ https://issues.apache.org/jira/browse/FLINK-7561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7561. --- Resolution: Abandoned I'm closing this as "Abandoned", since there is no more activity and

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

[ https://issues.apache.org/jira/browse/FLINK-18627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166214#comment-17166214 ] Aljoscha Krettek commented on FLINK-18627: -- I tend to agree with [~sjwiesman] here:

[jira] [Commented] (FLINK-17159) ES6 ElasticsearchSinkITCase unstable

[ https://issues.apache.org/jira/browse/FLINK-17159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166205#comment-17166205 ] Aljoscha Krettek commented on FLINK-17159: -- I think the reason is just that the embedded ES

[jira] [Updated] (FLINK-18724) Integration with DataStream and DataSet API report error

[ https://issues.apache.org/jira/browse/FLINK-18724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18724: - Component/s: (was: API / Core) > Integration with DataStream and DataSet API report

[jira] [Commented] (FLINK-11779) CLI ignores -m parameter if high-availability is ZOOKEEPER

[ https://issues.apache.org/jira/browse/FLINK-11779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165676#comment-17165676 ] Aljoscha Krettek commented on FLINK-11779: -- And {{jobmanager.rpc.address}}? That can't really

[jira] [Commented] (FLINK-11779) CLI ignores -m parameter if high-availability is ZOOKEEPER

[ https://issues.apache.org/jira/browse/FLINK-11779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165650#comment-17165650 ] Aljoscha Krettek commented on FLINK-11779: -- Turns out this is a smidge more complicated. Should

[jira] [Assigned] (FLINK-18702) Flink elasticsearch connector leaks threads and classloaders thereof

[ https://issues.apache.org/jira/browse/FLINK-18702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-18702: Assignee: Jun Qin > Flink elasticsearch connector leaks threads and classloaders

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

[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18478: - Fix Version/s: (was: 1.11.1) (was: 1.12.0)

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

[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-18478: Assignee: (was: Aljoscha Krettek) > AvroDeserializationSchema does not work

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

[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-18478: -- > AvroDeserializationSchema does not work with types generated by avrohugger >

[jira] [Updated] (FLINK-18692) AvroSerializationSchema does not work with types generated by avrohugger

[ https://issues.apache.org/jira/browse/FLINK-18692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18692: - Labels: starter (was: pull-request-available) > AvroSerializationSchema does not work

[jira] [Assigned] (FLINK-18692) AvroSerializationSchema does not work with types generated by avrohugger

[ https://issues.apache.org/jira/browse/FLINK-18692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-18692: Assignee: (was: Aljoscha Krettek) > AvroSerializationSchema does not work

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

[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164261#comment-17164261 ] Aljoscha Krettek commented on FLINK-18478: -- So, the reason why it's deserializing the record as

[jira] [Updated] (FLINK-18692) AvroSerializationSchema does not work with types generated by avrohugger

[ https://issues.apache.org/jira/browse/FLINK-18692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18692: - Fix Version/s: (was: 1.11.1) (was: 1.12.0)

[jira] [Updated] (FLINK-18693) AvroSerializationSchema does not work with types generated by avrohugger

[ https://issues.apache.org/jira/browse/FLINK-18693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18693: - Fix Version/s: (was: 1.11.1) (was: 1.12.0)

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

[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163801#comment-17163801 ] Aljoscha Krettek edited comment on FLINK-18478 at 7/24/20, 8:15 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-18693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164249#comment-17164249 ] Aljoscha Krettek commented on FLINK-18693: -- Yes, thanks! Something went wrong with my

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

[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163801#comment-17163801 ] Aljoscha Krettek commented on FLINK-18478: -- This is a simpler reproducer: {code} object AvroBug

[jira] [Created] (FLINK-18693) AvroSerializationSchema does not work with types generated by avrohugger

Aljoscha Krettek created FLINK-18693: Summary: AvroSerializationSchema does not work with types generated by avrohugger Key: FLINK-18693 URL: https://issues.apache.org/jira/browse/FLINK-18693

[jira] [Created] (FLINK-18692) AvroSerializationSchema does not work with types generated by avrohugger

Aljoscha Krettek created FLINK-18692: Summary: AvroSerializationSchema does not work with types generated by avrohugger Key: FLINK-18692 URL: https://issues.apache.org/jira/browse/FLINK-18692

[jira] [Commented] (FLINK-18643) Migrate Jenkins jobs to ci-builds.apache.org

[ https://issues.apache.org/jira/browse/FLINK-18643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163570#comment-17163570 ] Aljoscha Krettek commented on FLINK-18643: -- Just the other day I had a user asking if nightly

[jira] [Commented] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163560#comment-17163560 ] Aljoscha Krettek commented on FLINK-18685: -- For me the only option would be to fix the

[jira] [Updated] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18685: - Labels: starter (was: ) > JobClient.getAccumulators() blocks until streaming job has

[jira] [Closed] (FLINK-18398) ElasticSearch unavailibility causes TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-18398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18398. Resolution: Won't Fix I'm closing this for now since it seems to be caused by

[jira] [Closed] (FLINK-18650) The description of dispatcher in Flink Architecture document is not accurate

[ https://issues.apache.org/jira/browse/FLINK-18650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18650. Fix Version/s: 1.11.2 1.12.0 Resolution: Fixed release-1.11: 

[jira] [Assigned] (FLINK-18650) The description of dispatcher in Flink Architecture document is not accurate

[ https://issues.apache.org/jira/browse/FLINK-18650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-18650: Assignee: Peng > The description of dispatcher in Flink Architecture document is

[jira] [Commented] (FLINK-18629) ConnectedStreams#keyBy can not derive key TypeInformation for lambda KeySelectors

[ https://issues.apache.org/jira/browse/FLINK-18629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161876#comment-17161876 ] Aljoscha Krettek commented on FLINK-18629: -- I'm happy with either approach. Currently, if you

[jira] [Updated] (FLINK-12751) Create file based HA support

[ https://issues.apache.org/jira/browse/FLINK-12751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-12751: - Component/s: (was: FileSystems) Runtime / Coordination

[jira] [Commented] (FLINK-18650) The description of dispatcher in Flink Architecture document is not accurate

[ https://issues.apache.org/jira/browse/FLINK-18650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161841#comment-17161841 ] Aljoscha Krettek commented on FLINK-18650: -- Yes, this is wrong. Do you want to open a PR to fix

[jira] [Commented] (FLINK-18649) Add a MongoDB Connector with Exactly-Once Semantics

[ https://issues.apache.org/jira/browse/FLINK-18649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161840#comment-17161840 ] Aljoscha Krettek commented on FLINK-18649: -- I think this could be implemented either like the

[jira] [Updated] (FLINK-18649) Add a MongoDB Connector with Exactly-Once Semantics

[ https://issues.apache.org/jira/browse/FLINK-18649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18649: - Summary: Add a MongoDB Connector with Exactly-Once Semantics (was: MongoDB

[jira] [Updated] (FLINK-18649) MongoDB Exactly-Once Semantics - recommended approach

[ https://issues.apache.org/jira/browse/FLINK-18649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18649: - Component/s: (was: API / DataStream) Connectors / Common > MongoDB

[jira] [Updated] (FLINK-18649) MongoDB Exactly-Once Semantics - recommended approach

[ https://issues.apache.org/jira/browse/FLINK-18649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18649: - Issue Type: New Feature (was: Task) > MongoDB Exactly-Once Semantics - recommended

[jira] [Updated] (FLINK-18649) MongoDB Exactly-Once Semantics - recommended approach

[ https://issues.apache.org/jira/browse/FLINK-18649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18649: - Issue Type: Wish (was: New Feature) > MongoDB Exactly-Once Semantics - recommended

[jira] [Updated] (FLINK-18637) Key group is not in KeyGroupRange

[ https://issues.apache.org/jira/browse/FLINK-18637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18637: - Component/s: Runtime / State Backends > Key group is not in KeyGroupRange >

[jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161371#comment-17161371 ] Aljoscha Krettek commented on FLINK-11654: -- I've assigned [~freezhan] for now, unless

[jira] [Assigned] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-11654: Assignee: freezhan (was: Jiangjie Qin) > Multiple transactional KafkaProducers

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

[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161370#comment-17161370 ] Aljoscha Krettek commented on FLINK-18478: -- Now you can actually try the Flink 1.11.1 release

[jira] [Commented] (FLINK-18629) ConnectedStreams#keyBy can not derive key TypeInformation for lambda KeySelectors

[ https://issues.apache.org/jira/browse/FLINK-18629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161359#comment-17161359 ] Aljoscha Krettek commented on FLINK-18629: -- Yes, I believe this was a mistake. But why not

[jira] [Updated] (FLINK-18599) Compile error when use windowAll and TumblingProcessingTimeWindows

[ https://issues.apache.org/jira/browse/FLINK-18599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18599: - Component/s: (was: API / DataStream) API / Scala > Compile error

[jira] [Commented] (FLINK-18599) Compile error when use windowAll and TumblingProcessingTimeWindows

[ https://issues.apache.org/jira/browse/FLINK-18599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158241#comment-17158241 ] Aljoscha Krettek commented on FLINK-18599: -- There is a quick in the Scala compiler which causes

[jira] [Closed] (FLINK-18599) Compile error when use windowAll and TumblingProcessingTimeWindows

[ https://issues.apache.org/jira/browse/FLINK-18599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-18599. Resolution: Not A Bug > Compile error when use windowAll and

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

[ https://issues.apache.org/jira/browse/FLINK-18478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17158218#comment-17158218 ] Aljoscha Krettek commented on FLINK-18478: -- >From the log you posted in the gist it seems that

[jira] [Updated] (FLINK-18589) java.io.EOFException when reading integer

[ https://issues.apache.org/jira/browse/FLINK-18589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18589: - Component/s: Runtime / State Backends > java.io.EOFException when reading integer >

[jira] [Updated] (FLINK-18587) java.lang.IllegalArgumentException: Position out of bounds when reading Long state

[ https://issues.apache.org/jira/browse/FLINK-18587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18587: - Component/s: Runtime / State Backends > java.lang.IllegalArgumentException: Position

[jira] [Updated] (FLINK-18577) Mail.run Blocked By the Legacy Source Thread

[ https://issues.apache.org/jira/browse/FLINK-18577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-18577: - Component/s: Runtime / Task > Mail.run Blocked By the Legacy Source Thread >

<    1   2   3   4   5   6   7   8   9   10   >