flink-issues mailing list archives: May 2021

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 · 61 · 62 · 63 · 64 · 65 · 66 · 67 · 68 · 69 · 70 · 71 · 72 · 73 · 74 · 75 · 76 · 77 · 78 · 79 · 80 · 81 · 82 · Next »Thread · Author · Date
GitBox [GitHub] [flink] zoucao commented on pull request #15987: [FLINK-22437][table-planner-blink]set parallelism for not null filter Tue, 25 May, 02:14
xueluo (Jira) [jira] [Created] (FLINK-22762) cannot use set table.sql-dialect=hive; Tue, 25 May, 02:16
Andy (Jira) [jira] [Commented] (FLINK-22038) Update TopN node to be without rowNumber if rowNumber field is projected out after TopN Tue, 25 May, 02:24
Andy (Jira) [jira] [Updated] (FLINK-22038) Update TopN node to be without rowNumber if rowNumber field is projected out after TopN Tue, 25 May, 02:24
xingyuan cheng (Jira) [jira] [Commented] (FLINK-22762) cannot use set table.sql-dialect=hive; Tue, 25 May, 02:26
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink Tue, 25 May, 02:47
John Phelan (Jira) [jira] [Commented] (FLINK-21439) Adaptive Scheduler: Add support for exception history Tue, 25 May, 02:48
GitBox [GitHub] [flink] paul8263 commented on a change in pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin… Tue, 25 May, 02:58
GitBox [GitHub] [flink] paul8263 commented on a change in pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin… Tue, 25 May, 02:58
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15771: [FLINK-18934] Idle stream does not advance watermark in connected stream Tue, 25 May, 03:08
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15994: [hotfix] [docs] Fix typo in JDBC Execution Options Documentation Tue, 25 May, 03:09
Yang Wang (Jira) [jira] [Commented] (FLINK-22663) Release YARN resource very slow when cancel the job after some NodeManagers shutdown Tue, 25 May, 03:33
GitBox [GitHub] [flink] paul8263 commented on a change in pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin… Tue, 25 May, 03:39
GitBox [GitHub] [flink] paul8263 commented on a change in pull request #15927: [FLINK-22639][runtime] ClassLoaderUtil cannot print classpath of Flin… Tue, 25 May, 03:40
Jark Wu (Jira) [jira] [Updated] (FLINK-22762) cannot use set table.sql-dialect=hive; Tue, 25 May, 03:59
Rui Li (Jira) [jira] [Assigned] (FLINK-22760) HiveParser::setCurrentTimestamp fails with hive-3.1.2 Tue, 25 May, 04:08
GitBox [GitHub] [flink] cuspymd commented on a change in pull request #15986: [FLINK-22155][table] EXPLAIN statement should validate insert and query separately Tue, 25 May, 04:17
GitBox [GitHub] [flink] wuchong closed pull request #10880: [FLINK-15469][SQL] Update UpsertStreamTableSink and RetractStreamTabl… Tue, 25 May, 04:35
Samuel Fiddis (Jira) [jira] [Created] (FLINK-22763) avro-confluent format does not allow for authorization credentials to be supplied to Confluent Schema Registery Tue, 25 May, 05:28
JasonLee (Jira) [jira] [Commented] (FLINK-22762) cannot use set table.sql-dialect=hive; Tue, 25 May, 05:30
Samuel Fiddis (Jira) [jira] [Updated] (FLINK-22763) avro-confluent format does not allow for authorization credentials to be supplied to Confluent Schema Registry Tue, 25 May, 05:30
Samuel Fiddis (Jira) [jira] [Updated] (FLINK-22763) avro-confluent format does not allow for authorization credentials to be supplied to Confluent Schema Registry Tue, 25 May, 05:30
Samuel Fiddis (Jira) [jira] [Updated] (FLINK-22763) avro-confluent format does not allow for authorization credentials to be supplied to Confluent Schema Registry Tue, 25 May, 05:35
Piotr Nowojski (Jira) [jira] [Commented] (FLINK-16641) Announce sender's backlog to solve the deadlock issue without exclusive buffers Tue, 25 May, 05:44
Piotr Nowojski (Jira) [jira] [Commented] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering Tue, 25 May, 06:00
Piotr Nowojski (Jira) [jira] [Assigned] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering Tue, 25 May, 06:01
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink Tue, 25 May, 06:10
GitBox [GitHub] [flink] alec-brooks commented on pull request #15994: [hotfix] [docs] Fix typo in JDBC Execution Options Documentation Tue, 25 May, 06:20
luoyuxia (Jira) [jira] [Updated] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced Tue, 25 May, 06:28
luoyuxia (Jira) [jira] [Commented] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced Tue, 25 May, 06:34
luoyuxia (Jira) [jira] [Commented] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced Tue, 25 May, 06:35
luoyuxia (Jira) [jira] [Issue Comment Deleted] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced Tue, 25 May, 06:35
GitBox [GitHub] [flink] dawidwys merged pull request #15771: [FLINK-18934] Idle stream does not advance watermark in connected stream Tue, 25 May, 06:39
Dawid Wysakowicz (Jira) [jira] [Updated] (FLINK-18934) Idle stream does not advance watermark in connected stream Tue, 25 May, 06:41
Dawid Wysakowicz (Jira) [jira] [Closed] (FLINK-18934) Idle stream does not advance watermark in connected stream Tue, 25 May, 06:41
Samuel Fiddis (Jira) [jira] [Closed] (FLINK-22763) avro-confluent format does not allow for authorization credentials to be supplied to Confluent Schema Registry Tue, 25 May, 06:47
Leonard Xu (Jira) [jira] [Created] (FLINK-22764) Disable Values Source node in streaming plan optimization Tue, 25 May, 06:47
Tzu-Li (Gordon) Tai (Jira) [jira] [Commented] (FLINK-21420) Add path templating to the DataStream API Tue, 25 May, 06:50
Matthias (Jira) [jira] [Commented] (FLINK-21439) Adaptive Scheduler: Add support for exception history Tue, 25 May, 06:51
Leonard Xu (Jira) [jira] [Commented] (FLINK-22764) Disable Values Source node in streaming plan optimization Tue, 25 May, 06:56
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15938: [FLINK-11103][runtime] Set a configurable default uncaught exception handler for all entrypoints Tue, 25 May, 06:56
Kurt Young (Jira) [jira] [Commented] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced Tue, 25 May, 07:03
luoyuxia (Jira) [jira] [Commented] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced Tue, 25 May, 07:17
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15938: [FLINK-11103][runtime] Set a configurable default uncaught exception handler for all entrypoints Tue, 25 May, 07:18
Robert Metzger (Jira) [jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails Tue, 25 May, 07:34
luoyuxia (Jira) [jira] [Commented] (FLINK-22762) cannot use set table.sql-dialect=hive; Tue, 25 May, 07:35
Robert Metzger (Jira) [jira] [Reopened] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP Tue, 25 May, 07:35
Robert Metzger (Jira) [jira] [Updated] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP Tue, 25 May, 07:35
Timo Walther (Jira) [jira] [Updated] (FLINK-4542) Add MULTISET operations Tue, 25 May, 07:35
Timo Walther (Jira) [jira] [Reopened] (FLINK-4542) Add MULTISET operations Tue, 25 May, 07:35
luoyuxia (Jira) [jira] [Comment Edited] (FLINK-22762) cannot use set table.sql-dialect=hive; Tue, 25 May, 07:36
luoyuxia (Jira) [jira] [Comment Edited] (FLINK-22762) cannot use set table.sql-dialect=hive; Tue, 25 May, 07:36
Moses (Jira) [jira] [Commented] (FLINK-22685) Write data to hive table in batch mode throws FileNotFoundException. Tue, 25 May, 07:36
Robert Metzger (Jira) [jira] [Updated] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP Tue, 25 May, 07:36
Robert Metzger (Jira) [jira] [Commented] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP Tue, 25 May, 07:36
GitBox [GitHub] [flink-statefun] tzulitai closed pull request #230: [FLINK-22468] Fix Java 11 build by adding dependency to javax.annotations Tue, 25 May, 07:36
Timo Walther (Jira) [jira] [Closed] (FLINK-16277) StreamTableEnvironment.toAppendStream fails with Decimal types Tue, 25 May, 07:37
Timo Walther (Jira) [jira] [Updated] (FLINK-17362) Improve table examples to reflect latest status Tue, 25 May, 07:38
Timo Walther (Jira) [jira] [Updated] (FLINK-16277) StreamTableEnvironment.toAppendStream fails with Decimal types Tue, 25 May, 07:38
Tzu-Li (Gordon) Tai (Jira) [jira] [Closed] (FLINK-22468) Make StateFun build with Java 11 Tue, 25 May, 07:38
Tzu-Li (Gordon) Tai (Jira) [jira] [Updated] (FLINK-22468) Make StateFun build with Java 11 Tue, 25 May, 07:38
Robert Metzger (Jira) [jira] [Commented] (FLINK-22520) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition hangs Tue, 25 May, 07:38
Timo Walther (Jira) [jira] [Reopened] (FLINK-4262) Consider null handling during sorting Tue, 25 May, 07:39
Robert Metzger (Jira) [jira] [Commented] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout Tue, 25 May, 07:39
Timo Walther (Jira) [jira] [Updated] (FLINK-4262) Consider null handling during sorting Tue, 25 May, 07:39
GitBox [GitHub] [flink] wangyang0918 commented on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching Tue, 25 May, 07:39
Timo Walther (Jira) [jira] [Commented] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client Tue, 25 May, 07:41
Timo Walther (Jira) [jira] [Closed] (FLINK-20644) Check return type of ScalarFunction eval method shouldn't be void Tue, 25 May, 07:43
Robert Metzger (Jira) [jira] [Commented] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable Tue, 25 May, 07:43
Robert Metzger (Jira) [jira] [Created] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable Tue, 25 May, 07:43
Robert Metzger (Jira) [jira] [Commented] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout Tue, 25 May, 07:44
Robert Metzger (Jira) [jira] [Commented] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler` Tue, 25 May, 07:44
Robert Metzger (Jira) [jira] [Assigned] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler` Tue, 25 May, 07:45
Timo Walther (Jira) [jira] [Updated] (FLINK-19913) The precision in document and code of `INTERVAL DAY(p1) TO SECOND(p2)` are inconsistent Tue, 25 May, 07:45
Timo Walther (Jira) [jira] [Updated] (FLINK-22590) Add Scala implicit conversions for new API methods Tue, 25 May, 07:45
GitBox [GitHub] [flink-statefun] tzulitai opened a new pull request #235: [FLINK-20336] [core] Do not silently pass UNRECOGNIZED state mutations Tue, 25 May, 07:45
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-20336) RequestReplyFunction should not silently ignore UNRECOGNIZED state value mutations types Tue, 25 May, 07:46
GitBox [GitHub] [flink] akalash commented on pull request #15959: [FLINK-22684][runtime] Added ability to ignore in-flight data during … Tue, 25 May, 07:48
GitBox [GitHub] [flink] luoyuxia opened a new pull request #15995: [FLINK-22760][Hive] Fix issue of HiveParser::setCurrentTimestamp fails with hive-3.1.2 Tue, 25 May, 07:48
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-22760) HiveParser::setCurrentTimestamp fails with hive-3.1.2 Tue, 25 May, 07:49
Kurt Young (Jira) [jira] [Assigned] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced Tue, 25 May, 07:49
GitBox [GitHub] [flink] alpinegizmo commented on a change in pull request #15991: Adding gcs documentation. Connecting flink to gcs. Tue, 25 May, 07:49
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15959: [FLINK-22684][runtime] Added ability to ignore in-flight data during … Tue, 25 May, 07:50
GitBox [GitHub] [flink] flinkbot commented on pull request #15995: [FLINK-22760][Hive] Fix issue of HiveParser::setCurrentTimestamp fails with hive-3.1.2 Tue, 25 May, 07:51
GitBox [GitHub] [flink] AHeise commented on pull request #15991: Adding gcs documentation. Connecting flink to gcs. Tue, 25 May, 07:54
GitBox [GitHub] [flink] LiuPeien opened a new pull request #15996: FLINK-22663 Stop NMClient get stuck if there are stopped NodeManagers Tue, 25 May, 07:55
ASF GitHub Bot (Jira) [jira] [Updated] (FLINK-22663) Release YARN resource very slow when cancel the job after some NodeManagers shutdown Tue, 25 May, 07:56
Timo Walther (Jira) [jira] [Updated] (FLINK-10211) Time indicators are not correctly materialized for LogicalJoin Tue, 25 May, 07:56
Timo Walther (Jira) [jira] [Commented] (FLINK-22719) WindowJoinUtil.containsWindowStartEqualityAndEndEquality should not throw exception Tue, 25 May, 07:57
GitBox [GitHub] [flink] twalthr closed pull request #15989: [FLINK-22747] Upgrade to commons-io 2.8.0 Tue, 25 May, 07:58
GitBox [GitHub] [flink] flinkbot commented on pull request #15996: FLINK-22663 Stop YARN NMClient get stuck if it try to stop the containers on dead NodeManagers Tue, 25 May, 07:59
Qingsheng Ren (Jira) [jira] [Created] (FLINK-22766) Report metrics of KafkaConsumer in Kafka new source Tue, 25 May, 08:00
Zhilong Hong (Jira) [jira] [Updated] (FLINK-21920) Optimize ExecutionGraphToInputsLocationsRetrieverAdapter Tue, 25 May, 08:07
Zhilong Hong (Jira) [jira] [Updated] (FLINK-21920) Optimize DefaultScheduler#allocateSlots Tue, 25 May, 08:07
Zhilong Hong (Jira) [jira] [Updated] (FLINK-21920) Optimize ExecutionGraphToInputsLocationsRetrieverAdapter Tue, 25 May, 08:08
Jark Wu (Jira) [jira] [Commented] (FLINK-22764) Disable Values Source node in streaming plan optimization Tue, 25 May, 08:10
Zhilong Hong (Jira) [jira] [Created] (FLINK-22767) Optimize the initialization of ExecutionSlotSharingGroupBuilder Tue, 25 May, 08:10
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink Tue, 25 May, 08:12
Robert Metzger (Jira) [jira] [Commented] (FLINK-22464) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure hangs with `AdaptiveScheduler` Tue, 25 May, 08:13
GitBox [GitHub] [flink] flinkbot edited a comment on pull request #15959: [FLINK-22684][runtime] Added ability to ignore in-flight data during … Tue, 25 May, 08:13
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 · 61 · 62 · 63 · 64 · 65 · 66 · 67 · 68 · 69 · 70 · 71 · 72 · 73 · 74 · 75 · 76 · 77 · 78 · 79 · 80 · 81 · 82 · Next »Thread · Author · Date
Box list
Aug 2021679
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