[
https://issues.apache.org/jira/browse/FLINK-11044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-11044.
Resolution: Fixed
Fix Version/s: 1.7.1
1.8.0
Fixed in master:
[
https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-11065:
-
Description:
This issue covers the third step of the migration plan mentioned in
Timo Walther created FLINK-11067:
Summary: Port TableEnvironments to Java
Key: FLINK-11067
URL: https://issues.apache.org/jira/browse/FLINK-11067
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-10522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708556#comment-16708556
]
ASF GitHub Bot commented on FLINK-10522:
azagrebin commented on a change in pull request #7047:
lining created FLINK-11062:
--
Summary: web ui log error
Key: FLINK-11062
URL: https://issues.apache.org/jira/browse/FLINK-11062
Project: Flink
Issue Type: Bug
Components: REST, Webfrontend
[
https://issues.apache.org/jira/browse/FLINK-11062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining updated FLINK-11062:
---
Description:
!image-2018-12-04-16-53-23-887.png!
see log will error which reason is
asfgit closed pull request #7208: FLINK-11044 connect docs fix for
registerTableSink
URL: https://github.com/apache/flink/pull/7208
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
[
https://issues.apache.org/jira/browse/FLINK-11044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708436#comment-16708436
]
ASF GitHub Bot commented on FLINK-11044:
asfgit closed pull request #7208: FLINK-11044 connect
lamber-ken commented on issue #7180: [FLINK-11010] [TABLE] Flink SQL timestamp
is inconsistent with currentProcessingTime()
URL: https://github.com/apache/flink/pull/7180#issuecomment-444025862
@walterddr , hi, I had add process time.
fhueske commented on issue #7226: FLINK-11050 add lowerBound and upperBound for
optimizing RocksDBMapState's entries
URL: https://github.com/apache/flink/pull/7226#issuecomment-444030473
Hi @Myracle, thanks for the PR. I think we should either support the new API
for all `MapState`
twalthr commented on a change in pull request #7228: [FLINK-9740][Table API
] Support group windows over intervals of months
URL: https://github.com/apache/flink/pull/7228#discussion_r238582610
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708465#comment-16708465
]
ASF GitHub Bot commented on FLINK-7208:
---
dianfu commented on a change in pull request #7201:
dianfu commented on a change in pull request #7201: [FLINK-7208] [table]
Optimize Min/MaxWithRetractAggFunction with DataView
URL: https://github.com/apache/flink/pull/7201#discussion_r238585416
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-11063:
-
Affects Version/s: 1.7.0
> Make flink-table Scala-free
> ---
>
>
Timo Walther created FLINK-11063:
Summary: Make flink-table Scala-free
Key: FLINK-11063
URL: https://issues.apache.org/jira/browse/FLINK-11063
Project: Flink
Issue Type: New Feature
Timo Walther created FLINK-11065:
Summary: Migrate flink-table runtime classes
Key: FLINK-11065
URL: https://issues.apache.org/jira/browse/FLINK-11065
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-11065:
-
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-11063)
> Migrate
jihyun commented on a change in pull request #6774: [FLINK-10457] Support
SequenceFile for StreamingFileSink
URL: https://github.com/apache/flink/pull/6774#discussion_r238614740
##
File path:
Dawid Wysakowicz created FLINK-11061:
Summary: Add travis profile that would run on each commit with
scala 2.12
Key: FLINK-11061
URL: https://issues.apache.org/jira/browse/FLINK-11061
Project:
[
https://issues.apache.org/jira/browse/FLINK-11039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ambition updated FLINK-11039:
-
Description:
RelTimeIndicatorConverter.visit(exchange: LogicalExchange) function realization.
[
https://issues.apache.org/jira/browse/FLINK-11062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lining updated FLINK-11062:
---
Attachment: image-2018-12-04-16-53-23-887.png
> web ui log error
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-11057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-11057:
-
Component/s: Table API & SQL
> where in grammar will cause stream inner join loigcal
>
[
https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708469#comment-16708469
]
luoguohao commented on FLINK-11046:
---
HI, [~tzulitai],
Thank you for your reply. Because our
[
https://issues.apache.org/jira/browse/FLINK-10688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-10688:
-
Description:
This issue covers the fifth step of the migration plan mentioned in
[
https://issues.apache.org/jira/browse/FLINK-10522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin updated FLINK-10522:
Fix Version/s: 1.7.1
> Check if RecoverableWriter supportsResume and act accordingly.
>
klion26 commented on a change in pull request #6777: [FLINK-10461] [State
Backends, Checkpointing] Speed up download files when restore from DFS
URL: https://github.com/apache/flink/pull/6777#discussion_r238623643
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708585#comment-16708585
]
ASF GitHub Bot commented on FLINK-10784:
yanghua opened a new pull request #7230: [FLINK-10784]
fhueske commented on issue #7213: [FLINK-11045][table] Set correct
UserCodeClassLoader for RuntimeUDFContext in CollectionExecutor
URL: https://github.com/apache/flink/pull/7213#issuecomment-444026117
+1 from me as well.
Thanks for fixing this @hequn8128!
lamber-ken edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL
timestamp is inconsistent with currentProcessingTime()
URL: https://github.com/apache/flink/pull/7180#issuecomment-444025862
hi, @walterddr, I had add sql proctime test.
[
https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708439#comment-16708439
]
ASF GitHub Bot commented on FLINK-11010:
lamber-ken edited a comment on issue #7180:
lamber-ken edited a comment on issue #7180: [FLINK-11010] [TABLE] Flink SQL
timestamp is inconsistent with currentProcessingTime()
URL: https://github.com/apache/flink/pull/7180#issuecomment-444025862
@walterddr , hi, I had add sql proctime test.
[
https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708440#comment-16708440
]
ASF GitHub Bot commented on FLINK-11010:
lamber-ken edited a comment on issue #7180:
[
https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708473#comment-16708473
]
ASF GitHub Bot commented on FLINK-9740:
---
XuQianJin-Stars commented on issue #7228:
[
https://issues.apache.org/jira/browse/FLINK-11057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708480#comment-16708480
]
yuemeng commented on FLINK-11057:
-
[~twalthr]
thanks for your reply,FLINK-10474 can resolve this issue
[
https://issues.apache.org/jira/browse/FLINK-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708536#comment-16708536
]
ASF GitHub Bot commented on FLINK-10457:
jihyun commented on a change in pull request #6774:
[
https://issues.apache.org/jira/browse/FLINK-6712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-6712.
---
Resolution: Won't Fix
> Bump Kafka010 version to 0.10.2.0
>
zjffdu commented on issue #7121: [FLINK-9555]Support table api in scala shell
URL: https://github.com/apache/flink/pull/7121#issuecomment-444009960
@shuiqiangchen Travis is failed, could you check that ? Thanks
This is an
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708356#comment-16708356
]
ASF GitHub Bot commented on FLINK-9555:
---
zjffdu commented on issue #7121: [FLINK-9555]Support table
[
https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708455#comment-16708455
]
ASF GitHub Bot commented on FLINK-9740:
---
twalthr commented on a change in pull request #7228:
[
https://issues.apache.org/jira/browse/FLINK-11050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708457#comment-16708457
]
ASF GitHub Bot commented on FLINK-11050:
fhueske commented on issue #7226: FLINK-11050 add
jihyun commented on a change in pull request #6774: [FLINK-10457] Support
SequenceFile for StreamingFileSink
URL: https://github.com/apache/flink/pull/6774#discussion_r238608508
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-11068:
-
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-11066
> Port Table class to Java
[
https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xueyu reassigned FLINK-11065:
-
Assignee: xueyu
> Migrate flink-table runtime classes
> ---
>
>
zjffdu opened a new pull request #7229: [FLINK-11060][scala-shell] Unable to
set number of task manager and slot per task manager in scala shell local mode
URL: https://github.com/apache/flink/pull/7229
## What is the purpose of the change
* This PR fix the issue of unable to set
shuiqiangchen commented on issue #7121: [FLINK-9555]Support table api in scala
shell
URL: https://github.com/apache/flink/pull/7121#issuecomment-444015671
> @shuiqiangchen Travis is failed, could you check that ? Thanks
Thanks! It's the matter of checkStyle. I have fixed it.
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708389#comment-16708389
]
ASF GitHub Bot commented on FLINK-9555:
---
shuiqiangchen commented on issue #7121:
[
https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708407#comment-16708407
]
ASF GitHub Bot commented on FLINK-6756:
---
dawidwys closed pull request #7168:
dawidwys closed pull request #7168: [FLINK-6756][DataStream API] Provide Rich
AsyncFunction to Scala API …
URL: https://github.com/apache/flink/pull/7168
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of
[
https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-6756.
---
Resolution: Fixed
Fix Version/s: 1.8.0
Closed via:
dawidwys commented on issue #7168: [FLINK-6756][DataStream API] Provide Rich
AsyncFunction to Scala API …
URL: https://github.com/apache/flink/pull/7168#issuecomment-444019083
Thanks for the contribution @Clark. Merging.
[
https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708401#comment-16708401
]
ASF GitHub Bot commented on FLINK-6756:
---
dawidwys commented on issue #7168: [FLINK-6756][DataStream
fhueske commented on issue #5641: [WIP] Introduce ElasticBloomFilter for
Approximate calculation and other situations of performance optimization
URL: https://github.com/apache/flink/pull/5641#issuecomment-444027402
Hi @sihuazhou and @yanghua, I would suggest to first get approval from an
[
https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708463#comment-16708463
]
ASF GitHub Bot commented on FLINK-9740:
---
twalthr commented on issue #7228: [FLINK-9740][Table API ]
[
https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708515#comment-16708515
]
Jozef Vilcek commented on FLINK-2491:
-
Stumbled on this on this one today. Happy to see it 'in
jihyun commented on issue #6774: [FLINK-10457] Support SequenceFile for
StreamingFileSink
URL: https://github.com/apache/flink/pull/6774#issuecomment-444053307
Sorry. I missed too many Null checking.
I'll fix it. Thanks
azagrebin commented on a change in pull request #7047: [FLINK-10522] Check if
RecoverableWriter supportsResume() and act accordingly.
URL: https://github.com/apache/flink/pull/7047#discussion_r238593584
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-11057.
Resolution: Duplicate
This issue should have been fixed in Flink 1.7.0. See FLINK-10474. Feel
[
https://issues.apache.org/jira/browse/FLINK-11010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708438#comment-16708438
]
ASF GitHub Bot commented on FLINK-11010:
lamber-ken commented on issue #7180: [FLINK-11010]
[
https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708460#comment-16708460
]
ASF GitHub Bot commented on FLINK-7208:
---
twalthr commented on a change in pull request #7201:
twalthr commented on a change in pull request #7201: [FLINK-7208] [table]
Optimize Min/MaxWithRetractAggFunction with DataView
URL: https://github.com/apache/flink/pull/7201#discussion_r238584350
##
File path:
XuQianJin-Stars commented on issue #7228: [FLINK-9740][Table API ] Support
group windows over intervals of months
URL: https://github.com/apache/flink/pull/7228#issuecomment-444035288
@twalthr Thank you very much. I will rearrange and try to make a design
Timo Walther created FLINK-11066:
Summary: Migrate main Table API classes to flink-table-api-base
Key: FLINK-11066
URL: https://issues.apache.org/jira/browse/FLINK-11066
Project: Flink
Issue
Timo Walther created FLINK-11068:
Summary: Port Table class to Java
Key: FLINK-11068
URL: https://issues.apache.org/jira/browse/FLINK-11068
Project: Flink
Issue Type: New Feature
yanghua opened a new pull request #7230: [FLINK-10784] Update
FlinkKafkaConsumerBaseMigrationTest for 1.7
URL: https://github.com/apache/flink/pull/7230
## What is the purpose of the change
*This pull request updates FlinkKafkaConsumerBaseMigrationTest for 1.7*
## Brief
[
https://issues.apache.org/jira/browse/FLINK-11060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11060:
---
Labels: pull-request-available (was: )
> Unable to set number of task manager and slot per
[
https://issues.apache.org/jira/browse/FLINK-11060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708383#comment-16708383
]
ASF GitHub Bot commented on FLINK-11060:
zjffdu opened a new pull request #7229:
[
https://issues.apache.org/jira/browse/FLINK-11045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708441#comment-16708441
]
ASF GitHub Bot commented on FLINK-11045:
fhueske commented on issue #7213: [FLINK-11045][table]
[
https://issues.apache.org/jira/browse/FLINK-11020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708452#comment-16708452
]
Fabian Hueske commented on FLINK-11020:
---
Hi [~hequn8128], Yes, agreed. It would be good to have an
[
https://issues.apache.org/jira/browse/FLINK-11039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708459#comment-16708459
]
Fabian Hueske commented on FLINK-11039:
---
Please correct me, if I'm wrong, but this is only
XuQianJin-Stars commented on issue #7228: [FLINK-9740][Table API ] Support
group windows over intervals of months
URL: https://github.com/apache/flink/pull/7228#issuecomment-444032065
@twalthr Thank you very much. I will adjust it according to your suggestion
twalthr commented on issue #7228: [FLINK-9740][Table API ] Support group
windows over intervals of months
URL: https://github.com/apache/flink/pull/7228#issuecomment-444032456
I think you should post a little design outline first. Because this change
is not trivial.
[
https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708461#comment-16708461
]
ASF GitHub Bot commented on FLINK-9740:
---
XuQianJin-Stars commented on issue #7228:
[
https://issues.apache.org/jira/browse/FLINK-7209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-7209:
--
Assignee: Dian Fu
> Support DataView in Java and Scala Tuples and case classes or as the
>
[
https://issues.apache.org/jira/browse/FLINK-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708534#comment-16708534
]
ASF GitHub Bot commented on FLINK-10457:
jihyun commented on a change in pull request #6774:
jihyun commented on a change in pull request #6774: [FLINK-10457] Support
SequenceFile for StreamingFileSink
URL: https://github.com/apache/flink/pull/6774#discussion_r238608030
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708532#comment-16708532
]
ASF GitHub Bot commented on FLINK-10457:
jihyun commented on issue #6774: [FLINK-10457] Support
Timo Walther created FLINK-11064:
Summary: Setup a new flink-table module structure
Key: FLINK-11064
URL: https://issues.apache.org/jira/browse/FLINK-11064
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708553#comment-16708553
]
ASF GitHub Bot commented on FLINK-10457:
jihyun commented on a change in pull request #6774:
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708579#comment-16708579
]
ASF GitHub Bot commented on FLINK-10461:
klion26 commented on a change in pull request #6777:
KarmaGYZ opened a new pull request #7238: [hotfix][docs] Fix typo in Windows
documentation
URL: https://github.com/apache/flink/pull/7238
## What is the purpose of the change
This pr is to Fix typo in Windows documentation
## Brief change log
- Fix typo in
twalthr commented on a change in pull request #7201: [FLINK-7208] [table]
Optimize Min/MaxWithRetractAggFunction with DataView
URL: https://github.com/apache/flink/pull/7201#discussion_r238959968
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16709707#comment-16709707
]
ASF GitHub Bot commented on FLINK-7208:
---
twalthr commented on a change in pull request #7201:
yanghua opened a new pull request #7231: [FLINK-10788] Update
ContinuousFileProcessingMigrationTest for 1.7
URL: https://github.com/apache/flink/pull/7231
## What is the purpose of the change
*This pull request updates ContinuousFileProcessingMigrationTest for 1.7*
##
[
https://issues.apache.org/jira/browse/FLINK-10788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10788:
---
Labels: pull-request-available (was: )
> Update ContinuousFileProcessingMigrationTest for
[
https://issues.apache.org/jira/browse/FLINK-11020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708626#comment-16708626
]
Hequn Cheng commented on FLINK-11020:
-
[~fhueske] Opening another Jira is a good idea. Sorry that I
[
https://issues.apache.org/jira/browse/FLINK-10788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708593#comment-16708593
]
ASF GitHub Bot commented on FLINK-10788:
yanghua opened a new pull request #7231: [FLINK-10788]
[
https://issues.apache.org/jira/browse/FLINK-11070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-11070:
Description:
Currently, we don't reorder join and rely on the order provided by the user.
This
[
https://issues.apache.org/jira/browse/FLINK-10978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708682#comment-16708682
]
Hequn Cheng commented on FLINK-10978:
-
The code of this task is ready now. I implement it base on
[
https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xueyu reassigned FLINK-11065:
-
Assignee: (was: xueyu)
> Migrate flink-table runtime classes
> ---
[
https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708679#comment-16708679
]
xueyu commented on FLINK-11065:
---
I see..Thanks for reminding, [~twalthr]
> Migrate flink-table runtime
Till Rohrmann created FLINK-11069:
-
Summary: Remove FutureUtil
Key: FLINK-11069
URL: https://issues.apache.org/jira/browse/FLINK-11069
Project: Flink
Issue Type: Improvement
Affects
[
https://issues.apache.org/jira/browse/FLINK-11065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708671#comment-16708671
]
Timo Walther commented on FLINK-11065:
--
[~xueyu] I don't think if it makes sense to assign the
[
https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708707#comment-16708707
]
ASF GitHub Bot commented on FLINK-10884:
wg1026688210 commented on a change in pull request
Hequn Cheng created FLINK-11070:
---
Summary: Add stream-stream non-window cross join
Key: FLINK-11070
URL: https://issues.apache.org/jira/browse/FLINK-11070
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-11070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-11070:
Description:
Currently, we don't reorder join and rely on the order provided by the user.
This
[
https://issues.apache.org/jira/browse/FLINK-11043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708668#comment-16708668
]
ASF GitHub Bot commented on FLINK-11043:
fhueske commented on issue #138: [FLINK-11043] Fix
[
https://issues.apache.org/jira/browse/FLINK-11043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708667#comment-16708667
]
ASF GitHub Bot commented on FLINK-11043:
asfgit closed pull request #138: [FLINK-11043] Fix
wg1026688210 commented on a change in pull request #7185: [FLINK-10884]
[yarn/mesos] adjust container memory param to set a safe margin from offheap
memory
URL: https://github.com/apache/flink/pull/7185#discussion_r238663287
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10784:
---
Labels: pull-request-available (was: )
> Update FlinkKafkaConsumerBaseMigrationTest for
[
https://issues.apache.org/jira/browse/FLINK-10946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16708829#comment-16708829
]
ASF GitHub Bot commented on FLINK-10946:
tillrohrmann closed pull request #7204: [FLINK-10946]
1 - 100 of 242 matches
Mail list logo
