flink-issues mailing list archives: July 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 · Next »Thread · Author · Date
GitBox [GitHub] [flink] sunjincheng121 commented on a change in pull request #8916: [FLINK-12897][python][docs] Improve the Python Table API docs by adding more examples Mon, 01 Jul, 01:53
Jark Wu (JIRA) [jira] [Commented] (FLINK-13034) Improve the performance when checking whether mapstate is empty for RocksDBStateBackend Mon, 01 Jul, 01:55
GitBox [GitHub] [flink] flinkbot edited a comment on issue #8916: [FLINK-12897][python][docs] Improve the Python Table API docs by adding more examples Mon, 01 Jul, 01:55
vinoyang (JIRA) [jira] [Commented] (FLINK-13032) Allow Access to Per-Window State in mergeable window ProcessWindowFunction Mon, 01 Jul, 02:23
GitBox [GitHub] [flink] zhuzhurk commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler Mon, 01 Jul, 02:28
vinoyang (JIRA) [jira] [Commented] (FLINK-12953) View logs from Job view in Web Dashboard Mon, 01 Jul, 02:53
GitBox [GitHub] [flink] JingsongLi commented on issue #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC Mon, 01 Jul, 03:56
Chad Dombrova (JIRA) [jira] [Commented] (FLINK-12953) View logs from Job view in Web Dashboard Mon, 01 Jul, 03:57
GitBox [GitHub] [flink] asfgit closed pull request #8916: [FLINK-12897][python][docs] Improve the Python Table API docs by adding more examples Mon, 01 Jul, 04:08
sunjincheng (JIRA) [jira] [Closed] (FLINK-12897) Improve the Python Table API docs by adding more examples Mon, 01 Jul, 04:13
GitBox [GitHub] [flink] wuchong commented on issue #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC Mon, 01 Jul, 04:19
GitBox [GitHub] [flink] wuchong edited a comment on issue #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC Mon, 01 Jul, 04:19
GitBox [GitHub] [flink] JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC Mon, 01 Jul, 04:23
GitBox [GitHub] [flink] JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC Mon, 01 Jul, 04:23
GitBox [GitHub] [flink] JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC Mon, 01 Jul, 04:23
GitBox [GitHub] [flink] bowenli86 commented on issue #8919: [FLINK-13022][table][hive] unify catalog function implementations Mon, 01 Jul, 05:02
GitBox [GitHub] [flink] asfgit closed pull request #8919: [FLINK-13022][table][hive] unify catalog function implementations Mon, 01 Jul, 05:04
GitBox [GitHub] [flink] JingsongLi commented on issue #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC Mon, 01 Jul, 05:19
GitBox [GitHub] [flink] JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC Mon, 01 Jul, 06:02
GitBox [GitHub] [flink] JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC Mon, 01 Jul, 06:07
GitBox [GitHub] [flink] JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC Mon, 01 Jul, 06:09
GitBox [GitHub] [flink] JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC Mon, 01 Jul, 06:09
GitBox [GitHub] [flink] JingsongLi commented on a change in pull request #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC Mon, 01 Jul, 06:15
GitBox [GitHub] [flink] wuchong commented on issue #7550: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink for HBase Mon, 01 Jul, 06:38
GitBox [GitHub] [flink] wuchong commented on a change in pull request #8867: [FLINK-12956][jdbc] Introduce upsert table sink for JDBC Mon, 01 Jul, 06:39
vinoyang (JIRA) [jira] [Commented] (FLINK-12953) View logs from Job view in Web Dashboard Mon, 01 Jul, 06:46
GitBox [GitHub] [flink] yanghua commented on a change in pull request #8871: [FLINK-12976] Bump Kafka client version to 2.3.0 for universal Kafka connector Mon, 01 Jul, 06:49
GitBox [GitHub] [flink] aljoscha commented on issue #8894: [FLINK-12961][datastream] Providing an internal execution method of StreamExecutionEnvironment accepting StreamGraph as input parameter Mon, 01 Jul, 06:59
GitBox [GitHub] [flink] zjuwangg commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager Mon, 01 Jul, 07:01
GitBox [GitHub] [flink] aljoscha edited a comment on issue #8894: [FLINK-12961][datastream] Providing an internal execution method of StreamExecutionEnvironment accepting StreamGraph as input parameter Mon, 01 Jul, 07:03
GitBox [GitHub] [flink] zjuwangg commented on a change in pull request #8920: [FLINK-13024][table] integrate FunctionCatalog with CatalogManager Mon, 01 Jul, 07:04
Wong (JIRA) [jira] [Created] (FLINK-13035) LocalStreamEnvironment shall launch actuall task solts Mon, 01 Jul, 07:12
GitBox [GitHub] [flink] shaoxuan-wang commented on issue #8526: [FLINK-12597][ml] Remove the legacy flink-libraries/flink-ml Mon, 01 Jul, 07:21
GitBox [GitHub] [flink] zjuwangg commented on a change in pull request #8800: [FLINK-12627][doc][sql client][hive] Document how to configure and use catalogs in SQL CLI Mon, 01 Jul, 07:27
GitBox [GitHub] [flink] shaoxuan-wang commented on issue #8643: [FLINK-12758][ml] Add flink-ml-lib module Mon, 01 Jul, 07:31
GitBox [GitHub] [flink] flinkbot edited a comment on issue #8643: [FLINK-12758][ml] Add flink-ml-lib module Mon, 01 Jul, 07:32
GitBox [GitHub] [flink] c4emmmm commented on issue #8526: [FLINK-12597][ml] Remove the legacy flink-libraries/flink-ml Mon, 01 Jul, 07:40
GitBox [GitHub] [flink] aloyszhang commented on issue #8837: [FLINK-12938][docs]Translate "Streaming Connectors" page into Chinese Mon, 01 Jul, 07:45
GitBox [GitHub] [flink] c4emmmm edited a comment on issue #8526: [FLINK-12597][ml] Remove the legacy flink-libraries/flink-ml Mon, 01 Jul, 07:49
GitBox [GitHub] [flink] asfgit closed pull request #8643: [FLINK-12758][ml] Add flink-ml-lib module Mon, 01 Jul, 07:50
FaxianZhao (JIRA) [jira] [Created] (FLINK-13036) Elasticsearch ActionRequestFailureHandler can access RuntimeContext Mon, 01 Jul, 07:51
GitBox [GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode Mon, 01 Jul, 07:53
Konstantin Knauf (JIRA) [jira] [Created] (FLINK-13037) Translate "Concepts -> Glossary" page into Chinese Mon, 01 Jul, 07:55
GitBox [GitHub] [flink] knaufk commented on issue #8607: [FLINK-12652] [documentation] add first version of a glossary Mon, 01 Jul, 07:55
GitBox [GitHub] [flink] shaoxuan-wang commented on issue #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. Mon, 01 Jul, 07:56
GitBox [GitHub] [flink] FaxianZhao opened a new pull request #8927: [FLINK-12770] [elasticsearch] ActionRequestFailureHandler can access RuntimeContext Mon, 01 Jul, 07:57
GitBox [GitHub] [flink] flinkbot commented on issue #8927: [FLINK-12770] [elasticsearch] ActionRequestFailureHandler can access RuntimeContext Mon, 01 Jul, 07:59
GitBox [GitHub] [flink] Aitozi commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode Mon, 01 Jul, 08:08
GitBox [GitHub] [flink] aloyszhang commented on issue #8838: [FLINK-12946][docs]Translate Apache NiFi Connector page into Chinese Mon, 01 Jul, 08:09
Liya Fan (JIRA) [jira] [Assigned] (FLINK-12628) Check test failure if partition has no consumers in Execution.getPartitionMaxParallelism Mon, 01 Jul, 08:11
Danny (JIRA) [jira] [Created] (FLINK-13038) CEP WITHIN don’t support interval expression Mon, 01 Jul, 08:13
GitBox [GitHub] [flink] c4emmmm edited a comment on issue #8526: [FLINK-12597][ml] Remove the legacy flink-libraries/flink-ml Mon, 01 Jul, 08:15
yelun (JIRA) [jira] [Updated] (FLINK-11637) Translate "Checkpoints" page into Chinese Mon, 01 Jul, 08:17
GitBox [GitHub] [flink] zentol commented on a change in pull request #8924: [hotfix][docs] Update the generated configuration docs for previous changes Mon, 01 Jul, 08:20
GitBox [GitHub] [flink] aloyszhang commented on issue #8843: [FLINK-12945][docs] Translate RabbitMQ Connector page into Chinese Mon, 01 Jul, 08:20
GitBox [GitHub] [flink] azagrebin commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager Mon, 01 Jul, 08:26
GitBox [GitHub] [flink] azagrebin commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager Mon, 01 Jul, 08:26
GitBox [GitHub] [flink] SuXingLee commented on issue #8927: [FLINK-12770] [elasticsearch] ActionRequestFailureHandler can access RuntimeContext Mon, 01 Jul, 08:31
GitBox [GitHub] [flink] pnowojski commented on issue #8811: [FLINK-12777][network] Support CheckpointBarrierHandler in StreamTwoInputSelectableProcessor Mon, 01 Jul, 08:31
GitBox [GitHub] [flink] pnowojski edited a comment on issue #8811: [FLINK-12777][network] Support CheckpointBarrierHandler in StreamTwoInputSelectableProcessor Mon, 01 Jul, 08:32
GitBox [GitHub] [flink] SuXingLee edited a comment on issue #8927: [FLINK-12770] [elasticsearch] ActionRequestFailureHandler can access RuntimeContext Mon, 01 Jul, 08:36
GitBox [GitHub] [flink] NicoK commented on issue #8917: [FLINK-13017][docs] do not mount local $HOME into docker Mon, 01 Jul, 08:36
GitBox [GitHub] [flink] GJL commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler Mon, 01 Jul, 08:40
yanxiaobin (JIRA) [jira] [Commented] (FLINK-12992) All host(s) tried for query failed (tried com.datastax.driver.core.exceptions.TransportException: Error writing...) Mon, 01 Jul, 08:44
GitBox [GitHub] [flink] aloyszhang commented on issue #8897: [FLINK-12943][docs]Translate HDFS Connector page into Chinese Mon, 01 Jul, 08:46
GitBox [GitHub] [flink] zhijiangW commented on a change in pull request #8924: [hotfix][docs] Update the generated configuration docs for previous changes Mon, 01 Jul, 08:47
GitBox [GitHub] [flink] zentol opened a new pull request #8928: [FLINK-12997][coordination] Release partitions when a vertex is reset Mon, 01 Jul, 08:50
ASF GitHub Bot (JIRA) [jira] [Updated] (FLINK-12997) Release partitions for reset vertices Mon, 01 Jul, 08:51
GitBox [GitHub] [flink] azagrebin commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager Mon, 01 Jul, 08:51
GitBox [GitHub] [flink] flinkbot commented on issue #8928: [FLINK-12997][coordination] Release partitions when a vertex is reset Mon, 01 Jul, 08:52
GitBox [GitHub] [flink] GJL commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler Mon, 01 Jul, 08:52
GitBox [GitHub] [flink] azagrebin commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager Mon, 01 Jul, 08:52
GitBox [GitHub] [flink] GJL commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler Mon, 01 Jul, 08:53
GitBox [GitHub] [flink] azagrebin commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager Mon, 01 Jul, 08:54
GitBox [GitHub] [flink] Aitozi commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode Mon, 01 Jul, 08:57
GitBox [GitHub] [flink] GJL commented on issue #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler Mon, 01 Jul, 08:58
GitBox [GitHub] [flink] GJL closed pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler Mon, 01 Jul, 08:58
GitBox [GitHub] [flink] StefanRRichter commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService Mon, 01 Jul, 08:59
Piotr Nowojski (JIRA) [jira] [Created] (FLINK-13039) Clean up thrown exception lists of `ResultSubpartitionView#getNextBuffer` Mon, 01 Jul, 09:02
GitBox [GitHub] [flink] StefanRRichter commented on a change in pull request #8692: [FLINK-12804] Introduce mailbox-based ExecutorService Mon, 01 Jul, 09:02
GitBox [GitHub] [flink] pnowojski edited a comment on issue #8811: [FLINK-12777][network] Support CheckpointBarrierHandler in StreamTwoInputSelectableProcessor Mon, 01 Jul, 09:03
GitBox [GitHub] [flink] pnowojski edited a comment on issue #8811: [FLINK-12777][network] Support CheckpointBarrierHandler in StreamTwoInputSelectableProcessor Mon, 01 Jul, 09:03
GitBox [GitHub] [flink] pnowojski commented on issue #8811: [FLINK-12777][network] Support CheckpointBarrierHandler in StreamTwoInputSelectableProcessor Mon, 01 Jul, 09:04
GitBox [GitHub] [flink] zhijiangW commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager Mon, 01 Jul, 09:04
GitBox [GitHub] [flink] zhijiangW commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager Mon, 01 Jul, 09:04
GitBox [GitHub] [flink] pnowojski edited a comment on issue #8811: [FLINK-12777][network] Support CheckpointBarrierHandler in StreamTwoInputSelectableProcessor Mon, 01 Jul, 09:04
GitBox [GitHub] [flink] zhijiangW commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager Mon, 01 Jul, 09:07
vinoyang (JIRA) [jira] [Commented] (FLINK-13025) Elasticsearch 7.x support Mon, 01 Jul, 09:09
GitBox [GitHub] [flink] zhijiangW commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode Mon, 01 Jul, 09:09
GitBox [GitHub] [flink] aloyszhang commented on issue #8918: [FLINK-12944][docs]Translate Streaming File Sink page into Chinese Mon, 01 Jul, 09:12
GitBox [GitHub] [flink] twalthr opened a new pull request #8929: [FLINK-13028][table] Move expression resolver to flink-table-api-java Mon, 01 Jul, 09:13
GitBox [GitHub] [flink] Aitozi commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode Mon, 01 Jul, 09:13
ASF GitHub Bot (JIRA) [jira] [Updated] (FLINK-13028) Move expression resolver to flink-table-api-java Mon, 01 Jul, 09:14
vinoyang (JIRA) [jira] [Assigned] (FLINK-5018) Make source idle timeout user configurable Mon, 01 Jul, 09:15
GitBox [GitHub] [flink] flinkbot commented on issue #8929: [FLINK-13028][table] Move expression resolver to flink-table-api-java Mon, 01 Jul, 09:15
vinoyang (JIRA) [jira] [Assigned] (FLINK-9780) scala-shell yarn mode silently goes into standalone mode if no yarn option is specified Mon, 01 Jul, 09:16
GitBox [GitHub] [flink] GJL commented on a change in pull request #8922: [FLINK-12876][runtime] Add an adapter of region failover NG for legacy scheduler Mon, 01 Jul, 09:21
vinoyang (JIRA) [jira] [Commented] (FLINK-9558) Memory leaks during usage of bucketing-sink with disabled checkpointing Mon, 01 Jul, 09:22
GitBox [GitHub] [flink] aljoscha commented on a change in pull request #8695: [FLINK-12805][FLINK-12808][FLINK-12809][table-api] Introduce PartitionableTableSource and PartitionableTableSink and OverwritableTableSink Mon, 01 Jul, 09:23
GitBox [GitHub] [flink] aljoscha commented on a change in pull request #8695: [FLINK-12805][FLINK-12808][FLINK-12809][table-api] Introduce PartitionableTableSource and PartitionableTableSink and OverwritableTableSink Mon, 01 Jul, 09:23
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 · Next »Thread · Author · Date
Box list
Aug 20195664
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