GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation |
Wed, 27 Nov, 17:53 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox |
Wed, 27 Nov, 17:54 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10341: [FLINK-14974][runtime] Calculate managed memory fractions with BigDecimal and round down it properly |
Wed, 27 Nov, 17:55 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile |
Wed, 27 Nov, 17:59 |
Bowen Li (Jira) |
[jira] [Created] (FLINK-14980) add documentation and example for function DDL |
Wed, 27 Nov, 18:00 |
GitBox |
[GitHub] [flink] eskabetxe commented on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink |
Wed, 27 Nov, 18:08 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send() |
Wed, 27 Nov, 18:24 |
GitBox |
[GitHub] [flink] flinkbot commented on issue #10342: [FLINK-14967][table] Add a utility for creating data types via reflection |
Wed, 27 Nov, 18:25 |
GitBox |
[GitHub] [flink] bowenli86 commented on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support |
Wed, 27 Nov, 18:31 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink |
Wed, 27 Nov, 18:33 |
GitBox |
[GitHub] [flink] HuangZhenQiu commented on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support |
Wed, 27 Nov, 18:36 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support |
Wed, 27 Nov, 18:53 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10330: [FLINK-14189][runtime] Extend TaskExecutor to support dynamic slot allocation |
Wed, 27 Nov, 18:54 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10341: [FLINK-14974][runtime] Calculate managed memory fractions with BigDecimal and round down it properly |
Wed, 27 Nov, 18:55 |
GitBox |
[GitHub] [flink] eskabetxe edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink |
Wed, 27 Nov, 18:55 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10342: [FLINK-14967][table] Add a utility for creating data types via reflection |
Wed, 27 Nov, 18:55 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink |
Wed, 27 Nov, 19:03 |
GitBox |
[GitHub] [flink] bowenli86 commented on a change in pull request #10318: [FLINK-14721][hive]HiveTableSource implement LimitableTableSource interface |
Wed, 27 Nov, 19:20 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support |
Wed, 27 Nov, 19:23 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile |
Wed, 27 Nov, 19:28 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink |
Wed, 27 Nov, 19:32 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10342: [FLINK-14967][table] Add a utility for creating data types via reflection |
Wed, 27 Nov, 19:54 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support |
Wed, 27 Nov, 20:28 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink |
Wed, 27 Nov, 20:38 |
GitBox |
[GitHub] [flink] bowenli86 commented on a change in pull request #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support |
Wed, 27 Nov, 21:05 |
GitBox |
[GitHub] [flink] HuangZhenQiu commented on a change in pull request #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support |
Wed, 27 Nov, 21:23 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support |
Wed, 27 Nov, 21:57 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support |
Wed, 27 Nov, 22:26 |
GitBox |
[GitHub] [flink] walterddr commented on a change in pull request #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time |
Wed, 27 Nov, 23:20 |
GitBox |
[GitHub] [flink] walterddr commented on a change in pull request #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time |
Wed, 27 Nov, 23:20 |
GitBox |
[GitHub] [flink] walterddr commented on a change in pull request #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time |
Wed, 27 Nov, 23:20 |
GitBox |
[GitHub] [flink] walterddr commented on a change in pull request #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time |
Wed, 27 Nov, 23:20 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10327: [FLINK-14914][table] refactor CatalogFunction by adding Language support |
Wed, 27 Nov, 23:25 |
GitBox |
[GitHub] [flink] XuQianJin-Stars commented on issue #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time |
Wed, 27 Nov, 23:47 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time |
Thu, 28 Nov, 00:20 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #8746: [hotfix][FLINK-11120][table]fix the bug of timestampadd handles time |
Thu, 28 Nov, 00:49 |
GitBox |
[GitHub] [flink] fangpengcheng95 opened a new pull request #10343: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource |
Thu, 28 Nov, 02:12 |
ASF GitHub Bot (Jira) |
[jira] [Updated] (FLINK-14729) Multi-topics consuming from KafkaTableSource |
Thu, 28 Nov, 02:13 |
GitBox |
[GitHub] [flink] flinkbot commented on issue #10343: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource |
Thu, 28 Nov, 02:15 |
liu (Jira) |
[jira] [Created] (FLINK-14981) web frontend support dynamic adjustment of the log level |
Thu, 28 Nov, 02:18 |
GitBox |
[GitHub] [flink] zhuzhurk commented on a change in pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible |
Thu, 28 Nov, 02:31 |
yuzhemin (Jira) |
[jira] [Updated] (FLINK-14966) Online document typo, package name org.apache.flinktypes.xxxx should be corrected as org.apache.flink.types.xxxx . From online documents flink-docs-release-1.9 (Application Development > Basic API Concepts>Supported Data Types>Values). |
Thu, 28 Nov, 02:38 |
Yingjie Cao (Jira) |
[jira] [Commented] (FLINK-14845) Introduce data compression to blocking shuffle. |
Thu, 28 Nov, 02:47 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible |
Thu, 28 Nov, 02:47 |
GitBox |
[GitHub] [flink] flinkbot commented on issue #10343: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource |
Thu, 28 Nov, 02:50 |
yuzhemin (Jira) |
[jira] [Commented] (FLINK-14966) Online document typo, package name org.apache.flinktypes.xxxx should be corrected as org.apache.flink.types.xxxx . From online documents flink-docs-release-1.9 (Application Development > Basic API Concepts>Supported Data Types>Values). |
Thu, 28 Nov, 02:55 |
Yingjie Cao (Jira) |
[jira] [Commented] (FLINK-14952) Yarn containers can exceed physical memory limits when using BoundedBlockingSubpartition. |
Thu, 28 Nov, 03:03 |
lining (Jira) |
[jira] [Commented] (FLINK-14717) JobExceptionsHandler show exceptions of prior attempts |
Thu, 28 Nov, 03:04 |
lining (Jira) |
[jira] [Updated] (FLINK-14717) JobExceptionsHandler show exceptions of prior attempts |
Thu, 28 Nov, 03:04 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible |
Thu, 28 Nov, 03:16 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10343: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource |
Thu, 28 Nov, 03:19 |
GitBox |
[GitHub] [flink] fangpengcheng95 commented on issue #10343: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource |
Thu, 28 Nov, 03:41 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible |
Thu, 28 Nov, 03:46 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10343: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource |
Thu, 28 Nov, 04:18 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10343: [FLINK-14729][connectors] Multi-topics consuming from KafkaTableSource |
Thu, 28 Nov, 04:47 |
lining (Jira) |
[jira] [Updated] (FLINK-14147) Reduce REST API Request/Response redundancy |
Thu, 28 Nov, 06:39 |
GitBox |
[GitHub] [flink] klion26 opened a new pull request #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api |
Thu, 28 Nov, 06:48 |
ASF GitHub Bot (Jira) |
[jira] [Updated] (FLINK-14264) Expose CheckpointBackend in checkpoint config RestAPI |
Thu, 28 Nov, 06:49 |
GitBox |
[GitHub] [flink] klion26 commented on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api |
Thu, 28 Nov, 06:51 |
GitBox |
[GitHub] [flink] flinkbot commented on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api |
Thu, 28 Nov, 06:51 |
lining (Jira) |
[jira] [Commented] (FLINK-14470) Watermark display not working with high parallelism job |
Thu, 28 Nov, 06:52 |
lining (Jira) |
[jira] [Commented] (FLINK-14470) Watermark display not working with high parallelism job |
Thu, 28 Nov, 06:52 |
Eric Lee (Jira) |
[jira] [Updated] (FLINK-14963) Massive Duplicated Useless Oss Message in jobmanager.log |
Thu, 28 Nov, 06:52 |
GitBox |
[GitHub] [flink] TisonKun commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients |
Thu, 28 Nov, 06:56 |
GitBox |
[GitHub] [flink] TisonKun commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients |
Thu, 28 Nov, 06:56 |
GitBox |
[GitHub] [flink] TisonKun commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients |
Thu, 28 Nov, 06:56 |
GitBox |
[GitHub] [flink] TisonKun commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients |
Thu, 28 Nov, 06:56 |
GitBox |
[GitHub] [flink] TisonKun commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients |
Thu, 28 Nov, 06:56 |
GitBox |
[GitHub] [flink] TisonKun commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients |
Thu, 28 Nov, 06:56 |
GitBox |
[GitHub] [flink] TisonKun commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients |
Thu, 28 Nov, 06:56 |
GitBox |
[GitHub] [flink] TisonKun commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients |
Thu, 28 Nov, 06:56 |
GitBox |
[GitHub] [flink] TisonKun commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients |
Thu, 28 Nov, 06:56 |
GitBox |
[GitHub] [flink] klion26 commented on a change in pull request #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api |
Thu, 28 Nov, 06:57 |
GitBox |
[GitHub] [flink] klion26 commented on a change in pull request #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api |
Thu, 28 Nov, 06:57 |
GitBox |
[GitHub] [flink] TisonKun commented on issue #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients |
Thu, 28 Nov, 06:57 |
GitBox |
[GitHub] [flink] TisonKun commented on a change in pull request #9973: [FLINK-9955] Add Kubernetes ClusterDescriptor to support deploying session cluster. |
Thu, 28 Nov, 07:03 |
lining (Jira) |
[jira] [Comment Edited] (FLINK-14470) Watermark display not working with high parallelism job |
Thu, 28 Nov, 07:12 |
lining (Jira) |
[jira] [Comment Edited] (FLINK-14470) Watermark display not working with high parallelism job |
Thu, 28 Nov, 07:13 |
lining (Jira) |
[jira] [Comment Edited] (FLINK-14470) Watermark display not working with high parallelism job |
Thu, 28 Nov, 07:13 |
GitBox |
[GitHub] [flink] HuangZhenQiu commented on issue #9711: [FLINK-14033][yarn] upload user artifacts for yarn job cluster |
Thu, 28 Nov, 07:13 |
GitBox |
[GitHub] [flink] flinkbot commented on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api |
Thu, 28 Nov, 07:15 |
lining (Jira) |
[jira] [Comment Edited] (FLINK-14470) Watermark display not working with high parallelism job |
Thu, 28 Nov, 07:16 |
Zhenqiu Huang (Jira) |
[jira] [Created] (FLINK-14982) YARN IT Test Case log config is mistakenly disabled |
Thu, 28 Nov, 07:21 |
GitBox |
[GitHub] [flink] HuangZhenQiu commented on issue #9711: [FLINK-14033][yarn] upload user artifacts for yarn job cluster |
Thu, 28 Nov, 07:21 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9711: [FLINK-14033][yarn] upload user artifacts for yarn job cluster |
Thu, 28 Nov, 07:27 |
lining (Jira) |
[jira] [Comment Edited] (FLINK-14470) Watermark display not working with high parallelism job |
Thu, 28 Nov, 07:29 |
lining (Jira) |
[jira] [Comment Edited] (FLINK-14470) Watermark display not working with high parallelism job |
Thu, 28 Nov, 07:30 |
lining (Jira) |
[jira] [Issue Comment Deleted] (FLINK-14470) Watermark display not working with high parallelism job |
Thu, 28 Nov, 07:31 |
lining (Jira) |
[jira] [Commented] (FLINK-8949) Rest API failure with long URL |
Thu, 28 Nov, 07:38 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api |
Thu, 28 Nov, 07:45 |
Dezhi Cai (Jira) |
[jira] [Updated] (FLINK-14970) Doomed test for equality to NaN |
Thu, 28 Nov, 07:53 |
Dezhi Cai (Jira) |
[jira] [Updated] (FLINK-14970) Doomed test for equality to NaN |
Thu, 28 Nov, 07:56 |
Dezhi Cai (Jira) |
[jira] [Commented] (FLINK-14970) Doomed test for equality to NaN |
Thu, 28 Nov, 07:57 |
GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9711: [FLINK-14033][yarn] upload user artifacts for yarn job cluster |
Thu, 28 Nov, 07:57 |
Timo Walther (Jira) |
[jira] [Created] (FLINK-14983) Add interfaces for input type inference |
Thu, 28 Nov, 08:03 |
Timo Walther (Jira) |
[jira] [Updated] (FLINK-14983) Add interfaces for input type inference |
Thu, 28 Nov, 08:04 |
lining (Jira) |
[jira] [Comment Edited] (FLINK-14717) JobExceptionsHandler show exceptions of prior attempts |
Thu, 28 Nov, 08:12 |
lining (Jira) |
[jira] [Comment Edited] (FLINK-14717) JobExceptionsHandler show exceptions of prior attempts |
Thu, 28 Nov, 08:12 |
lining (Jira) |
[jira] [Comment Edited] (FLINK-14717) JobExceptionsHandler show exceptions of prior attempts |
Thu, 28 Nov, 08:12 |
Fang Peng Cheng (Jira) |
[jira] [Commented] (FLINK-14729) Multi-topics consuming from KafkaTableSource |
Thu, 28 Nov, 08:22 |