[
https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614390#comment-16614390
]
ASF GitHub Bot commented on FLINK-9913:
---
zhijiangW commented on a change in pull request #6417:
[
https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614389#comment-16614389
]
ASF GitHub Bot commented on FLINK-9913:
---
zhijiangW commented on a change in pull request #6417:
zhijiangW commented on a change in pull request #6417: [FLINK-9913][runtime]
Improve output serialization only once in RecordWriter
URL: https://github.com/apache/flink/pull/6417#discussion_r217605192
##
File path:
zhijiangW commented on a change in pull request #6417: [FLINK-9913][runtime]
Improve output serialization only once in RecordWriter
URL: https://github.com/apache/flink/pull/6417#discussion_r217605083
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614371#comment-16614371
]
Jayant Ameta commented on FLINK-10310:
--
Hi [~till.rohrmann]
{{CassandraSinkBase}} would have a
[
https://issues.apache.org/jira/browse/FLINK-10240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614335#comment-16614335
]
陈梓立 commented on FLINK-10240:
-
Introduce pluggable schedule strategy is an excellent idea that could expand
[
https://issues.apache.org/jira/browse/FLINK-10319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614325#comment-16614325
]
ASF GitHub Bot commented on FLINK-10319:
TisonKun commented on issue #6680: [FLINK-10319]
TisonKun commented on issue #6680: [FLINK-10319] [runtime] Too many
requestPartitionState would crash JM
URL: https://github.com/apache/flink/pull/6680#issuecomment-421222747
cc @tillrohrmann
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-10240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614296#comment-16614296
]
Zhu Zhu commented on FLINK-10240:
-
Here's the design for a pluggable scheduling mechanism, which I think
[
https://issues.apache.org/jira/browse/FLINK-9991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614294#comment-16614294
]
ASF GitHub Bot commented on FLINK-9991:
---
yanghua commented on issue #6450: [FLINK-9991] [table] Add
yanghua commented on issue #6450: [FLINK-9991] [table] Add regexp_replace
supported in TableAPI and SQL
URL: https://github.com/apache/flink/pull/6450#issuecomment-421216764
@xccui I have refactored this PR. Can you review it again?
[
https://issues.apache.org/jira/browse/FLINK-10240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-10240:
Summary: Pluggable scheduling strategy for batch job (was: Flexible
scheduling strategy is needed for
[
https://issues.apache.org/jira/browse/FLINK-10332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614131#comment-16614131
]
ASF GitHub Bot commented on FLINK-10332:
NicoK opened a new pull request #6693:
[
https://issues.apache.org/jira/browse/FLINK-10332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10332:
---
Labels: pull-request-available (was: )
> Move data available notification in
NicoK opened a new pull request #6693: [FLINK-10332][network] move data
notification out of the synchronized block
URL: https://github.com/apache/flink/pull/6693
## What is the purpose of the change
Currently, calls to `PipelinedSubpartition#notifyDataAvailable()` are
unnecessarily
[
https://issues.apache.org/jira/browse/FLINK-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614130#comment-16614130
]
ASF GitHub Bot commented on FLINK-10222:
fhueske commented on a change in pull request #6622:
fhueske commented on a change in pull request #6622: [FLINK-10222] [table]
Table scalar function expression parses error when function name equals the
exists keyword suffix
URL: https://github.com/apache/flink/pull/6622#discussion_r217554963
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614128#comment-16614128
]
ASF GitHub Bot commented on FLINK-10331:
NicoK opened a new pull request #6692:
[
https://issues.apache.org/jira/browse/FLINK-10331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10331:
---
Labels: pull-request-available (was: )
> Fix unnecessary flush requests to the network
NicoK opened a new pull request #6692: [FLINK-10331][network] reduce unnecesary
flushing
URL: https://github.com/apache/flink/pull/6692
## What is the purpose of the change
With the re-design of the record writer interaction with the
result(sub)partitions, flush requests can
[
https://issues.apache.org/jira/browse/FLINK-10290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614115#comment-16614115
]
ASF GitHub Bot commented on FLINK-10290:
fhueske commented on a change in pull request #:
[
https://issues.apache.org/jira/browse/FLINK-10290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614114#comment-16614114
]
ASF GitHub Bot commented on FLINK-10290:
fhueske commented on a change in pull request #:
[
https://issues.apache.org/jira/browse/FLINK-10290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614116#comment-16614116
]
ASF GitHub Bot commented on FLINK-10290:
fhueske commented on a change in pull request #:
[
https://issues.apache.org/jira/browse/FLINK-10290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614113#comment-16614113
]
ASF GitHub Bot commented on FLINK-10290:
fhueske commented on a change in pull request #:
fhueske commented on a change in pull request #: [FLINK-10290] [table] Fix
conversion error in StreamScan and BatchScan
URL: https://github.com/apache/flink/pull/#discussion_r217544935
##
File path:
fhueske commented on a change in pull request #: [FLINK-10290] [table] Fix
conversion error in StreamScan and BatchScan
URL: https://github.com/apache/flink/pull/#discussion_r217547642
##
File path:
fhueske commented on a change in pull request #: [FLINK-10290] [table] Fix
conversion error in StreamScan and BatchScan
URL: https://github.com/apache/flink/pull/#discussion_r217547586
##
File path:
fhueske commented on a change in pull request #: [FLINK-10290] [table] Fix
conversion error in StreamScan and BatchScan
URL: https://github.com/apache/flink/pull/#discussion_r217545093
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-8688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-8688.
Resolution: Implemented
Fix Version/s: 1.7.0
All sub-issues have been implemented
> Enable
[
https://issues.apache.org/jira/browse/FLINK-9232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-9232:
-
Issue Type: Improvement (was: Sub-task)
Parent: (was: FLINK-8688)
> Add harness
[
https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-8739:
-
Issue Type: Improvement (was: Sub-task)
Parent: (was: FLINK-8688)
> Optimize
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16614083#comment-16614083
]
ASF GitHub Bot commented on FLINK-5315:
---
asfgit closed pull request #6521: [FLINK-5315][table]
[
https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5315.
Resolution: Implemented
Fix Version/s: 1.7.0
Implemented for 1.7.0 with
asfgit closed pull request #6521: [FLINK-5315][table] Adding support for
distinct operation for table API on DataStream
URL: https://github.com/apache/flink/pull/6521
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the
[
https://issues.apache.org/jira/browse/FLINK-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-10223.
> TaskManagers should log their ResourceID during startup
>
[
https://issues.apache.org/jira/browse/FLINK-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao resolved FLINK-10223.
--
Resolution: Fixed
Fixed via
1.5: 9cbf99e7a56c50ba4e7bd5ee6444f6a08b4e5796
1.6:
[
https://issues.apache.org/jira/browse/FLINK-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613974#comment-16613974
]
ASF GitHub Bot commented on FLINK-10223:
asfgit closed pull request #6679:
asfgit closed pull request #6679: [FLINK-10223][LOG]Logging with resourceId
during taskmanager startup
URL: https://github.com/apache/flink/pull/6679
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-10329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613739#comment-16613739
]
ASF GitHub Bot commented on FLINK-10329:
tillrohrmann commented on issue #6686: [FLINK-10329]
[
https://issues.apache.org/jira/browse/FLINK-10329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613738#comment-16613738
]
ASF GitHub Bot commented on FLINK-10329:
tillrohrmann commented on a change in pull request
tillrohrmann commented on issue #6686: [FLINK-10329] [FLINK-10328] Fail
ZooKeeperSubmittedJobGraphStore#removeJobGraph if job cannot be removed &
Release all locks when stopping the ZooKeeperSubmittedJobGraphStore
URL: https://github.com/apache/flink/pull/6686#issuecomment-421070901
tillrohrmann commented on a change in pull request #6686: [FLINK-10329]
[FLINK-10328] Fail ZooKeeperSubmittedJobGraphStore#removeJobGraph if job cannot
be removed & Release all locks when stopping the ZooKeeperSubmittedJobGraphStore
URL:
[
https://issues.apache.org/jira/browse/FLINK-10303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613713#comment-16613713
]
Konstantin Knauf commented on FLINK-10303:
--
[~Zentol] I think, this was done with Sonar. I just
[
https://issues.apache.org/jira/browse/FLINK-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10340:
Assignee: vinoyang
> Implement Cosh udf
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann deleted FLINK-10345:
--
> Rethink SubmittedJobGraphListener
> -
>
> Key:
Till Rohrmann created FLINK-10344:
-
Summary: Rethink SubmittedJobGraphListener
Key: FLINK-10344
URL: https://issues.apache.org/jira/browse/FLINK-10344
Project: Flink
Issue Type: Sub-task
Till Rohrmann created FLINK-10345:
-
Summary: Rethink SubmittedJobGraphListener
Key: FLINK-10345
URL: https://issues.apache.org/jira/browse/FLINK-10345
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-10336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10336:
Assignee: vinoyang
> Use ZooKeeperStateStore in ZooKeeperSubmittedJobGraphStore
>
[
https://issues.apache.org/jira/browse/FLINK-10335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10335:
Assignee: vinoyang
> Create common ZooKeeperStateStore based on ZooKeeperStateHandleStore and
>
[
https://issues.apache.org/jira/browse/FLINK-10334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10334:
Assignee: vinoyang
> Move RetrievableStateStorageHelper out of ZooKeeperStateHandleStore
>
[
https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10333:
--
Description:
While going over the ZooKeeper based stores
[
https://issues.apache.org/jira/browse/FLINK-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
aitozi updated FLINK-10343:
---
Description:
when we use reducing state / aggregating keyed state and so on , we have to
read value from
aitozi created FLINK-10343:
--
Summary: Expose setCurrentKey method to streamRuntimeContext
Key: FLINK-10343
URL: https://issues.apache.org/jira/browse/FLINK-10343
Project: Flink
Issue Type:
walterddr commented on issue #6471: [FLINK-10010][DataStream API] Deprecate
unused BaseAlignedWindowAssigner related components
URL: https://github.com/apache/flink/pull/6471#issuecomment-421048859
Hi @fhueske @aljoscha, could you kindly take a look at this PR? We would
like to make some
[
https://issues.apache.org/jira/browse/FLINK-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613652#comment-16613652
]
ASF GitHub Bot commented on FLINK-10010:
walterddr commented on issue #6471:
[
https://issues.apache.org/jira/browse/FLINK-8354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613606#comment-16613606
]
ASF GitHub Bot commented on FLINK-8354:
---
aljoscha commented on issue #6615: [FLINK-8354]
aljoscha commented on issue #6615: [FLINK-8354] [flink-connectors] Add ability
to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#issuecomment-421038704
For this, I would await the outcome of #6577. If we end up only having one
"modern" Kafka connector we
[
https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613603#comment-16613603
]
ASF GitHub Bot commented on FLINK-9913:
---
NicoK commented on a change in pull request #6417:
[
https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613604#comment-16613604
]
ASF GitHub Bot commented on FLINK-9913:
---
NicoK commented on a change in pull request #6417:
[
https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613602#comment-16613602
]
ASF GitHub Bot commented on FLINK-9913:
---
NicoK commented on a change in pull request #6417:
[
https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613601#comment-16613601
]
ASF GitHub Bot commented on FLINK-9913:
---
NicoK commented on a change in pull request #6417:
NicoK commented on a change in pull request #6417: [FLINK-9913][runtime]
Improve output serialization only once in RecordWriter
URL: https://github.com/apache/flink/pull/6417#discussion_r217404839
##
File path:
NicoK commented on a change in pull request #6417: [FLINK-9913][runtime]
Improve output serialization only once in RecordWriter
URL: https://github.com/apache/flink/pull/6417#discussion_r217406052
##
File path:
NicoK commented on a change in pull request #6417: [FLINK-9913][runtime]
Improve output serialization only once in RecordWriter
URL: https://github.com/apache/flink/pull/6417#discussion_r217397453
##
File path:
NicoK commented on a change in pull request #6417: [FLINK-9913][runtime]
Improve output serialization only once in RecordWriter
URL: https://github.com/apache/flink/pull/6417#discussion_r217415039
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleksandr Nitavskyi reassigned FLINK-10342:
---
Assignee: Oleksandr Nitavskyi
> Kafka duplicate topic consumption when
Oleksandr Nitavskyi created FLINK-10342:
---
Summary: Kafka duplicate topic consumption when topic name is
changed
Key: FLINK-10342
URL: https://issues.apache.org/jira/browse/FLINK-10342
Project:
JTaky opened a new pull request #6691: Reproduce double topic subscription
URL: https://github.com/apache/flink/pull/6691
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community review your
contribution in the best
[
https://issues.apache.org/jira/browse/FLINK-10304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613564#comment-16613564
]
ASF GitHub Bot commented on FLINK-10304:
TisonKun commented on issue #6673: [FLINK-10304]
TisonKun commented on issue #6673: [FLINK-10304] [client] Remove deprecated
AbstractYarnClusterDescriptor field
URL: https://github.com/apache/flink/pull/6673#issuecomment-421026733
cc @GJL
This is an automated message from
[
https://issues.apache.org/jira/browse/FLINK-10321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613562#comment-16613562
]
ASF GitHub Bot commented on FLINK-10321:
Aitozi commented on issue #6688: [FLINK-10321][network]
Aitozi commented on issue #6688: [FLINK-10321][network] Simplify the condition
of BroadcastPartitioner
URL: https://github.com/apache/flink/pull/6688#issuecomment-421025756
LGTM.
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-10321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613561#comment-16613561
]
ASF GitHub Bot commented on FLINK-10321:
TisonKun commented on issue #6688:
TisonKun commented on issue #6688: [FLINK-10321][network] Simplify the
condition of BroadcastPartitioner
URL: https://github.com/apache/flink/pull/6688#issuecomment-421024900
FYI, travis fails by irrelevant issue.
```
Status: Downloaded newer image for java:8-jre-alpine
--->
[
https://issues.apache.org/jira/browse/FLINK-10275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
陈梓立 updated FLINK-10275:
Description:
StreamTask support efficient object reuse. The purpose behind this is to reduce
pressure on the
[
https://issues.apache.org/jira/browse/FLINK-10275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
陈梓立 reassigned FLINK-10275:
---
Assignee: (was: 陈梓立)
> StreamTask support object reuse
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-10275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613553#comment-16613553
]
ASF GitHub Bot commented on FLINK-10275:
TisonKun commented on issue #6643: [FLINK-10275]
[
https://issues.apache.org/jira/browse/FLINK-10275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613554#comment-16613554
]
ASF GitHub Bot commented on FLINK-10275:
TisonKun closed pull request #6643: [FLINK-10275]
TisonKun closed pull request #6643: [FLINK-10275] StreamTask support object
reuse
URL: https://github.com/apache/flink/pull/6643
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
TisonKun commented on issue #6643: [FLINK-10275] StreamTask support object reuse
URL: https://github.com/apache/flink/pull/6643#issuecomment-421020528
Although I don't think remain a stall pull request does harm, since this
pull request should be updated nearly as a rework, I would close
[
https://issues.apache.org/jira/browse/FLINK-10275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613544#comment-16613544
]
ASF GitHub Bot commented on FLINK-10275:
kl0u commented on issue #6643: [FLINK-10275] StreamTask
[
https://issues.apache.org/jira/browse/FLINK-10341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613543#comment-16613543
]
ASF GitHub Bot commented on FLINK-10341:
TisonKun commented on issue #6690: [FLINK-10341][shell
kl0u commented on issue #6643: [FLINK-10275] StreamTask support object reuse
URL: https://github.com/apache/flink/pull/6643#issuecomment-421019224
Hi @TisonKun,
In the above discussion, there is consensus that until the related FLIP is
agreed upon, there is not going to be any
TisonKun commented on issue #6690: [FLINK-10341][shell script] Add option to
print flink command when running bin/flink
URL: https://github.com/apache/flink/pull/6690#issuecomment-421019008
I am not a bash expert and find @dawidwys, you are right. To be accurate, it
would be `bash -x
[
https://issues.apache.org/jira/browse/FLINK-10327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613537#comment-16613537
]
ASF GitHub Bot commented on FLINK-10327:
kl0u commented on issue #6687: [FLINK-10327][streaming]
kl0u commented on issue #6687: [FLINK-10327][streaming] Expose
processWatermarks notifications to (Co)ProcessFunction
URL: https://github.com/apache/flink/pull/6687#issuecomment-421017411
Hi @pnowojski !
I can understand that this can be an interesting addition for some usecases,
[
https://issues.apache.org/jira/browse/FLINK-10329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613534#comment-16613534
]
ASF GitHub Bot commented on FLINK-10329:
azagrebin commented on a change in pull request #6686:
azagrebin commented on a change in pull request #6686: [FLINK-10329]
[FLINK-10328] Fail ZooKeeperSubmittedJobGraphStore#removeJobGraph if job cannot
be removed & Release all locks when stopping the ZooKeeperSubmittedJobGraphStore
URL:
[
https://issues.apache.org/jira/browse/FLINK-10223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-10223:
Assignee: Gary Yao (was: aitozi)
> TaskManagers should log their ResourceID during startup
>
[
https://issues.apache.org/jira/browse/FLINK-8354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613528#comment-16613528
]
ASF GitHub Bot commented on FLINK-8354:
---
alexeyt820 commented on issue #6615: [FLINK-8354]
alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add
ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#issuecomment-421014612
@tzulitai, using ```Record``` wrapping Kafka ```ConsumerRecord``` allows to
add for example timestamp
[
https://issues.apache.org/jira/browse/FLINK-10341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613521#comment-16613521
]
ASF GitHub Bot commented on FLINK-10341:
dawidwys commented on issue #6690: [FLINK-10341][shell
dawidwys commented on issue #6690: [FLINK-10341][shell script] Add option to
print flink command when running bin/flink
URL: https://github.com/apache/flink/pull/6690#issuecomment-421012461
I am sorry, but I don't think this is a valuable addition and I doubt it
will be merged. For
[
https://issues.apache.org/jira/browse/FLINK-10331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-10331:
Description:
With the re-design of the record writer interaction with the
result(sub)partitions,
fhueske edited a comment on issue #6508: [Flink-10079] [table] Automatically
register sink table from external catalogs
URL: https://github.com/apache/flink/pull/6508#issuecomment-421010897
Please also rebase your PR on the current master.
Thank you,
Fabian
fhueske commented on issue #6508: [Flink-10079] [table] Automatically register
sink table from external catalogs
URL: https://github.com/apache/flink/pull/6508#issuecomment-421010897
Please also rebase your PR on the current master.
Thank you,
Fabina
[
https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613513#comment-16613513
]
Till Rohrmann edited comment on FLINK-10184 at 9/13/18 1:40 PM:
[
https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613513#comment-16613513
]
Till Rohrmann commented on FLINK-10184:
---
[~Jamalarm] yes, you would need to checkout my branch and
fhueske commented on a change in pull request #6508: [Flink-10079] [table]
Automatically register sink table from external catalogs
URL: https://github.com/apache/flink/pull/6508#discussion_r217384955
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-10341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16613504#comment-16613504
]
ASF GitHub Bot commented on FLINK-10341:
TisonKun commented on issue #6690: [FLINK-10341][shell
1 - 100 of 197 matches
Mail list logo
