[
https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-20114:
--
Assignee: Robert Metzger
> Test Kafka Source based on the new Source API
> -
[
https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-20114:
--
Assignee: (was: Robert Metzger)
> Test Kafka Source based on the new Source API
[
https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-20114:
--
Assignee: (was: Robert Metzger)
> Test Kafka Source based on the new Source API
rmetzger commented on pull request #14239:
URL: https://github.com/apache/flink/pull/14239#issuecomment-734697959
Note: CI is failing because of checkstyle.
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239561#comment-17239561
]
silence commented on FLINK-20281:
-
[~jark] Over window is also not supported
!screensho
[
https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
silence updated FLINK-20281:
Attachment: screenshot-1.png
> Window aggregation supports changelog stream input
> --
[
https://issues.apache.org/jira/browse/FLINK-20380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239560#comment-17239560
]
tianyu guo commented on FLINK-20380:
Thanks, I see what you mean. I'm going to check
rmetzger commented on pull request #14239:
URL: https://github.com/apache/flink/pull/14239#issuecomment-734696972
I've rebuild Flink using the latest version of this PR + I added myself some
logging into the JobMaster / Scheduler to find out the issue:
```
Caused by: org.apache.fl
[
https://issues.apache.org/jira/browse/FLINK-18262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239557#comment-17239557
]
Dian Fu commented on FLINK-18262:
-
https://dev.azure.com/apache-flink/apache-flink/_buil
flinkbot edited a comment on pull request #14244:
URL: https://github.com/apache/flink/pull/14244#issuecomment-734665945
## CI report:
* e2d25f123282470094c6ebe4122e04921304cc57 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239556#comment-17239556
]
Dian Fu commented on FLINK-20389:
-
cc [~AHeise]
> UnalignedCheckpointITCase failure cau
[
https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-20389:
Fix Version/s: 1.12.0
> UnalignedCheckpointITCase failure caused by NullPointerException
> ---
[
https://issues.apache.org/jira/browse/FLINK-20380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239553#comment-17239553
]
Zheng Hu commented on FLINK-20380:
--
Would you mind to check your jars ? Pls extract t
Matthias created FLINK-20389:
Summary: UnalignedCheckpointITCase failure caused by
NullPointerException
Key: FLINK-20389
URL: https://issues.apache.org/jira/browse/FLINK-20389
Project: Flink
Iss
dianfu commented on a change in pull request #14204:
URL: https://github.com/apache/flink/pull/14204#discussion_r531418654
##
File path: tools/azure-pipelines/build-apache-repo.yml
##
@@ -68,6 +68,35 @@ stages:
run_end_to_end: false
container: flink-build-
[
https://issues.apache.org/jira/browse/FLINK-20380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239551#comment-17239551
]
Zheng Hu commented on FLINK-20380:
--
I guess you have included a hive-metastore jar whic
[
https://issues.apache.org/jira/browse/FLINK-20382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-20382:
---
Priority: Critical (was: Major)
> Exception thrown from JobMaster.startScheduling() may be
[
https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239548#comment-17239548
]
hailong wang commented on FLINK-20386:
--
Yes, currently we just validate between the
[
https://issues.apache.org/jira/browse/FLINK-20375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239547#comment-17239547
]
YufeiLiu commented on FLINK-20375:
--
+1 for this.
I think it's necessary to provide a wa
flinkbot edited a comment on pull request #14245:
URL: https://github.com/apache/flink/pull/14245#issuecomment-734680404
## CI report:
* 4cc62d164e11aa827f6de269c8945667a6fc8461 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
rmetzger commented on a change in pull request #14222:
URL: https://github.com/apache/flink/pull/14222#discussion_r531416434
##
File path: docs/ops/deployment/overview.md
##
@@ -0,0 +1,358 @@
+---
+title: "Clusters & Deployment"
+nav-id: deployment
+nav-parent_id: ops
+nav-pos:
hailong wang created FLINK-20388:
Summary: Supports users setting operators' metrics name
Key: FLINK-20388
URL: https://issues.apache.org/jira/browse/FLINK-20388
Project: Flink
Issue Type: Im
[
https://issues.apache.org/jira/browse/FLINK-20162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20162:
---
Assignee: Leonard Xu
> Fix time zone problems for some time related functions
> ---
[
https://issues.apache.org/jira/browse/FLINK-20378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239529#comment-17239529
]
Jark Wu commented on FLINK-20378:
-
Supporting TIMESTAMP WITH LOCAL TIME ZONE is on the r
Jark Wu created FLINK-20387:
---
Summary: Support column of TIMESTAMP WITH LOCAL ZONE TIME type as
rowtime attribute
Key: FLINK-20387
URL: https://issues.apache.org/jira/browse/FLINK-20387
Project: Flink
flinkbot commented on pull request #14245:
URL: https://github.com/apache/flink/pull/14245#issuecomment-734680404
## CI report:
* 4cc62d164e11aa827f6de269c8945667a6fc8461 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-18545.
--
Release Note: Introduce `pipeline.name` to allow users to specify job name
by configuration. This opti
[
https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-18545:
---
Fix Version/s: (was: 1.11.4)
1.11.3
> Sql api cannot specify flink job name
>
[
https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239476#comment-17239476
]
godfrey he edited comment on FLINK-18545 at 11/27/20, 6:52 AM:
---
godfreyhe merged pull request #14233:
URL: https://github.com/apache/flink/pull/14233
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go t
flinkbot commented on pull request #14245:
URL: https://github.com/apache/flink/pull/14245#issuecomment-734675458
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pro
godfreyhe commented on a change in pull request #14228:
URL: https://github.com/apache/flink/pull/14228#discussion_r531410506
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/processors/utils/InputOrderCalculator.java
##
@@
[
https://issues.apache.org/jira/browse/FLINK-18897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18897:
---
Labels: pull-request-available (was: )
> Add documentation for the maxwell-json format
> --
fsk119 opened a new pull request #14245:
URL: https://github.com/apache/flink/pull/14245
## What is the purpose of the change
*Add document for maxwell format*
## Brief change log
> Update Chinese table overview
> --
dianfu commented on pull request #14242:
URL: https://github.com/apache/flink/pull/14242#issuecomment-734661595
@klion26 Yes, we should merge it to both master and release-1.12 branch.
This is an automated message from the Ap
T0UGH opened a new pull request #14244:
URL: https://github.com/apache/flink/pull/14244
## What is the purpose of the change
Sync `/docs/dev/table/index.zh.md` with the changes introduced in FLINK-18279
commit: 0fd9dc6f717fc4bb0a4e77b2212f317c8f318e03
## Brie
flinkbot edited a comment on pull request #14204:
URL: https://github.com/apache/flink/pull/14204#issuecomment-733048767
## CI report:
* 6550d3e1b01af94d4f652f993834b75272da1020 UNKNOWN
* 595ab82c651f8c225193eeeba90d6366fdff341d Azure:
[CANCELED](https://dev.azure.com/apache-f
flinkbot edited a comment on pull request #14235:
URL: https://github.com/apache/flink/pull/14235#issuecomment-734255724
## CI report:
* 49108f9990bc2844f793113e6a624c5aa3368ccb Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
wuchong commented on pull request #14204:
URL: https://github.com/apache/flink/pull/14204#issuecomment-734653626
Hi @HuangXingBo , `./tools/ci/docs.sh` will run `build_doc.sh` first, so I
think this can cover the problem you mentioned of linking Chinese documents to
English documents?
flinkbot edited a comment on pull request #14243:
URL: https://github.com/apache/flink/pull/14243#issuecomment-734643602
## CI report:
* 99365bd5ed999a9f19e1678a89ca1289a507d467 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14239:
URL: https://github.com/apache/flink/pull/14239#issuecomment-734365513
## CI report:
* 93e06a32ad83c81adcec2b71e6d1e61358fb8b88 UNKNOWN
* a56c3a56de6254bca14410b923cd9c4dce69dc98 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #14235:
URL: https://github.com/apache/flink/pull/14235#issuecomment-734255724
## CI report:
* 49108f9990bc2844f793113e6a624c5aa3368ccb Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #14243:
URL: https://github.com/apache/flink/pull/14243#issuecomment-734643602
## CI report:
* 99365bd5ed999a9f19e1678a89ca1289a507d467 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #14239:
URL: https://github.com/apache/flink/pull/14239#issuecomment-734365513
## CI report:
* 93e06a32ad83c81adcec2b71e6d1e61358fb8b88 UNKNOWN
* 4c0bcde650774d1afacb024f1045441269f04af3 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot commented on pull request #14243:
URL: https://github.com/apache/flink/pull/14243#issuecomment-734638648
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pro
[
https://issues.apache.org/jira/browse/FLINK-20366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20366:
---
Labels: pull-request-available (was: )
> ColumnIntervalUtil#getColumnIntervalWithFilter doe
godfreyhe opened a new pull request #14243:
URL: https://github.com/apache/flink/pull/14243
## What is the purpose of the change
*ColumnIntervalUtil#getColumnIntervalWithFilter should consider constant
predicate, see https://issues.apache.org/jira/browse/FLINK-20366*
#
[
https://issues.apache.org/jira/browse/FLINK-20368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239503#comment-17239503
]
Danny Chen edited comment on FLINK-20368 at 11/27/20, 4:22 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-20378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239504#comment-17239504
]
wxmimperio edited comment on FLINK-20378 at 11/27/20, 4:10 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-20378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239504#comment-17239504
]
wxmimperio commented on FLINK-20378:
[~jark]
Thank you for your answer.
However, I a
[
https://issues.apache.org/jira/browse/FLINK-20368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239503#comment-17239503
]
Danny Chen commented on FLINK-20368:
Hi [~ksp0422] ~
The DDL does not use DataStrea
HuangXingBo commented on pull request #14204:
URL: https://github.com/apache/flink/pull/14204#issuecomment-734633566
Many Chinese docs newly added recently have links to English documents that
cause `build_doc.sh` to fail. But the existing logic of `check_docs.sh` is to
test whether there
becketqin commented on a change in pull request #14239:
URL: https://github.com/apache/flink/pull/14239#discussion_r531331794
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContextTest.java
##
@@ -170,6 +178,70 @@ public
flinkbot edited a comment on pull request #14239:
URL: https://github.com/apache/flink/pull/14239#issuecomment-734365513
## CI report:
* 93e06a32ad83c81adcec2b71e6d1e61358fb8b88 UNKNOWN
* 4c0bcde650774d1afacb024f1045441269f04af3 Azure:
[FAILURE](https://dev.azure.com/apache-fl
zlzhang0122 commented on pull request #13580:
URL: https://github.com/apache/flink/pull/13580#issuecomment-734631818
> Thanks for looking into that @zizhang0122. Unfortunately, you change was
already merged as part of
[FLINK-19553](https://issues.apache.org/jira/browse/FLINK-19553).
becketqin commented on a change in pull request #14239:
URL: https://github.com/apache/flink/pull/14239#discussion_r531331794
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContextTest.java
##
@@ -170,6 +178,70 @@ public
[
https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239500#comment-17239500
]
Congxian Qiu edited comment on FLINK-20376 at 11/27/20, 3:40 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239500#comment-17239500
]
Congxian Qiu commented on FLINK-20376:
--
The exception said that there is some opera
[
https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-20385:
---
Description:
In FLIP-107, we support read meta from CDC format Debezium, Canal-json is also
another
Leonard Xu created FLINK-20385:
--
Summary: Allow to read metadata for Canal-json format
Key: FLINK-20385
URL: https://issues.apache.org/jira/browse/FLINK-20385
Project: Flink
Issue Type: New Feat
tzulitai commented on a change in pull request #179:
URL: https://github.com/apache/flink-statefun/pull/179#discussion_r531363954
##
File path: statefun-examples/statefun-python-walkthrough-example/walkthrough.py
##
@@ -111,12 +115,29 @@ def state2(context, message):
conte
flinkbot edited a comment on pull request #14240:
URL: https://github.com/apache/flink/pull/14240#issuecomment-734499029
## CI report:
* bb6fc14107467373c1422cb23a06ddda8bb585ec Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
uglymagic commented on a change in pull request #11830:
URL: https://github.com/apache/flink/pull/11830#discussion_r531363295
##
File path:
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/aggregate/GroupAggFunctionTestBase.java
##
@
wangyang0918 commented on pull request #14237:
URL: https://github.com/apache/flink/pull/14237#issuecomment-734623706
Another concern is that the following command has the same semantic but it
could not work too. Because we only check the cli option
`cmd.hasOption(applicationId.getOpt())`.
wangyang0918 commented on pull request #14237:
URL: https://github.com/apache/flink/pull/14237#issuecomment-734618924
@rmetzger Thanks for this PR. I am afraid we could not simply use `-yid`
instead of `id`. Since all other options does not have the prefix (`y` for
short, `yarn` for long)
[
https://issues.apache.org/jira/browse/FLINK-20380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239496#comment-17239496
]
tianyu guo commented on FLINK-20380:
Hello, do you know the reason for my problem? I
flinkbot commented on pull request #14242:
URL: https://github.com/apache/flink/pull/14242#issuecomment-734591430
## CI report:
* 64189c2e0b4c4069fc46c0f2fd79f2cacc491c89 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #14241:
URL: https://github.com/apache/flink/pull/14241#issuecomment-734564072
## CI report:
* 3b3d1e5f945d5e8951d80d314668a986b6000d78 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-20327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-20327.
Resolution: Fixed
master (1.13): 562e5a44fddf862517cb7e4e3c3088610b00ee35
release-1.12: 3c432d82e
JingsongLi merged pull request #14231:
URL: https://github.com/apache/flink/pull/14231
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
[
https://issues.apache.org/jira/browse/FLINK-20241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-20241.
Resolution: Fixed
master (1.13): fad84798d9b66ae3b43fb3d4940a1e5c3b26600e
release-1.12: 598386763
JingsongLi merged pull request #14203:
URL: https://github.com/apache/flink/pull/14203
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
flinkbot commented on pull request #14242:
URL: https://github.com/apache/flink/pull/14242#issuecomment-734568557
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pro
[
https://issues.apache.org/jira/browse/FLINK-20384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20384:
---
Labels: pull-request-available (was: )
> Broken Link in deployment/ha/kubernetes_ha.zh.md
>
HuangXingBo opened a new pull request #14242:
URL: https://github.com/apache/flink/pull/14242
## What is the purpose of the change
*This pull request will fix wrong links in some Chinese docs*
## Brief change log
- *Fix wrong links in `plugins.zh.md`*
- *Fix w
flinkbot commented on pull request #14241:
URL: https://github.com/apache/flink/pull/14241#issuecomment-734564072
## CI report:
* 3b3d1e5f945d5e8951d80d314668a986b6000d78 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #14177:
URL: https://github.com/apache/flink/pull/14177#issuecomment-732207895
## CI report:
* ce283f64f17cadd3f4ab80534343dbfe917867fa Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-20259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239491#comment-17239491
]
Xintong Song commented on FLINK-20259:
--
Thanks [~vthinkxie]. I've assigned you. Ple
[
https://issues.apache.org/jira/browse/FLINK-20259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-20259:
Assignee: Yadong Xie
> Add explanation that "configured values" for JM/TM memory sizes in
[
https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239490#comment-17239490
]
Yun Tang commented on FLINK-20376:
--
I think the reported message has given enough hint:
[
https://issues.apache.org/jira/browse/FLINK-20259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239487#comment-17239487
]
Yadong Xie commented on FLINK-20259:
Hi, could anyone assign this to me?
I can help
flinkbot commented on pull request #14241:
URL: https://github.com/apache/flink/pull/14241#issuecomment-734546268
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the pro
KarmaGYZ commented on pull request #14241:
URL: https://github.com/apache/flink/pull/14241#issuecomment-734543108
cc @xintongsong
This is an automated message from the Apache Git Service.
To respond to the message, please lo
[
https://issues.apache.org/jira/browse/FLINK-20073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20073:
---
Labels: pull-request-available (was: )
> Add kerberos setup documentation for native k8s in
KarmaGYZ opened a new pull request #14241:
URL: https://github.com/apache/flink/pull/14241
## What is the purpose of the change
Add native k8s integration to kerberos setup documentation
This is an automate
[
https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239484#comment-17239484
]
Dian Fu commented on FLINK-19863:
-
[~Leonard Xu] Thanks a lot~
> SQLClientHBaseITCase.t
1 - 100 of 439 matches
Mail list logo
