twalthr commented on pull request #13332:
URL: https://github.com/apache/flink/pull/13332#issuecomment-694692321
@wuchong I think this is fine as long as it is still possible to override
the `flink-conf.yaml`. The `flink-conf.yaml` should be the default source of
truth.
-
[
https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198160#comment-17198160
]
limbo commented on FLINK-19285:
---
[~dwysakowicz] Oh, yes, I find my version is 1.11.0, than
wuchong commented on pull request #13332:
URL: https://github.com/apache/flink/pull/13332#issuecomment-694690614
Hi @twalthr , do you have any concerns on this change?
This is an automated message from the Apache Git Service
flinkbot edited a comment on pull request #13406:
URL: https://github.com/apache/flink/pull/13406#issuecomment-694116951
## CI report:
* 3bad8595c926440aa24c754eddeda1d9b54af8fd Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198159#comment-17198159
]
Jingsong Lee commented on FLINK-19121:
--
The fix did not go into release-1.11.2, fix
HuangXingBo commented on pull request #13415:
URL: https://github.com/apache/flink/pull/13415#issuecomment-694690389
@dianfu Thanks a lot for the review. I have addressed the comments at the
latest commit.
This is an automat
wuchong commented on a change in pull request #13332:
URL: https://github.com/apache/flink/pull/13332#discussion_r490736412
##
File path: flink-table/flink-sql-client/conf/sql-client-defaults.yaml
##
@@ -121,10 +121,10 @@ execution:
# current database of the current catalog
[
https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198158#comment-17198158
]
Dawid Wysakowicz commented on FLINK-19285:
--
I see you changed the affected vers
[
https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-19285.
Resolution: Duplicate
> Kafka sql connector fixed partitioner not work
> -
[
https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
limbo updated FLINK-19285:
--
Affects Version/s: (was: 1.11.1)
1.11.0
> Kafka sql connector fixed partitioner not
[
https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
limbo updated FLINK-19285:
--
Affects Version/s: (was: 1.11.2)
1.11.1
> Kafka sql connector fixed partitioner not
Zhu Zhu created FLINK-19287:
---
Summary: Fix minor version in flink docs
Key: FLINK-19287
URL: https://issues.apache.org/jira/browse/FLINK-19287
Project: Flink
Issue Type: Bug
Components: D
[
https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198154#comment-17198154
]
limbo commented on FLINK-19285:
---
Hi [~jark], thanks very much
I set parallelism is 2, and
wuchong commented on a change in pull request #13214:
URL: https://github.com/apache/flink/pull/13214#discussion_r490207066
##
File path:
flink-table/flink-table-common/src/test/java/org/apache/flink/table/factories/TestFormatDeserializationOnlyFactory.java
##
@@ -0,0 +1,83 @@
[
https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198149#comment-17198149
]
Dawid Wysakowicz commented on FLINK-19285:
--
[~limbo] Could you please double ch
flinkbot edited a comment on pull request #13416:
URL: https://github.com/apache/flink/pull/13416#issuecomment-694678006
## CI report:
* b1405ce3314c2799cd8172b50b4653389f36eca9 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #13406:
URL: https://github.com/apache/flink/pull/13406#issuecomment-694116951
## CI report:
* 6cc539fc8089fd3b0497fcf3c4af0ed929bcfe0f Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-19121.
Resolution: Fixed
> Avoid accessing HDFS frequently in HiveBulkWriterFactory
> ---
shuiqiangchen commented on pull request #13322:
URL: https://github.com/apache/flink/pull/13322#issuecomment-694682737
Hi @wangyang0918, could you please help review this PR? : )
This is an automated message from the Apache G
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190606#comment-17190606
]
Jingsong Lee edited comment on FLINK-19121 at 9/18/20, 6:28 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reopened FLINK-19121:
--
> Avoid accessing HDFS frequently in HiveBulkWriterFactory
> -
[
https://issues.apache.org/jira/browse/FLINK-19121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19121:
-
Fix Version/s: (was: 1.11.2)
1.11.3
> Avoid accessing HDFS frequently in
[
https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198145#comment-17198145
]
Leonard Xu commented on FLINK-18333:
Thanks [~dian.fu] [~jark] :)
> UnsignedTypeCon
[
https://issues.apache.org/jira/browse/FLINK-19243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-19243:
-
Fix Version/s: shaded-12.0
> Bump Snakeyaml to 1.27
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-19243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198146#comment-17198146
]
Chesnay Schepler commented on FLINK-19243:
--
shaded-master: c02c44840c25499c3f89
zentol commented on pull request #13406:
URL: https://github.com/apache/flink/pull/13406#issuecomment-694679929
@rmetzger done
This is an automated message from the Apache Git Service.
To respond to the message, please log on
SteNicholas commented on pull request #13298:
URL: https://github.com/apache/flink/pull/13298#issuecomment-694679741
> Thanks @SteNicholas. I will take a look shortly.
@twalthr could you please take a look for this pull request?
--
zentol merged pull request #90:
URL: https://github.com/apache/flink-shaded/pull/90
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
SteNicholas removed a comment on pull request #13298:
URL: https://github.com/apache/flink/pull/13298#issuecomment-685310268
@twalthr @rmetzger Could you please review this pull request? The current
behavior of SortOperationFactory are familiar to you. Thanks！
[
https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198143#comment-17198143
]
Jark Wu commented on FLINK-19285:
-
Hi [~limbo], what's the parallelism of your sink?
I
[
https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-19285:
Environment: (was: CREATE TABLE kafkaTable (
col1 BIGINT
) WITH (
'connector' = 'kafka',
'topic' =
[
https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-19285:
Description:
{code:sql}
CREATE TABLE kafkaTable (
col1 BIGINT
) WITH (
'connector' = 'kafka',
'topic'
flinkbot commented on pull request #13416:
URL: https://github.com/apache/flink/pull/13416#issuecomment-694678006
## CI report:
* b1405ce3314c2799cd8172b50b4653389f36eca9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-19280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198139#comment-17198139
]
Jark Wu commented on FLINK-19280:
-
Assigned to you [~lsy]
> The option "sink.buffer-flu
[
https://issues.apache.org/jira/browse/FLINK-19280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-19280:
---
Assignee: dalongliu
> The option "sink.buffer-flush.max-rows" for JDBC can't be disabled by set to
flinkbot edited a comment on pull request #13332:
URL: https://github.com/apache/flink/pull/13332#issuecomment-687612845
## CI report:
* 42afac79c813d8cedbbe30b5a9e158d4427515c2 UNKNOWN
* 95d5e493cc42f0ddb02c4ab9d99203e765ad104b Azure:
[SUCCESS](https://dev.azure.com/apache-fl
[
https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198137#comment-17198137
]
Jark Wu commented on FLINK-18333:
-
Thanks [~dian.fu]
> UnsignedTypeConversionITCase fai
zhuxiaoshang commented on a change in pull request #13414:
URL: https://github.com/apache/flink/pull/13414#discussion_r490723252
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java
##
@@ -187,8 +187,8 @@ public void r
SteNicholas commented on pull request #13332:
URL: https://github.com/apache/flink/pull/13332#issuecomment-694674838
@wuchong I have followed up with your comments to comment the `parallelism`
and `restart-strategy`, recoved the other options (`time-characteristic`,
`periodic-watermarks-in
zhuxiaoshang commented on a change in pull request #13414:
URL: https://github.com/apache/flink/pull/13414#discussion_r490721683
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java
##
@@ -223,6 +223,9 @@ public
zentol merged pull request #13403:
URL: https://github.com/apache/flink/pull/13403
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
dianfu commented on a change in pull request #13415:
URL: https://github.com/apache/flink/pull/13415#discussion_r49076
##
File path:
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/aggregate/arrow/batch/BatchArrowPythonGroupWindowAggregateFunctionOperato
[
https://issues.apache.org/jira/browse/FLINK-19281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198129#comment-17198129
]
Benchao Li commented on FLINK-19281:
[~ZhuShang] yes, you're right. assigned to you.
[
https://issues.apache.org/jira/browse/FLINK-19281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-19281:
--
Assignee: CloseRiver
> LIKE cannot recognize full table path
> --
flinkbot commented on pull request #13416:
URL: https://github.com/apache/flink/pull/13416#issuecomment-694667551
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
xintongsong closed pull request #13397:
URL: https://github.com/apache/flink/pull/13397
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
Zhu Zhu created FLINK-19286:
---
Summary: Improve pipelined region scheduling performance
Key: FLINK-19286
URL: https://issues.apache.org/jira/browse/FLINK-19286
Project: Flink
Issue Type: Sub-task
xintongsong commented on pull request #13397:
URL: https://github.com/apache/flink/pull/13397#issuecomment-694667340
Offline discussed with @KarmaGYZ, we decided to combine the changes of
FLINK-19178 & FLINK-19179 in #13416, to improve readability and avoid leaving
intermediate commits in
xintongsong commented on pull request #13416:
URL: https://github.com/apache/flink/pull/13416#issuecomment-694666993
cc @KarmaGYZ @azagrebin
This is an automated message from the Apache Git Service.
To respond to the message
[
https://issues.apache.org/jira/browse/FLINK-19179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19179:
---
Labels: pull-request-available (was: )
> Implement the managed memory fraction calculation
xintongsong opened a new pull request #13416:
URL: https://github.com/apache/flink/pull/13416
## What is the purpose of the change
This PR contains changes for both FLINK-19178 & FLINK-19179. Extends the
managed memory weight/fraction configurations and settings with respect to
mult
[
https://issues.apache.org/jira/browse/FLINK-19281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu updated FLINK-19281:
--
Description:
for example, if we have a table whose full path is
{{default_catalog.default_database.my
[
https://issues.apache.org/jira/browse/FLINK-19280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198123#comment-17198123
]
dalongliu commented on FLINK-19280:
---
I want to try fix it, can you assigne it to me.
[
https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198121#comment-17198121
]
limbo commented on FLINK-19285:
---
I tracked the code and find that
[https://github.com/apa
flinkbot edited a comment on pull request #13415:
URL: https://github.com/apache/flink/pull/13415#issuecomment-694656988
## CI report:
* 4a182a499c3867765b6ef3c3957fbe4c63c2dce1 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-18114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-18114.
---
Resolution: Won't Do
> Expose more details in logs for debugging bulk slot allocation failures
> ---
limbo created FLINK-19285:
-
Summary: Kafka sql connector fixed partitioner not work
Key: FLINK-19285
URL: https://issues.apache.org/jira/browse/FLINK-19285
Project: Flink
Issue Type: Bug
Co
[
https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-18333.
---
Resolution: Fixed
Thanks [~Leonard Xu] [~jark] for the fix and review. This issue doesn't occur
for more th
flinkbot commented on pull request #13415:
URL: https://github.com/apache/flink/pull/13415#issuecomment-694656988
## CI report:
* 4a182a499c3867765b6ef3c3957fbe4c63c2dce1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #13415:
URL: https://github.com/apache/flink/pull/13415#issuecomment-694653386
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-19277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19277:
---
Labels: pull-request-available (was: )
> Introduce BatchArrowPythonGroupWindowAggregateFunc
HuangXingBo opened a new pull request #13415:
URL: https://github.com/apache/flink/pull/13415
## What is the purpose of the change
*This pull request will introduce
BatchArrowPythonGroupWindowAggregateFunctionOperator for supporting Pandas
Batch Group Window Aggregation*
[
https://issues.apache.org/jira/browse/FLINK-19277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-19277:
---
Assignee: Huang Xingbo
> Introduce BatchArrowPythonGroupWindowAggregateFunctionOperator
> -
flinkbot edited a comment on pull request #13414:
URL: https://github.com/apache/flink/pull/13414#issuecomment-694646569
## CI report:
* 5b3479227664c09f527c045ab6d3623790fe3968 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
dianfu closed pull request #13388:
URL: https://github.com/apache/flink/pull/13388
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
[
https://issues.apache.org/jira/browse/FLINK-19184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-19184.
---
Resolution: Fixed
Merged to master(1.12) via da86aee1c36dbb7530ab750e1c3634f32b2479c7
> Add Batch Physical
flinkbot commented on pull request #13414:
URL: https://github.com/apache/flink/pull/13414#issuecomment-694646569
## CI report:
* 5b3479227664c09f527c045ab6d3623790fe3968 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #13412:
URL: https://github.com/apache/flink/pull/13412#issuecomment-694253946
## CI report:
* 85d80667243bb98025bc5aa52565f4e6b57d468a Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
JingsongLi commented on a change in pull request #13414:
URL: https://github.com/apache/flink/pull/13414#discussion_r490696171
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java
##
@@ -187,8 +187,8 @@ public void reg
flinkbot edited a comment on pull request #13412:
URL: https://github.com/apache/flink/pull/13412#issuecomment-694253946
## CI report:
* 85d80667243bb98025bc5aa52565f4e6b57d468a Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #13414:
URL: https://github.com/apache/flink/pull/13414#issuecomment-694640971
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-19227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19227:
---
Labels: pull-request-available starter (was: starter)
> The catalog is still created after
zhuxiaoshang opened a new pull request #13414:
URL: https://github.com/apache/flink/pull/13414
## What is the purpose of the change
When I create the HiveCatalog and Flink is not able to connect to the
HiveMetastore, the statement can not be executed, but the catalog is still
create
Jiayi-Liao commented on pull request #13412:
URL: https://github.com/apache/flink/pull/13412#issuecomment-694638017
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message, plea
[
https://issues.apache.org/jira/browse/FLINK-19262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-19262.
Resolution: Fixed
master: 49e3ff72e7fb06360c02578e30fa03cce24ca04f
> Can not setParallelism for F
[
https://issues.apache.org/jira/browse/FLINK-19281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198100#comment-17198100
]
CloseRiver commented on FLINK-19281:
I think ,we should use `sqlTableLike.getSourceT
JingsongLi merged pull request #13402:
URL: https://github.com/apache/flink/pull/13402
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-19200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198099#comment-17198099
]
leslieyuan commented on FLINK-19200:
[~jark] Hi jark
thanks for your work, in my op
[
https://issues.apache.org/jira/browse/FLINK-18444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198096#comment-17198096
]
Roc Marshal commented on FLINK-18444:
-
Hi, [~dian.fu]
According to the logic of the
[
https://issues.apache.org/jira/browse/FLINK-19264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198094#comment-17198094
]
Zhu Zhu commented on FLINK-19264:
-
[~aljoscha] yes the {{StreamNode}} hash is, if not sp
[
https://issues.apache.org/jira/browse/FLINK-19283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198091#comment-17198091
]
Yun Tang commented on FLINK-19283:
--
[~adriank], I am not familiar with the background o
flinkbot edited a comment on pull request #13388:
URL: https://github.com/apache/flink/pull/13388#issuecomment-692422938
## CI report:
* 6d3f77bd08ed3dba62375807a06325e320b98fb3 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
JingsongLi commented on pull request #13411:
URL: https://github.com/apache/flink/pull/13411#issuecomment-694616610
We should add case to test file sink without input.
This is an automated message from the Apache Git Service.
flinkbot edited a comment on pull request #13388:
URL: https://github.com/apache/flink/pull/13388#issuecomment-692422938
## CI report:
* 6d3f77bd08ed3dba62375807a06325e320b98fb3 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
leonardBang commented on pull request #13294:
URL: https://github.com/apache/flink/pull/13294#issuecomment-694613774
'canal-json.database.include' and 'canal-json.table.include' make sense to
me,
LGTM
This is an
wuchong commented on pull request #13332:
URL: https://github.com/apache/flink/pull/13332#issuecomment-694613797
@godfreyhe , I don't think so. The purpose of this task is fallback some
important runtime configuration to `flink-conf.yaml` instead of setting them in
`sql-client-defaults.yam
HuangXingBo commented on pull request #13388:
URL: https://github.com/apache/flink/pull/13388#issuecomment-694612738
@dianfu Thanks a lot for the review. I have addressed comments at the latest
commit.
This is an automated m
HuangXingBo commented on a change in pull request #13388:
URL: https://github.com/apache/flink/pull/13388#discussion_r490665709
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/batch/table/AggregateTest.scala
##
@@ -72,4 +7
[
https://issues.apache.org/jira/browse/FLINK-19246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-19246.
---
Fix Version/s: 1.12.0
Resolution: Fixed
Fixed in master (1.12.0): b930423c5a7f1f30ce0ff837d28bde15a40
HuangXingBo commented on a change in pull request #13388:
URL: https://github.com/apache/flink/pull/13388#discussion_r490665510
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecPythonGroupAggregate.sca
wuchong commented on pull request #13407:
URL: https://github.com/apache/flink/pull/13407#issuecomment-694611904
Merging...
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
wuchong merged pull request #13407:
URL: https://github.com/apache/flink/pull/13407
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
HuangXingBo commented on a change in pull request #13388:
URL: https://github.com/apache/flink/pull/13388#discussion_r490665353
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/BatchExecPythonAggregateRule.java
HuangXingBo commented on a change in pull request #13388:
URL: https://github.com/apache/flink/pull/13388#discussion_r490665067
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/BatchExecPythonAggregateRule.java
HuangXingBo commented on a change in pull request #13388:
URL: https://github.com/apache/flink/pull/13388#discussion_r490664786
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/BatchExecSortAggRule.scala
##
dianfu commented on a change in pull request #13230:
URL: https://github.com/apache/flink/pull/13230#discussion_r490225135
##
File path: docs/dev/python/datastream-api-users-guide/operators.md
##
@@ -0,0 +1,87 @@
+---
+title: "Operators"
+nav-parent_id: python_datastream_api
+n
[
https://issues.apache.org/jira/browse/FLINK-12751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198068#comment-17198068
]
Yang Wang commented on FLINK-12751:
---
Yes, you are right. I am aware of this solution.
SteNicholas removed a comment on pull request #13298:
URL: https://github.com/apache/flink/pull/13298#issuecomment-694090738
> Thanks @SteNicholas. I will take a look shortly.
@twalthr Thanks.
This is an automated mess
[
https://issues.apache.org/jira/browse/FLINK-19246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198057#comment-17198057
]
Dian Fu commented on FLINK-19246:
-
https://dev.azure.com/apache-flink/apache-flink/_buil
[
https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17198056#comment-17198056
]
Dian Fu commented on FLINK-17274:
-
https://dev.azure.com/apache-flink/apache-flink/_buil
1 - 100 of 358 matches
Mail list logo
