[
https://issues.apache.org/jira/browse/FLINK-12085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacky Yin updated FLINK-12085:
--
Labels: (was: stale-minor)
> Improve Mesos job cluster entry point 'MesosJobClusterEntrypoint'
> --
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321850#comment-17321850
]
Jark Wu commented on FLINK-22281:
-
If you don't have the full historical data, only the
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-22281.
---
Resolution: Not A Problem
> flink sql consumer kakfa canal-json message then sum(amount)
> ---
[
https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-22275:
---
Assignee: Yi Tang
> Datagen add a max lag option for a series of timestamp-related types
>
[
https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-22275:
---
Assignee: (was: Yi Tang)
> Datagen add a max lag option for a series of timestamp-related types
[
https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321851#comment-17321851
]
Jark Wu commented on FLINK-22275:
-
We should discuss about the API/options and behaviors
[
https://issues.apache.org/jira/browse/FLINK-16120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Li resolved FLINK-16120.
Release Note: Hive connector doc has been moved to the {{Table & SQL
Connectors}}. Closing this one.
[
https://issues.apache.org/jira/browse/FLINK-16120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Li updated FLINK-16120:
---
Release Note: (was: Hive connector doc has been moved to the {{Table &
SQL Connectors}}. Closing this one.
[
https://issues.apache.org/jira/browse/FLINK-16120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321852#comment-17321852
]
Rui Li commented on FLINK-16120:
Hive connector doc has been moved to the {{Table & SQL
[
https://issues.apache.org/jira/browse/FLINK-14927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-14927:
Labels: (was: stale-minor)
> Remove
> LegacyTimestampTypeInfo/LegacyLocalDateTimeTypeInfo/LegacyInstant
[
https://issues.apache.org/jira/browse/FLINK-14927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-14927:
Priority: Major (was: Minor)
> Remove
> LegacyTimestampTypeInfo/LegacyLocalDateTimeTypeInfo/LegacyInstan
[
https://issues.apache.org/jira/browse/FLINK-22279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321854#comment-17321854
]
todd commented on FLINK-22279:
--
Thank you very much, what you said is right. I did not pay
[
https://issues.apache.org/jira/browse/FLINK-22279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
todd closed FLINK-22279.
Resolution: Invalid
> Upload the pipeline.classpaths file in yarn application mode
> -
[
https://issues.apache.org/jira/browse/FLINK-16325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
todd closed FLINK-16325.
Resolution: Invalid
> A connection check is required, and it needs to be reopened when the JDBC
> connection is
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321856#comment-17321856
]
xx chai commented on FLINK-22281:
-
i add the Parameter
streamTableEnvironment.getConfi
[
https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321863#comment-17321863
]
Dian Fu commented on FLINK-22125:
-
Hi [~RocMarshal], there is a method named is_empty()
[
https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321843#comment-17321843
]
Roc Marshal edited comment on FLINK-22125 at 4/15/21, 2:42 AM:
---
dianfu opened a new pull request #15618:
URL: https://github.com/apache/flink/pull/15618
## What is the purpose of the change
*Currently it will throw KeyError when a key doesn't exist when calling
MapState.get. This pull request change the behavior of MapState.get to None
when
[
https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-22125:
---
Labels: pull-request-available (was: )
> Revisit the return value of MapState.get when the
flinkbot commented on pull request #15618:
URL: https://github.com/apache/flink/pull/15618#issuecomment-820020073
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
dianfu closed pull request #15609:
URL: https://github.com/apache/flink/pull/15609
--
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 to the specific comment.
For queries about this service, please
[
https://issues.apache.org/jira/browse/FLINK-22273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-22273.
---
Resolution: Fixed
Merged to master via 00a92b4fb188a8c1504279c07504b8fa10ca46e6
> Add documentation for Gen
[
https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-22125:
---
Assignee: Dian Fu
> Revisit the return value of MapState.get when the key doesn't exist
> -
[
https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-22125:
Summary: Revisit the return value of MapState.get when a key doesn't exist
(was: Revisit the return value
[
https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321868#comment-17321868
]
Xu Guangheng commented on FLINK-22113:
--
Hello [~jark],
Thanks for you reply.
Yes
[
https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321868#comment-17321868
]
Xu Guangheng edited comment on FLINK-22113 at 4/15/21, 3:00 AM:
--
HideOnBush created FLINK-22283:
--
Summary: GraphiteReporter Metrics named xxx alredy exists
Key: FLINK-22283
URL: https://issues.apache.org/jira/browse/FLINK-22283
Project: Flink
Issue Type: Bug
flinkbot edited a comment on pull request #15020:
URL: https://github.com/apache/flink/pull/15020#issuecomment-785804760
## CI report:
* 4a4f8a643c603007519ebefc4c1e732347b6d3d2 UNKNOWN
* 6ebcd56d7080224fcd21f0f22ee467a951feb2e0 Azure:
[FAILURE](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321872#comment-17321872
]
Yi Tang commented on FLINK-22275:
-
Of course.
First of all, it is obvious that this opt
Zhilong Hong created FLINK-22284:
Summary: Null address will be logged when channel is closed in
NettyPartitionRequestClient
Key: FLINK-22284
URL: https://issues.apache.org/jira/browse/FLINK-22284
Pro
flinkbot commented on pull request #15618:
URL: https://github.com/apache/flink/pull/15618#issuecomment-820024114
## CI report:
* a5030e29742e58a6df2dbca7d7e1ce27a90e8722 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhilong Hong updated FLINK-22284:
-
Description:
In NettyPartitionRequestClient#requestSubpartition, when a channel is closed,
the
kezhuw commented on a change in pull request #15601:
URL: https://github.com/apache/flink/pull/15601#discussion_r613727138
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/CoordinatorEventsExactlyOnceITCase.java
##
@@ -285,41 +348,130 @
[
https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhilong Hong updated FLINK-22284:
-
Description:
In NettyPartitionRequestClient#requestSubpartition, when a channel is closed,
the
[
https://issues.apache.org/jira/browse/FLINK-22284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhilong Hong updated FLINK-22284:
-
Attachment: exception.png
> Null address will be logged when channel is closed in
> NettyPartit
[
https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin updated FLINK-6113:
Attachment: split_select.patch
> Implement split/select with Side Outputs
> ---
[
https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chen Qin closed FLINK-6113.
---
Resolution: Fixed
> Implement split/select with Side Outputs
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-6113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321877#comment-17321877
]
Chen Qin commented on FLINK-6113:
-
Seems community already get rid of split and select tr
[
https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321872#comment-17321872
]
Yi Tang edited comment on FLINK-22275 at 4/15/21, 3:22 AM:
---
Of
[
https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321872#comment-17321872
]
Yi Tang edited comment on FLINK-22275 at 4/15/21, 3:23 AM:
---
Of
flinkbot edited a comment on pull request #14484:
URL: https://github.com/apache/flink/pull/14484#issuecomment-750730068
## CI report:
* adaac76c0ae0a62ca7f156340653128a43bf7b20 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321878#comment-17321878
]
xx chai commented on FLINK-22281:
-
thanks [~jark] I solve the question .
> flink sql co
[
https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321868#comment-17321868
]
Xu Guangheng edited comment on FLINK-22113 at 4/15/21, 3:25 AM:
--
flinkbot edited a comment on pull request #15525:
URL: https://github.com/apache/flink/pull/15525#issuecomment-815836876
## CI report:
* 00492ee3748f2830378d9f7c73afa8b6e3e48fcb Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15618:
URL: https://github.com/apache/flink/pull/15618#issuecomment-820024114
## CI report:
* a5030e29742e58a6df2dbca7d7e1ce27a90e8722 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321879#comment-17321879
]
Yun Gao commented on FLINK-22140:
-
Tested the unified binary save-point with [an artific
KurtYoung commented on a change in pull request #15549:
URL: https://github.com/apache/flink/pull/15549#discussion_r613734122
##
File path:
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java
##
@@ -442,6 +448,4
KurtYoung commented on a change in pull request #15603:
URL: https://github.com/apache/flink/pull/15603#discussion_r613735406
##
File path:
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliTableauResultViewTest.java
##
@@ -233,22 +233,7 @@ public
KurtYoung commented on a change in pull request #15603:
URL: https://github.com/apache/flink/pull/15603#discussion_r613735406
##
File path:
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliTableauResultViewTest.java
##
@@ -233,22 +233,7 @@ public
flinkbot edited a comment on pull request #14484:
URL: https://github.com/apache/flink/pull/14484#issuecomment-750730068
## CI report:
* adaac76c0ae0a62ca7f156340653128a43bf7b20 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15020:
URL: https://github.com/apache/flink/pull/15020#issuecomment-785804760
## CI report:
* 4a4f8a643c603007519ebefc4c1e732347b6d3d2 UNKNOWN
* 6ebcd56d7080224fcd21f0f22ee467a951feb2e0 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #15525:
URL: https://github.com/apache/flink/pull/15525#issuecomment-815836876
## CI report:
* 00492ee3748f2830378d9f7c73afa8b6e3e48fcb Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15607:
URL: https://github.com/apache/flink/pull/15607#issuecomment-819349925
## CI report:
* 58d729cf2d2ecb4239cd3a2ee380e64f484e7df0 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321885#comment-17321885
]
Yang Wang commented on FLINK-22262:
---
Could you please share the JobManager logs when y
[
https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-22262:
--
Component/s: Deployment / Kubernetes
> Flink on Kubernetes ConfigMaps are created without OwnerReferen
lirui-apache commented on a change in pull request #15549:
URL: https://github.com/apache/flink/pull/15549#discussion_r613742399
##
File path:
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java
##
@@ -442,6 +44
flinkbot edited a comment on pull request #15549:
URL: https://github.com/apache/flink/pull/15549#issuecomment-816597084
## CI report:
* 6bc0d4aa007b6fe629822142a3e6eb1d6c6fe7d9 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15607:
URL: https://github.com/apache/flink/pull/15607#issuecomment-819349925
## CI report:
* 58d729cf2d2ecb4239cd3a2ee380e64f484e7df0 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15605:
URL: https://github.com/apache/flink/pull/15605#issuecomment-819212302
## CI report:
* e9f7f5526078a9ed65d6403eab5cde7fc82b177b Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321901#comment-17321901
]
Kurt Young commented on FLINK-22280:
I also think this would be helpful. [~flacombe]
flinkbot edited a comment on pull request #15549:
URL: https://github.com/apache/flink/pull/15549#issuecomment-816597084
## CI report:
* 6bc0d4aa007b6fe629822142a3e6eb1d6c6fe7d9 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15546:
URL: https://github.com/apache/flink/pull/15546#issuecomment-816538766
## CI report:
* e16ddc3fb9157cc0b70ea07023202a2ebdd9fe15 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15595:
URL: https://github.com/apache/flink/pull/15595#issuecomment-818681408
## CI report:
* 6e06c0cb3d52f23f31ab7855880da5177f7d1627 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
kezhuw commented on a change in pull request #15605:
URL: https://github.com/apache/flink/pull/15605#discussion_r613755154
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/SubtaskGatewayImpl.java
##
@@ -64,6 +69,17 @@
s
kezhuw commented on a change in pull request #15605:
URL: https://github.com/apache/flink/pull/15605#discussion_r613758218
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/SubtaskGatewayImpl.java
##
@@ -64,6 +69,17 @@
s
flinkbot edited a comment on pull request #15595:
URL: https://github.com/apache/flink/pull/15595#issuecomment-818681408
## CI report:
* 6e06c0cb3d52f23f31ab7855880da5177f7d1627 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321914#comment-17321914
]
Jark Wu commented on FLINK-22281:
-
[~chaixiaoxue] you should add the configuration by
{
[
https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321916#comment-17321916
]
hayden zhou commented on FLINK-22054:
-
[~trohrmann] [~yittg] I can't submit batch jo
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321917#comment-17321917
]
xx chai commented on FLINK-22281:
-
Yes, I have added this parameter correctly
> flink s
flinkbot edited a comment on pull request #15438:
URL: https://github.com/apache/flink/pull/15438#issuecomment-810469495
## CI report:
* d16ff5596d58f30aa2752007efc8f7908059596d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321916#comment-17321916
]
hayden zhou edited comment on FLINK-22054 at 4/15/21, 5:48 AM:
---
flinkbot edited a comment on pull request #15595:
URL: https://github.com/apache/flink/pull/15595#issuecomment-818681408
## CI report:
* 6e06c0cb3d52f23f31ab7855880da5177f7d1627 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15607:
URL: https://github.com/apache/flink/pull/15607#issuecomment-819349925
## CI report:
* 8a62da0c014fc75b3bad145c2fd46fc1809a9c28 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
KurtYoung commented on a change in pull request #15603:
URL: https://github.com/apache/flink/pull/15603#discussion_r613735406
##
File path:
flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliTableauResultViewTest.java
##
@@ -233,22 +233,7 @@ public
KurtYoung merged pull request #15603:
URL: https://github.com/apache/flink/pull/15603
--
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 to the specific comment.
For queries about this service, plea
[
https://issues.apache.org/jira/browse/FLINK-22169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-22169.
--
Resolution: Fixed
fixed: 326a564ebc0e397654ccd4e5a83a77ef811c6a76
> Beautify the CliTableauResultView
[
https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321916#comment-17321916
]
hayden zhou edited comment on FLINK-22054 at 4/15/21, 5:53 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-22267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321920#comment-17321920
]
Jark Wu commented on FLINK-22267:
-
>From the log information, it did restore source offs
[
https://issues.apache.org/jira/browse/FLINK-22267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-22267.
---
Resolution: Not A Problem
> Savepoint an application for source of upsert-kafka, then restart the
> applica
[
https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-22113:
---
Assignee: Xu Guangheng
> UniqueKey constraint is lost with multiple sources join in SQL
> -
spoon-lz closed pull request #15576:
URL: https://github.com/apache/flink/pull/15576
--
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 to the specific comment.
For queries about this service, pleas
flinkbot edited a comment on pull request #15438:
URL: https://github.com/apache/flink/pull/15438#issuecomment-810469495
## CI report:
* 6459e87724e47a8c6cf7c0478f498c48d860c809 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #15615:
URL: https://github.com/apache/flink/pull/15615#issuecomment-819492632
## CI report:
* 445953000e30ecb7cb4730abb1c1e0bc0dd2b981 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321929#comment-17321929
]
Carl commented on FLINK-22267:
--
Thank you for your reply! If I don't delete the data, is th
flinkbot edited a comment on pull request #15615:
URL: https://github.com/apache/flink/pull/15615#issuecomment-819492632
## CI report:
* 445953000e30ecb7cb4730abb1c1e0bc0dd2b981 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321932#comment-17321932
]
Zhilong Hong commented on FLINK-22276:
--
Thank you for pointing this out, [~mapohl].
[
https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321933#comment-17321933
]
Yi Tang commented on FLINK-22054:
-
[~hayden zhou] Yes, it's an issue fixed in FLINK-2194
[
https://issues.apache.org/jira/browse/FLINK-22141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321934#comment-17321934
]
Yuan Mei commented on FLINK-22141:
--
Couple of things found related to documentation whe
[
https://issues.apache.org/jira/browse/FLINK-22267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321935#comment-17321935
]
Jark Wu commented on FLINK-22267:
-
If you are using upsert-kafka, [~yanchenyun] it will
[
https://issues.apache.org/jira/browse/FLINK-21117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321940#comment-17321940
]
Guowei Ma commented on FLINK-21117:
---
https://dev.azure.com/apache-flink/apache-flink/_
[
https://issues.apache.org/jira/browse/FLINK-21117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-21117:
--
Affects Version/s: 1.13.0
> KafkaProducerExactlyOnceITCase fails with "Exceeded checkpoint tolerable
[
https://issues.apache.org/jira/browse/FLINK-22179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-22179:
---
Description:
* 1. Test time functions return expected value in both batch and streaming
mode, we ca
[
https://issues.apache.org/jira/browse/FLINK-22179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-22179:
---
Description:
* 1. Test time functions return expected value in both batch and streaming
mode, we ca
Guowei Ma created FLINK-22285:
-
Summary: org.apache.flink.yarn.YARNHighAvailabilityITCase Hang
Key: FLINK-22285
URL: https://issues.apache.org/jira/browse/FLINK-22285
Project: Flink
Issue Type: B
godfreyhe commented on a change in pull request #15559:
URL: https://github.com/apache/flink/pull/15559#discussion_r613798035
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalDataStreamTableScan.scala
godfreyhe commented on a change in pull request #15559:
URL: https://github.com/apache/flink/pull/15559#discussion_r613798035
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalDataStreamTableScan.scala
[
https://issues.apache.org/jira/browse/FLINK-21746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-21746.
-
Resolution: Fixed
Fix in FLINK-22082. Verify the case in local environment.
> flink sql fields
[
https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jin Xing updated FLINK-22276:
-
Attachment: image-2021-04-15-14-46-42-660.png
> ExceptionHistoryEntryExtractor throws fatal error when t
[
https://issues.apache.org/jira/browse/FLINK-19458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321948#comment-17321948
]
Guowei Ma commented on FLINK-19458:
---
1.11
https://dev.azure.com/apache-flink/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-22276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jin Xing updated FLINK-22276:
-
Description:
When running my batch job on Flink cluster, I got a fatal error as below and JM
exits:
!i
1301 - 1400 of 1406 matches
Mail list logo
