[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xx chai updated FLINK-22281:
Component/s: Table SQL / API
Affects Version/s: 1.12.0
Description: I use flink sql to
[
https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321843#comment-17321843
]
Roc Marshal commented on FLINK-22125:
-
When we judge whether mapstate is empty or not, there may be
[
https://issues.apache.org/jira/browse/FLINK-16120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321852#comment-17321852
]
Rui Li commented on FLINK-16120:
Hive connector doc has been moved to the {{Table & SQL Connectors}}.
[
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
[
https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321843#comment-17321843
]
Roc Marshal edited comment on FLINK-22125 at 4/15/21, 2:42 AM:
---
When we
[
https://issues.apache.org/jira/browse/FLINK-22125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321863#comment-17321863
]
Dian Fu commented on FLINK-22125:
-
Hi [~RocMarshal], there is a method named is_empty() in MapState. You
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
flinkbot edited a comment on pull request #15020:
URL: https://github.com/apache/flink/pull/15020#issuecomment-785804760
## CI report:
* 4a4f8a643c603007519ebefc4c1e732347b6d3d2 UNKNOWN
* 6ebcd56d7080224fcd21f0f22ee467a951feb2e0 Azure:
flinkbot edited a comment on pull request #14484:
URL: https://github.com/apache/flink/pull/14484#issuecomment-750730068
## CI report:
* adaac76c0ae0a62ca7f156340653128a43bf7b20 Azure:
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 @@
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321850#comment-17321850
]
Jark Wu commented on FLINK-22281:
-
If you don't have the full historical data, only the incremental
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 edited a comment on pull request #15525:
URL: https://github.com/apache/flink/pull/15525#issuecomment-815836876
## CI report:
* 00492ee3748f2830378d9f7c73afa8b6e3e48fcb Azure:
flinkbot edited a comment on pull request #15618:
URL: https://github.com/apache/flink/pull/15618#issuecomment-820024114
## CI report:
* a5030e29742e58a6df2dbca7d7e1ce27a90e8722 Azure:
flinkbot edited a comment on pull request #15595:
URL: https://github.com/apache/flink/pull/15595#issuecomment-818681408
## CI report:
* 6e06c0cb3d52f23f31ab7855880da5177f7d1627 Azure:
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 @@
flinkbot edited a comment on pull request #15607:
URL: https://github.com/apache/flink/pull/15607#issuecomment-819349925
## CI report:
* 8a62da0c014fc75b3bad145c2fd46fc1809a9c28 Azure:
[
https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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:
flinkbot edited a comment on pull request #15438:
URL: https://github.com/apache/flink/pull/15438#issuecomment-810469495
## CI report:
* d16ff5596d58f30aa2752007efc8f7908059596d Azure:
[
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'
>
flinkbot edited a comment on pull request #15020:
URL: https://github.com/apache/flink/pull/15020#issuecomment-785804760
## CI report:
* 4a4f8a643c603007519ebefc4c1e732347b6d3d2 UNKNOWN
* 6ebcd56d7080224fcd21f0f22ee467a951feb2e0 Azure:
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 @@
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xx chai updated FLINK-22281:
Description:
I use flink sql to consumer kafka canal-json message the sql is
CREATE TABLE
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xx chai updated FLINK-22281:
Description:
I use flink sql to consumer kafka canal-json message the sql is
CREATE TABLE
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xx chai updated FLINK-22281:
Attachment: screenshot-1.png
> flink sql consumer kakfa canal-json message then sum(amount)
>
[
https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin reassigned FLINK-22282:
Assignee: Jiangjie Qin
> Move creation of SplitEnumerator to the SourceCoordinator
[
https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321851#comment-17321851
]
Jark Wu commented on FLINK-22275:
-
We should discuss about the API/options and behaviors first.
>
[
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
[
https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321872#comment-17321872
]
Yi Tang commented on FLINK-22275:
-
Of course.
First of all, it is obvious that this option can only be
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
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
[
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=17321877#comment-17321877
]
Chen Qin commented on FLINK-6113:
-
Seems community already get rid of split and select transformation in
[
https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321885#comment-17321885
]
Yang Wang commented on FLINK-22262:
---
Could you please share the JobManager logs when you cancel the
[
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
flinkbot edited a comment on pull request #15549:
URL: https://github.com/apache/flink/pull/15549#issuecomment-816597084
## CI report:
* 6bc0d4aa007b6fe629822142a3e6eb1d6c6fe7d9 Azure:
[
https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=17321920#comment-17321920
]
Jark Wu commented on FLINK-22267:
-
>From the log information, it did restore source offset state from
[
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
>
[
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
>
KurtYoung merged pull request #15155:
URL: https://github.com/apache/flink/pull/15155
--
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,
Jiangjie Qin created FLINK-22282:
Summary: Move creation of SplitEnumerator to the SourceCoordinator
thread
Key: FLINK-22282
URL: https://issues.apache.org/jira/browse/FLINK-22282
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xx chai updated FLINK-22281:
Description:
I use flink sql to consumer kafka canal-json message the sql is
CREATE TABLE
[
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
>
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-22279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321854#comment-17321854
]
todd commented on FLINK-22279:
--
Thank you very much, what you said is right. I did not pay attention to
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321856#comment-17321856
]
xx chai commented on FLINK-22281:
-
i add the Parameter
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
[
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-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321878#comment-17321878
]
xx chai commented on FLINK-22281:
-
thanks [~jark] I solve the question .
> flink sql consumer kakfa
[
https://issues.apache.org/jira/browse/FLINK-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321868#comment-17321868
]
Xu Guangheng edited comment on FLINK-22113 at 4/15/21, 3:25 AM:
Hello
flinkbot edited a comment on pull request #14484:
URL: https://github.com/apache/flink/pull/14484#issuecomment-750730068
## CI report:
* adaac76c0ae0a62ca7f156340653128a43bf7b20 Azure:
flinkbot edited a comment on pull request #15525:
URL: https://github.com/apache/flink/pull/15525#issuecomment-815836876
## CI report:
* 00492ee3748f2830378d9f7c73afa8b6e3e48fcb Azure:
flinkbot edited a comment on pull request #15607:
URL: https://github.com/apache/flink/pull/15607#issuecomment-819349925
## CI report:
* 58d729cf2d2ecb4239cd3a2ee380e64f484e7df0 Azure:
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
[
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
lirui-apache commented on a change in pull request #15549:
URL: https://github.com/apache/flink/pull/15549#discussion_r613709681
##
File path:
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java
##
@@ -442,6
[
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
[
https://issues.apache.org/jira/browse/FLINK-22140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321879#comment-17321879
]
Yun Gao commented on FLINK-22140:
-
Tested the unified binary save-point with [an artificial
flinkbot edited a comment on pull request #15595:
URL: https://github.com/apache/flink/pull/15595#issuecomment-818681408
## CI report:
* 6e06c0cb3d52f23f31ab7855880da5177f7d1627 Azure:
flinkbot edited a comment on pull request #15549:
URL: https://github.com/apache/flink/pull/15549#issuecomment-816597084
## CI report:
* 6bc0d4aa007b6fe629822142a3e6eb1d6c6fe7d9 Azure:
flinkbot edited a comment on pull request #15546:
URL: https://github.com/apache/flink/pull/15546#issuecomment-816538766
## CI report:
* e16ddc3fb9157cc0b70ea07023202a2ebdd9fe15 Azure:
[
https://issues.apache.org/jira/browse/FLINK-22180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-22180.
Resolution: Fixed
master: 9fd6ecf18ddb744a971f575ab11eb19b44383899
> RM reclaims slots
xx chai created FLINK-22281:
---
Summary: flink sql
Key: FLINK-22281
URL: https://issues.apache.org/jira/browse/FLINK-22281
Project: Flink
Issue Type: Improvement
Reporter: xx chai
[
https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated FLINK-22282:
-
Issue Type: Improvement (was: Bug)
> Move creation of SplitEnumerator to the SourceCoordinator
[
https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated FLINK-22282:
-
Fix Version/s: 1.12.3
1.13.0
> Move creation of SplitEnumerator to the
[
https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated FLINK-22282:
-
Issue Type: Bug (was: Task)
> Move creation of SplitEnumerator to the SourceCoordinator thread
[
https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated FLINK-22282:
-
Priority: Critical (was: Major)
> Move creation of SplitEnumerator to the SourceCoordinator
[
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-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-22113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=17321868#comment-17321868
]
Xu Guangheng edited comment on FLINK-22113 at 4/15/21, 3:00 AM:
Hello
[
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
[
https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321872#comment-17321872
]
Yi Tang edited comment on FLINK-22275 at 4/15/21, 3:22 AM:
---
Of course.
How
[
https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321872#comment-17321872
]
Yi Tang edited comment on FLINK-22275 at 4/15/21, 3:23 AM:
---
Of course.
How
flinkbot edited a comment on pull request #15605:
URL: https://github.com/apache/flink/pull/15605#issuecomment-819212302
## CI report:
* e9f7f5526078a9ed65d6403eab5cde7fc82b177b Azure:
flinkbot edited a comment on pull request #15607:
URL: https://github.com/apache/flink/pull/15607#issuecomment-819349925
## CI report:
* 58d729cf2d2ecb4239cd3a2ee380e64f484e7df0 Azure:
[
https://issues.apache.org/jira/browse/FLINK-22054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321916#comment-17321916
]
hayden zhou commented on FLINK-22054:
-
[~trohrmann] [~yittg] I can't submit batch jobs more than
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321917#comment-17321917
]
xx chai commented on FLINK-22281:
-
Yes, I have added this parameter correctly
> flink sql consumer
[
https://issues.apache.org/jira/browse/FLINK-21660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-21660.
--
Resolution: Fixed
fixed: 5b9e7882207357120717966d8bf7efd53c53ede5
> CREATE TABLE LIKE cannot
KurtYoung commented on a change in pull request #15549:
URL: https://github.com/apache/flink/pull/15549#discussion_r613693906
##
File path:
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/TableEnvHiveConnectorITCase.java
##
@@ -442,6
[
https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321842#comment-17321842
]
Yi Tang commented on FLINK-22275:
-
[~jark] You can assign it to me, if no further more discussion
[
https://issues.apache.org/jira/browse/FLINK-22280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-22280:
Component/s: (was: Table SQL / API)
Table SQL / Ecosystem
Formats
[
https://issues.apache.org/jira/browse/FLINK-22280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321845#comment-17321845
]
Jark Wu commented on FLINK-22280:
-
Yes. I think this can be a xml format.
> Add XML output format for
[
https://issues.apache.org/jira/browse/FLINK-22279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-22279:
--
Priority: Major (was: Blocker)
> Upload the pipeline.classpaths file in yarn application mode
>
[
https://issues.apache.org/jira/browse/FLINK-22279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321846#comment-17321846
]
Yang Wang commented on FLINK-22279:
---
I do not think this is a bug of Flink. The config option
[
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
>
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 @@
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 @@
[
https://issues.apache.org/jira/browse/FLINK-22280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321901#comment-17321901
]
Kurt Young commented on FLINK-22280:
I also think this would be helpful. [~flacombe]
> Add XML
[
https://issues.apache.org/jira/browse/FLINK-22281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321914#comment-17321914
]
Jark Wu commented on FLINK-22281:
-
[~chaixiaoxue] you should add the configuration by
flinkbot edited a comment on pull request #15606:
URL: https://github.com/apache/flink/pull/15606#issuecomment-819310662
## CI report:
* 0e8a4ab5a5ce24a7b8082bd772da8e22fb155a8d Azure:
1 - 100 of 1407 matches
Mail list logo