klion26 commented on a change in pull request #13505:
URL: https://github.com/apache/flink/pull/13505#discussion_r504417756
##
File path: docs/dev/packaging.zh.md
##
@@ -24,36 +24,20 @@ under the License.
-->
-As described earlier, Flink programs can be executed on
[
https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19630:
-
Fix Version/s: (was: 1.11.3)
1.12.0
> Sink data in [ORC] format into
[
https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213625#comment-17213625
]
Jingsong Lee commented on FLINK-19630:
--
Hi [~neighborhood], can you use hive 1.2.2 dependencies?
flinkbot commented on pull request #13626:
URL: https://github.com/apache/flink/pull/13626#issuecomment-708171532
## CI report:
* 1f6974a2251daef826687b981fd5a5fb428fe66c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13625:
URL: https://github.com/apache/flink/pull/13625#issuecomment-708152298
## CI report:
* 2599ad69ed0b2117dff5fd47eb5b51208a2b9efb Azure:
flinkbot edited a comment on pull request #13580:
URL: https://github.com/apache/flink/pull/13580#issuecomment-706475658
## CI report:
* 64e06319bfd0a593c645f9449ce5605c9a00de2c Azure:
flinkbot edited a comment on pull request #13611:
URL: https://github.com/apache/flink/pull/13611#issuecomment-707634048
## CI report:
* 97bf0d8b9d1541d8ecb077fa977e2fe3c7a15d2d UNKNOWN
* bbf13d4f68c7c6450d264d862eaf9db45ff80e6d Azure:
HuangXingBo commented on pull request #13504:
URL: https://github.com/apache/flink/pull/13504#issuecomment-708170328
@dianfu Thanks a lot for the review. I have addressed the comments at the
latest commit.
This is an
flinkbot commented on pull request #13626:
URL: https://github.com/apache/flink/pull/13626#issuecomment-708168756
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
[
https://issues.apache.org/jira/browse/FLINK-19594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19594:
---
Labels: pull-request-available (was: )
> SubTasks start index don't unified and may
zlzhang0122 opened a new pull request #13626:
URL: https://github.com/apache/flink/pull/13626
What is the purpose of the change
This pull request modified web ui subtasks starting index from 0, which can
make consistent in the REST API.
Brief change log
*modify web ui subtasks
flinkbot edited a comment on pull request #13611:
URL: https://github.com/apache/flink/pull/13611#issuecomment-707634048
## CI report:
* 97bf0d8b9d1541d8ecb077fa977e2fe3c7a15d2d UNKNOWN
* bbf13d4f68c7c6450d264d862eaf9db45ff80e6d Azure:
flinkbot edited a comment on pull request #13580:
URL: https://github.com/apache/flink/pull/13580#issuecomment-706475658
## CI report:
* 64e06319bfd0a593c645f9449ce5605c9a00de2c Azure:
dianfu commented on a change in pull request #13504:
URL: https://github.com/apache/flink/pull/13504#discussion_r504406366
##
File path:
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/aggregate/arrow/stream/AbstractStreamArrowPythonBoundedRowsOperator.java
[
https://issues.apache.org/jira/browse/FLINK-19441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213611#comment-17213611
]
Yingjie Cao commented on FLINK-19441:
-
Really sorry for the late responses. I will take a look and
flinkbot edited a comment on pull request #13625:
URL: https://github.com/apache/flink/pull/13625#issuecomment-708152298
## CI report:
* 2599ad69ed0b2117dff5fd47eb5b51208a2b9efb Azure:
flinkbot edited a comment on pull request #13611:
URL: https://github.com/apache/flink/pull/13611#issuecomment-707634048
## CI report:
* 97bf0d8b9d1541d8ecb077fa977e2fe3c7a15d2d UNKNOWN
* bbf13d4f68c7c6450d264d862eaf9db45ff80e6d Azure:
gm7y8 edited a comment on pull request #13458:
URL: https://github.com/apache/flink/pull/13458#issuecomment-708157763
@AHeise sorry for the delay to respond back. it should simple fix in the UI
layer with some text changes. I would take the opinion of @XComp @vthinkxie if
it ok with the
gm7y8 commented on pull request #13458:
URL: https://github.com/apache/flink/pull/13458#issuecomment-708157763
@AHeise sorry for the delay to respond back. it should simple fix in the UI
layer. I would take the opinion of @XComp @vthinkxie if it ok with the above
change.
flinkbot commented on pull request #13625:
URL: https://github.com/apache/flink/pull/13625#issuecomment-708152298
## CI report:
* 2599ad69ed0b2117dff5fd47eb5b51208a2b9efb UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13616:
URL: https://github.com/apache/flink/pull/13616#issuecomment-707722760
## CI report:
* f5f2b5eb85c94a1ecdbcce1901ef342c27cf42fc Azure:
flinkbot edited a comment on pull request #13605:
URL: https://github.com/apache/flink/pull/13605#issuecomment-707521684
## CI report:
* a9df8a1384eb6306656b4fd952edd4be5d7a857d UNKNOWN
* 8beabe2e1b04afe449610c44f4c376909b463e10 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213601#comment-17213601
]
Lsw_aka_laplace commented on FLINK-19630:
-
[~lirui]
Thanks for ur suggestion. It's hard to
[
https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213596#comment-17213596
]
Rui Li commented on FLINK-19630:
[~lzljs3620320] Yes this is the same issue as FLINK-13998.
flinkbot edited a comment on pull request #13616:
URL: https://github.com/apache/flink/pull/13616#issuecomment-707722760
## CI report:
* f5f2b5eb85c94a1ecdbcce1901ef342c27cf42fc Azure:
flinkbot edited a comment on pull request #13617:
URL: https://github.com/apache/flink/pull/13617#issuecomment-707791817
## CI report:
* Unknown: [CANCELED](TBD)
* 524a25e7d549af7ad9a5e92f39377cbde30059fb Azure:
flinkbot commented on pull request #13625:
URL: https://github.com/apache/flink/pull/13625#issuecomment-708147417
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
[
https://issues.apache.org/jira/browse/FLINK-19623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19623:
---
Labels: pull-request-available (was: )
> Introduce ExecEdge to describe information on
flinkbot edited a comment on pull request #13504:
URL: https://github.com/apache/flink/pull/13504#issuecomment-700556506
## CI report:
* 5e9643b76e1c28968baa3cf41492d55bc8ed9ad0 Azure:
TsReaper opened a new pull request #13625:
URL: https://github.com/apache/flink/pull/13625
## What is the purpose of the change
Deadlock breakup algorithm and Multi-input operator creation algorithm need
information about the input edges of an exec node, for example what's the
[
https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213589#comment-17213589
]
Jingsong Lee commented on FLINK-19630:
--
Should be same reason to FLINK-13998
> Sink data in [ORC]
[
https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213585#comment-17213585
]
Jingsong Lee commented on FLINK-19630:
--
Thanks [~neighborhood] for reporting, nice catch!
It seems
[
https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19630:
-
Fix Version/s: 1.11.3
> Sink data in [ORC] format into Hive By using Legacy Table API caused
[
https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213583#comment-17213583
]
Jingsong Lee commented on FLINK-19630:
--
CC: [~lirui]
> Sink data in [ORC] format into Hive By
[
https://issues.apache.org/jira/browse/FLINK-19531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-19531:
--
Summary: Implement the writer operator (was: Implement the
`WriterOperator`)
> Implement the writer
Yuan Mei created FLINK-19632:
Summary: Introduce a new ResultPartitionType for Approximate Local
Recovery
Key: FLINK-19632
URL: https://issues.apache.org/jira/browse/FLINK-19632
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213579#comment-17213579
]
Lsw_aka_laplace commented on FLINK-19630:
-
[~jark]
[~lzljs3620320]
Would u guys mind taking
[
https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lsw_aka_laplace updated FLINK-19630:
Description:
*ENV:*
*Flink version 1.11.2*
*Hive exec version: 2.0.1*
*Hive file
KarmaGYZ commented on a change in pull request #13592:
URL: https://github.com/apache/flink/pull/13592#discussion_r504365654
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/TaskExecutorProcessSpecContainerResourcePriorityAdapter.java
##
@@ -0,0 +1,127 @@
+/*
+ *
flinkbot edited a comment on pull request #13624:
URL: https://github.com/apache/flink/pull/13624#issuecomment-708132432
## CI report:
* 58df8007e120a6b17f11579dd59f91b6d10f5ecf Azure:
flinkbot edited a comment on pull request #13623:
URL: https://github.com/apache/flink/pull/13623#issuecomment-708132144
## CI report:
* 15cc49ee7ecb3060ec52ab5545f4b6fae58c25de Azure:
flinkbot edited a comment on pull request #13617:
URL: https://github.com/apache/flink/pull/13617#issuecomment-707791817
## CI report:
* Unknown: [CANCELED](TBD)
* 524a25e7d549af7ad9a5e92f39377cbde30059fb UNKNOWN
Bot commands
The @flinkbot bot supports the
flinkbot edited a comment on pull request #13605:
URL: https://github.com/apache/flink/pull/13605#issuecomment-707521684
## CI report:
* a9df8a1384eb6306656b4fd952edd4be5d7a857d UNKNOWN
* 8beabe2e1b04afe449610c44f4c376909b463e10 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-19125:
--
Description:
This ticket tracks the problem of memory fragmentation when launching default
Flink docker
flinkbot edited a comment on pull request #13504:
URL: https://github.com/apache/flink/pull/13504#issuecomment-700556506
## CI report:
* 5e9643b76e1c28968baa3cf41492d55bc8ed9ad0 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lsw_aka_laplace updated FLINK-19630:
Attachment: image-2020-10-14-11-48-51-310.png
> Sink data in [ORC] format into Hive By
curcur commented on pull request #13614:
URL: https://github.com/apache/flink/pull/13614#issuecomment-708138894
Local azure results:
https://dev.azure.com/mymeiyuan/Flink/_build/results?buildId=92=results
green light except `JMXReporterFactoryTest` due to FLINK-19539
[
https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lsw_aka_laplace updated FLINK-19630:
Attachment: image-2020-10-14-11-42-57-353.png
> Sink data in [ORC] format into Hive By
[
https://issues.apache.org/jira/browse/FLINK-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lsw_aka_laplace updated FLINK-19630:
Attachment: image-2020-10-14-11-41-53-379.png
> Sink data in [ORC] format into Hive By
[
https://issues.apache.org/jira/browse/FLINK-18999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-18999.
Resolution: Fixed
master:
24f88069f596673c6f58b136d85d1b00ddf840f2
JingsongLi merged pull request #13216:
URL: https://github.com/apache/flink/pull/13216
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-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lsw_aka_laplace updated FLINK-19630:
Attachment: image-2020-10-14-11-36-48-086.png
> Sink data in [ORC] format into Hive By
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213569#comment-17213569
]
shizhengchao commented on FLINK-19629:
--
Avro union(something, null) spelled incorrectly, should be
guoweiM commented on pull request #13617:
URL: https://github.com/apache/flink/pull/13617#issuecomment-708134965
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213565#comment-17213565
]
Jark Wu commented on FLINK-19629:
-
What's wrong with the example? Do you mean changing {{behavior
flinkbot commented on pull request #13624:
URL: https://github.com/apache/flink/pull/13624#issuecomment-708132432
## CI report:
* 58df8007e120a6b17f11579dd59f91b6d10f5ecf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-19631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19631:
-
Issue Type: Bug (was: Test)
> Comments of DecodingFormatFactory is not clear
>
[
https://issues.apache.org/jira/browse/FLINK-19631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19631:
-
Labels: starter (was: )
> Comments of DecodingFormatFactory is not clear
>
HuangXingBo commented on pull request #13504:
URL: https://github.com/apache/flink/pull/13504#issuecomment-708131977
@dianfu Thanks a lot for the review. I have addressed the comments at the
latest commit.
This is an
flinkbot commented on pull request #13623:
URL: https://github.com/apache/flink/pull/13623#issuecomment-708132144
## CI report:
* 15cc49ee7ecb3060ec52ab5545f4b6fae58c25de UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
Jingsong Lee created FLINK-19631:
Summary: Comments of DecodingFormatFactory is not clear
Key: FLINK-19631
URL: https://issues.apache.org/jira/browse/FLINK-19631
Project: Flink
Issue Type:
flinkbot edited a comment on pull request #13611:
URL: https://github.com/apache/flink/pull/13611#issuecomment-707634048
## CI report:
* 97bf0d8b9d1541d8ecb077fa977e2fe3c7a15d2d UNKNOWN
* 51d4364176c11ed1b766a00bdbab9597f7ca4af2 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213561#comment-17213561
]
shizhengchao commented on FLINK-19629:
--
[~jark], i can complete this work, could you assign it to
[
https://issues.apache.org/jira/browse/FLINK-19584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-19584.
---
Resolution: Fixed
Fixed in master: b62c13b9d494110b806a1cf88233f075df16c810
> HBaseSinkFunction no needs
[
https://issues.apache.org/jira/browse/FLINK-19441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213559#comment-17213559
]
Yuan Mei edited comment on FLINK-19441 at 10/14/20, 3:21 AM:
-
I have
wuchong commented on pull request #13613:
URL: https://github.com/apache/flink/pull/13613#issuecomment-708131146
Build is passed, merging...
This is an automated message from the Apache Git Service.
To respond to the
Lsw_aka_laplace created FLINK-19630:
---
Summary: Sink data in [ORC] format into Hive By using Legacy Table
API caused unexpected Exception
Key: FLINK-19630
URL: https://issues.apache.org/jira/browse/FLINK-19630
wuchong merged pull request #13613:
URL: https://github.com/apache/flink/pull/13613
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
[
https://issues.apache.org/jira/browse/FLINK-19441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213559#comment-17213559
]
Yuan Mei commented on FLINK-19441:
--
forward this to [~kevin.cyj] and pinged him in person.
>
shizhengchao created FLINK-19629:
Summary: English words are spelled incorrectly and an example is
not provided
Key: FLINK-19629
URL: https://issues.apache.org/jira/browse/FLINK-19629
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-19622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li updated FLINK-19622:
---
Affects Version/s: (was: 1.11.1)
1.11.2
> Flinksql version 1.11 is for
tzulitai commented on pull request #163:
URL: https://github.com/apache/flink-statefun/pull/163#issuecomment-708128215
cc @sjwiesman @igalshilman
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-19368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Li updated FLINK-19368:
---
Priority: Blocker (was: Major)
> TableEnvHiveConnectorITCase fails with Hive-3.x
>
[
https://issues.apache.org/jira/browse/FLINK-19622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
宋洪亮 updated FLINK-19622:
Description:
Hello, when I use flinksql version 1.11 to analyze data in avro format in
Kafka, I used the Map
[
https://issues.apache.org/jira/browse/FLINK-19620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19620:
---
Labels: pull-request-available (was: )
> Merge StateFun's ExactlyOnceE2E and
[
https://issues.apache.org/jira/browse/FLINK-19622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
宋洪亮 updated FLINK-19622:
Description:
Hello, when I use flinksql version 1.11 to analyze data in avro format in
Kafka, I used the Map
tzulitai opened a new pull request #163:
URL: https://github.com/apache/flink-statefun/pull/163
The original `ExactlyOnceE2E` verified end-to-end exactly-once with TM
failures, while the `RemoteModuleE2E` verified a deployment with remote
functions.
As mentioned in #159 by
flinkbot commented on pull request #13624:
URL: https://github.com/apache/flink/pull/13624#issuecomment-708127677
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
Caizhi Weng created FLINK-19628:
---
Summary: Introduce multi-input operator for streaming
Key: FLINK-19628
URL: https://issues.apache.org/jira/browse/FLINK-19628
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-19368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19368:
---
Labels: pull-request-available (was: )
> TableEnvHiveConnectorITCase fails with Hive-3.x
>
Caizhi Weng created FLINK-19627:
---
Summary: Introduce multi-input operator for batch
Key: FLINK-19627
URL: https://issues.apache.org/jira/browse/FLINK-19627
Project: Flink
Issue Type: Sub-task
lirui-apache opened a new pull request #13624:
URL: https://github.com/apache/flink/pull/13624
## What is the purpose of the change
Fix `TableEnvHiveConnectorITCase` for Hive-3.x.
## Brief change log
- Set ACID transaction manager for 3.x -- it's required
Caizhi Weng created FLINK-19626:
---
Summary: Introduce multi-input operator construction algorithm
Key: FLINK-19626
URL: https://issues.apache.org/jira/browse/FLINK-19626
Project: Flink
Issue
Caizhi Weng created FLINK-19625:
---
Summary: Introduce multi-input exec node
Key: FLINK-19625
URL: https://issues.apache.org/jira/browse/FLINK-19625
Project: Flink
Issue Type: Sub-task
flinkbot edited a comment on pull request #13577:
URL: https://github.com/apache/flink/pull/13577#issuecomment-706470705
## CI report:
* 90f8521b60440ef0782c1ce4356d260fe56a1bc0 Azure:
flinkbot edited a comment on pull request #13299:
URL: https://github.com/apache/flink/pull/13299#issuecomment-684842866
## CI report:
* a0719cf3cfc2219361b74540399126cc84a8e1cd Azure:
[
https://issues.apache.org/jira/browse/FLINK-19622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
宋洪亮 updated FLINK-19622:
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
Affects Version/s: 1.11.1
> flinksql
Caizhi Weng created FLINK-19624:
---
Summary: Update deadlock break-up algorithm to cover more cases
Key: FLINK-19624
URL: https://issues.apache.org/jira/browse/FLINK-19624
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-19624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-19624:
Description:
Current deadlock breakup algorithm fails to cover the following case:
!pasted
[
https://issues.apache.org/jira/browse/FLINK-19622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213552#comment-17213552
]
Benchao Li commented on FLINK-19622:
[~奔跑的小飞袁] We should use English in Jira issues, could you
[
https://issues.apache.org/jira/browse/FLINK-19606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19606:
---
Labels: pull-request-available (was: )
> Implement streaming window join operator
>
flinkbot commented on pull request #13623:
URL: https://github.com/apache/flink/pull/13623#issuecomment-708125660
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
[
https://issues.apache.org/jira/browse/FLINK-19618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-19618:
---
Assignee: hailong wang
> Broken link in docs
> ---
>
> Key:
Caizhi Weng created FLINK-19623:
---
Summary: Introduce ExecEdge to describe information on input edges
for ExecNode
Key: FLINK-19623
URL: https://issues.apache.org/jira/browse/FLINK-19623
Project: Flink
danny0405 opened a new pull request #13623:
URL: https://github.com/apache/flink/pull/13623
## What is the purpose of the change
This patch introduces `WindowJoinOperator` and `WindowJoinOperatorSimple`,
The `WindowJoinOperator` accepts two streams and windows each stream,
[
https://issues.apache.org/jira/browse/FLINK-19618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213549#comment-17213549
]
hailong wang commented on FLINK-19618:
--
[~dian.fu] Yes, Thank you for assgining to me~
> Broken
宋洪亮 created FLINK-19622:
---
Summary: flinksql 1.11版本针对avro格式中Map类型value值的空指针异常
Key: FLINK-19622
URL: https://issues.apache.org/jira/browse/FLINK-19622
Project: Flink
Issue Type: Bug
Caizhi Weng created FLINK-19621:
---
Summary: Introduce Multi-input operator in Blink planner
Key: FLINK-19621
URL: https://issues.apache.org/jira/browse/FLINK-19621
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-19618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213547#comment-17213547
]
Dian Fu commented on FLINK-19618:
-
[~hailong wang] Good catch! Would you like to submit a PR?
> Broken
[
https://issues.apache.org/jira/browse/FLINK-19619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-19619:
Affects Version/s: 1.11.0
> Test failed in Azure For EmulatedPubSubSourceTest
>
1 - 100 of 574 matches
Mail list logo
