flinkbot edited a comment on issue #11482: [FLINK-16581][table] Minibatch
deduplication lack state TTL bug fix
URL: https://github.com/apache/flink/pull/11482#issuecomment-60726
## CI report:
* 95c74ce398cdc779ac895edb7cf3433579f1 Travis:
flinkbot edited a comment on issue #10973: [FLINK-15647][k8s] Support
user-specified annotations for JM/TM Pods
URL: https://github.com/apache/flink/pull/10973#issuecomment-580223229
## CI report:
* 72aae7d37888a080b735d194dacc6ff457e741ca Travis:
flinkbot edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink
work with NAT.
URL: https://github.com/apache/flink/pull/11284#issuecomment-593407935
## CI report:
* 0be3fd11e11d708b254036e9e91fc71f1fd02181 Travis:
[
https://issues.apache.org/jira/browse/FLINK-15932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee resolved FLINK-15932.
--
Resolution: Duplicate
> Add download url to hive dependencies
>
[
https://issues.apache.org/jira/browse/FLINK-15667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064581#comment-17064581
]
Zili Chen commented on FLINK-15667:
---
master via f56a075aa029832b9cbacab51649c900498e18e9
> Support to
[
https://issues.apache.org/jira/browse/FLINK-15667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen closed FLINK-15667.
-
Resolution: Fixed
> Support to mount Hadoop Configurations
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-16708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064580#comment-17064580
]
Weike Dong commented on FLINK-16708:
Hi [~lzljs3620320] , do you have time to look into this issue?
[
https://issues.apache.org/jira/browse/FLINK-13420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-13420.
Resolution: Invalid
> Supported hive versions are hard coded
>
TisonKun closed pull request #11415: [FLINK-15667][k8s] Support to mount custom
Hadoop configurations
URL: https://github.com/apache/flink/pull/11415
This is an automated message from the Apache Git Service.
To respond to
pingle wang created FLINK-16714:
---
Summary: Kafka committedOffsets value <0
Key: FLINK-16714
URL: https://issues.apache.org/jira/browse/FLINK-16714
Project: Flink
Issue Type: Improvement
flinkbot edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink
work with NAT.
URL: https://github.com/apache/flink/pull/11284#issuecomment-593407935
## CI report:
* ff670f742762f45214ca32df966e02f4dbe6f758 Travis:
[
https://issues.apache.org/jira/browse/FLINK-16421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064611#comment-17064611
]
Gyula Fora commented on FLINK-16421:
my point is that defualt_database should switch to the catalogs
[
https://issues.apache.org/jira/browse/FLINK-16713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064613#comment-17064613
]
jackray wang commented on FLINK-16713:
--
Hi [~lzljs3620320] ,this feature is essential for our
[
https://issues.apache.org/jira/browse/FLINK-16156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064619#comment-17064619
]
Kurt Young commented on FLINK-16156:
FunctionITCase.testDynamicTableFunction
has been fixed in
TisonKun commented on issue #11458: [FLINK-16625][k8s] Extract
BootstrapTools#getEnvironmentVariables to a general utility in
ConfigurationUtils
URL: https://github.com/apache/flink/pull/11458#issuecomment-602454643
@zhengcanbin please rebase on master. I think this PR itself is good to
[
https://issues.apache.org/jira/browse/FLINK-16175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064624#comment-17064624
]
Dawid Wysakowicz commented on FLINK-16175:
--
I agree with the principle of the ticket to support
TisonKun commented on issue #11472: [FLINK-16547][yarn] Respect the config
option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH
URL: https://github.com/apache/flink/pull/11472#issuecomment-602458510
> Thanks for the work @zhengcanbin and for the review @TisonKun. I will
merge this.
>
[
https://issues.apache.org/jira/browse/FLINK-16620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064631#comment-17064631
]
Roman Khachatryan commented on FLINK-16620:
---
I think this way we'll have in too many places,
kl0u commented on a change in pull request #11471: [FLINK-16692] flink
joblistener can register from config
URL: https://github.com/apache/flink/pull/11471#discussion_r396291783
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java
##
kl0u commented on a change in pull request #11471: [FLINK-16692] flink
joblistener can register from config
URL: https://github.com/apache/flink/pull/11471#discussion_r396289877
##
File path:
kl0u commented on a change in pull request #11471: [FLINK-16692] flink
joblistener can register from config
URL: https://github.com/apache/flink/pull/11471#discussion_r396289410
##
File path:
kl0u commented on a change in pull request #11471: [FLINK-16692] flink
joblistener can register from config
URL: https://github.com/apache/flink/pull/11471#discussion_r396281963
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064665#comment-17064665
]
Xintong Song commented on FLINK-16715:
--
bq. In general the whole YarnClusterDescriptor could use
ifndef-SleePy commented on a change in pull request #11347:
[FLINK-14971][checkpointing] Make all the non-IO operations in
CheckpointCoordinator single-threaded
URL: https://github.com/apache/flink/pull/11347#discussion_r396319772
##
File path:
tillrohrmann closed pull request #11475: [hotfix] [docs] Document union list
metadata gotcha
URL: https://github.com/apache/flink/pull/11475
This is an automated message from the Apache Git Service.
To respond to the
flinkbot commented on issue #11487: [FLINK-16656] Introduce the
DispatcherBootstrap.
URL: https://github.com/apache/flink/pull/11487#issuecomment-602504532
## CI report:
* 8d31a75920164c244f4cc94cbcb8eaa284ff1b9d UNKNOWN
Bot commands
The @flinkbot bot supports
flinkbot edited a comment on issue #11467: [FLINK-16317][operators] Provide
support for watermarks, key selector and latency marker in
MultipleInputStreamOperator
URL: https://github.com/apache/flink/pull/11467#issuecomment-601798473
## CI report:
*
wangyang0918 commented on a change in pull request #10973: [FLINK-15647][k8s]
Support user-specified annotations for JM/TM Pods
URL: https://github.com/apache/flink/pull/10973#discussion_r396222138
##
File path: docs/_includes/generated/kubernetes_config_configuration.html
TisonKun commented on issue #11458: [FLINK-16625][k8s] Extract
BootstrapTools#getEnvironmentVariables to a general utility in
ConfigurationUtils
URL: https://github.com/apache/flink/pull/11458#issuecomment-602413877
@flinkbot run azure
[
https://issues.apache.org/jira/browse/FLINK-16688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064570#comment-17064570
]
Jingsong Lee commented on FLINK-16688:
--
How does spark solve this problem?
> Hive-connector should
TisonKun commented on issue #11460: [FLINK-16655][FLINK-16657] Introduce
embedded executor and use it for Web Submission
URL: https://github.com/apache/flink/pull/11460#issuecomment-602414132
@flinkbot run azure
This is an
dianfu commented on a change in pull request #11448:
[FLINK-1][python][table] Support new Python dependency configuration
options in flink-java, flink-streaming-java and flink-table.
URL: https://github.com/apache/flink/pull/11448#discussion_r395605885
##
File path:
dianfu commented on a change in pull request #11448:
[FLINK-1][python][table] Support new Python dependency configuration
options in flink-java, flink-streaming-java and flink-table.
URL: https://github.com/apache/flink/pull/11448#discussion_r395610655
##
File path:
dianfu commented on a change in pull request #11448:
[FLINK-1][python][table] Support new Python dependency configuration
options in flink-java, flink-streaming-java and flink-table.
URL: https://github.com/apache/flink/pull/11448#discussion_r395617760
##
File path:
dianfu commented on a change in pull request #11448:
[FLINK-1][python][table] Support new Python dependency configuration
options in flink-java, flink-streaming-java and flink-table.
URL: https://github.com/apache/flink/pull/11448#discussion_r395617656
##
File path:
dianfu commented on a change in pull request #11448:
[FLINK-1][python][table] Support new Python dependency configuration
options in flink-java, flink-streaming-java and flink-table.
URL: https://github.com/apache/flink/pull/11448#discussion_r395611705
##
File path:
dianfu commented on a change in pull request #11448:
[FLINK-1][python][table] Support new Python dependency configuration
options in flink-java, flink-streaming-java and flink-table.
URL: https://github.com/apache/flink/pull/11448#discussion_r396223611
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-16421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064575#comment-17064575
]
Jingsong Lee commented on FLINK-16421:
--
Why not change `current-database`?
> Changing default
flinkbot edited a comment on issue #11415: [FLINK-15667][k8s] Support to mount
custom Hadoop configurations
URL: https://github.com/apache/flink/pull/11415#issuecomment-599458187
## CI report:
* 26d89b759470268a467b668af7330b2878e239fd Travis:
[
https://issues.apache.org/jira/browse/FLINK-16405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-16405.
Resolution: Invalid
See FLINK-16412
> Fix hive-metastore dependency description in connecting to
flinkbot edited a comment on issue #11440:
[FLINK-16647][table-runtime-blink][hive] Miss file extension when ins…
URL: https://github.com/apache/flink/pull/11440#issuecomment-600593420
## CI report:
* 75499741faf565a3af7c70f5a04c01a411eb372e Travis:
TisonKun commented on a change in pull request #11415: [FLINK-15667][k8s]
Support to mount custom Hadoop configurations
URL: https://github.com/apache/flink/pull/11415#discussion_r396239782
##
File path:
flinkbot edited a comment on issue #11471: [FLINK-16692] flink joblistener can
register from config
URL: https://github.com/apache/flink/pull/11471#issuecomment-602012274
## CI report:
* ad9049971efa640a2b22ee8f258b0a0d7f64cc47 Travis:
flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Support
new Python dependency configuration options in flink-java, flink-streaming-java
and flink-table.
URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255
## CI report:
*
[
https://issues.apache.org/jira/browse/FLINK-13483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-13483:
---
Affects Version/s: 1.10.0
> PrestoS3FileSystemITCase.testDirectoryListing fails on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-13483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-13483:
---
Fix Version/s: 1.11.0
> PrestoS3FileSystemITCase.testDirectoryListing fails on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-13483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-13483:
---
Labels: test-stability (was: )
> PrestoS3FileSystemITCase.testDirectoryListing fails on
WeiZhong94 commented on a change in pull request #11448:
[FLINK-1][python][table] Support new Python dependency configuration
options in flink-java, flink-streaming-java and flink-table.
URL: https://github.com/apache/flink/pull/11448#discussion_r396254822
##
File path:
kl0u edited a comment on issue #11471: [FLINK-16692] flink joblistener can
register from config
URL: https://github.com/apache/flink/pull/11471#issuecomment-602438160
Hi @liuyongvs . Thanks for the work, I had some comments on the JIRA and I
will have a better look at the PR now.
[
https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Canbin Zheng updated FLINK-16715:
-
Description: In the YarnClusterDescriptor#{{startAppMaster()}} we are using
some time the
[
https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Canbin Zheng updated FLINK-16715:
-
Priority: Trivial (was: Minor)
> Always use the configuration argument in
[
https://issues.apache.org/jira/browse/FLINK-16692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064621#comment-17064621
]
jackylau commented on FLINK-16692:
--
HI [~kkl0u],
1) i will move the arguments to DeploymentOptions
[
https://issues.apache.org/jira/browse/FLINK-16685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-16685.
---
Fix Version/s: statefun-1.1
Resolution: Fixed
Merged to master via
[
https://issues.apache.org/jira/browse/FLINK-16706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-16706.
---
Fix Version/s: statefun-1.1
Resolution: Fixed
Merged via
[
https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064634#comment-17064634
]
Xintong Song commented on FLINK-16715:
--
I tend to think this differently.
Instead of always using
[
https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064658#comment-17064658
]
Kostas Kloudas commented on FLINK-16715:
[~xintongsong] I see your point. In general the whole
[
https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064658#comment-17064658
]
Kostas Kloudas edited comment on FLINK-16715 at 3/23/20, 9:33 AM:
--
flinkbot edited a comment on issue #11460: [FLINK-16655][FLINK-16657] Introduce
embedded executor and use it for Web Submission
URL: https://github.com/apache/flink/pull/11460#issuecomment-601593052
## CI report:
* c11fff341434facac54867f779744e57e50ffd16 Travis:
[
https://issues.apache.org/jira/browse/FLINK-16718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-16718.
Resolution: Fixed
1.10: 00f27c6b42cc7db29d5a71ad9872ef3ee27272e0
master:
[
https://issues.apache.org/jira/browse/FLINK-16717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16717:
---
Labels: pull-request-available (was: )
> Use headless service for rpc and blob port when
DeliangFan opened a new pull request #11488: [FLINK-16717][k8s] Use headless
service for rpc and blob port
URL: https://github.com/apache/flink/pull/11488
## What is the purpose of the change
Use headless service instead of node port when run flink job on kubernetes
for
[
https://issues.apache.org/jira/browse/FLINK-7614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-7614:
---
Assignee: (was: Timo Walther)
> Add a code snippet example of a valid POJO to "Data
flinkbot commented on issue #11487: [FLINK-16656] Introduce the
DispatcherBootstrap.
URL: https://github.com/apache/flink/pull/11487#issuecomment-602490738
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make
all the non-IO operations in CheckpointCoordinator single-threaded
URL: https://github.com/apache/flink/pull/11347#issuecomment-596323413
## CI report:
* 655adff5f2d9298b34b167b5a355f4b536613246 Travis:
tillrohrmann commented on issue #10687: [FLINK-15364] Introduce streaming task
using heap backend e2e tests for Mesos
URL: https://github.com/apache/flink/pull/10687#issuecomment-602502147
Don't we test that Flink can interact with Mesos via
`test_mesos_wordcount.sh` and
wangyang0918 commented on issue #11489: [FLINK-15640][k8s] Support to set
labels and node-selector for jobmanager and taskmanager pod
URL: https://github.com/apache/flink/pull/11489#issuecomment-602502909
@TisonKun @zhengcanbin Do you mind to take a look this PR?
flinkbot edited a comment on issue #11403: [FLINK-16316][operators] Implement
new StreamOperatorBase as a replacement for AbstractStreamOperator
URL: https://github.com/apache/flink/pull/11403#issuecomment-598702521
## CI report:
* 6e60715d78ca865c3d687699124338afb1f6d1e2
flinkbot edited a comment on issue #10973: [FLINK-15647][k8s] Support
user-specified annotations for JM/TM Pods
URL: https://github.com/apache/flink/pull/10973#issuecomment-580223229
## CI report:
* 72aae7d37888a080b735d194dacc6ff457e741ca Travis:
[
https://issues.apache.org/jira/browse/FLINK-16405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-16405:
-
Fix Version/s: (was: 1.10.1)
(was: 1.11.0)
> Fix hive-metastore
[
https://issues.apache.org/jira/browse/FLINK-15932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-15932:
-
Fix Version/s: (was: 1.11.0)
> Add download url to hive dependencies
>
[
https://issues.apache.org/jira/browse/FLINK-16547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16547:
---
Labels: pull-request-available (was: )
> Respect the config option of
kl0u closed pull request #11472: [FLINK-16547][yarn] Respect the config option
of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH
URL: https://github.com/apache/flink/pull/11472
This is an automated message from the Apache Git
zhengcanbin commented on issue #11472: [FLINK-16547][yarn] Respect the config
option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH
URL: https://github.com/apache/flink/pull/11472#issuecomment-602436628
> Thanks for the work @zhengcanbin and for the review @TisonKun. I will
merge this.
>
wangyang0918 commented on a change in pull request #11284:
[FLINK-15911][runtime] Make Flink work with NAT.
URL: https://github.com/apache/flink/pull/11284#discussion_r396259803
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
Gary Yao created FLINK-16718:
Summary: KvStateServerHandlerTest leaks Netty ByteBufs
Key: FLINK-16718
URL: https://issues.apache.org/jira/browse/FLINK-16718
Project: Flink
Issue Type: Bug
flinkbot edited a comment on issue #11486: [FLINK-16712][task] Refactor
StreamTask to construct final fields
URL: https://github.com/apache/flink/pull/11486#issuecomment-602377929
## CI report:
* 9535112ff0782fd584600cc3fdbefe0457b1bcfb Travis:
flinkbot edited a comment on issue #11284: [FLINK-15911][runtime] Make Flink
work with NAT.
URL: https://github.com/apache/flink/pull/11284#issuecomment-593407935
## CI report:
* ff670f742762f45214ca32df966e02f4dbe6f758 Travis:
[
https://issues.apache.org/jira/browse/FLINK-16718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-16718:
-
Description: The {{KvStateServerHandlerTest}} leaks Netty {{ByteBuf}}
instances. (was: The
[
https://issues.apache.org/jira/browse/FLINK-16718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16718:
---
Labels: pull-request-available (was: )
> KvStateServerHandlerTest leaks Netty ByteBufs
>
ifndef-SleePy commented on issue #11347: [FLINK-14971][checkpointing] Make all
the non-IO operations in CheckpointCoordinator single-threaded
URL: https://github.com/apache/flink/pull/11347#issuecomment-602485849
Hi @pnowojski , I have addressed all comments and done the squashing. Could
igalshilman commented on issue #62: [FLINK-16685] Add a k8s example for the
Python SDK
URL: https://github.com/apache/flink-statefun/pull/62#issuecomment-602491738
@tzulitai Thanks for the review and merging.
@sjwiesman I will follow up with FLINK-16064, and we can base any
[
https://issues.apache.org/jira/browse/FLINK-7614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-7614:
Comment: was deleted
(was: I will work on improving the data types documentation soon.)
> Add a
flinkbot commented on issue #11488: [FLINK-16717][k8s] Use headless service for
rpc and blob port
URL: https://github.com/apache/flink/pull/11488#issuecomment-602491751
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
flinkbot edited a comment on issue #11347: [FLINK-14971][checkpointing] Make
all the non-IO operations in CheckpointCoordinator single-threaded
URL: https://github.com/apache/flink/pull/11347#issuecomment-596323413
## CI report:
* 655adff5f2d9298b34b167b5a355f4b536613246 Travis:
flinkbot edited a comment on issue #10973: [FLINK-15647][k8s] Support
user-specified annotations for JM/TM Pods
URL: https://github.com/apache/flink/pull/10973#issuecomment-580223229
## CI report:
* 33776e6aa098656ddb2820bbac39b4b08f9fa3f8 Travis:
WeiZhong94 commented on issue #11448: [FLINK-1][python][table] Support new
Python dependency configuration options in flink-java, flink-streaming-java and
flink-table.
URL: https://github.com/apache/flink/pull/11448#issuecomment-602495165
@dianfu Thanks for your comments! I have
tillrohrmann commented on a change in pull request #10973: [FLINK-15647][k8s]
Support user-specified annotations for JM/TM Pods
URL: https://github.com/apache/flink/pull/10973#discussion_r396335787
##
File path:
tillrohrmann commented on a change in pull request #10973: [FLINK-15647][k8s]
Support user-specified annotations for JM/TM Pods
URL: https://github.com/apache/flink/pull/10973#discussion_r396336277
##
File path:
tillrohrmann commented on a change in pull request #10973: [FLINK-15647][k8s]
Support user-specified annotations for JM/TM Pods
URL: https://github.com/apache/flink/pull/10973#discussion_r396336700
##
File path:
flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Support
new Python dependency configuration options in flink-java, flink-streaming-java
and flink-table.
URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255
## CI report:
*
jackray wang created FLINK-16719:
Summary: flink-runtime-web install failure
Key: FLINK-16719
URL: https://issues.apache.org/jira/browse/FLINK-16719
Project: Flink
Issue Type: Bug
zhengcanbin commented on a change in pull request #10973: [FLINK-15647][k8s]
Support user-specified annotations for JM/TM Pods
URL: https://github.com/apache/flink/pull/10973#discussion_r396231441
##
File path: docs/_includes/generated/kubernetes_config_configuration.html
zhengcanbin commented on a change in pull request #10973: [FLINK-15647][k8s]
Support user-specified annotations for JM/TM Pods
URL: https://github.com/apache/flink/pull/10973#discussion_r396231613
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-16498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-16498:
-
Summary: connect PostgresCatalog to table planner (was: make Postgres
table work end-2-end in Flink
TisonKun commented on issue #11338: [FLINK-10052][ha] Tolerate temporarily
suspended ZooKeeper connections
URL: https://github.com/apache/flink/pull/11338#issuecomment-602414984
Hi @zentol , further concerns?
This is an
TisonKun closed pull request #7144: [FLINK-10932] [ResourceManager] Initial
flink-kubernetes module with empty implementation
URL: https://github.com/apache/flink/pull/7144
This is an automated message from the Apache Git
TisonKun commented on issue #7144: [FLINK-10932] [ResourceManager] Initial
flink-kubernetes module with empty implementation
URL: https://github.com/apache/flink/pull/7144#issuecomment-602414679
implemented at 3d94ba0fae6a7391c03b7eddb087a68bf178b45d
[
https://issues.apache.org/jira/browse/FLINK-16434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-16434.
Resolution: Fixed
> Add document to explain how to pack hive with their own hive dependencies
>
[
https://issues.apache.org/jira/browse/FLINK-9970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064571#comment-17064571
]
Zili Chen commented on FLINK-9970:
--
It seems we'd already implemented these functions in blink planner.
[
https://issues.apache.org/jira/browse/FLINK-16434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064572#comment-17064572
]
Jingsong Lee commented on FLINK-16434:
--
Already done in FLINK-16455
> Add document to explain how
1 - 100 of 607 matches
Mail list logo
