flink-issues mailing list archives: October 2019

Site index · List index
Message list1 · 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 · 49 · 50 · 51 · 52 · 53 · 54 · 55 · 56 · 57 · 58 · 59 · 60 · 61 · 62 · 63 · 64 · 65 · 66 · 67 · 68 · 69 · 70 · 71 · 72 · 73 · 74 · 75 · 76 · 77 · 78 · 79 · 80 · 81 · 82 · 83 · 84 · 85 · 86 · 87 · 88 · 89 · 90 · 91 · 92 · 93 · 94 · 95 · 96 · 97 · 98 · 99 · 100 · 101 · 102 · 103 · 104 · 105 · 106 · 107 · 108 · 109 · 110 · 111 · 112 · 113 · 114 · 115 · 116 · 117 · Next »Thread · Author · Date
Benoît Paris (Jira) [jira] [Commented] (FLINK-14200) Temporal Table Function Joins do not work on Tables (only TableSources) on the query side Mon, 14 Oct, 09:12
Marco Zühlke (Jira) [jira] [Commented] (FLINK-14380) Type Extractor POJO setter check does not allow for Immutable Case Class Tue, 22 Oct, 16:11
Marco Zühlke (Jira) [jira] [Commented] (FLINK-14380) Type Extractor POJO setter check does not allow for Immutable Case Class Wed, 23 Oct, 12:04
Marco Zühlke (Jira) [jira] [Commented] (FLINK-14380) Type Extractor POJO setter check does not allow for Immutable Case Class Fri, 25 Oct, 22:22
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS Tue, 01 Oct, 08:13
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14299) Factor status and system metrics out of JobManagerMetricGroup Tue, 01 Oct, 08:26
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14303) Factor resource manager related metrics out of JobManagerMetricGroup Tue, 01 Oct, 09:04
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14305) Move ownership of JobManagerMetricGroup to Dispatcher Tue, 01 Oct, 09:15
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14252) Encapsulate Dispatcher services in DispatcherServices container Tue, 01 Oct, 09:36
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14184) Provide a stage listener API to be invoked per task manager Tue, 01 Oct, 11:21
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14307) Extract JobGraphWriter from JobGraphStore Tue, 01 Oct, 12:27
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14278) Pass in ioExecutor into AbstractDispatcherResourceManagerComponentFactory Tue, 01 Oct, 12:38
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-11843) Dispatcher fails to recover jobs if leader change happens during JobManagerRunner termination Tue, 01 Oct, 13:34
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14276) Quickstarts Scala nightly end-to-end test fails on Travis Wed, 02 Oct, 09:59
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14247) Use NoResourceAvailableException to wrap TimeoutException on slot allocation (Scheduler NG) Wed, 02 Oct, 15:56
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14309) Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis Thu, 03 Oct, 05:54
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14317) make hadoop history server logs accessible through flink ui Fri, 04 Oct, 05:58
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14315) NPE with JobMaster.disconnectTaskManager Fri, 04 Oct, 12:03
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment Fri, 04 Oct, 23:39
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14296) SqlNodes in the parser module should use an Optional for optional parameters Sun, 06 Oct, 06:40
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14329) Simplify code with lambda expressions in flink-core module Sun, 06 Oct, 08:43
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14271) Remove legacy RestartPipelinedRegionStrategy Sun, 06 Oct, 15:37
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14310) Get ExecutionVertexID from ExecutionVertex rather than creating new instances Sun, 06 Oct, 15:54
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14332) add flink-metrics-signalfx to flink-metrics Mon, 07 Oct, 07:29
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14341) Flink-python builds with failure: no such option: --prefix Tue, 08 Oct, 06:16
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14343) Remove uncompleted YARNHighAvailabilityService Tue, 08 Oct, 08:14
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-13904) Avoid competition between different rounds of checkpoint triggering Tue, 08 Oct, 11:18
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14230) Change the endInput call of the downstream operator to after the upstream operator closes Tue, 08 Oct, 12:23
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14306) flink-python build fails with No module named pkg_resources Tue, 08 Oct, 12:28
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14337) HistoryServerTest.testHistoryServerIntegration failed on Travis Tue, 08 Oct, 13:28
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14300) StreamTask#invoke leaks threads if OperatorChain fails to be constructed Tue, 08 Oct, 23:54
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14331) Reset vertices right after they transition to terminated states Wed, 09 Oct, 08:03
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14237) No need to rename shipped Flink jar Wed, 09 Oct, 08:05
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14335) Java version of ExampleIntegrationTest in testing docs is incorrect Wed, 09 Oct, 08:07
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14008) Flink Scala 2.12 binary distribution contains incorrect NOTICE-binary file Wed, 09 Oct, 08:38
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14254) Introduce FileSystemOutputFormat for batch Wed, 09 Oct, 08:43
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14212) Support Python UDFs without arguments Wed, 09 Oct, 09:04
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14349) Create a Connector Descriptor for HBase so that user can connect HBase by TableEnvironment#connect Wed, 09 Oct, 11:40
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14351) Refactor MetricRegistry delimiter retrieval into separate interface Wed, 09 Oct, 12:34
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14350) Introduce dedicated MetricScope Wed, 09 Oct, 12:51
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14291) Add unit tests for DefaultScheduler to test concurrent failover behavior Wed, 09 Oct, 13:12
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14353) Enable fork-reuse for table-planner Wed, 09 Oct, 13:12
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14336) Exceptions in AsyncCheckpointRunnable#run are never logged Wed, 09 Oct, 14:40
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14240) The configuration added via TableConfig#configuration should be added to GlobalJobParameters for the legacy planner Thu, 10 Oct, 02:12
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14134) Introduce LimitableTableSource to optimize limit Thu, 10 Oct, 08:00
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14360) Flink on yarn should support obtain delegation tokens of multi hdfs namespaces Thu, 10 Oct, 09:01
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14149) Introduce ZooKeeperLeaderElectionServiceNG Thu, 10 Oct, 09:13
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14334) ElasticSearch docs refer to non-existent ExceptionUtils.containsThrowable Thu, 10 Oct, 16:33
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string Fri, 11 Oct, 02:13
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14377) Translate ProgramOptions relevant for job execution to ConfigOptions. Fri, 11 Oct, 13:25
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-1430) Add test for streaming scala api completeness Fri, 11 Oct, 19:02
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-13818) Check whether web submission are enabled Sat, 12 Oct, 02:38
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14266) Introduce RowCsvInputFormat to new CSV module Sat, 12 Oct, 02:39
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14344) Snapshot master hook state asynchronously Sat, 12 Oct, 07:35
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14027) Add documentation for Python user-defined functions Sat, 12 Oct, 13:12
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14208) Optimize Python UDFs with parameters of constant values Sat, 12 Oct, 15:25
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14215) Add Docs for TM and JM Environment Variable Setting Sat, 12 Oct, 23:50
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14227) Add Razorpay to Chinese Powered By page Sun, 13 Oct, 07:00
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14355) Example code in state processor API docs doesn't compile Sun, 13 Oct, 10:18
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14272) Support Blink planner for Python UDF Sun, 13 Oct, 13:03
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-13999) Correct the documentation of MATCH_RECOGNIZE Mon, 14 Oct, 08:02
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14342) Remove method FunctionDefinition#getLanguage Mon, 14 Oct, 08:36
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14045) Rewrite DefaultExecutionSlotAllocator to use SlotProviderStrategy Mon, 14 Oct, 10:40
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-2030) Implement discrete and continuous histograms Mon, 14 Oct, 11:16
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-1725) New Partitioner for better load balancing for skewed data Mon, 14 Oct, 11:18
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-3109) Join two streams with two different buffer time Mon, 14 Oct, 11:18
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-3996) Add addition, subtraction and multiply by scalar to DenseVector.scala and SparseVector.scala Mon, 14 Oct, 11:22
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-4016) FoldApplyWindowFunction is not properly initialized Mon, 14 Oct, 11:22
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-3857) Add reconnect attempt to Elasticsearch host Mon, 14 Oct, 11:25
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-3783) Support weighted random sampling with reservoir Mon, 14 Oct, 11:26
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs Mon, 14 Oct, 11:26
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-3030) Enhance Dashboard to show Execution Attempts Mon, 14 Oct, 11:28
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-4521) Fix "Submit new Job" panel in development mode Mon, 14 Oct, 11:29
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-2055) Implement Streaming HBaseSink Mon, 14 Oct, 11:30
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-4205) Implement stratified sampling for DataSet Mon, 14 Oct, 11:30
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-4615) Reusing the memory allocated for the drivers and iterators Mon, 14 Oct, 11:32
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-4705) Instrument FixedLengthRecordSorter Mon, 14 Oct, 11:33
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects Mon, 14 Oct, 11:34
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14390) Add class for SqlOperators, and add sql operations to AlgoOperator, BatchOperator and StreamOperator. Mon, 14 Oct, 11:57
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14359) Create a module called flink-sql-connector-hbase to shade HBase Mon, 14 Oct, 11:58
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14365) Annotate MiniCluster tests in core modules with AlsoRunWithSchedulerNG Tue, 15 Oct, 03:57
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14366) Annotate MiniCluster tests in flink-tests with AlsoRunWithSchedulerNG Tue, 15 Oct, 04:03
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14363) Prevent vertex from being affected by outdated deployment (SchedulerNG) Tue, 15 Oct, 06:13
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14394) Remove unnecessary interface method BufferProvider#requestBufferBlocking Tue, 15 Oct, 06:25
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-14232) Support global failure handling for DefaultScheduler (SchedulerNG) Tue, 15 Oct, 10:02
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-4272) Create a JobClient for job control and monitoring Tue, 15 Oct, 11:36
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-5104) Implement BipartiteGraph validator Tue, 15 Oct, 11:37
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-3555) Web interface does not render job information properly Tue, 15 Oct, 11:37
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-5031) Consecutive DataStream.split() ignored Tue, 15 Oct, 11:37
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-1707) Add an Affinity Propagation Library Method Tue, 15 Oct, 11:37
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-4647) Implement BipartiteGraph reader Tue, 15 Oct, 11:40
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-4649) Implement bipartite graph metrics Tue, 15 Oct, 11:40
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-2184) Cannot get last element with maxBy/minBy Tue, 15 Oct, 11:40
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-4648) Implement bipartite graph generators Tue, 15 Oct, 11:40
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-5244) Implement methods for BipartiteGraph transformations Tue, 15 Oct, 11:40
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-5362) Implement methods to access BipartiteGraph properties Tue, 15 Oct, 11:40
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-2186) Rework CSV import to support very wide files Tue, 15 Oct, 11:40
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-6192) reuse zookeeer client created by CuratorFramework Tue, 15 Oct, 11:41
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-6096) Refactor the migration of old versioned savepoints Tue, 15 Oct, 11:42
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-4714) Set task state to RUNNING after state has been restored Tue, 15 Oct, 11:43
Message list1 · 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 · 49 · 50 · 51 · 52 · 53 · 54 · 55 · 56 · 57 · 58 · 59 · 60 · 61 · 62 · 63 · 64 · 65 · 66 · 67 · 68 · 69 · 70 · 71 · 72 · 73 · 74 · 75 · 76 · 77 · 78 · 79 · 80 · 81 · 82 · 83 · 84 · 85 · 86 · 87 · 88 · 89 · 90 · 91 · 92 · 93 · 94 · 95 · 96 · 97 · 98 · 99 · 100 · 101 · 102 · 103 · 104 · 105 · 106 · 107 · 108 · 109 · 110 · 111 · 112 · 113 · 114 · 115 · 116 · 117 · Next »Thread · Author · Date
Box list
Nov 20196616
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