flink-issues mailing list archives: March 2019

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · 41 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · Next »Thread · Author · Date
Achyuth Narayan Samudrala (JIRA) [jira] [Created] (FLINK-11931) Avro Bulk Writer Factory for StreamingFileSink Bulk Format Fri, 15 Mar, 10:38
Aleksandr Salatich (JIRA) [jira] [Assigned] (FLINK-5080) Cassandra connector ignores saveAsync result onSuccess Tue, 05 Mar, 12:14
Alex (JIRA) [jira] [Assigned] (FLINK-11798) Incorrect Kubernetes Documentation Thu, 07 Mar, 16:04
Alex (JIRA) [jira] [Commented] (FLINK-11798) Incorrect Kubernetes Documentation Thu, 07 Mar, 19:49
Alex Vinnik (JIRA) [jira] [Commented] (FLINK-11143) AskTimeoutException is thrown during job submission and completion Fri, 01 Mar, 04:27
Alex Vinnik (JIRA) [jira] [Commented] (FLINK-11143) AskTimeoutException is thrown during job submission and completion Thu, 14 Mar, 20:58
Alex Vinnik (JIRA) [jira] [Comment Edited] (FLINK-11143) AskTimeoutException is thrown during job submission and completion Thu, 14 Mar, 21:52
Alex Vinnik (JIRA) [jira] [Commented] (FLINK-11143) AskTimeoutException is thrown during job submission and completion Thu, 14 Mar, 21:52
Alexander Chermenin (JIRA) [jira] [Assigned] (FLINK-11968) Fix runtime SingleElementIterator.iterator and remove table.SingleElementIterator Wed, 20 Mar, 13:21
Alexander Lehmann (JIRA) [jira] [Commented] (FLINK-4399) Add support for oversized messages Wed, 06 Mar, 19:53
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-3746) WebRuntimeMonitorITCase.testNoCopyFromJar failing intermittently Fri, 01 Mar, 09:06
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-3744) LocalFlinkMiniClusterITCase times out occasionally when building locally Fri, 01 Mar, 09:06
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-3745) TimestampITCase testWatermarkPropagationNoFinalWatermarkOnStop failing intermittently Fri, 01 Mar, 09:06
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-10737) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis Fri, 01 Mar, 10:20
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-11791) Describe how to build Flink with Hadoop in build guide Fri, 01 Mar, 15:04
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11249) FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer Fri, 01 Mar, 15:25
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11249) FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer Fri, 01 Mar, 15:25
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11249) FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer Fri, 01 Mar, 15:26
Aljoscha Krettek (JIRA) [jira] [Assigned] (FLINK-11420) Serialization of case classes containing a Map[String, Any] sometimes throws ArrayIndexOutOfBoundsException Fri, 01 Mar, 15:26
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-11791) Describe how to build Flink with Hadoop in build guide Mon, 04 Mar, 09:41
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11716) Introduce Task Manager configuration option to customize address binding mechanism Mon, 04 Mar, 12:29
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-11836) Update NOTICE-binary and licenses-binary for Flink 1.8.0 Wed, 06 Mar, 10:37
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-11751) Extend release notes for Flink 1.8 Wed, 06 Mar, 10:54
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11821) Fix package declaration of KafkaDeserializationSchemaWrapper Wed, 06 Mar, 10:56
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-11836) Update NOTICE-binary and licenses-binary for Flink 1.8.0 Wed, 06 Mar, 13:09
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-11836) Update NOTICE-binary and licenses-binary for Flink 1.8.0 Wed, 06 Mar, 13:13
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11821) Fix package declaration and location of internal Kafka schema wrappers Wed, 06 Mar, 13:21
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11821) Fix package declaration and location of internal Kafka schema wrappers Wed, 06 Mar, 14:19
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-11821) Fix package declaration and location of internal Kafka schema wrappers Wed, 06 Mar, 15:20
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-10083) Kafka08ITCase#testOneSourceMultiplePartitions failed on travis Thu, 07 Mar, 11:13
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-11706) Add the SumFunction to support KeyedStream.sum with field which is array Thu, 07 Mar, 14:37
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11689) Code clean for StreamingJobGraphGenerator Thu, 07 Mar, 14:57
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-11689) Code clean for StreamingJobGraphGenerator Thu, 07 Mar, 14:58
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-11539) Add TypeSerializerSnapshot for TraversableSerializer Sat, 09 Mar, 10:27
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-11539) Add TypeSerializerSnapshot for TraversableSerializer Sat, 09 Mar, 10:39
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-11865) Code generation in TraversableSerializer is prohibitively slow Sat, 09 Mar, 13:04
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-11539) Add TypeSerializerSnapshot for TraversableSerializer Sat, 09 Mar, 13:05
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-11539) Add TypeSerializerSnapshot for TraversableSerializer Mon, 11 Mar, 08:04
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-11539) Add TypeSerializerSnapshot for TraversableSerializer Mon, 11 Mar, 08:36
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11865) Code generation in TraversableSerializer is prohibitively slow Mon, 11 Mar, 08:53
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs Mon, 11 Mar, 09:31
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11865) Code generation in TraversableSerializer is prohibitively slow Mon, 11 Mar, 13:03
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11420) Serialization of case classes containing a Map[String, Any] sometimes throws ArrayIndexOutOfBoundsException Mon, 11 Mar, 13:03
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-10183) Processing-Time based windows aren't emitted when a finite stream ends Mon, 11 Mar, 13:45
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-11889) Remove "stop" signal along with Stoppable interfaces Tue, 12 Mar, 13:50
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11889) Remove "stop" signal along with Stoppable interfaces Tue, 12 Mar, 13:50
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-11865) Code generation in TraversableSerializer is prohibitively slow Tue, 12 Mar, 14:29
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-11539) Add TypeSerializerSnapshot for TraversableSerializer Tue, 12 Mar, 16:16
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-11865) Code generation in TraversableSerializer is prohibitively slow Tue, 12 Mar, 16:16
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-11865) Code generation in TraversableSerializer is prohibitively slow Tue, 12 Mar, 16:16
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11911) KafkaTopicPartition is not a valid POJO Thu, 14 Mar, 11:13
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11950) Add missing dependencies in NOTICE file of flink-dist. Mon, 18 Mar, 10:47
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11950) Add missing dependencies in NOTICE file of flink-dist. Mon, 18 Mar, 10:48
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11892) Port conflict when running nightly end-to-end tests Mon, 18 Mar, 14:49
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11950) Add missing dependencies in NOTICE file of flink-dist. Mon, 18 Mar, 14:49
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-11891) Fix some script or test case bug in 1.8 RC Mon, 18 Mar, 14:50
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs Mon, 18 Mar, 15:10
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-11933) Exception in thread "main" java.lang.RuntimeException: No data sinks have been created yet. A program needs at least one sink that consumes data. Examples are writing the data set or printing it. Tue, 19 Mar, 08:16
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11825) Resolve name clash of StateTTL TimeCharacteristic class Tue, 19 Mar, 08:53
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-10958) Add overload support for user defined function Tue, 19 Mar, 08:53
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11960) Verify builtin Blink Table API functions and operators are reasonable Tue, 19 Mar, 12:01
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11886) Update CLI output in HA docs Tue, 19 Mar, 13:21
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-10756) TaskManagerProcessFailureBatchRecoveryITCase did not finish on time Tue, 19 Mar, 13:21
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11183) Heap/NonHeap memory metrics broken Tue, 19 Mar, 13:21
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11902) JarRunHandler wraps all exceptions in a RestHandlerException Tue, 19 Mar, 13:22
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11866) Wrong method name for registering custom types Tue, 19 Mar, 13:22
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-11825) Resolve name clash of StateTTL TimeCharacteristic class Wed, 20 Mar, 14:44
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11971) Fix `Command: start_kubernetes_if_not_ruunning failed` error Thu, 21 Mar, 10:46
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11980) Improve efficiency of iterating KeySelectionListener on notification Thu, 21 Mar, 12:24
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11972) The classpath is missing the `flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test. Thu, 21 Mar, 12:24
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11781) Reject "DISABLED" as value for yarn.per-job-cluster.include-user-jar Thu, 21 Mar, 12:24
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11745) TTL end-to-end test restores from the savepoint after the job cancelation Thu, 21 Mar, 12:24
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11950) Add missing dependencies in NOTICE file of flink-dist. Thu, 21 Mar, 12:24
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-11990) Streaming bucketing end-to-end test fail with hadoop 2.8 Thu, 21 Mar, 13:13
Aljoscha Krettek (JIRA) [jira] [Closed] (FLINK-11990) Streaming bucketing end-to-end test fail with hadoop 2.8 Thu, 21 Mar, 15:54
Aljoscha Krettek (JIRA) [jira] [Commented] (FLINK-11990) Streaming bucketing end-to-end test fail with hadoop 2.8 Thu, 21 Mar, 15:54
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11993) Introduce partitionable filesystem sink Fri, 22 Mar, 09:18
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11982) BatchTableSourceFactory support Json Format File Fri, 22 Mar, 09:19
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11727) JSON row format is not serializable Fri, 22 Mar, 09:23
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11492) Support the full Blink SQL runtime Fri, 22 Mar, 09:24
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11506) In the Windows environment, through sql-client, execute the SQL statement for a few minutes after the client interrupt exit, reported IO exception Fri, 22 Mar, 09:24
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11490) Add an initial Blink SQL batch runtime Fri, 22 Mar, 09:27
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11484) Blink java.util.concurrent.TimeoutException Fri, 22 Mar, 09:27
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11489) Add an initial Blink SQL streaming runtime Fri, 22 Mar, 09:27
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11481) Integrate HiveTableFactory with existing table factory discovery mechanism Fri, 22 Mar, 09:28
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11482) Implement GenericHiveMetastoreCatalog Fri, 22 Mar, 09:28
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11479) Implement HiveCatalog Fri, 22 Mar, 09:29
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11482) Implement GenericHiveMetastoreCatalog Fri, 22 Mar, 09:29
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11480) Create HiveTableFactory that creates TableSource/Sink from a Hive table Fri, 22 Mar, 09:29
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11421) Add compilation options to allow compiling generated code with JDK compiler Fri, 22 Mar, 09:30
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11238) Enhance SQL-Client to recursively list tables Fri, 22 Mar, 09:31
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11239) Enhance SQL-Client to recursively list UDFs Fri, 22 Mar, 09:31
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11222) Change api.scala.DataStream to api.datastream.DataStream for createHarnessTester in HarnessTestBase Fri, 22 Mar, 09:32
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11176) Improve the harness tests to use the code-generated operator Fri, 22 Mar, 09:32
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11115) Port some flink.ml algorithms to table based Fri, 22 Mar, 09:33
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11111) Create a new set of parameters Fri, 22 Mar, 09:34
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11096) Create a new table based flink ML package Fri, 22 Mar, 09:34
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11095) Table based ML Pipeline Fri, 22 Mar, 09:34
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11113) Support periodically update models when inferencing Fri, 22 Mar, 09:34
Aljoscha Krettek (JIRA) [jira] [Updated] (FLINK-11114) Support wrapping inference pipeline as a UDF function in SQL Fri, 22 Mar, 09:34
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · 41 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · Next »Thread · Author · Date
Box list
Jul 202110617
Jun 202110018
May 20218192
Apr 202125421
Mar 202112878
Feb 20217802
Jan 20218278
Dec 20208216
Nov 202011656
Oct 202010635
Sep 20208763
Aug 20207154
Jul 20206500
Jun 202011245
May 202012632
Apr 202014175
Mar 202012382
Feb 202010561
Jan 20208835
Dec 201913015
Nov 201911280
Oct 201911647
Sep 20198451
Aug 201910193
Jul 201911502
Jun 20198159
May 20197326
Apr 20195671
Mar 20194764
Feb 20195750
Jan 20194225
Dec 20183613
Nov 20186764
Oct 20186946
Sep 20184634
Aug 20185670
Jul 20187170
Jun 20184380
May 20185152
Apr 20183465
Mar 20184883
Feb 20185764
Jan 20184880
Dec 20172682
Nov 20174639
Oct 20174859
Sep 20173958
Aug 20174518
Jul 20175392
Jun 20174893
May 20176475
Apr 20174390
Mar 20177839
Feb 20175379
Jan 20175351
Dec 20163688
Nov 20164834
Oct 20164002
Sep 20163620
Aug 20165065
Jul 20163523
Jun 20164191
May 20163116
Apr 20163318
Mar 20163053
Feb 20164198
Jan 20162281
Dec 20151770
Nov 20153847
Oct 20153578
Sep 20153866
Aug 20154488
Jul 20152905
Jun 20153211
May 20152758
Apr 20152329
Mar 20152558
Feb 20151980
Jan 20151685
Dec 2014836
Nov 20141506
Oct 2014575
Sep 2014744
Aug 2014435
Jul 20141002
Jun 2014300