[
https://issues.apache.org/jira/browse/FLINK-10866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
BoWang reassigned FLINK-10866:
--
Assignee: BoWang
> Queryable state can prevent cluster from starting
> --
[
https://issues.apache.org/jira/browse/FLINK-10866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733902#comment-16733902
]
BoWang commented on FLINK-10866:
hi, has anyone taken this jira? If not, I would like to
yanghua commented on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not
be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405#issuecomment-451369403
cc @pnowojski and @aljoscha
This is an aut
Fokko commented on issue #7407: [FLINK-11260] Bump the Janino compiler to 3.0.11
URL: https://github.com/apache/flink/pull/7407#issuecomment-451364596
It passed on my fork: https://travis-ci.org/Fokko/flink/builds/474918896
Th
Fokko commented on issue #7406: [FLINK-11259] Bump Zookeeper to 3.4.13
URL: https://github.com/apache/flink/pull/7406#issuecomment-451364495
The error looks related, let me dive into it.
This is an automated message from the A
[
https://issues.apache.org/jira/browse/FLINK-11264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuiqiangchen reassigned FLINK-11264:
-
Assignee: shuiqiangchen
> Fail to start scala shell
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-11230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733806#comment-16733806
]
jiwei commented on FLINK-11230:
---
[~hequn8128],it is useful for me maybe .I will try it. Th
[
https://issues.apache.org/jira/browse/FLINK-11263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733813#comment-16733813
]
Hongtao Zhang commented on FLINK-11263:
---
Hi [~Tison] [~csq]
so currently, the per
[
https://issues.apache.org/jira/browse/FLINK-11263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733757#comment-16733757
]
shuiqiangchen commented on FLINK-11263:
---
Hi HongTao，when started the yarn session,
[
https://issues.apache.org/jira/browse/FLINK-11263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733749#comment-16733749
]
TisonKun commented on FLINK-11263:
--
[~hongtao12310] It's an unimplemented future, see a
[
https://issues.apache.org/jira/browse/FLINK-11264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-11264:
---
Component/s: Scala Shell
> Fail to start scala shell
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-11264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-11264:
---
Affects Version/s: 1.7.1
> Fail to start scala shell
> -
>
>
Jeff Zhang created FLINK-11264:
--
Summary: Fail to start scala shell
Key: FLINK-11264
URL: https://issues.apache.org/jira/browse/FLINK-11264
Project: Flink
Issue Type: Bug
Reporter: J
[
https://issues.apache.org/jira/browse/FLINK-11263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongtao Zhang updated FLINK-11263:
--
Priority: Critical (was: Major)
> yarn session script doesn't boot up task managers
> ---
[
https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16729516#comment-16729516
]
TisonKun edited comment on FLINK-10333 at 1/4/19 2:20 AM:
--
Foll
Hongtao Zhang created FLINK-11263:
-
Summary: yarn session script doesn't boot up task managers
Key: FLINK-11263
URL: https://issues.apache.org/jira/browse/FLINK-11263
Project: Flink
Issue Typ
KarmaGYZ commented on issue #7380: [hotfix][docs] Fix incorrect example in cep
doc
URL: https://github.com/apache/flink/pull/7380#issuecomment-451328811
@dawidwys Thanks for the review!
I've added a new commit fix the problems and it now passes the Travis-ci.
---
HuangZhenQiu commented on issue #7356: [FLINK-10868][flink-yarn] Enforce
maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#issuecomment-451305740
@suez1224 Thanks for the input. I will revise the PR tonight.
---
HuangZhenQiu commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r245161387
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManage
HuangZhenQiu commented on a change in pull request #7356:
[FLINK-10868][flink-yarn] Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r245161384
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemana
suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn]
Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r245156585
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.ja
suez1224 commented on a change in pull request #7356: [FLINK-10868][flink-yarn]
Enforce maximum failed TMs in YarnResourceManager
URL: https://github.com/apache/flink/pull/7356#discussion_r245151839
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/
stevenzwu commented on issue #7020: [FLINK-10774] [Kafka] connection leak when
partition discovery is disabled an…
URL: https://github.com/apache/flink/pull/7020#issuecomment-451278571
@tillrohrmann can you take a look at latest update?
-
zentol closed pull request #7342: [FLINK-11023][ES] Add NOTICE file
URL: https://github.com/apache/flink/pull/7342
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 foreign pull request
[
https://issues.apache.org/jira/browse/FLINK-11079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-11079.
Resolution: Fixed
master: 9e0ea45645b242c1b13f59c684fbe9d47eaeda06
1.7: 7679a84f5cae29ae42
[
https://issues.apache.org/jira/browse/FLINK-11194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-11194.
Resolution: Fixed
Fix Version/s: 1.8.0
1.7.2
master: 7a0a525504e
zentol closed pull request #7336: [FLINK-11194][hbase] Use type instead of
classifier
URL: https://github.com/apache/flink/pull/7336
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 fo
zentol closed pull request #7343: [FLINK-11079][storm] Skip deployment of
storm-examples
URL: https://github.com/apache/flink/pull/7343
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
tillrohrmann commented on a change in pull request #7342: [FLINK-11023][ES] Add
NOTICE file
URL: https://github.com/apache/flink/pull/7342#discussion_r245084804
##
File path:
flink-connectors/flink-sql-connector-elasticsearch6/src/main/resources/META-INF/NOTICE
##
@@ -0,0
tillrohrmann commented on a change in pull request #7342: [FLINK-11023][ES] Add
NOTICE file
URL: https://github.com/apache/flink/pull/7342#discussion_r245084507
##
File path:
flink-connectors/flink-sql-connector-elasticsearch6/src/main/resources/META-INF/NOTICE
##
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-10848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733245#comment-16733245
]
Shuyi Chen commented on FLINK-10848:
[~xinpu], thanks for sharing your thoughts. You
[
https://issues.apache.org/jira/browse/FLINK-10761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-10761.
Resolution: Fixed
Fix Version/s: 1.7.2
1.6.4
master: aa92438c4aa
zentol closed pull request #7347: [FLINK-10761][metrics] Do not acquire lock
for getAllVariables()
URL: https://github.com/apache/flink/pull/7347
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
zentol closed pull request #7246: [FLINK-11023] Add LICENSE & NOTICE files for
connectors (batch #1)
URL: https://github.com/apache/flink/pull/7246
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:
[
https://issues.apache.org/jira/browse/FLINK-11163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-11163.
Resolution: Fixed
master: 903a9090324f8d14af15621b7ec026f4a8485050
> RestClusterClientTes
zentol closed pull request #7345: [FLINK-11163][tests] Use random port in
RestClusterClientTest
URL: https://github.com/apache/flink/pull/7345
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 t
pnowojski commented on a change in pull request #6445: [FLINK-8302] [table] Add
SHIFT_LEFT and SHIFT_RIGHT
URL: https://github.com/apache/flink/pull/6445#discussion_r245056827
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarOperator
pnowojski commented on a change in pull request #6445: [FLINK-8302] [table] Add
SHIFT_LEFT and SHIFT_RIGHT
URL: https://github.com/apache/flink/pull/6445#discussion_r245056827
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarOperator
pnowojski commented on a change in pull request #6445: [FLINK-8302] [table] Add
SHIFT_LEFT and SHIFT_RIGHT
URL: https://github.com/apache/flink/pull/6445#discussion_r245056827
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarOperator
pnowojski commented on a change in pull request #6445: [FLINK-8302] [table] Add
SHIFT_LEFT and SHIFT_RIGHT
URL: https://github.com/apache/flink/pull/6445#discussion_r244966034
##
File path: docs/dev/table/functions.md
##
@@ -1095,6 +1095,40 @@ MOD(numeric1, numeric2)
[
https://issues.apache.org/jira/browse/FLINK-11261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11261:
Assignee: vinoyang
> BlobServer moves file with open OutputStream
> -
[
https://issues.apache.org/jira/browse/FLINK-11064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11064:
---
Labels: pull-request-available (was: )
> Setup a new flink-table module structure
> ---
twalthr opened a new pull request #7409: [FLINK-11064] [table] Setup a new
flink-table module structure
URL: https://github.com/apache/flink/pull/7409
## What is the purpose of the change
This commit splits the `flink-table` module into multiple submodules in
accordance with FLIP-28
zentol commented on issue #7346: [FLINK-11134][rest] Do not log stacktrace
handled exceptions
URL: https://github.com/apache/flink/pull/7346#issuecomment-451198244
Yeah the error handling is really all over the place.
I've consolidated it in `AbstractHandler` as you suggested.
-
[
https://issues.apache.org/jira/browse/FLINK-11064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-11064:
-
Description:
This issue covers the first step of the migration plan mentioned in
[FLIP-28|https
[
https://issues.apache.org/jira/browse/FLINK-11262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11262:
---
Labels: pull-request-available (was: )
> Bump jython-standalone to 2.7.1
>
zentol commented on issue #7347: [FLINK-10761][metrics] Do not acquire lock for
getAllVariables()
URL: https://github.com/apache/flink/pull/7347#issuecomment-451193997
Well _performance_ of course. if no reporter is configured and the WebUI is
not used we would spend memory on maps and str
Fokko opened a new pull request #7408: [FLINK-11262] Bump jython-standalone to
2.7.1
URL: https://github.com/apache/flink/pull/7408
Bump the jython depdendency because of a security issue.
https://ossindex.sonatype.org/vuln/7a4be7b3-74f5-4a9b-a24f-d1fd80ed6bbc
## What
Chesnay Schepler created FLINK-11261:
Summary: BlobServer moves file with open OutputStream
Key: FLINK-11261
URL: https://issues.apache.org/jira/browse/FLINK-11261
Project: Flink
Issue Ty
Fokko Driesprong created FLINK-11262:
Summary: Bump jython-standalone to 2.7.1
Key: FLINK-11262
URL: https://issues.apache.org/jira/browse/FLINK-11262
Project: Flink
Issue Type: Improveme
tillrohrmann commented on issue #7246: [FLINK-11023] Add LICENSE & NOTICE files
for connectors (batch #1)
URL: https://github.com/apache/flink/pull/7246#issuecomment-451190133
Thanks for addressing my comments @zentol. +1 for merging.
---
[
https://issues.apache.org/jira/browse/FLINK-11260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fokko Driesprong updated FLINK-11260:
-
Description: Bump the Janino dependency:
http://janino-compiler.github.io/janino/changel
[
https://issues.apache.org/jira/browse/FLINK-11260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fokko Driesprong updated FLINK-11260:
-
Description: Bump the Janino depdency:
http://janino-compiler.github.io/janino/changelog
[
https://issues.apache.org/jira/browse/FLINK-11259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11259:
---
Labels: pull-request-available (was: )
> Bump Zookeeper dependency to 3.4.13
>
[
https://issues.apache.org/jira/browse/FLINK-11260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11260:
---
Labels: pull-request-available (was: )
> Bump Janino compiler dependency
>
Fokko opened a new pull request #7407: [FLINK-11260] Bump the Janino compiler
URL: https://github.com/apache/flink/pull/7407
Fixes minor (NPE) issues and performance improvoments:
http://janino-compiler.github.io/janino/changelog.html
## What is the purpose of the change
Fokko Driesprong created FLINK-11260:
Summary: Bump Janino compiler dependency
Key: FLINK-11260
URL: https://issues.apache.org/jira/browse/FLINK-11260
Project: Flink
Issue Type: Improveme
Fokko opened a new pull request #7406: [FLINK-11259] Bump Zookeeper to 3.4.13
URL: https://github.com/apache/flink/pull/7406
The patched version provides some hotfixes:
https://zookeeper.apache.org/doc/r3.4.13/releasenotes.html
## What is the purpose of the change
*(
[
https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11249:
---
Labels: pull-request-available (was: )
> FlinkKafkaProducer011 can not be migrated to Flink
yanghua opened a new pull request #7405: [FLINK-11249] FlinkKafkaProducer011
can not be migrated to FlinkKafkaProducer
URL: https://github.com/apache/flink/pull/7405
## What is the purpose of the change
*This pull request fixed FlinkKafkaProducer011 can not be migrated to
FlinkKafka
Fokko Driesprong created FLINK-11259:
Summary: Bump Zookeeper dependency to 3.4.13
Key: FLINK-11259
URL: https://issues.apache.org/jira/browse/FLINK-11259
Project: Flink
Issue Type: Impro
[
https://issues.apache.org/jira/browse/FLINK-11258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11258:
---
Labels: pull-request-available (was: )
> Add badge to the README
> ---
Fokko opened a new pull request #7404: [FLINK-11258] Add badge to the README
URL: https://github.com/apache/flink/pull/7404
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That wa
Fokko Driesprong created FLINK-11258:
Summary: Add badge to the README
Key: FLINK-11258
URL: https://issues.apache.org/jira/browse/FLINK-11258
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-10960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Wozniakowski closed FLINK-10960.
---
Resolution: Workaround
Release Note: It seems this issue was as David described
tillrohrmann commented on a change in pull request #7345: [FLINK-11163][tests]
Use random port in RestClusterClientTest
URL: https://github.com/apache/flink/pull/7345#discussion_r245025401
##
File path:
flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterCl
[
https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733129#comment-16733129
]
Fabian Hueske commented on FLINK-11220:
---
Hi, I think manually assigning timestamps
lamber-ken commented on issue #7396: [FLINK-11250][streaming] fix thread lack
when StreamTask switched from DEPLOYING to CANCELING
URL: https://github.com/apache/flink/pull/7396#issuecomment-451164639
@zentol，I close the streamRecordWriters in `StreamTask#cancel` method and
test it at my f
[
https://issues.apache.org/jira/browse/FLINK-11256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11256:
---
Labels: pull-request-available (was: )
> Referencing StreamNode objects directly in StreamE
sunhaibotb opened a new pull request #7403: [FLINK-11256] Replace the reference
of StreamNode object with ID in S…
URL: https://github.com/apache/flink/pull/7403
## What is the purpose of the change
This pull request replaces the reference of StreamNode object with ID in
StreamEdge
[
https://issues.apache.org/jira/browse/FLINK-11256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16733025#comment-16733025
]
Haibo Suen commented on FLINK-11256:
The simplest solution is to put the ID of Strea
KarmaGYZ opened a new pull request #7402: [hotfix][docs] Fulfill some empty
description in Config Doc
URL: https://github.com/apache/flink/pull/7402
## What is the purpose of the change
This PR fulfill some empty description in Config Doc and relevance javadoc.
## Brief change
dawidwys commented on a change in pull request #7380: [hotfix][docs] Fix
incorrect example in cep doc
URL: https://github.com/apache/flink/pull/7380#discussion_r244991333
##
File path: docs/dev/libs/cep.md
##
@@ -1324,7 +1324,7 @@ For example, for a given pattern `b+ c` an
KarmaGYZ commented on a change in pull request #7380: [hotfix][docs] Fix
incorrect example in cep doc
URL: https://github.com/apache/flink/pull/7380#discussion_r244988094
##
File path: docs/dev/libs/cep.md
##
@@ -1373,7 +1372,7 @@ Pattern: `a b+` and sequence: `a b1 b2 b3`
KarmaGYZ commented on a change in pull request #7380: [hotfix][docs] Fix
incorrect example in cep doc
URL: https://github.com/apache/flink/pull/7380#discussion_r244988003
##
File path: docs/dev/libs/cep.md
##
@@ -1324,7 +1324,7 @@ For example, for a given pattern `b+ c` an
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732989#comment-16732989
]
Hequn Cheng commented on FLINK-11222:
-
[~aljoscha] Great to have your suggestions!
[
https://issues.apache.org/jira/browse/FLINK-11230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732986#comment-16732986
]
Hequn Cheng commented on FLINK-11230:
-
[~jiweiautohome] The bottom aggregate after w
[
https://issues.apache.org/jira/browse/FLINK-11187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-11187:
--
Fix Version/s: 1.8.0
> StreamingFileSink with S3 backend transient socket timeout issues
> --
[
https://issues.apache.org/jira/browse/FLINK-8823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732964#comment-16732964
]
boshu Zheng commented on FLINK-8823:
Haven't started working on this issue, do you ha
kisimple opened a new pull request #7401: [hotfix][doc] Fix an error in
state_backends
URL: https://github.com/apache/flink/pull/7401
Class of state backend factory to be implemented is `StateBackendFactory`,
not `FsStateBackendFactory`.
---
[
https://issues.apache.org/jira/browse/FLINK-11254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732948#comment-16732948
]
Congxian Qiu commented on FLINK-11254:
--
Thanks for your quick response [~tzulitai],
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732942#comment-16732942
]
Albert Bikeev edited comment on FLINK-11226 at 1/3/19 11:27 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732942#comment-16732942
]
Albert Bikeev commented on FLINK-11226:
---
Yep. In short, in my case - a window size
[
https://issues.apache.org/jira/browse/FLINK-11254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732931#comment-16732931
]
Tzu-Li (Gordon) Tai edited comment on FLINK-11254 at 1/3/19 11:20 AM:
[
https://issues.apache.org/jira/browse/FLINK-11254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732931#comment-16732931
]
Tzu-Li (Gordon) Tai commented on FLINK-11254:
-
Yes, we've discussed on this
[
https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732912#comment-16732912
]
vinoyang commented on FLINK-11249:
--
[~aljoscha] Understand, I will provide a custom ser
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732894#comment-16732894
]
vinoyang commented on FLINK-11226:
--
I guess there may be some need for extension and cu
dawidwys commented on a change in pull request #7380: [hotfix][docs] Fix
incorrect example in cep doc
URL: https://github.com/apache/flink/pull/7380#discussion_r244961085
##
File path: docs/dev/libs/cep.md
##
@@ -1373,7 +1372,7 @@ Pattern: `a b+` and sequence: `a b1 b2 b3`
dawidwys commented on a change in pull request #7380: [hotfix][docs] Fix
incorrect example in cep doc
URL: https://github.com/apache/flink/pull/7380#discussion_r244960959
##
File path: docs/dev/libs/cep.md
##
@@ -1324,7 +1324,7 @@ For example, for a given pattern `b+ c` an
[
https://issues.apache.org/jira/browse/FLINK-11257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732855#comment-16732855
]
shengjk1 commented on FLINK-11257:
--
hi ,[~till.rohrmann],In order to ensure the compati
[
https://issues.apache.org/jira/browse/FLINK-11213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-11213.
Resolution: Invalid
Please ask questions like this on the user mailing lists.
> Is there
[
https://issues.apache.org/jira/browse/FLINK-11222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732844#comment-16732844
]
Aljoscha Krettek commented on FLINK-11222:
--
This change makes sense! +1
> Chan
[
https://issues.apache.org/jira/browse/FLINK-11254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732839#comment-16732839
]
Congxian Qiu commented on FLINK-11254:
--
Thanks for the quick response [~till.rohrma
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732836#comment-16732836
]
Aljoscha Krettek commented on FLINK-11226:
--
{{getKeySelector()}} is an internal
[
https://issues.apache.org/jira/browse/FLINK-11228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-11228:
--
Priority: Minor (was: Blocker)
> Flink web UI can not read stdout logs
>
[
https://issues.apache.org/jira/browse/FLINK-11231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732833#comment-16732833
]
Aljoscha Krettek commented on FLINK-11231:
--
Also, {{getTransformation()}} is an
[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-11226:
-
Issue Type: Improvement (was: Bug)
> Lack of getKeySelector in Scala KeyedStream API un
[
https://issues.apache.org/jira/browse/FLINK-11250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-11250:
--
Description:
begin flink-1.5.x version, streamRecordWriters was created in StreamTask's
const
[
https://issues.apache.org/jira/browse/FLINK-11231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732829#comment-16732829
]
Aljoscha Krettek commented on FLINK-11231:
--
The Scala API and Java API work sli
[
https://issues.apache.org/jira/browse/FLINK-10981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732826#comment-16732826
]
Piotr Nowojski commented on FLINK-10981:
[~gaoyunhaii] aren't the already existi
1 - 100 of 121 matches
Mail list logo
