klion26 commented on issue #8263: [FLINK-12296][StateBackend]Data loss silently
in RocksDBStateBackend because of local directory collision
URL: https://github.com/apache/flink/pull/8263#issuecomment-486530076
@flinkbot attention @StefanRRichter
flinkbot commented on issue #8264: [hotfix][yarn] userJarFiles can be a local
variable
URL: https://github.com/apache/flink/pull/8264#issuecomment-486528896
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
TisonKun opened a new pull request #8264: [hotfix][yarn] userJarFiles can be a
local variable
URL: https://github.com/apache/flink/pull/8264
## What is the purpose of the change
Variable `AbstractYarnClusterDescriptor#userJarFiles` can be a local
variable. Localize it for
flinkbot commented on issue #8263: [FLINK-12296][StateBackend]Data loss
silently in RocksDBStateBackend because of local directory collision
URL: https://github.com/apache/flink/pull/8263#issuecomment-486528377
Thanks a lot for your contribution to the Apache Flink project. I'm the
[
https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12296:
---
Labels: pull-request-available (was: )
> Data loss silently in RocksDBStateBackend when
[
https://issues.apache.org/jira/browse/FLINK-11477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825745#comment-16825745
]
Bowen Li commented on FLINK-11477:
--
[~twalthr] FLINK-9172, its PR, and most discussions were based on
klion26 opened a new pull request #8263: St[FLINK-12296][StateBackend]Data loss
silently in RocksDBStateBackend because of local directory collision
URL: https://github.com/apache/flink/pull/8263
## What is the purpose of the change
Fix the data loss silently problem in
[
https://issues.apache.org/jira/browse/FLINK-6976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanchun Zhang reassigned FLINK-6976:
-
Assignee: Zhanchun Zhang
> Add STR_TO_DATE supported in TableAPI
>
[
https://issues.apache.org/jira/browse/FLINK-11477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-11477:
-
Description:
As the configuration for SQL client, the YAML file currently allows one to
register
[
https://issues.apache.org/jira/browse/FLINK-11477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-11477:
-
Description:
As the configuration for SQL client, the YAML file currently allows one to
register
klion26 commented on issue #8223: [FLINK-9904]Allow users to control
MaxDirectMemorySize
URL: https://github.com/apache/flink/pull/8223#issuecomment-486525091
@tianchen92 thanks for your contribution, Could you please clear the last
merge commit? you can use `git rebase`.
Aitozi closed pull request #8258: [FLINK-12297]Harden ClosureCleaner to handle
the wrapped function
URL: https://github.com/apache/flink/pull/8258
This is an automated message from the Apache Git Service.
To respond to the
Aitozi commented on issue #8258: [FLINK-12297]Harden ClosureCleaner to handle
the wrapped function
URL: https://github.com/apache/flink/pull/8258#issuecomment-486524025
close for the failed travis ci and will reopen then
[
https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825700#comment-16825700
]
Yingjie Cao edited comment on FLINK-12070 at 4/25/19 4:25 AM:
--
The test is
[
https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825700#comment-16825700
]
Yingjie Cao edited comment on FLINK-12070 at 4/25/19 4:21 AM:
--
The test is
[
https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825700#comment-16825700
]
Yingjie Cao edited comment on FLINK-12070 at 4/25/19 4:18 AM:
--
The test is
[
https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825700#comment-16825700
]
Yingjie Cao commented on FLINK-12070:
-
The test is still running and will take a bit more time. Now
Yingjie Cao created FLINK-12329:
---
Summary: Netty thread deadlock bug of the SpilledSubpartitionView
Key: FLINK-12329
URL: https://issues.apache.org/jira/browse/FLINK-12329
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825698#comment-16825698
]
Dian Fu commented on FLINK-12308:
-
Hi [~sunjincheng121] that's very kind of you. It is great to
lamber-ken edited a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-486509247
@tillrohrmann, I add a junit case
KurtYoung commented on a change in pull request #8222: [FLINK-11518] [table]
Add partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r278388857
##
File path:
KurtYoung commented on a change in pull request #8222: [FLINK-11518] [table]
Add partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r278387973
##
File path:
KurtYoung commented on a change in pull request #8222: [FLINK-11518] [table]
Add partition related catalog APIs and implement them in GenericInMemoryCatalog
URL: https://github.com/apache/flink/pull/8222#discussion_r278388563
##
File path:
lamber-ken commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-486510735
hi @tillrohrmann, a minimal reproducible flink program can simulate this bug
lamber-ken edited a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-486509247
@tillrohrmann, I add a junit case
lamber-ken edited a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-486509247
@tillrohrmann, I add a junit case
lamber-ken commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-486509247
@tillrohrmann, I add a junit case
[
https://issues.apache.org/jira/browse/FLINK-12320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825684#comment-16825684
]
shin chen edited comment on FLINK-12320 at 4/25/19 3:40 AM:
Hi. [~kisimple]
[
https://issues.apache.org/jira/browse/FLINK-12320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825684#comment-16825684
]
shin chen commented on FLINK-12320:
---
Hi.
When I using SequenceFile.CompressionType.Record, everything
[
https://issues.apache.org/jira/browse/FLINK-11635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825679#comment-16825679
]
PengYang commented on FLINK-11635:
--
[~klion26] Ok, thank you, I have already assigned it.
> Translate
[
https://issues.apache.org/jira/browse/FLINK-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825678#comment-16825678
]
vinoyang commented on FLINK-12328:
--
[~chauncy] Absolutely yes! Any contribution is welcome. Some minor
[
https://issues.apache.org/jira/browse/FLINK-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PengYang reassigned FLINK-12328:
Assignee: (was: PengYang)
> Invalid Express
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-12320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825677#comment-16825677
]
boshu Zheng commented on FLINK-12320:
-
Hi [~shinchen] could you please give more detail about this
[
https://issues.apache.org/jira/browse/FLINK-11635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PengYang reassigned FLINK-11635:
Assignee: PengYang
> Translate "Checkpointing" page into Chinese
>
[
https://issues.apache.org/jira/browse/FLINK-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PengYang reassigned FLINK-12328:
Assignee: PengYang (was: chauncy)
> Invalid Express
> ---
>
> Key:
Kejian-Li closed pull request #8262: [FLINK-12306][runtime] Change the name of
variable "log" to upper case "LOG"
URL: https://github.com/apache/flink/pull/8262
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-11635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825674#comment-16825674
]
Congxian Qiu(klion26) commented on FLINK-11635:
---
[~pengyang] Please feel free to take it.
[
https://issues.apache.org/jira/browse/FLINK-11635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825672#comment-16825672
]
彭洋 commented on FLINK-11635:
I hope I can come to translate this page
> Translate "Checkpointing" page into
Kejian-Li opened a new pull request #8262: [FLINK-12306][runtime] Change the
name of variable "log" to upper case "LOG"
URL: https://github.com/apache/flink/pull/8262
## What is the purpose of the change
Change the name of variable "log" into "LOG" to correspond to other
[
https://issues.apache.org/jira/browse/FLINK-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825668#comment-16825668
]
chauncy commented on FLINK-12328:
-
[~yanghua] can i create pull request for this problem
> Invalid
Kejian-Li closed pull request #8262: [FLINK-12306][runtime] Change the name of
variable "log" to upper case "LOG"
URL: https://github.com/apache/flink/pull/8262
This is an automated message from the Apache Git Service.
To
vthinkxie edited a comment on issue #8016: [FLINK-10705][web]: Rework Flink Web
Dashboard
URL: https://github.com/apache/flink/pull/8016#issuecomment-486503724
Hi @rmetzger
I have added the failure message and update the NOTICE and LICENSE file
Thanks a lot for taking your time for
vthinkxie commented on issue #8016: [FLINK-10705][web]: Rework Flink Web
Dashboard
URL: https://github.com/apache/flink/pull/8016#issuecomment-486503724
Hi @rmetzger
I have added the failure message and update the NOTICE and LICENSE file
Thanks a lot for taking your time for the
Kejian-Li closed pull request #8262: Change the name of variable "log" to upper
case "LOG"
URL: https://github.com/apache/flink/pull/8262
This is an automated message from the Apache Git Service.
To respond to the message,
flinkbot commented on issue #8262: Change the name of variable "log" to upper
case "LOG"
URL: https://github.com/apache/flink/pull/8262#issuecomment-486503240
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
Kejian-Li opened a new pull request #8262: Change the name of variable "log" to
upper case "LOG"
URL: https://github.com/apache/flink/pull/8262
## What is the purpose of the change
Change the name of variable "log" into "LOG" to correspond to other class
files.
Kejian-Li opened a new pull request #8262: Change the name of variable "log" to
upper case "LOG"
URL: https://github.com/apache/flink/pull/8262
## What is the purpose of the change
Change the name of variable "log" into "LOG" to correspond to other class
files.
zjffdu commented on issue #8144: [FLINK-12159]. Enable YarnMiniCluster
integration test under non-secure mode
URL: https://github.com/apache/flink/pull/8144#issuecomment-486502919
@tillrohrmann I am afraid that just adding yarn-site.xml explicitly via
addShipFiles is not sufficient. It
chauncy created FLINK-12328:
---
Summary: Invalid Express
Key: FLINK-12328
URL: https://issues.apache.org/jira/browse/FLINK-12328
Project: Flink
Issue Type: Improvement
Affects Versions: 1.8.0
Kejian-Li closed pull request #8249: [FLINK-12306][runtime] Change the name of
variable log into LOG to co…
URL: https://github.com/apache/flink/pull/8249
This is an automated message from the Apache Git Service.
To respond
Kejian-Li removed a comment on issue #8249: [FLINK-12306][runtime] Change the
name of variable log into LOG to co…
URL: https://github.com/apache/flink/pull/8249#issuecomment-486500160
Hi, Jark Wu @wuchong, I have made a trivial change. Could you please help me
review it at your
[
https://issues.apache.org/jira/browse/FLINK-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-10713:
Assignee: Yun Tang
> RestartIndividualStrategy does not restore state
>
Kejian-Li commented on issue #8249: [FLINK-12306][runtime] Change the name of
variable log into LOG to co…
URL: https://github.com/apache/flink/pull/8249#issuecomment-486500160
Hi, Jark Wu @wuchong, I have made a trivial change. Could you please help me
review it at your convenience.
[
https://issues.apache.org/jira/browse/FLINK-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
boshu Zheng reassigned FLINK-10713:
---
Assignee: (was: boshu Zheng)
> RestartIndividualStrategy does not restore state
>
[
https://issues.apache.org/jira/browse/FLINK-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825659#comment-16825659
]
boshu Zheng commented on FLINK-10713:
-
[~yunta] Sure, feel free to go ahead :)
>
tianchen92 commented on issue #8219: [FLINK-10441]Don't log warning when
creating upload directory
URL: https://github.com/apache/flink/pull/8219#issuecomment-486498189
@zentol @uce Thanks for your detailed comments, I have got your point. Is it
right to add a param in createUploadDir to
[
https://issues.apache.org/jira/browse/FLINK-12196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chauncy reassigned FLINK-12196:
---
Assignee: chauncy
> FlinkKafkaProducer011ITCase#testRunOutOfProducersInThePool throws NPE
>
[
https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825651#comment-16825651
]
vinoyang commented on FLINK-11935:
--
[~walterddr] In CALCITE-2989, [~julianhyde] gave a link which
[
https://issues.apache.org/jira/browse/FLINK-12196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chauncy updated FLINK-12196:
Summary: FlinkKafkaProducer011ITCase#testRunOutOfProducersInThePool throws
NPE (was:
[
https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825650#comment-16825650
]
Ning Shi commented on FLINK-12296:
--
[~srichter] The assumption totally made sense in that context. I
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278376140
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278376354
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -213,8
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278376236
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278376009
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -99,31
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278375994
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -99,31
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278376654
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278375904
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -99,31
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278375241
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -22,47
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278376056
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278375067
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -22,47
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278374734
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -22,47
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278375942
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -99,31
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278375468
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -99,31
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278376961
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278376045
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278372657
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -22,47
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278372897
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -22,47
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278374422
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -22,47
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278374962
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -22,47
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278374985
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -22,47
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278374306
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -22,47
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278373475
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -22,47
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278375042
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -22,47
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278373794
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -22,47
wuchong commented on a change in pull request #8200: [FLINK-11614] [docs-zh]
Translate the "Configuring Dependencies" page into Chinese
URL: https://github.com/apache/flink/pull/8200#discussion_r278373674
##
File path: docs/dev/projectsetup/dependencies.zh.md
##
@@ -22,47
[
https://issues.apache.org/jira/browse/FLINK-12196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825646#comment-16825646
]
vinoyang commented on FLINK-12196:
--
[~chauncy] It reported by travis CI and the code base is flink
[
https://issues.apache.org/jira/browse/FLINK-12196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-12196:
-
Affects Version/s: 1.8.0
> FlinkKafkaProducerITCase#testRunOutOfProducersInThePool throws NPE
>
[
https://issues.apache.org/jira/browse/FLINK-12196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825644#comment-16825644
]
chauncy commented on FLINK-12196:
-
what's your version of Flink
>
[
https://issues.apache.org/jira/browse/FLINK-12307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12307:
---
Labels: pull-request-available (was: )
> Support translation from StreamExecWindowJoin to
beyond1920 opened a new pull request #8261: [FLINK-12307][table-planner-blink]
Support translation from StreamExecWindowJoin to StreamTransformation.
URL: https://github.com/apache/flink/pull/8261
## What is the purpose of the change
Support translation from StreamExecWindowJoin to
flinkbot commented on issue #8261: [FLINK-12307][table-planner-blink] Support
translation from StreamExecWindowJoin to StreamTransformation.
URL: https://github.com/apache/flink/pull/8261#issuecomment-486490777
Thanks a lot for your contribution to the Apache Flink project. I'm the
KurtYoung commented on a change in pull request #8179: [FLINK-12200]
[Table-planner] Support UNNEST for MAP types
URL: https://github.com/apache/flink/pull/8179#discussion_r278374663
##
File path:
sunjincheng created FLINK-12327:
---
Summary: Add simplicity support for submitting Python Table API
job in CliFrontend, i.e. `flink run -py wordcount.py` can be work(with simple
test).
Key: FLINK-12327
URL:
[
https://issues.apache.org/jira/browse/FLINK-12326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-12326:
---
Assignee: Dian Fu
> Add a basic test framework, just like the existing Java TableAPI, abstract
>
[
https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825623#comment-16825623
]
sunjincheng commented on FLINK-12308:
-
Hi [~dian.fu], Thank you for your approval this FLIP and
[
https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825624#comment-16825624
]
Liya Fan commented on FLINK-12319:
--
Hi [~mpf], thank you for opening this issue.
It seems like a bug
sunjincheng created FLINK-12326:
---
Summary: Add a basic test framework, just like the existing Java
TableAPI, abstract some TestBase.
Key: FLINK-12326
URL: https://issues.apache.org/jira/browse/FLINK-12326
[
https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-12308:
Description:
At the Flink API level, we have DataStreamAPI/DataSetAPI/TableAPI, the
Table API
hequn8128 commented on issue #8050: [FLINK-11067][table] Convert
TableEnvironments to interfaces
URL: https://github.com/apache/flink/pull/8050#issuecomment-486485987
@dawidwys Hi, I have updated the PR. I removed the fix commit which is
marked unnecessary by you. I also added a new
[
https://issues.apache.org/jira/browse/FLINK-11477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-11477:
-
Fix Version/s: 1.9.0
> Define catalog entries in SQL client YAML file and handle the creation and
>
1 - 100 of 350 matches
Mail list logo
