[
https://issues.apache.org/jira/browse/FLINK-19791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise resolved FLINK-19791.
-
Resolution: Fixed
> PartitionRequestClientFactoryTest.testInterruptsNotCached fails with
> Null
[
https://issues.apache.org/jira/browse/FLINK-19791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220523#comment-17220523
]
Arvid Heise commented on FLINK-19791:
-
Merged a fix into master as 0184672733fb2417c
AHeise merged pull request #13778:
URL: https://github.com/apache/flink/pull/13778
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 t
AHeise commented on a change in pull request #13778:
URL: https://github.com/apache/flink/pull/13778#discussion_r511748513
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java
##
@@ -61,15 +61,23 @@
flinkbot commented on pull request #13790:
URL: https://github.com/apache/flink/pull/13790#issuecomment-716344358
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-19806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19806:
---
Labels: pull-request-available (was: )
> Job may try to leave SUSPENDED state in ExecutionG
fsk119 commented on a change in pull request #13771:
URL: https://github.com/apache/flink/pull/13771#discussion_r511743424
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushPartitionIntoTableSourceScanRule.java
zhuzhurk opened a new pull request #13790:
URL: https://github.com/apache/flink/pull/13790
## What is the purpose of the change
SUSPENDED is a terminal state which a job is not supposed to leave this
state once entering. However, ExecutionGraph#failJob() did not check it and may
try
Zhu Zhu created FLINK-19806:
---
Summary: Job may try to leave SUSPENDED state in
ExecutionGraph#failJob()
Key: FLINK-19806
URL: https://issues.apache.org/jira/browse/FLINK-19806
Project: Flink
Issue
flinkbot edited a comment on pull request #13786:
URL: https://github.com/apache/flink/pull/13786#issuecomment-716269806
## CI report:
* f6bedbd6f4cc29777a888be558030b56ba803a54 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13721:
URL: https://github.com/apache/flink/pull/13721#issuecomment-713489063
## CI report:
* 8201a73f78f9e80468737dcdb020e67aa71c8a19 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
wuchong commented on pull request #13721:
URL: https://github.com/apache/flink/pull/13721#issuecomment-716328987
After discussing with @leonardBang , I renamed `UpsertMaterialize` into
`ChangelogNormalize`. Because this can be more general purpose and can be used
for cdc source to drop dup
flinkbot edited a comment on pull request #13771:
URL: https://github.com/apache/flink/pull/13771#issuecomment-715323930
## CI report:
* e5442954ffac19a92ba1f9a4620584e61acb601a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13721:
URL: https://github.com/apache/flink/pull/13721#issuecomment-713489063
## CI report:
* b03cd2b69573ff31561807574f0d9d9f2af803b3 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13631:
URL: https://github.com/apache/flink/pull/13631#issuecomment-708335709
## CI report:
* 11b0dfc5a9a5e6aa335f070abfc6781569deb96d UNKNOWN
* a7fe7dec5d7c869ccbc644bba45df241dd05e953 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #13664:
URL: https://github.com/apache/flink/pull/13664#issuecomment-710017891
## CI report:
* 9be74ce0ce0d57bbda859ca9f5ec7d226df277b1 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-19797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zou updated FLINK-19797:
Description:
Flink version: 1.11
Flink throws NPE when we use decimal array as input of UDAF.
Here is a simpl
[
https://issues.apache.org/jira/browse/FLINK-19797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220505#comment-17220505
]
Zou commented on FLINK-19797:
-
Flink 1.11
> NPE when we use decimal array as input of UDAF
danny0405 commented on pull request #12919:
URL: https://github.com/apache/flink/pull/12919#issuecomment-716324174
@maver1ck , you are right, we ignore the nullability of
`TIMESTAMP_WITHOUT_TIME_ZONE`, `DATE`, and `TIME_WITHOUT_TIME_ZONE` and
`Decimal`, would fix it altogether in this PR.
[
https://issues.apache.org/jira/browse/FLINK-19252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-19252:
Assignee: Yangze Guo
> Jaas file created under io.tmp.dirs - folder not created if not ex
wsry commented on pull request #13595:
URL: https://github.com/apache/flink/pull/13595#issuecomment-716321736
@StephanEwen @zhijiangW @gaoyunhaii Thanks for the review and comments, I
have updated the PR according to the review comments.
---
[
https://issues.apache.org/jira/browse/FLINK-17372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-17372:
-
Fix Version/s: (was: 1.12.0)
1.13.0
> SlotManager should expose total req
[
https://issues.apache.org/jira/browse/FLINK-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-13554:
-
Fix Version/s: (was: 1.12.0)
1.13.0
> ResourceManager should have a timeo
[
https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-18229:
-
Fix Version/s: (was: 1.12.0)
1.13.0
> Pending worker requests should be p
flinkbot edited a comment on pull request #13767:
URL: https://github.com/apache/flink/pull/13767#issuecomment-715256450
## CI report:
* 11330173d2fcaeead16e067e1f7d31c50081c2e1 UNKNOWN
* c532d886b68b7dd265c9056945a3cfc94e8352b7 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #13771:
URL: https://github.com/apache/flink/pull/13771#issuecomment-715323930
## CI report:
* e5442954ffac19a92ba1f9a4620584e61acb601a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13677:
URL: https://github.com/apache/flink/pull/13677#issuecomment-711161777
## CI report:
* b74b5ddf6a01dcb080cf5cf2e6773d919a6ecdec Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13664:
URL: https://github.com/apache/flink/pull/13664#issuecomment-710017891
## CI report:
* 9be74ce0ce0d57bbda859ca9f5ec7d226df277b1 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
Shawn-Hx commented on pull request #13664:
URL: https://github.com/apache/flink/pull/13664#issuecomment-716314480
Hi, @klion26
I have made some changes according to your advice.
Also leave some comments about the last advice. Please take a look.
Thanks.
--
zhuzhurk commented on a change in pull request #13730:
URL: https://github.com/apache/flink/pull/13730#discussion_r511720650
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocator.java
##
@@ -212,20 +214,24 @@ private Res
flinkbot edited a comment on pull request #13789:
URL: https://github.com/apache/flink/pull/13789#issuecomment-716299701
## CI report:
* 6329930d7acc5d2d4d84e777561e79bd25ac9367 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13771:
URL: https://github.com/apache/flink/pull/13771#issuecomment-715323930
## CI report:
* e5442954ffac19a92ba1f9a4620584e61acb601a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13766:
URL: https://github.com/apache/flink/pull/13766#issuecomment-715255564
## CI report:
* 42f066384d04bcfe67ccbb5766f09ab5dde9e19c Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13744:
URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975
## CI report:
* 4d7e601658c0dacc100c572f4fe8878c058e035f Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13677:
URL: https://github.com/apache/flink/pull/13677#issuecomment-711161777
## CI report:
* b74b5ddf6a01dcb080cf5cf2e6773d919a6ecdec Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
Shawn-Hx commented on a change in pull request #13664:
URL: https://github.com/apache/flink/pull/13664#discussion_r511723364
##
File path: docs/ops/deployment/cluster_setup.zh.md
##
@@ -100,52 +105,60 @@ configuration files (which need to be accessible at the
same path on all
klion26 commented on a change in pull request #13664:
URL: https://github.com/apache/flink/pull/13664#discussion_r511322491
##
File path: docs/ops/deployment/cluster_setup.zh.md
##
@@ -22,65 +22,70 @@ specific language governing permissions and limitations
under the License.
flinkbot commented on pull request #13789:
URL: https://github.com/apache/flink/pull/13789#issuecomment-716299701
## CI report:
* 6329930d7acc5d2d4d84e777561e79bd25ac9367 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #13788:
URL: https://github.com/apache/flink/pull/13788#issuecomment-716292584
## CI report:
* 0f484654476d9ab49f6ce4a82475fe665e88fe5e Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13771:
URL: https://github.com/apache/flink/pull/13771#issuecomment-715323930
## CI report:
* e5442954ffac19a92ba1f9a4620584e61acb601a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13767:
URL: https://github.com/apache/flink/pull/13767#issuecomment-715256450
## CI report:
* 11330173d2fcaeead16e067e1f7d31c50081c2e1 UNKNOWN
* c532d886b68b7dd265c9056945a3cfc94e8352b7 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #13766:
URL: https://github.com/apache/flink/pull/13766#issuecomment-715255564
## CI report:
* 42f066384d04bcfe67ccbb5766f09ab5dde9e19c Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13744:
URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975
## CI report:
* 4d7e601658c0dacc100c572f4fe8878c058e035f Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13759:
URL: https://github.com/apache/flink/pull/13759#issuecomment-715027223
## CI report:
* 2e62d962b92ff2c18567a80dcae46fdcfe61d10d Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
shouweikun commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r511716192
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@ -99
flinkbot edited a comment on pull request #13631:
URL: https://github.com/apache/flink/pull/13631#issuecomment-708335709
## CI report:
* 11b0dfc5a9a5e6aa335f070abfc6781569deb96d UNKNOWN
* a7fe7dec5d7c869ccbc644bba45df241dd05e953 Azure:
[FAILURE](https://dev.azure.com/apache-fl
shouweikun commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r511713970
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@ -99
shouweikun commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r511713970
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@ -99
shouweikun commented on pull request #13789:
URL: https://github.com/apache/flink/pull/13789#issuecomment-716296334
@JingsongLi
I push the pr, still some questions should be well discussed. I have left
some comments.
Thi
shouweikun commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r511713970
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@ -99
flinkbot commented on pull request #13789:
URL: https://github.com/apache/flink/pull/13789#issuecomment-716295445
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-19727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19727:
---
Labels: pull-request-available (was: )
> Implement ParallelismProvider for sink in blink pl
shouweikun opened a new pull request #13789:
URL: https://github.com/apache/flink/pull/13789
…n blink planner
## What is the purpose of the change
- Implement `ParallelismProvider` for sink in blink planner
- `SinkFunctionProvider` and `OutputFormatProvider` work with
`P
flinkbot commented on pull request #13788:
URL: https://github.com/apache/flink/pull/13788#issuecomment-716292584
## CI report:
* 0f484654476d9ab49f6ce4a82475fe665e88fe5e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #13787:
URL: https://github.com/apache/flink/pull/13787#issuecomment-716285196
## CI report:
* 93ee445aac08ecae0dd55add35411b67a0ec0b01 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13759:
URL: https://github.com/apache/flink/pull/13759#issuecomment-715027223
## CI report:
* 2e62d962b92ff2c18567a80dcae46fdcfe61d10d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
HuangXingBo commented on pull request #13759:
URL: https://github.com/apache/flink/pull/13759#issuecomment-716291287
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message, ple
[
https://issues.apache.org/jira/browse/FLINK-19068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-19068.
Resolution: Fixed
Fixed via
* master: 4b6d0e62cba16e4f43866e68f72bcc3a54337d85
> Filter verbose p
xintongsong closed pull request #13765:
URL: https://github.com/apache/flink/pull/13765
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-19750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin closed FLINK-19750.
Release Note:
Patch merged.
master: 200be714ff7476f66b7f56cd9b266670b752afe0
release-1.11: 78cd462
wuchong commented on a change in pull request #13721:
URL: https://github.com/apache/flink/pull/13721#discussion_r511709209
##
File path:
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/join/SemiAntiJoinTest.xml
##
@@ -30
becketqin merged pull request #13785:
URL: https://github.com/apache/flink/pull/13785
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
wuchong commented on a change in pull request #13721:
URL: https://github.com/apache/flink/pull/13721#discussion_r511707227
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/StreamExecTableSourceScanRule.scala
wuchong commented on a change in pull request #13721:
URL: https://github.com/apache/flink/pull/13721#discussion_r511707353
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdColumnUniqueness.scala
##
@@ -3
wuchong commented on a change in pull request #13721:
URL: https://github.com/apache/flink/pull/13721#discussion_r511706661
##
File path:
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/TableScanTest.xml
##
@@ -87,6 +129,
[
https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-19795:
---
Assignee: Jark Wu
> Flink SQL throws exception when changelog source contains duplicate change
> e
[
https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-19795:
Parent: FLINK-18822
Issue Type: Sub-task (was: Bug)
> Flink SQL throws exception when changelog s
flinkbot commented on pull request #13788:
URL: https://github.com/apache/flink/pull/13788#issuecomment-716285137
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
flinkbot commented on pull request #13787:
URL: https://github.com/apache/flink/pull/13787#issuecomment-716285196
## CI report:
* 93ee445aac08ecae0dd55add35411b67a0ec0b01 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-19252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19252:
---
Labels: pull-request-available (was: )
> Jaas file created under io.tmp.dirs - folder not c
flinkbot edited a comment on pull request #13595:
URL: https://github.com/apache/flink/pull/13595#issuecomment-707168234
## CI report:
* 690ec79d32dbd8e2a9c62556c0548a56c6a52521 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13631:
URL: https://github.com/apache/flink/pull/13631#issuecomment-708335709
## CI report:
* 11b0dfc5a9a5e6aa335f070abfc6781569deb96d UNKNOWN
* a7fe7dec5d7c869ccbc644bba45df241dd05e953 Azure:
[FAILURE](https://dev.azure.com/apache-fl
KarmaGYZ opened a new pull request #13788:
URL: https://github.com/apache/flink/pull/13788
## What is the purpose of the change
Create the working dir for Jaas conf proactively.
cc @zentol
This is a
[
https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-19795:
Fix Version/s: 1.12.0
> Flink SQL throws exception when changelog source contains duplicate change
> even
[
https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220462#comment-17220462
]
Jark Wu commented on FLINK-19795:
-
Regarding to this issue, I think this is very common,
[
https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220461#comment-17220461
]
Jark Wu commented on FLINK-19795:
-
After offline discussion with [~shen_dijie], I helped
[
https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-19795:
Description: We are using Canal to synchornize MySQL data into Kafka, the
synchornization delivery is not
[
https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-19795:
Summary: Flink SQL throws exception when changelog source contains
duplicate change events (was: When TO
[
https://issues.apache.org/jira/browse/FLINK-19795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-19795:
Description: We are using Canal to synchornize MySQL data into Kafka, the
synchornization delivery is not
flinkbot edited a comment on pull request #13767:
URL: https://github.com/apache/flink/pull/13767#issuecomment-715256450
## CI report:
* 11330173d2fcaeead16e067e1f7d31c50081c2e1 UNKNOWN
* c532d886b68b7dd265c9056945a3cfc94e8352b7 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot commented on pull request #13787:
URL: https://github.com/apache/flink/pull/13787#issuecomment-716280232
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
flinkbot edited a comment on pull request #13631:
URL: https://github.com/apache/flink/pull/13631#issuecomment-708335709
## CI report:
* 11b0dfc5a9a5e6aa335f070abfc6781569deb96d UNKNOWN
* a7fe7dec5d7c869ccbc644bba45df241dd05e953 Azure:
[FAILURE](https://dev.azure.com/apache-fl
dforciea commented on pull request #13787:
URL: https://github.com/apache/flink/pull/13787#issuecomment-716280150
The second commit gets rid of the PostgresRowConverterTest that I had
originally added. Let me know if you think this is useful, and I can bring it
back. Otherwise, I'll just r
flinkbot edited a comment on pull request #13595:
URL: https://github.com/apache/flink/pull/13595#issuecomment-707168234
## CI report:
* 690ec79d32dbd8e2a9c62556c0548a56c6a52521 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-19797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220457#comment-17220457
]
Jark Wu commented on FLINK-19797:
-
Which version are you using?
> NPE when we use decim
dforciea opened a new pull request #13787:
URL: https://github.com/apache/flink/pull/13787
## What is the purpose of the change
Fixes an issue where null arrays in postgres cause a NullPointerException
when retrieving data
## Brief change log
- Update PostgresRowConve
TsReaper commented on a change in pull request #13742:
URL: https://github.com/apache/flink/pull/13742#discussion_r511700500
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/reuse/MultipleInputNodeCreationProcessor.java
##
@
TsReaper commented on a change in pull request #13742:
URL: https://github.com/apache/flink/pull/13742#discussion_r511700192
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/reuse/MultipleInputNodeCreationProcessor.java
##
@
[
https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220455#comment-17220455
]
Jark Wu commented on FLINK-11220:
-
Hi [~twalthr], I think they are different issue.
II
TsReaper commented on a change in pull request #13742:
URL: https://github.com/apache/flink/pull/13742#discussion_r511699119
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/reuse/MultipleInputNodeCreationProcessor.java
##
@
TsReaper commented on a change in pull request #13742:
URL: https://github.com/apache/flink/pull/13742#discussion_r511699281
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/reuse/MultipleInputNodeCreationProcessor.java
##
@
[
https://issues.apache.org/jira/browse/FLINK-19771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220454#comment-17220454
]
Leonard Xu commented on FLINK-19771:
[~dforciea]
Your branch makes sense to me, I
[
https://issues.apache.org/jira/browse/FLINK-19771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-19771:
---
Assignee: Dylan Forciea
> NullPointerException when accessing null array from postgres in JDBC Conn
flinkbot edited a comment on pull request #13786:
URL: https://github.com/apache/flink/pull/13786#issuecomment-716269806
## CI report:
* f6bedbd6f4cc29777a888be558030b56ba803a54 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
wsry commented on pull request #13595:
URL: https://github.com/apache/flink/pull/13595#issuecomment-716275114
> Thanks a lot, the code looks generally good to me.
>
> I think the current configuration works also as a feature flag, which is
nice. If I read it correctly, sort-shuffle w
[
https://issues.apache.org/jira/browse/FLINK-19761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220452#comment-17220452
]
Xuannan Su commented on FLINK-19761:
You are right that not returning all the inform
[
https://issues.apache.org/jira/browse/FLINK-19771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220450#comment-17220450
]
Dylan Forciea commented on FLINK-19771:
---
[~Leonard Xu] Thank you for the pointer o
flinkbot edited a comment on pull request #13631:
URL: https://github.com/apache/flink/pull/13631#issuecomment-708335709
## CI report:
* 11b0dfc5a9a5e6aa335f070abfc6781569deb96d UNKNOWN
* 46f99482ad7bea8e467130fe5dd92b61b7d3d444 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-16012:
Fix Version/s: (was: 1.12.0)
1.13.0
> Reduce the default number of exclusiv
[
https://issues.apache.org/jira/browse/FLINK-16641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao updated FLINK-16641:
Fix Version/s: (was: 1.12.0)
1.13.0
> Announce sender's backlog to solve th
1 - 100 of 241 matches
Mail list logo
