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
MalcolmSanders (JIRA) [jira] [Updated] (FLINK-11806) Import shaded jetcd Mon, 04 Mar, 12:24
MalcolmSanders (JIRA) [jira] [Created] (FLINK-11807) Implement etcd based LeaderElectionService and LeaderRetrievalService Mon, 04 Mar, 12:34
MalcolmSanders (JIRA) [jira] [Created] (FLINK-11808) etcd based SharedCount or sequencer Mon, 04 Mar, 12:43
MalcolmSanders (JIRA) [jira] [Updated] (FLINK-11808) etcd based SharedCount or sequencer Mon, 04 Mar, 12:46
MalcolmSanders (JIRA) [jira] [Updated] (FLINK-11808) Implement etcd based SharedCount or sequencer Mon, 04 Mar, 12:47
MalcolmSanders (JIRA) [jira] [Created] (FLINK-11809) Implement etcd based StateHandleStore Mon, 04 Mar, 13:03
MalcolmSanders (JIRA) [jira] [Updated] (FLINK-11808) Implement etcd based SharedCount or sequencer Mon, 04 Mar, 13:10
MalcolmSanders (JIRA) [jira] [Created] (FLINK-11810) Implement etcd based CheckpointRecoveryFactory Mon, 04 Mar, 13:11
MalcolmSanders (JIRA) [jira] [Assigned] (FLINK-11809) Implement etcd based StateHandleStore Mon, 04 Mar, 13:13
MalcolmSanders (JIRA) [jira] [Updated] (FLINK-11810) Implement etcd based CheckpointRecoveryFactory Mon, 04 Mar, 13:21
MalcolmSanders (JIRA) [jira] [Created] (FLINK-11811) Implement etcd based RunningJobsRegistry and SubmittedJobGraphStore Mon, 04 Mar, 13:28
MalcolmSanders (JIRA) [jira] [Created] (FLINK-11812) Composite etcd based HighAvailability components Mon, 04 Mar, 13:36
Mark Cho (JIRA) [jira] [Created] (FLINK-11957) Expose failure cause in the API response when dispatcher fails to submit a job Mon, 18 Mar, 21:50
Mark Cho (JIRA) [jira] [Updated] (FLINK-11957) Expose failure cause in the API response when dispatcher fails to submit a job Mon, 18 Mar, 21:52
Martijn van de Grift (JIRA) [jira] [Commented] (FLINK-11378) Allow HadoopRecoverableWriter to write to Hadoop compatible Filesystems Wed, 06 Mar, 13:02
Martijn van de Grift (JIRA) [jira] [Closed] (FLINK-11378) Allow HadoopRecoverableWriter to write to Hadoop compatible Filesystems Wed, 06 Mar, 13:03
Matrix42 (JIRA) [jira] [Created] (FLINK-11958) flink on windows yarn deploy failed Tue, 19 Mar, 01:49
Matrix42 (JIRA) [jira] [Updated] (FLINK-11958) flink on windows yarn deploy failed Tue, 19 Mar, 15:09
Maximilian Michels (JIRA) [jira] [Commented] (FLINK-2491) Checkpointing only works if all operators/tasks are still running Wed, 13 Mar, 21:35
Maximilian Michels (JIRA) [jira] [Assigned] (FLINK-2491) Checkpointing only works if all operators/tasks are still running Tue, 19 Mar, 10:42
Michael Holler (JIRA) [jira] [Created] (FLINK-11817) DataStream API Tutorial uses deprecated fold function Mon, 04 Mar, 21:58
Michael Holler (JIRA) [jira] [Updated] (FLINK-11817) DataStream API Tutorial uses deprecated fold function Mon, 04 Mar, 22:16
Michel Davit (JIRA) [jira] [Created] (FLINK-12023) Override TaskManager memory when submitting a Flink job Tue, 26 Mar, 15:57
Michel Davit (JIRA) [jira] [Commented] (FLINK-12023) Override TaskManager memory when submitting a Flink job Wed, 27 Mar, 13:40
Mikhail Pryakhin (JIRA) [jira] [Commented] (FLINK-6949) Add ability to ship custom resource files to YARN cluster Fri, 29 Mar, 11:39
Nico Kruber (JIRA) [jira] [Commented] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException" Sat, 30 Mar, 08:46
Padarn Wilson (JIRA) [jira] [Commented] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions Fri, 08 Mar, 15:50
Paul Lin (JIRA) [jira] [Commented] (FLINK-9048) LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers sometimes fails Fri, 15 Mar, 06:48
Paul Lin (JIRA) [jira] [Created] (FLINK-12022) Enable StreamWriter to update file length on sync flush Tue, 26 Mar, 13:08
Paul Lin (JIRA) [jira] [Created] (FLINK-12042) RocksDBStateBackend mistakenly uses default filesystem Thu, 28 Mar, 05:32
Paul Lin (JIRA) [jira] [Updated] (FLINK-12042) RocksDBStateBackend mistakenly uses default filesystem Thu, 28 Mar, 06:07
Piotr Nowojski (JIRA) [jira] [Closed] (FLINK-11397) Speed up initialization of AbstractStreamOperatorTestHarness Fri, 01 Mar, 15:56
Piotr Nowojski (JIRA) [jira] [Closed] (FLINK-7175) Add simple benchmark suite for Flink Fri, 01 Mar, 16:26
Piotr Nowojski (JIRA) [jira] [Created] (FLINK-11815) Support execution with static resources (Flip-6): E.g. spreading tasks across available set of TMs Mon, 04 Mar, 15:46
Piotr Nowojski (JIRA) [jira] [Commented] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes Mon, 04 Mar, 16:35
Piotr Nowojski (JIRA) [jira] [Closed] (FLINK-11646) Remove legacy MockRecordWriter Tue, 12 Mar, 11:36
Piotr Nowojski (JIRA) [jira] [Updated] (FLINK-11875) Enhance stream operator API to support selective reading and EndOfInput event Wed, 13 Mar, 08:50
Piotr Nowojski (JIRA) [jira] [Commented] (FLINK-11865) Code generation in TraversableSerializer is prohibitively slow Wed, 13 Mar, 12:22
Piotr Nowojski (JIRA) [jira] [Closed] (FLINK-11885) Introduce RecordWriterBuilder for creating RecordWriter instance Fri, 22 Mar, 10:55
Piotr Nowojski (JIRA) [jira] [Commented] (FLINK-11775) Introduce MemorySegmentWritable to let DataOutputView direct copy to internal bytes Fri, 22 Mar, 11:28
Piotr Nowojski (JIRA) [jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs Fri, 22 Mar, 12:39
Piotr Nowojski (JIRA) [jira] [Commented] (FLINK-11974) Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen Fri, 22 Mar, 12:52
Piotr Nowojski (JIRA) [jira] [Closed] (FLINK-11988) Remove legacy MockNetworkEnvironment Fri, 22 Mar, 13:03
Piotr Nowojski (JIRA) [jira] [Assigned] (FLINK-11249) FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer Wed, 27 Mar, 09:33
Piotr Nowojski (JIRA) [jira] [Commented] (FLINK-12025) Support FOR SYSTEM_TIME AS OF in temporal table Thu, 28 Mar, 10:24
Piotr Nowojski (JIRA) [jira] [Commented] (FLINK-11974) Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen Thu, 28 Mar, 10:36
Pritesh Patel (JIRA) [jira] [Created] (FLINK-11798) Incorrect Kubernetes Documentation Sun, 03 Mar, 09:10
Quan Shi (JIRA) [jira] [Created] (FLINK-12043) Null value check in array serializers classes Thu, 28 Mar, 07:06
Ramesh Srinivasalu (JIRA) [jira] [Created] (FLINK-11906) Getting error while submitting job Wed, 13 Mar, 15:10
Robert Metzger (JIRA) [jira] [Closed] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() Fri, 01 Mar, 07:46
Robert Metzger (JIRA) [jira] [Updated] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration() Fri, 01 Mar, 07:48
Robert Metzger (JIRA) [jira] [Updated] (FLINK-8390) Refactor Hadoop kerberos integration test code Fri, 01 Mar, 07:55
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11783) Deadlock during Join operation Fri, 01 Mar, 07:56
Robert Metzger (JIRA) [jira] [Updated] (FLINK-9685) Flink should support hostname-substitution for security.kerberos.login.principal Fri, 01 Mar, 07:58
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11199) Support interactive programming in Flink Fri, 01 Mar, 12:38
Robert Metzger (JIRA) [jira] [Updated] (FLINK-7344) Migrate usage of joda-time to the Java 8 DateTime API Fri, 01 Mar, 12:39
Robert Metzger (JIRA) [jira] [Commented] (FLINK-11756) Update migration tests for Flink 1.8 Fri, 01 Mar, 12:41
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11524) LeaderChangeClusterComponentsTest.testReelectionOfJobMaster failed on Travis Fri, 01 Mar, 12:42
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11658) Implement HadoopMapreduceITCase for new Hadoop API Fri, 01 Mar, 12:42
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11659) Implement HadoopMapFunctionITCase for new Hadoop API Fri, 01 Mar, 12:42
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11710) Refactor SimpleSlotProvider to TestingLogicalSlotProvider Fri, 01 Mar, 12:42
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11660) Implement HadoopReduceFunctionITCase for new Hadoop API Fri, 01 Mar, 12:42
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11446) FlinkKafkaProducer011ITCase.testRecoverCommittedTransaction failed on Travis Fri, 01 Mar, 12:42
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11155) HadoopFreeFsFactoryTest fails with ClassCastException Fri, 01 Mar, 12:43
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11343) TaskExecutorTest is unstable on travis Fri, 01 Mar, 12:43
Robert Metzger (JIRA) [jira] [Updated] (FLINK-10914) Prefer notifying status changed to waiting and checking in ExecutionGraph tests Fri, 01 Mar, 12:43
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11397) Speed up initialization of AbstractStreamOperatorTestHarness Fri, 01 Mar, 12:43
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11153) UdfAnalyzerTest fails with CodeAnalyzerException Fri, 01 Mar, 12:43
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11428) BufferFileWriterFileSegmentReaderTest#testWriteRead failed on Travis Fri, 01 Mar, 12:43
Robert Metzger (JIRA) [jira] [Updated] (FLINK-10756) TaskManagerProcessFailureBatchRecoveryITCase did not finish on time Fri, 01 Mar, 12:44
Robert Metzger (JIRA) [jira] [Updated] (FLINK-10819) The instability problem of CI, JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test fail. Fri, 01 Mar, 12:44
Robert Metzger (JIRA) [jira] [Updated] (FLINK-10828) Enforce that all TypeSerializers are tested through SerializerTestBase Fri, 01 Mar, 12:44
Robert Metzger (JIRA) [jira] [Updated] (FLINK-10368) 'Kerberized YARN on Docker test' unstable Fri, 01 Mar, 12:45
Robert Metzger (JIRA) [jira] [Updated] (FLINK-10569) Clean up uses of Scheduler and Instance in valid tests Fri, 01 Mar, 12:45
Robert Metzger (JIRA) [jira] [Updated] (FLINK-10466) flink-yarn-tests should depend flink-dist Fri, 01 Mar, 12:45
Robert Metzger (JIRA) [jira] [Updated] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase) Fri, 01 Mar, 12:46
Robert Metzger (JIRA) [jira] [Updated] (FLINK-10294) Split MiniClusterResource to be usable in runtime/streaming-java/clients Fri, 01 Mar, 12:46
Robert Metzger (JIRA) [jira] [Updated] (FLINK-10320) Introduce JobMaster schedule micro-benchmark Fri, 01 Mar, 12:46
Robert Metzger (JIRA) [jira] [Updated] (FLINK-9925) ClientTest.testSimpleRequests fails on Travis Fri, 01 Mar, 12:46
Robert Metzger (JIRA) [jira] [Updated] (FLINK-9613) YARNSessionCapacitySchedulerITCase failed because YarnTestBase.checkClusterEmpty() Fri, 01 Mar, 12:47
Robert Metzger (JIRA) [jira] [Updated] (FLINK-9078) End-to-end test: Add test that verifies that a specific classloading issue with avro is fixed Fri, 01 Mar, 12:47
Robert Metzger (JIRA) [jira] [Updated] (FLINK-9429) Quickstart E2E not working locally Fri, 01 Mar, 12:47
Robert Metzger (JIRA) [jira] [Updated] (FLINK-8803) Mini Cluster Shutdown with HA unstable, causing test failures Fri, 01 Mar, 12:48
Robert Metzger (JIRA) [jira] [Updated] (FLINK-7084) Flip-6 testing Fri, 01 Mar, 12:49
Robert Metzger (JIRA) [jira] [Updated] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions Fri, 01 Mar, 12:49
Robert Metzger (JIRA) [jira] [Updated] (FLINK-7916) Remove NetworkStackThroughputITCase Fri, 01 Mar, 12:49
Robert Metzger (JIRA) [jira] [Updated] (FLINK-7085) Test slot allocation protocol Fri, 01 Mar, 12:49
Robert Metzger (JIRA) [jira] [Updated] (FLINK-5679) Refactor *CheckpointedITCase tests to speed up Fri, 01 Mar, 12:49
Robert Metzger (JIRA) [jira] [Updated] (FLINK-5428) Decrease restart delay in RecoveryITCase Fri, 01 Mar, 12:49
Robert Metzger (JIRA) [jira] [Updated] (FLINK-2520) StreamFaultToleranceTestBase does not allow for multiple tests Fri, 01 Mar, 12:50
Robert Metzger (JIRA) [jira] [Updated] (FLINK-3843) StreamFaultToleranceTestBase hangs in case of test failure. Fri, 01 Mar, 12:50
Robert Metzger (JIRA) [jira] [Updated] (FLINK-4295) CoGroupGroupSortTranslationTest#testGroupSortTuplesDefaultCoGroup fails to run Fri, 01 Mar, 12:50
Robert Metzger (JIRA) [jira] [Commented] (FLINK-11837) Improve blink internal data format Wed, 06 Mar, 15:35
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11837) Improve blink internal data format Wed, 06 Mar, 15:35
Robert Metzger (JIRA) [jira] [Updated] (FLINK-11865) Code generation in TraversableSerializer is prohibitively slow Sat, 09 Mar, 17:31
Robert Metzger (JIRA) [jira] [Updated] (FLINK-12) [GitHub] Rework Configuration Objects Wed, 13 Mar, 18:59
Robert Metzger (JIRA) [jira] [Updated] (FLINK-50) HBase port from Paris Hackathon Thu, 14 Mar, 10:43
Robert Metzger (JIRA) [jira] [Updated] (FLINK-258) Scala renames and cleanups Thu, 14 Mar, 12:53
Robert Metzger (JIRA) [jira] [Updated] (FLINK-261) JDBC Input and Output format for Stratosphere Thu, 14 Mar, 13:28
Robert Metzger (JIRA) [jira] [Updated] (FLINK-261) JDBC Input and Output format for Stratosphere Thu, 14 Mar, 13:31
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
Aug 20212602
Jul 202110977
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