flink-issues mailing list archives: May 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 · 49 · 50 · 51 · 52 · 53 · 54 · 55 · 56 · 57 · 58 · 59 · 60 · Next »Thread · Author · Date
GitBox [GitHub] [flink] WeiZhong94 commented on issue #8531: [FLINK-12440][python] Add all connector support align Java Table API. Fri, 24 May, 09:25
[GitHub] [flink] WeiZhong94 commented on a change in pull request #8531: [FLINK-12440][python] Add all connector support align Java Table API.
GitBox   [GitHub] [flink] WeiZhong94 commented on a change in pull request #8531: [FLINK-12440][python] Add all connector support align Java Table API. Fri, 24 May, 09:25
GitBox   [GitHub] [flink] WeiZhong94 commented on a change in pull request #8531: [FLINK-12440][python] Add all connector support align Java Table API. Fri, 24 May, 09:25
GitBox   [GitHub] [flink] WeiZhong94 commented on a change in pull request #8531: [FLINK-12440][python] Add all connector support align Java Table API. Fri, 24 May, 09:25
GitBox   [GitHub] [flink] WeiZhong94 commented on a change in pull request #8531: [FLINK-12440][python] Add all connector support align Java Table API. Fri, 24 May, 09:25
GitBox [GitHub] [flink] dianfu removed a comment on issue #8531: [FLINK-12440][python] Add all connector support align Java Table API. Fri, 24 May, 09:25
GitBox [GitHub] [flink] zentol commented on issue #8303: [FLINK-12343]add file replication config for yarn configuration Fri, 24 May, 09:27
GitBox [GitHub] [flink] dawidwys merged pull request #8404: [FLINK-11476][table] Create CatalogManager to manage multiple catalogs Fri, 24 May, 09:33
GitBox [GitHub] [flink] zjffdu commented on issue #8533: [FLINK-12596][scala-shell] Unify all kinds of cluster via ClusterClient in FlinkShell Fri, 24 May, 09:34
GitBox [GitHub] [flink] aljoscha opened a new pull request #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord Fri, 24 May, 09:37
GitBox [GitHub] [flink] aljoscha commented on issue #7782: [FLINK-11693] Add KafkaSerializationSchema that directly uses ProducerRecord Fri, 24 May, 09:37
[GitHub] [flink] aljoscha commented on issue #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord
GitBox   [GitHub] [flink] aljoscha commented on issue #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord Fri, 24 May, 09:38
GitBox   [GitHub] [flink] aljoscha commented on issue #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord Fri, 24 May, 12:12
GitBox   [GitHub] [flink] aljoscha commented on issue #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord Mon, 27 May, 13:48
GitBox [GitHub] [flink] flinkbot commented on issue #8535: [FLINK-11693] Add KafkaSerializationSchema that uses ProducerRecord Fri, 24 May, 09:38
[GitHub] [flink] zhijiangW commented on issue #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode
GitBox   [GitHub] [flink] zhijiangW commented on issue #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode Fri, 24 May, 09:41
GitBox   [GitHub] [flink] zhijiangW commented on issue #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode Mon, 27 May, 03:58
GitBox   [GitHub] [flink] zhijiangW commented on issue #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode Thu, 30 May, 04:34
[jira] [Commented] (FLINK-12264) Port ExecutionGraphTestUtils to new code base
Gary Yao (JIRA)   [jira] [Commented] (FLINK-12264) Port ExecutionGraphTestUtils to new code base Fri, 24 May, 09:43
leesf (JIRA)   [jira] [Commented] (FLINK-12264) Port ExecutionGraphTestUtils to new code base Sun, 26 May, 00:47
ASF GitHub Bot (JIRA)   [jira] [Updated] (FLINK-12264) Port ExecutionGraphTestUtils to new code base Sun, 26 May, 03:07
[jira] [Commented] (FLINK-12167) ClusterClient doesn't unset the context class loader after program run
Till Rohrmann (JIRA)   [jira] [Commented] (FLINK-12167) ClusterClient doesn't unset the context class loader after program run Fri, 24 May, 09:57
Till Rohrmann (JIRA)   [jira] [Assigned] (FLINK-12167) ClusterClient doesn't unset the context class loader after program run Fri, 24 May, 09:57
Abdul Qadeer (JIRA)   [jira] [Commented] (FLINK-12167) ClusterClient doesn't unset the context class loader after program run Fri, 24 May, 11:20
ASF GitHub Bot (JIRA)   [jira] [Updated] (FLINK-12167) ClusterClient doesn't unset the context class loader after program run Sun, 26 May, 05:39
Abdul Qadeer (JIRA)   [jira] [Resolved] (FLINK-12167) ClusterClient doesn't unset the context class loader after program run Mon, 27 May, 00:40
Till Rohrmann (JIRA)   [jira] [Reopened] (FLINK-12167) ClusterClient doesn't unset the context class loader after program run Mon, 27 May, 08:47
Till Rohrmann (JIRA)   [jira] [Resolved] (FLINK-12167) ClusterClient doesn't unset the context class loader after program run Mon, 27 May, 08:48
[jira] [Commented] (FLINK-12222) 'start-scala-shell -a <jars>' doesn't ship jars to yarn container
Chesnay Schepler (JIRA)   [jira] [Commented] (FLINK-12222) 'start-scala-shell -a <jars>' doesn't ship jars to yarn container Fri, 24 May, 09:59
Jeff Zhang (JIRA)   [jira] [Closed] (FLINK-12222) 'start-scala-shell -a <jars>' doesn't ship jars to yarn container Fri, 24 May, 14:32
Jeff Zhang (JIRA)   [jira] [Commented] (FLINK-12222) 'start-scala-shell -a <jars>' doesn't ship jars to yarn container Fri, 24 May, 14:32
[jira] [Commented] (FLINK-12101) Race condition when concurrently running uploaded jars via REST
Till Rohrmann (JIRA)   [jira] [Commented] (FLINK-12101) Race condition when concurrently running uploaded jars via REST Fri, 24 May, 09:59
leesf (JIRA)   [jira] [Commented] (FLINK-12101) Race condition when concurrently running uploaded jars via REST Sun, 26 May, 01:47
ASF GitHub Bot (JIRA)   [jira] [Updated] (FLINK-12101) Race condition when concurrently running uploaded jars via REST Sun, 26 May, 02:49
Chesnay Schepler (JIRA)   [jira] [Updated] (FLINK-12101) Race condition when concurrently running uploaded jars via REST Mon, 27 May, 13:07
Chesnay Schepler (JIRA)   [jira] [Updated] (FLINK-12101) Race condition when concurrently running uploaded jars via REST Mon, 27 May, 13:08
[jira] [Updated] (FLINK-12095) Canceling vs cancelling
Till Rohrmann (JIRA)   [jira] [Updated] (FLINK-12095) Canceling vs cancelling Fri, 24 May, 10:00
GitBox [GitHub] [flink] asfgit closed pull request #8420: [FLINK-12408][python] Allow to define the data types in Python Fri, 24 May, 10:02
[jira] [Created] (FLINK-12615) Track allocated partitions on the JM
Chesnay Schepler (JIRA)   [jira] [Created] (FLINK-12615) Track allocated partitions on the JM Fri, 24 May, 10:10
GitBox [GitHub] [flink] Myasuka commented on issue #8391: [FLINK-12416][FLINK-12375] Fix docker build scripts on Flink-1.8 Fri, 24 May, 10:10
[jira] [Closed] (FLINK-12103) Extend builtin operator metrics with user defined scope and variables
Till Rohrmann (JIRA)   [jira] [Closed] (FLINK-12103) Extend builtin operator metrics with user defined scope and variables Fri, 24 May, 10:13
[jira] [Created] (FLINK-12616) Maintain connection between JM<->TM until all partitions have been released
Chesnay Schepler (JIRA)   [jira] [Created] (FLINK-12616) Maintain connection between JM<->TM until all partitions have been released Fri, 24 May, 10:21
GitBox [GitHub] [flink] asfgit closed pull request #8402: [FLINK-12473][ml] Add the interface of ML pipeline and ML lib Fri, 24 May, 10:24
GitBox [GitHub] [flink] zentol closed pull request #8430: [FLINK-12068] [runtime] Backtrack failover regions if intermediate results are unavailable Fri, 24 May, 10:38
[GitHub] [flink] aljoscha commented on issue #7470: [FLINK-11283] Accessing the key when processing connected keyed stream
GitBox   [GitHub] [flink] aljoscha commented on issue #7470: [FLINK-11283] Accessing the key when processing connected keyed stream Fri, 24 May, 11:50
GitBox   [GitHub] [flink] aljoscha commented on issue #7470: [FLINK-11283] Accessing the key when processing connected keyed stream Mon, 27 May, 13:57
GitBox [GitHub] [flink] lirui-apache opened a new pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables Fri, 24 May, 12:07
GitBox [GitHub] [flink] flinkbot commented on issue #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables Fri, 24 May, 12:08
GitBox [GitHub] [flink] lirui-apache commented on issue #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables Fri, 24 May, 12:14
[jira] [Created] (FLINK-12617) StandaloneJobClusterEntrypoint should default to random JobID for non-HA setups
Konstantin Knauf (JIRA)   [jira] [Created] (FLINK-12617) StandaloneJobClusterEntrypoint should default to random JobID for non-HA setups Fri, 24 May, 12:38
ASF GitHub Bot (JIRA)   [jira] [Updated] (FLINK-12617) StandaloneJobClusterEntrypoint should default to random JobID for non-HA setups Fri, 24 May, 14:58
[jira] [Created] (FLINK-12618) jdk.tools exclusion interfering with swift-fs-hadoop build
Chesnay Schepler (JIRA)   [jira] [Created] (FLINK-12618) jdk.tools exclusion interfering with swift-fs-hadoop build Fri, 24 May, 12:40
Chesnay Schepler (JIRA)   [jira] [Closed] (FLINK-12618) jdk.tools exclusion interfering with swift-fs-hadoop build Mon, 27 May, 12:37
[jira] [Created] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint
Congxian Qiu(klion26) (JIRA)   [jira] [Created] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint Fri, 24 May, 12:44
Aljoscha Krettek (JIRA)   [jira] [Commented] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint Tue, 28 May, 09:47
Congxian Qiu(klion26) (JIRA)   [jira] [Commented] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint Tue, 28 May, 10:37
GitBox [GitHub] [flink] tillrohrmann opened a new pull request #8537: [FLINK-12115][fs] Add support for AzureFS Fri, 24 May, 13:38
GitBox [GitHub] [flink] flinkbot commented on issue #8537: [FLINK-12115][fs] Add support for AzureFS Fri, 24 May, 13:39
[GitHub] [flink] tillrohrmann commented on issue #8537: [FLINK-12115][fs] Add support for AzureFS
GitBox   [GitHub] [flink] tillrohrmann commented on issue #8537: [FLINK-12115][fs] Add support for AzureFS Fri, 24 May, 13:41
GitBox   [GitHub] [flink] tillrohrmann commented on issue #8537: [FLINK-12115][fs] Add support for AzureFS Tue, 28 May, 15:10
GitBox   [GitHub] [flink] tillrohrmann commented on issue #8537: [FLINK-12115][fs] Add support for AzureFS Tue, 28 May, 15:14
[GitHub] [flink] piyushnarang commented on issue #8537: [FLINK-12115][fs] Add support for AzureFS
GitBox   [GitHub] [flink] piyushnarang commented on issue #8537: [FLINK-12115][fs] Add support for AzureFS Fri, 24 May, 13:52
GitBox   [GitHub] [flink] piyushnarang commented on issue #8537: [FLINK-12115][fs] Add support for AzureFS Tue, 28 May, 15:44
[jira] [Updated] (FLINK-11947) Support MapState key / value schema evolution for RocksDB
Aljoscha Krettek (JIRA)   [jira] [Updated] (FLINK-11947) Support MapState key / value schema evolution for RocksDB Fri, 24 May, 14:15
Cliff Resnick (JIRA)   [jira] [Commented] (FLINK-11947) Support MapState key / value schema evolution for RocksDB Fri, 24 May, 16:00
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Commented] (FLINK-11947) Support MapState key / value schema evolution for RocksDB Mon, 27 May, 08:01
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Comment Edited] (FLINK-11947) Support MapState key / value schema evolution for RocksDB Mon, 27 May, 08:02
Congxian Qiu(klion26) (JIRA)   [jira] [Commented] (FLINK-11947) Support MapState key / value schema evolution for RocksDB Wed, 29 May, 04:48
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Commented] (FLINK-11947) Support MapState key / value schema evolution for RocksDB Wed, 29 May, 05:04
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Assigned] (FLINK-11947) Support MapState key / value schema evolution for RocksDB Wed, 29 May, 05:04
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-11947) Support MapState value schema evolution for RocksDB Wed, 29 May, 05:04
Cliff Resnick (JIRA)   [jira] [Commented] (FLINK-11947) Support MapState value schema evolution for RocksDB Wed, 29 May, 11:11
ASF GitHub Bot (JIRA)   [jira] [Updated] (FLINK-11947) Support MapState value schema evolution for RocksDB Wed, 29 May, 12:50
Congxian Qiu(klion26) (JIRA)   [jira] [Commented] (FLINK-11947) Support MapState value schema evolution for RocksDB Thu, 30 May, 04:21
Cliff Resnick (JIRA)   [jira] [Commented] (FLINK-11947) Support MapState value schema evolution for RocksDB Thu, 30 May, 12:29
[jira] [Updated] (FLINK-11107) Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured
Aljoscha Krettek (JIRA)   [jira] [Updated] (FLINK-11107) Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured Fri, 24 May, 14:23
Tzu-Li (Gordon) Tai (JIRA)   [jira] [Updated] (FLINK-11107) Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured Tue, 28 May, 09:18
[jira] [Commented] (FLINK-12297) Clean the closure for OutputTags in PatternStream
Aljoscha Krettek (JIRA)   [jira] [Commented] (FLINK-12297) Clean the closure for OutputTags in PatternStream Fri, 24 May, 14:27
aitozi (JIRA)   [jira] [Commented] (FLINK-12297) Clean the closure for OutputTags in PatternStream Sat, 25 May, 01:38
GitBox [GitHub] [flink] zentol commented on a change in pull request #8537: [FLINK-12115][fs] Add support for AzureFS Fri, 24 May, 14:45
[GitHub] [flink] pnowojski commented on issue #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode
GitBox   [GitHub] [flink] pnowojski commented on issue #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode Fri, 24 May, 14:47
GitBox   [GitHub] [flink] pnowojski commented on issue #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode Mon, 27 May, 09:01
GitBox [GitHub] [flink] aljoscha opened a new pull request #8538: [FLINK-11283] Accessing the key when processing connected keyed stream Fri, 24 May, 14:56
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 · 49 · 50 · 51 · 52 · 53 · 54 · 55 · 56 · 57 · 58 · 59 · 60 · Next »Thread · Author · Date
Box list
Jul 20198366
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