flink-issues mailing list archives: September 2021

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 · Next »Thread · Author · Date
GitBox [GitHub] [flink] Aitozi commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client Wed, 01 Sep, 00:11
Kurt Young (Jira) [jira] [Commented] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I Wed, 01 Sep, 01:02
GitBox [GitHub] [flink] JingsongLi commented on a change in pull request #17079: [FLINK-24054][table-runtime] Let SinkUpsertMaterializer produce +U's when possible Wed, 01 Sep, 01:20
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17025: [FLINK-24029][docs] Update doc example sql field in release-1.13.2 to dept_id Wed, 01 Sep, 01:33
GitBox [GitHub] [flink] lometheus commented on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case Wed, 01 Sep, 01:44
Xintong Song (Jira) [jira] [Assigned] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager Wed, 01 Sep, 01:44
Xintong Song (Jira) [jira] [Commented] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager Wed, 01 Sep, 01:45
Xintong Song (Jira) [jira] [Updated] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable Wed, 01 Sep, 01:47
Xintong Song (Jira) [jira] [Updated] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable Wed, 01 Sep, 01:48
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case Wed, 01 Sep, 01:57
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17025: [FLINK-24029][docs] Update doc example sql field in release-1.13.2 to dept_id Wed, 01 Sep, 01:57
Xintong Song (Jira) [jira] [Commented] (FLINK-23747) Testing Window TVF offset Wed, 01 Sep, 01:59
Xintong Song (Jira) [jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure Wed, 01 Sep, 02:03
Xintong Song (Jira) [jira] [Created] (FLINK-24091) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure fails on azure Wed, 01 Sep, 02:07
Xintong Song (Jira) [jira] [Commented] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis Wed, 01 Sep, 02:08
Xintong Song (Jira) [jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis Wed, 01 Sep, 02:08
Xintong Song (Jira) [jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis Wed, 01 Sep, 02:08
Xintong Song (Jira) [jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure Wed, 01 Sep, 02:09
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-22601) PushWatermarkIntoScan should produce digest created by Expression Wed, 01 Sep, 02:10
Xintong Song (Jira) [jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure Wed, 01 Sep, 02:10
Xintong Song (Jira) [jira] [Created] (FLINK-24092) OrcFsStreamingSinkITCase.testPart times out on azure Wed, 01 Sep, 02:13
GitBox [GitHub] [flink] wuchong merged pull request #17074: [FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType Wed, 01 Sep, 02:13
Jark Wu (Jira) [jira] [Commented] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type Wed, 01 Sep, 02:14
GitBox [GitHub] [flink] wuchong merged pull request #17083: [FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType Wed, 01 Sep, 02:17
Jark Wu (Jira) [jira] [Comment Edited] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type Wed, 01 Sep, 02:18
JING ZHANG (Jira) [jira] [Commented] (FLINK-23544) Window TVF Supports session window Wed, 01 Sep, 02:18
GitBox [GitHub] [flink] wuchong commented on pull request #17085: [FLINK-24081][table-blink-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType Wed, 01 Sep, 02:18
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-24082) Python UDTF throws exception when the result type is generator of Row Wed, 01 Sep, 02:23
GitBox [GitHub] [flink] flinkbot commented on pull request #17089: [FLINK-22601][table-planner] PushWatermarkIntoScan should produce digest created by Expression. Wed, 01 Sep, 02:24
Caizhi Weng (Jira) [jira] [Commented] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient Wed, 01 Sep, 02:26
GitBox [GitHub] [flink] flinkbot commented on pull request #17090: [FLINK-24082][python] Fix Python UDTF to handle properly when the result is a generator of Row Wed, 01 Sep, 02:26
Jin Xing (Jira) [jira] [Commented] (FLINK-22672) Some enhancements for pluggable shuffle service framework Wed, 01 Sep, 02:28
liwei li (Jira) [jira] [Commented] (FLINK-23747) Testing Window TVF offset Wed, 01 Sep, 02:29
godfrey he (Jira) [jira] [Commented] (FLINK-23544) Window TVF Supports session window Wed, 01 Sep, 02:32
Caizhi Weng (Jira) [jira] [Issue Comment Deleted] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient Wed, 01 Sep, 02:32
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax. Wed, 01 Sep, 02:32
godfrey he (Jira) [jira] [Comment Edited] (FLINK-23544) Window TVF Supports session window Wed, 01 Sep, 02:34
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #16983: [FLINK-23750][docs][table] Add documentation for Window Top-N after Windowing TVF. Wed, 01 Sep, 02:34
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case Wed, 01 Sep, 02:34
Caizhi Weng (Jira) [jira] [Commented] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient Wed, 01 Sep, 02:36
Caizhi Weng (Jira) [jira] [Comment Edited] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient Wed, 01 Sep, 02:37
Caizhi Weng (Jira) [jira] [Comment Edited] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient Wed, 01 Sep, 02:40
Caizhi Weng (Jira) [jira] [Updated] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient Wed, 01 Sep, 02:40
Caizhi Weng (Jira) [jira] [Updated] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient Wed, 01 Sep, 02:40
Leonard Xu (Jira) [jira] [Commented] (FLINK-24087) Kafka connector StartupMode requires a table dependency Wed, 01 Sep, 02:42
Zhihao Wang (Jira) [jira] [Commented] (FLINK-22113) UniqueKey constraint is lost with multiple sources join in SQL Wed, 01 Sep, 02:54
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax. Wed, 01 Sep, 03:21
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #16983: [FLINK-23750][docs][table] Add documentation for Window Top-N after Windowing TVF. Wed, 01 Sep, 03:22
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source. Wed, 01 Sep, 03:23
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17085: [FLINK-24081][table-blink-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType Wed, 01 Sep, 03:23
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17088: [FLINK-23817][docs] Add metric description to Kafka source. [1.14] Wed, 01 Sep, 03:23
GitBox [GitHub] [flink] flinkbot commented on pull request #17089: [FLINK-22601][table-planner] PushWatermarkIntoScan should produce digest created by Expression. Wed, 01 Sep, 03:23
GitBox [GitHub] [flink] flinkbot commented on pull request #17090: [FLINK-24082][python] Fix Python UDTF to handle properly when the result is a generator of Row Wed, 01 Sep, 03:23
liuzhuo (Jira) [jira] [Created] (FLINK-24093) Supports setting the percentage of kubernetes Request resources Wed, 01 Sep, 03:26
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-24083) The result isn't as expected when the result type is generator of string for Python UDTF Wed, 01 Sep, 03:36
liuzhuo (Jira) [jira] [Updated] (FLINK-24093) Supports setting the percentage of kubernetes Request resources Wed, 01 Sep, 03:39
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-24093) Supports setting the percentage of kubernetes Request resources Wed, 01 Sep, 03:39
Caizhi Weng (Jira) [jira] [Comment Edited] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient Wed, 01 Sep, 03:39
Dian Fu (Jira) [jira] [Closed] (FLINK-23924) Distribution is lacking Python Datastream examples Wed, 01 Sep, 03:40
Rui Li (Jira) [jira] [Commented] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data Wed, 01 Sep, 03:40
GitBox [GitHub] [flink] flinkbot commented on pull request #17091: [FLINK-24083][python] Fix Python UDTF to handle properly when the result is str Wed, 01 Sep, 03:40
lixu (Jira) [jira] [Created] (FLINK-24094) Could not execute ALTER TABLE check_rule_base_hive_catalog.test_flink.test_partition DROP PARTITION (dt=2021-08-31) Wed, 01 Sep, 03:42
GitBox [GitHub] [flink] flinkbot commented on pull request #17092: [FLINK-24093] Supports setting the percentage of kubernetes Request resources Wed, 01 Sep, 03:42
lixu (Jira) [jira] [Commented] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data Wed, 01 Sep, 03:45
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #16192: [FLINK-22954][table-planner-blink] Rewrite Join on constant TableFunctionScan to Correlate Wed, 01 Sep, 03:45
GitBox [GitHub] [flink] dianfu closed pull request #17065: [FLINK-24062][python] Fix the serialization of timer to avoid serializing timer data partially Wed, 01 Sep, 03:45
Dian Fu (Jira) [jira] [Closed] (FLINK-24062) Exception encountered during timer serialization in Python DataStream API Wed, 01 Sep, 03:47
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17075: [FLINK-24035][network][refactor] Move the blocking allocation of one floating buffer logic from the constructor of LocalBufferPool to SingleInputGate#setupChannels() Wed, 01 Sep, 03:48
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17085: [FLINK-24081][table-blink-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType Wed, 01 Sep, 03:49
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17090: [FLINK-24082][python] Fix Python UDTF to handle properly when the result is a generator of Row Wed, 01 Sep, 03:49
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17089: [FLINK-22601][table-planner] PushWatermarkIntoScan should produce digest created by Expression. Wed, 01 Sep, 03:49
Jark Wu (Jira) [jira] [Commented] (FLINK-24094) Could not execute ALTER TABLE check_rule_base_hive_catalog.test_flink.test_partition DROP PARTITION (dt=2021-08-31) Wed, 01 Sep, 04:00
GitBox [GitHub] [flink] wuchong commented on pull request #16037: [FLINK-22812][hive] Fix HiveConf, HiveMetaStoreClient and upgrade avr… Wed, 01 Sep, 04:01
JING ZHANG (Jira) [jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file Wed, 01 Sep, 04:19
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #16192: [FLINK-22954][table-planner-blink] Rewrite Join on constant TableFunctionScan to Correlate Wed, 01 Sep, 04:23
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17025: [FLINK-24029][docs] Update doc example sql field in release-1.13.2 to dept_id Wed, 01 Sep, 04:26
JING ZHANG (Jira) [jira] [Comment Edited] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file Wed, 01 Sep, 04:27
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17075: [FLINK-24035][network][refactor] Move the blocking allocation of one floating buffer logic from the constructor of LocalBufferPool to SingleInputGate#setupChannels() Wed, 01 Sep, 04:27
GitBox [GitHub] [flink] flinkbot commented on pull request #17091: [FLINK-24083][python] Fix Python UDTF to handle properly when the result is str Wed, 01 Sep, 04:27
GitBox [GitHub] [flink] flinkbot commented on pull request #17092: [FLINK-24093] Supports setting the percentage of kubernetes Request resources Wed, 01 Sep, 04:27
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-24088) "Internal server error" when quitting a SELECT query in the SqlClient Wed, 01 Sep, 04:38
GitBox [GitHub] [flink] flinkbot commented on pull request #17093: [FLINK-24088][streaming] Log FlinkJobNotFoundException in debug instead of warn level in CollectResultFetcher for a cleaner log Wed, 01 Sep, 04:40
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #16983: [FLINK-23750][docs][table] Add documentation for Window Top-N after Windowing TVF. Wed, 01 Sep, 04:51
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case Wed, 01 Sep, 04:52
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17092: [FLINK-24093] Supports setting the percentage of kubernetes Request resources Wed, 01 Sep, 04:52
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17091: [FLINK-24083][python] Fix Python UDTF to handle properly when the result is str Wed, 01 Sep, 04:52
GitBox [GitHub] [flink] flinkbot commented on pull request #17093: [FLINK-24088][streaming] Log FlinkJobNotFoundException in debug instead of warn level in CollectResultFetcher for a cleaner log Wed, 01 Sep, 04:52
JING ZHANG (Jira) [jira] [Updated] (FLINK-24024) Fix syntax mistake in session Window TVF Wed, 01 Sep, 05:09
GitBox [GitHub] [flink] Aitozi commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client Wed, 01 Sep, 05:27
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably. Wed, 01 Sep, 05:30
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17093: [FLINK-24088][streaming] Log FlinkJobNotFoundException in debug instead of warn level in CollectResultFetcher for a cleaner log Wed, 01 Sep, 05:30
GitBox [GitHub] [flink] Aitozi commented on pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client Wed, 01 Sep, 05:31
Yang Wang (Jira) [jira] [Updated] (FLINK-15648) Support to configure limit for CPU and memory requirement Wed, 01 Sep, 05:48
GitBox [GitHub] [flink] Airblader commented on a change in pull request #16805: [FLINK-16501][table] Support IS JSON for Table API Wed, 01 Sep, 05:51
GitBox [GitHub] [flink] Airblader commented on a change in pull request #16805: [FLINK-16501][table] Support IS JSON for Table API Wed, 01 Sep, 05:52
Yang Wang (Jira) [jira] [Commented] (FLINK-24093) Supports setting the percentage of kubernetes Request resources Wed, 01 Sep, 05:55
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client Wed, 01 Sep, 05:55
GitBox [GitHub] [flink] AHeise merged pull request #17086: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting watermarks after source operator finishes [1.14] Wed, 01 Sep, 05:56
Arvid Heise (Jira) [jira] [Resolved] (FLINK-23351) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails due to "too few watermarks emitted" on azure Wed, 01 Sep, 05:57
Arvid Heise (Jira) [jira] [Commented] (FLINK-23351) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails due to "too few watermarks emitted" on azure Wed, 01 Sep, 05:57
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 · Next »Thread · Author · Date
Box list
Oct 20213951
Sep 20219992
Aug 202114065
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