godfreyhe commented on a change in pull request #14606:
URL: https://github.com/apache/flink/pull/14606#discussion_r557118638
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchPhysicalHashJoin.scala
###
flinkbot edited a comment on pull request #14536:
URL: https://github.com/apache/flink/pull/14536#issuecomment-752909965
## CI report:
* a4c6b2e3d222c1679ce19d21a7f108d63d8dc3fc UNKNOWN
* e8c1e77209e80aa39985342f01c3d8d566220d1a UNKNOWN
* ba7aceff1a94c93ce89ed15359c992f62ad8
flinkbot edited a comment on pull request #14616:
URL: https://github.com/apache/flink/pull/14616#issuecomment-758526377
## CI report:
* 448c026a402e045e050f405daf934a8a7c880c9d UNKNOWN
* aac6ca6fa0792f2ecb4d982545fea6403115f24b Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #14614:
URL: https://github.com/apache/flink/pull/14614#issuecomment-758512892
## CI report:
* 879417b9fbfe847c1a90de5caef7817edd10d69a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14627:
URL: https://github.com/apache/flink/pull/14627#issuecomment-759272918
## CI report:
* a0e6a39605a3d1a80f75f8764534dfb82d08c31f Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
WeiNan Zhao created FLINK-20967:
---
Summary: Add Documentation for hbase connector new Function
Key: FLINK-20967
URL: https://issues.apache.org/jira/browse/FLINK-20967
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-20938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264678#comment-17264678
]
Shaun commented on FLINK-20938:
---
* Development needs support
> Implement Flink's own tenc
flinkbot edited a comment on pull request #14638:
URL: https://github.com/apache/flink/pull/14638#issuecomment-759991130
## CI report:
* 99448538758f042069a6e9eb6e319726a54ca92c Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-20967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-20967:
---
Assignee: WeiNan Zhao
> Add documentation for the new introduced 'properties.*' option in HBase
>
[
https://issues.apache.org/jira/browse/FLINK-20967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20967:
Summary: Add documentation for the new introduced 'properties.*' option in
HBase connector (was: Add Docu
[
https://issues.apache.org/jira/browse/FLINK-20967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20967:
Component/s: Table SQL / Ecosystem
> Add documentation for the new introduced 'properties.*' option in HBa
[
https://issues.apache.org/jira/browse/FLINK-20812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20812:
Summary: Support 'properties.*' option to pass through all the HBase
properties (was: flink connector hba
[
https://issues.apache.org/jira/browse/FLINK-20966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-20966:
--
Assignee: godfrey he
> Rename Stream(/Batch)ExecIntermediateTableScan to
> Stream(/Batch)Phy
wuchong commented on pull request #14616:
URL: https://github.com/apache/flink/pull/14616#issuecomment-760011288
The compile is failed again...
This is an automated message from the Apache Git Service.
To respond to the mess
godfrey he created FLINK-20968:
--
Summary: Remove legacy exec nodes
Key: FLINK-20968
URL: https://issues.apache.org/jira/browse/FLINK-20968
Project: Flink
Issue Type: Sub-task
Component
gaoyunhaii commented on pull request #13377:
URL: https://github.com/apache/flink/pull/13377#issuecomment-760012794
> Hi,@gaoyunhaii,could you rebase the branch to resovle the conflicts?
Hi, @wangjian2019 should be the author of the PR, and @wangjian2019 could
you help with the rebas
flinkbot edited a comment on pull request #14536:
URL: https://github.com/apache/flink/pull/14536#issuecomment-752909965
## CI report:
* a4c6b2e3d222c1679ce19d21a7f108d63d8dc3fc UNKNOWN
* e8c1e77209e80aa39985342f01c3d8d566220d1a UNKNOWN
* ba7aceff1a94c93ce89ed15359c992f62ad8
Erwan Loisant created FLINK-20969:
-
Summary: Update Scala 2.12 version to 2.12.13
Key: FLINK-20969
URL: https://issues.apache.org/jira/browse/FLINK-20969
Project: Flink
Issue Type: Task
flinkbot edited a comment on pull request #14626:
URL: https://github.com/apache/flink/pull/14626#issuecomment-759272820
## CI report:
* 1387747f865a79d120ee7f5d6f24685c90e0076f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14631:
URL: https://github.com/apache/flink/pull/14631#issuecomment-759388845
## CI report:
* e283ba5376620acf2206a9c9ff7a4cdc9ba9 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14637:
URL: https://github.com/apache/flink/pull/14637#issuecomment-759980085
## CI report:
* 8b2bf9a0a0d1c74ea4a6d1712dccb415dcd34a4d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-20969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Erwan Loisant updated FLINK-20969:
--
Component/s: (was: Build System)
API / Scala
> Update Scala 2.12 version
xiaoHoly commented on pull request #14616:
URL: https://github.com/apache/flink/pull/14616#issuecomment-760015927
> The compile is failed again...
fix again
This is an automated message from the Apache Git Service.
To
erwan opened a new pull request #14639:
URL: https://github.com/apache/flink/pull/14639
## What is the purpose of the change
Flink is compiled with Scala 2.12.7, that was released in 2018.
The latest version of the 2.12 series is 2.12.13, and upgrading will bring
build perform
[
https://issues.apache.org/jira/browse/FLINK-20969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20969:
---
Labels: pull-request-available (was: )
> Update Scala 2.12 version to 2.12.13
> ---
flinkbot commented on pull request #14639:
URL: https://github.com/apache/flink/pull/14639#issuecomment-760019540
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-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264691#comment-17264691
]
Erwan Loisant commented on FLINK-13414:
---
As we're working on upping the Scala vers
[
https://issues.apache.org/jira/browse/FLINK-20840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17258216#comment-17258216
]
Leonard Xu edited comment on FLINK-20840 at 1/14/21, 8:33 AM:
[
https://issues.apache.org/jira/browse/FLINK-20969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264694#comment-17264694
]
Erwan Loisant commented on FLINK-20969:
---
I'm getting a compatibility warning, what
zhuxiaoshang opened a new pull request #14640:
URL: https://github.com/apache/flink/pull/14640
…le with "watermark for proctime()" syntax
## What is the purpose of the change
*don't need to resolve schema when drop table *
## Brief change log
*(for example:)*
[
https://issues.apache.org/jira/browse/FLINK-20937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20937:
---
Labels: pull-request-available starter (was: starter)
> Drop table can fails, when i create
flinkbot commented on pull request #14640:
URL: https://github.com/apache/flink/pull/14640#issuecomment-760025295
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 #14530:
URL: https://github.com/apache/flink/pull/14530#issuecomment-752828495
## CI report:
* eaa0445691254f544c231ec0d2d55519af277b33 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14606:
URL: https://github.com/apache/flink/pull/14606#issuecomment-757754275
## CI report:
* 3776b52cfe3535dcc193b3a922a7d1d658126d66 UNKNOWN
* 155b18c169e45a97cd52c5b43883d5cf6b79f038 UNKNOWN
* 29868c9db791dc78af63512150e7f5c6a829
flinkbot edited a comment on pull request #14616:
URL: https://github.com/apache/flink/pull/14616#issuecomment-758526377
## CI report:
* 448c026a402e045e050f405daf934a8a7c880c9d UNKNOWN
* aac6ca6fa0792f2ecb4d982545fea6403115f24b Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #14631:
URL: https://github.com/apache/flink/pull/14631#issuecomment-759388845
## CI report:
* e283ba5376620acf2206a9c9ff7a4cdc9ba9 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14637:
URL: https://github.com/apache/flink/pull/14637#issuecomment-759980085
## CI report:
* 8b2bf9a0a0d1c74ea4a6d1712dccb415dcd34a4d Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #14639:
URL: https://github.com/apache/flink/pull/14639#issuecomment-760032294
## CI report:
* 8b40b5ac2faf8d07403c16dcd975ddee473ef8a1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-19158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-19158:
---
[~rmetzger] could you please take another look?
> Revisit java e2e download timeouts
>
[
https://issues.apache.org/jira/browse/FLINK-20835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-20835:
Assignee: Yangze Guo
> Implement FineGrainedSlotManager
> ---
Wong Mulan created FLINK-20970:
--
Summary: DECIMAL(10, 0) can not be GROUP BY key.
Key: FLINK-20970
URL: https://issues.apache.org/jira/browse/FLINK-20970
Project: Flink
Issue Type: Bug
flinkbot edited a comment on pull request #14616:
URL: https://github.com/apache/flink/pull/14616#issuecomment-758526377
## CI report:
* 448c026a402e045e050f405daf934a8a7c880c9d UNKNOWN
* aac6ca6fa0792f2ecb4d982545fea6403115f24b Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #14639:
URL: https://github.com/apache/flink/pull/14639#issuecomment-760032294
## CI report:
* 8b40b5ac2faf8d07403c16dcd975ddee473ef8a1 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #14640:
URL: https://github.com/apache/flink/pull/14640#issuecomment-760055828
## CI report:
* cd36249da9dfea6f8a8ce9eccfe89c220535131e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-20970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wong Mulan updated FLINK-20970:
---
Description:
If value which type is not DECIMAL(38, 18) is GROUP BY key, the result will be
-1.
So,
HuangXingBo opened a new pull request #14641:
URL: https://github.com/apache/flink/pull/14641
## What is the purpose of the change
*This pull request will Port batch python group aggregate nodes to Java*
## Brief change log
- *Port batch python group aggregate node
[
https://issues.apache.org/jira/browse/FLINK-20341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-20341.
-
Resolution: Fixed
Done since all subtasks have been completed.
> Rework Deployment / Coordinati
[
https://issues.apache.org/jira/browse/FLINK-20751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20751:
---
Labels: pull-request-available (was: )
> Port batch python group aggregate nodes to Java
>
flinkbot edited a comment on pull request #14640:
URL: https://github.com/apache/flink/pull/14640#issuecomment-760055828
## CI report:
* cd36249da9dfea6f8a8ce9eccfe89c220535131e Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
Timo Walther created FLINK-20971:
Summary: Allow SQL expressions in Table API
Key: FLINK-20971
URL: https://issues.apache.org/jira/browse/FLINK-20971
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-20944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-20944:
--
Fix Version/s: 1.12.2
1.13.0
> Launching in application mode requesting a C
[
https://issues.apache.org/jira/browse/FLINK-20944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-20944:
--
Priority: Critical (was: Major)
> Launching in application mode requesting a ClusterIP rest s
flinkbot commented on pull request #14641:
URL: https://github.com/apache/flink/pull/14641#issuecomment-760081285
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-20919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264722#comment-17264722
]
Till Rohrmann commented on FLINK-20919:
---
Could you maybe also share the client log
[
https://issues.apache.org/jira/browse/FLINK-20927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264726#comment-17264726
]
Till Rohrmann commented on FLINK-20927:
---
You can update them but it is not very im
AHeise commented on a change in pull request #13551:
URL: https://github.com/apache/flink/pull/13551#discussion_r557266156
##
File path:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java
##
@@ -69,13 +74,28 @@ pub
flinkbot edited a comment on pull request #14606:
URL: https://github.com/apache/flink/pull/14606#issuecomment-757754275
## CI report:
* 3776b52cfe3535dcc193b3a922a7d1d658126d66 UNKNOWN
* 155b18c169e45a97cd52c5b43883d5cf6b79f038 UNKNOWN
* 29868c9db791dc78af63512150e7f5c6a829
flinkbot edited a comment on pull request #14614:
URL: https://github.com/apache/flink/pull/14614#issuecomment-758512892
## CI report:
* f3a5b0e4feb3bf16edecba4946fc0d160d7a4bce Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14631:
URL: https://github.com/apache/flink/pull/14631#issuecomment-759388845
## CI report:
* e283ba5376620acf2206a9c9ff7a4cdc9ba9 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14637:
URL: https://github.com/apache/flink/pull/14637#issuecomment-759980085
## CI report:
* afd1a28c76fbfc06338673821228f041812618cb Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #14641:
URL: https://github.com/apache/flink/pull/14641#issuecomment-760086252
## CI report:
* e0c4115590cdbea89d30285c22f30208cf3895ca UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
AHeise commented on a change in pull request #13551:
URL: https://github.com/apache/flink/pull/13551#discussion_r557270935
##
File path: flink-runtime/pom.xml
##
@@ -509,6 +509,16 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-20927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264732#comment-17264732
]
Ruguo Yu commented on FLINK-20927:
--
Ok [~trohrmann] , could you assign it to me? THX!
chaozwn opened a new pull request #14642:
URL: https://github.com/apache/flink/pull/14642
## What is the purpose of the change
add change doc.
## Brief change log
## Verifying this change
## Does this pull request potentially affect one of the
flinkbot commented on pull request #14642:
URL: https://github.com/apache/flink/pull/14642#issuecomment-760092328
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
chaozwn closed pull request #14642:
URL: https://github.com/apache/flink/pull/14642
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
zentol commented on a change in pull request #13551:
URL: https://github.com/apache/flink/pull/13551#discussion_r557279916
##
File path:
flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java
##
@@ -69,13 +74,28 @@ pub
[
https://issues.apache.org/jira/browse/FLINK-20969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-20969.
Resolution: Duplicate
> Update Scala 2.12 version to 2.12.13
> ---
flinkbot edited a comment on pull request #14614:
URL: https://github.com/apache/flink/pull/14614#issuecomment-758512892
## CI report:
* f3a5b0e4feb3bf16edecba4946fc0d160d7a4bce Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14616:
URL: https://github.com/apache/flink/pull/14616#issuecomment-758526377
## CI report:
* 448c026a402e045e050f405daf934a8a7c880c9d UNKNOWN
* f429967b7680aa4dce4212ddb01b2c107b3b7117 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #14641:
URL: https://github.com/apache/flink/pull/14641#issuecomment-760086252
## CI report:
* e0c4115590cdbea89d30285c22f30208cf3895ca Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
zentol commented on a change in pull request #14630:
URL: https://github.com/apache/flink/pull/14630#discussion_r557283929
##
File path: flink-dist/src/main/flink-bin/bin/docker-entrypoint.sh
##
@@ -0,0 +1,176 @@
+#!/usr/bin/env bash
+
+#
zentol commented on pull request #14630:
URL: https://github.com/apache/flink/pull/14630#issuecomment-760098909
@wangyang0918 I have outlined this approach and already gotten their
approval.
https://github.com/docker-library/official-images/pull/9249#issuecomment-756902869
--
zentol edited a comment on pull request #14630:
URL: https://github.com/apache/flink/pull/14630#issuecomment-760098909
@wangyang0918 I have outlined this approach and already gotten their
approval.
https://github.com/docker-library/official-images/pull/9249#issuecomment-756902869
(note
huajiewang created FLINK-20972:
--
Summary: TwoPhaseCommitSinkFunction Output a large amount of
EventData
Key: FLINK-20972
URL: https://issues.apache.org/jira/browse/FLINK-20972
Project: Flink
Is
zentol edited a comment on pull request #14630:
URL: https://github.com/apache/flink/pull/14630#issuecomment-760098909
@wangyang0918 I have outlined this approach and already gotten their
approval.
https://github.com/docker-library/official-images/pull/9249#issuecomment-756902869
(note
[
https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264740#comment-17264740
]
Yordan Pavlov commented on FLINK-16267:
---
[~azagrebin] Do we consider the problem w
[
https://issues.apache.org/jira/browse/FLINK-20969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264743#comment-17264743
]
Aljoscha Krettek commented on FLINK-20969:
--
[~eloisant] Please continue on FLIN
[
https://issues.apache.org/jira/browse/FLINK-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264747#comment-17264747
]
Marek Simunek commented on FLINK-13247:
---
Hi, is there some raw plan when it will b
flinkbot edited a comment on pull request #14614:
URL: https://github.com/apache/flink/pull/14614#issuecomment-758512892
## CI report:
* f3a5b0e4feb3bf16edecba4946fc0d160d7a4bce Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #14630:
URL: https://github.com/apache/flink/pull/14630#issuecomment-759372895
## CI report:
* 656628f8e564ef8ee29032d392f1485a8b0d9eea UNKNOWN
* b3370da98fb5903795c396172842e33c2bbf7575 Azure:
[SUCCESS](https://dev.azure.com/apache-fl
aljoscha opened a new pull request #14643:
URL: https://github.com/apache/flink/pull/14643
This is a backport of #14312 for Flink 1.12. The changes applied cleanly.
Please see the ML discussion, where there was consensus for this backport:
https://lists.apache.org/thread.html/rb0de66
[
https://issues.apache.org/jira/browse/FLINK-16444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264751#comment-17264751
]
fanrui commented on FLINK-16444:
+1, some latency metrics are very useful.
Use flink-be
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huajiewang updated FLINK-20972:
---
Attachment: Jdbc2PCSinkFunction.scala
> TwoPhaseCommitSinkFunction Output a large amount of EventDat
[
https://issues.apache.org/jira/browse/FLINK-20927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264754#comment-17264754
]
Till Rohrmann commented on FLINK-20927:
---
I've assigned it to you.
> Update config
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
huajiewang updated FLINK-20972:
---
Description:
when TwoPhaseCommitSinkFunctionOutput tigger notifyCheckpointComplete,
Maybe A large n
[
https://issues.apache.org/jira/browse/FLINK-20927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-20927:
-
Assignee: Ruguo Yu
> Update configuration option in YarnConfigOptions class
> -
[
https://issues.apache.org/jira/browse/FLINK-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264757#comment-17264757
]
Till Rohrmann commented on FLINK-13247:
---
At the moment I am not aware that the com
flinkbot commented on pull request #14643:
URL: https://github.com/apache/flink/pull/14643#issuecomment-760109092
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
he jie created FLINK-20974:
--
Summary: docker容器pyflink中stream任务取消之后会留下几个僵尸进程
Key: FLINK-20974
URL: https://issues.apache.org/jira/browse/FLINK-20974
Project: Flink
Issue Type: Bug
Component
kunnni created FLINK-20973:
--
Summary: failed to submit flink-on-yarn job on Windows due to
error of classPath
Key: FLINK-20973
URL: https://issues.apache.org/jira/browse/FLINK-20973
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264765#comment-17264765
]
Yun Gao commented on FLINK-20972:
-
Hi [~benjobs], which log is outputted a lot~? Do you
leonardBang opened a new pull request #14644:
URL: https://github.com/apache/flink/pull/14644
## What is the purpose of the change
* Currently the rule `FlinkProjectJoinTransposeRule` was added in logical
optimize phase which uses volcano optimizer, the optimized plan is uncertain
b
leonardBang commented on pull request #14644:
URL: https://github.com/apache/flink/pull/14644#issuecomment-760112428
cc： @godfreyhe could you help review this PR?
This is an automated message from the Apache Git Service.
To r
[
https://issues.apache.org/jira/browse/FLINK-20974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-20974.
Resolution: Invalid
Please use English in JIRA.
> docker容器pyflink中stream任务取消之后会留下几个僵尸进程
>
[
https://issues.apache.org/jira/browse/FLINK-20840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20840:
---
Labels: pull-request-available (was: )
> Projection pushdown doesn't work in temporal(looku
Till Rohrmann created FLINK-20975:
-
Summary: HiveTableSourceITCase.testPartitionFilter fails on AZP
Key: FLINK-20975
URL: https://issues.apache.org/jira/browse/FLINK-20975
Project: Flink
Issu
tillrohrmann commented on pull request #14593:
URL: https://github.com/apache/flink/pull/14593#issuecomment-760112835
Thanks for the review @XComp. The failing test case seems to be unrelated.
Merging it now.
This is an auto
tillrohrmann closed pull request #14593:
URL: https://github.com/apache/flink/pull/14593
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 g
[
https://issues.apache.org/jira/browse/FLINK-20903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-20903.
-
Resolution: Fixed
Fixed via
7a001c6c7a813c8af55ac798547c5036446df71d
b580b7def435deac11cba8ff04
1 - 100 of 507 matches
Mail list logo
