[
https://issues.apache.org/jira/browse/FLINK-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566339#comment-16566339
]
ASF GitHub Bot commented on FLINK-10010:
yanghua commented on a change in pull request #6471:
yanghua commented on a change in pull request #6471: [FLINK-10010][DataStream
API] Deprecate unused BaseAlignedWindowAssigner related components
URL: https://github.com/apache/flink/pull/6471#discussion_r207100012
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566338#comment-16566338
]
ASF GitHub Bot commented on FLINK-10010:
yanghua commented on a change in pull request #6471:
yanghua commented on a change in pull request #6471: [FLINK-10010][DataStream
API] Deprecate unused BaseAlignedWindowAssigner related components
URL: https://github.com/apache/flink/pull/6471#discussion_r207099935
##
File path:
yanghua commented on a change in pull request #6471: [FLINK-10010][DataStream
API] Deprecate unused BaseAlignedWindowAssigner related components
URL: https://github.com/apache/flink/pull/6471#discussion_r207100160
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566337#comment-16566337
]
ASF GitHub Bot commented on FLINK-10010:
yanghua commented on a change in pull request #6471:
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566330#comment-16566330
]
ASF GitHub Bot commented on FLINK-9970:
---
yanghua commented on a change in pull request #6432:
yanghua commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r207099504
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566318#comment-16566318
]
ASF GitHub Bot commented on FLINK-9970:
---
hequn8128 commented on a change in pull request #6432:
hequn8128 commented on a change in pull request #6432: [FLINK-9970] [table] Add
ASCII/CHR function for table/sql API
URL: https://github.com/apache/flink/pull/6432#discussion_r207096222
##
File path:
walterddr opened a new pull request #6472: [Flink-9294][Table/SQL API] Improve
type inference for UDFs with composite parameter and/or result type
URL: https://github.com/apache/flink/pull/6472
## What is the purpose of the change
Support more strict type checks and type inference
[
https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-10019:
--
Issue Type: Bug (was: Sub-task)
Parent: (was: FLINK-9484)
> Fix Composite getResultType
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-5315:
-
Description:
Support distinct aggregations in Table API in the following format:
For Expressions:
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-5315:
-
Description:
Support distinct aggregations in Table API in the following format:
For Expressions:
[
https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566032#comment-16566032
]
Elias Levy commented on FLINK-10011:
[~azagrebin] I don't think they are the same issue. The issue
[
https://issues.apache.org/jira/browse/FLINK-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566023#comment-16566023
]
ASF GitHub Bot commented on FLINK-10010:
walterddr opened a new pull request #6471:
[
https://issues.apache.org/jira/browse/FLINK-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10010:
---
Labels: pull-request-available (was: )
> Deprecate unused BaseAlignedWindowAssigner
walterddr opened a new pull request #6471: [FLINK-10010][DataStream API]
Deprecate unused BaseAlignedWindowAssigner related components
URL: https://github.com/apache/flink/pull/6471
## What is the purpose of the change
Deprecate unused AlignedWindow related components. the links in
[
https://issues.apache.org/jira/browse/FLINK-9575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elias Levy updated FLINK-9575:
--
Description:
When we are removing the _JobGraph_ from _JobManager_ for example after
invoking
[
https://issues.apache.org/jira/browse/FLINK-10020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16566010#comment-16566010
]
Thomas Weise commented on FLINK-10020:
--
{code:java}
Thomas Weise created FLINK-10020:
Summary: Kinesis Consumer listShards should support more
recoverable exceptions
Key: FLINK-10020
URL: https://issues.apache.org/jira/browse/FLINK-10020
Project:
[
https://issues.apache.org/jira/browse/FLINK-10019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-10019:
--
Description:
If explicitly return a CompositeType in {{udf.getResultType}}, will result in
some
Rong Rong created FLINK-10019:
-
Summary: Fix Composite getResultType of UDF cannot be chained with
other operators
Key: FLINK-10019
URL: https://issues.apache.org/jira/browse/FLINK-10019
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565786#comment-16565786
]
ASF GitHub Bot commented on FLINK-9981:
---
azagrebin commented on a change in pull request #6438:
[
https://issues.apache.org/jira/browse/FLINK-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565788#comment-16565788
]
ASF GitHub Bot commented on FLINK-9981:
---
azagrebin commented on a change in pull request #6438:
[
https://issues.apache.org/jira/browse/FLINK-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565787#comment-16565787
]
ASF GitHub Bot commented on FLINK-9981:
---
azagrebin commented on a change in pull request #6438:
[
https://issues.apache.org/jira/browse/FLINK-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565785#comment-16565785
]
ASF GitHub Bot commented on FLINK-9981:
---
azagrebin commented on a change in pull request #6438:
[
https://issues.apache.org/jira/browse/FLINK-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565789#comment-16565789
]
ASF GitHub Bot commented on FLINK-9981:
---
azagrebin commented on a change in pull request #6438:
azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune
performance of RocksDB implementation
URL: https://github.com/apache/flink/pull/6438#discussion_r206982020
##
File path:
azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune
performance of RocksDB implementation
URL: https://github.com/apache/flink/pull/6438#discussion_r206983891
##
File path:
azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune
performance of RocksDB implementation
URL: https://github.com/apache/flink/pull/6438#discussion_r206966986
##
File path:
azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune
performance of RocksDB implementation
URL: https://github.com/apache/flink/pull/6438#discussion_r206962666
##
File path:
azagrebin commented on a change in pull request #6438: [FLINK-9981] Tune
performance of RocksDB implementation
URL: https://github.com/apache/flink/pull/6438#discussion_r206960632
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16507191#comment-16507191
]
Ted Yu edited comment on FLINK-9340 at 8/1/18 5:07 PM:
---
I wonder if it is easier to
[
https://issues.apache.org/jira/browse/FLINK-9936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565607#comment-16565607
]
ASF GitHub Bot commented on FLINK-9936:
---
GJL commented on a change in pull request #6464:
GJL commented on a change in pull request #6464: [FLINK-9936][mesos] WIP
URL: https://github.com/apache/flink/pull/6464#discussion_r206951198
##
File path:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java
##
@@ -278,22
[
https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565599#comment-16565599
]
ASF GitHub Bot commented on FLINK-9682:
---
eliaslevy commented on issue #6266: [FLINK-9682] Add
eliaslevy commented on issue #6266: [FLINK-9682] Add setDescription to
execution environment and provide description field for the rest api
URL: https://github.com/apache/flink/pull/6266#issuecomment-409638948
@tillrohrmann those locations in the UI work for me
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565586#comment-16565586
]
Kostas Kloudas commented on FLINK-9962:
---
[~phoenixjiangnan] I agree that for *responsiveness* it
[
https://issues.apache.org/jira/browse/FLINK-9962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565586#comment-16565586
]
Kostas Kloudas edited comment on FLINK-9962 at 8/1/18 4:30 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565583#comment-16565583
]
Andrey Zagrebin commented on FLINK-10011:
-
This problem might be related to the recently fixed
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-9963:
--
Description:
Sometimes it might be useful to just read or write a single value into Kafka or
other
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-9963:
--
Description:
Sometimes it might be useful to just read or write a single value into Kafka or
other
[
https://issues.apache.org/jira/browse/FLINK-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565552#comment-16565552
]
Antoine Philippot commented on FLINK-7883:
--
Yes [~aljoscha], I'm agree, as long as the solution
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-9963:
--
Summary: Add a single value table format factory (was: Add a string table
format factory)
> Add a
[
https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565539#comment-16565539
]
ASF GitHub Bot commented on FLINK-9900:
---
yanghua commented on issue #6468: [FLINK-9900][tests]
yanghua commented on issue #6468: [FLINK-9900][tests] Include more information
on timeout in Zookeeper HA ITCase
URL: https://github.com/apache/flink/pull/6468#issuecomment-409626058
+1
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-10006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565516#comment-16565516
]
ASF GitHub Bot commented on FLINK-10006:
yanghua commented on a change in pull request #6470:
[
https://issues.apache.org/jira/browse/FLINK-10006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565517#comment-16565517
]
ASF GitHub Bot commented on FLINK-10006:
yanghua commented on a change in pull request #6470:
yanghua commented on a change in pull request #6470: [FLINK-10006][network]
improve logging in BarrierBuffer: prepend owning task name
URL: https://github.com/apache/flink/pull/6470#discussion_r206931865
##
File path:
yanghua commented on a change in pull request #6470: [FLINK-10006][network]
improve logging in BarrierBuffer: prepend owning task name
URL: https://github.com/apache/flink/pull/6470#discussion_r206931425
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565504#comment-16565504
]
ASF GitHub Bot commented on FLINK-9679:
---
medcv commented on issue #6259: [FLINK-9679] Implement
medcv commented on issue #6259: [FLINK-9679] Implement AvroSerializationSchema
URL: https://github.com/apache/flink/pull/6259#issuecomment-409619105
@tillrohrmann Thanks for the update!
This is an automated message from
[
https://issues.apache.org/jira/browse/FLINK-10013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-10013.
Resolution: Fixed
Fixed on release-1.5 in
904a12b056c23079b32b2b99cc5df11d4bd2d0f8
> Fix
[
https://issues.apache.org/jira/browse/FLINK-10016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-10016.
Resolution: Fixed
Implemented on release-1.5 in
b075ad899a7f797f8583556cdb28eea870176c96
[
https://issues.apache.org/jira/browse/FLINK-9655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565487#comment-16565487
]
Chesnay Schepler commented on FLINK-9655:
-
The issue is that in FLINK-8993 the operator naming
[
https://issues.apache.org/jira/browse/FLINK-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565485#comment-16565485
]
Timo Walther commented on FLINK-9984:
-
[~xueyu] sorry for not responding earlier. I gave you
[
https://issues.apache.org/jira/browse/FLINK-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565481#comment-16565481
]
Timo Walther commented on FLINK-9984:
-
[~RuidongLi] this issue might already be covered by [this
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565459#comment-16565459
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull request #4801:
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206919014
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/utils/SystemResourcesCounter.java
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565458#comment-16565458
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull request #4801:
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206918739
##
File path: docs/monitoring/metrics.md
##
@@ -1370,6 +1370,147 @@ Thus, in order to infer the metric
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565454#comment-16565454
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull request #4801:
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565450#comment-16565450
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull request #4801:
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565452#comment-16565452
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull request #4801:
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565456#comment-16565456
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on issue #4801: [FLINK-7812] Log system
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565451#comment-16565451
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull request #4801:
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565455#comment-16565455
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull request #4801:
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565453#comment-16565453
]
ASF GitHub Bot commented on FLINK-7812:
---
zentol commented on a change in pull request #4801:
[
https://issues.apache.org/jira/browse/FLINK-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565446#comment-16565446
]
Aljoscha Krettek commented on FLINK-7883:
-
For a start, I renamed the issue. I hope it captures
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206915837
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/utils/SystemResourcesCounter.java
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206915920
##
File path:
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206916437
##
File path:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
##
@@
zentol commented on issue #4801: [FLINK-7812] Log system resources metrics
URL: https://github.com/apache/flink/pull/4801#issuecomment-409608732
Also needs a rebase.
This is an automated message from the Apache Git Service.
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206912468
##
File path: docs/monitoring/metrics.md
##
@@ -1370,6 +1370,147 @@ Thus, in order to infer the metric
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206916150
##
File path:
zentol commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206915374
##
File path: docs/_includes/generated/task_manager_configuration.html
##
@@ -37,6 +37,16 @@
[
https://issues.apache.org/jira/browse/FLINK-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7883:
Summary: Make savepoints atomic with respect to state and side effects
(was: Stop
[
https://issues.apache.org/jira/browse/FLINK-10018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565443#comment-16565443
]
Aljoscha Krettek commented on FLINK-10018:
--
In Flink, _cancel_ and _stop_ are used pretty much
[
https://issues.apache.org/jira/browse/FLINK-10018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-10018:
-
Priority: Major (was: Blocker)
> Want to have stop command with checkpointing
>
[
https://issues.apache.org/jira/browse/FLINK-9963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565436#comment-16565436
]
ASF GitHub Bot commented on FLINK-9963:
---
twalthr commented on a change in pull request #6447:
twalthr commented on a change in pull request #6447: [FLINK-9963] [table] Add a
string table format factory
URL: https://github.com/apache/flink/pull/6447#discussion_r206907666
##
File path: flink-formats/flink-string/pom.xml
##
@@ -0,0 +1,112 @@
+
+
Keshav Lodhi created FLINK-10018:
Summary: Want to have stop command with checkpointing
Key: FLINK-10018
URL: https://issues.apache.org/jira/browse/FLINK-10018
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565415#comment-16565415
]
ASF GitHub Bot commented on FLINK-9878:
---
NicoK commented on a change in pull request #6355:
NicoK commented on a change in pull request #6355: [FLINK-9878][network][ssl]
add more low-level ssl options
URL: https://github.com/apache/flink/pull/6355#discussion_r206905353
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10006:
---
Labels: pull-request-available (was: )
> Improve logging in BarrierBuffer
>
[
https://issues.apache.org/jira/browse/FLINK-10006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565414#comment-16565414
]
ASF GitHub Bot commented on FLINK-10006:
NicoK opened a new pull request #6470:
NicoK opened a new pull request #6470: [FLINK-10006][network] improve logging
in BarrierBuffer: prepend owning task name
URL: https://github.com/apache/flink/pull/6470
## What is the purpose of the change
Almost all log messages of `BarrierBuffer` do not contain the task name and
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-7812:
--
Labels: pull-request-available (was: )
> Log system resources as metrics
>
[
https://issues.apache.org/jira/browse/FLINK-7812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565409#comment-16565409
]
ASF GitHub Bot commented on FLINK-7812:
---
aljoscha commented on a change in pull request #4801:
[
https://issues.apache.org/jira/browse/FLINK-9979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-9979.
-
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed in 1.7.0:
aljoscha commented on a change in pull request #4801: [FLINK-7812] Log system
resources metrics
URL: https://github.com/apache/flink/pull/4801#discussion_r206900869
##
File path: docs/_includes/generated/task_manager_configuration.html
##
@@ -37,6 +37,16 @@
[
https://issues.apache.org/jira/browse/FLINK-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565406#comment-16565406
]
Stavros Kontopoulos commented on FLINK-5005:
[~aljoscha] since [Flink closure
[
https://issues.apache.org/jira/browse/FLINK-9979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565402#comment-16565402
]
ASF GitHub Bot commented on FLINK-9979:
---
asfgit closed pull request #6440: [FLINK-9979] [table]
asfgit closed pull request #6440: [FLINK-9979] [table] Support a
FlinkKafkaPartitioner for Kafka table sink factory
URL: https://github.com/apache/flink/pull/6440
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake
Timo Walther created FLINK-10017:
Summary: Support keyed formats for Kafka table source sink factory
Key: FLINK-10017
URL: https://issues.apache.org/jira/browse/FLINK-10017
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565389#comment-16565389
]
Aljoscha Krettek commented on FLINK-10016:
--
Implemented on release-1.6 in
[
https://issues.apache.org/jira/browse/FLINK-10016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565391#comment-16565391
]
ASF GitHub Bot commented on FLINK-10016:
aljoscha commented on issue #6469: [FLINK-10016] Make
[
https://issues.apache.org/jira/browse/FLINK-10016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16565390#comment-16565390
]
ASF GitHub Bot commented on FLINK-10016:
aljoscha closed pull request #6469: [FLINK-10016] Make
aljoscha commented on issue #6469: [FLINK-10016] Make YARN/Kerberos end-to-end
test stricter
URL: https://github.com/apache/flink/pull/6469#issuecomment-409590273
merged
This is an automated message from the Apache Git
1 - 100 of 299 matches
Mail list logo
