[
https://issues.apache.org/jira/browse/FLINK-9166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
SUBRAMANYA SURESH updated FLINK-9166:
-
Description:
With a high number of Flink SQL queries (100 of below), the Flink command lin
[
https://issues.apache.org/jira/browse/FLINK-8867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436801#comment-16436801
]
Aljoscha Krettek commented on FLINK-8867:
-
[~StephanEwen] mentioned that the probl
[
https://issues.apache.org/jira/browse/FLINK-9167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex Klibisz updated FLINK-9167:
Description:
I'm new to Flink, and I'm curious about an extension of approximate KNN to
support in
Alex Klibisz created FLINK-9167:
---
Summary: Approximate KNN with Incremental Insertion
Key: FLINK-9167
URL: https://issues.apache.org/jira/browse/FLINK-9167
Project: Flink
Issue Type: New Featur
[
https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1643#comment-1643
]
yuqi commented on FLINK-9158:
-
+1, the reason of this issue ?
> Set default FixedRestartDelay
[
https://issues.apache.org/jira/browse/FLINK-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436565#comment-16436565
]
Zili Chen commented on FLINK-8795:
--
Thank you [~Zentol]! It works for me.
> Scala shell
[
https://issues.apache.org/jira/browse/FLINK-9166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
SUBRAMANYA SURESH updated FLINK-9166:
-
Description:
With a high number of Flink SQL queries (100 of below), the Flink command lin
[
https://issues.apache.org/jira/browse/FLINK-9166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
SUBRAMANYA SURESH updated FLINK-9166:
-
Description:
With a high number of Flink SQL queries (100 of below), the Flink command lin
SUBRAMANYA SURESH created FLINK-9166:
Summary: Performance issue with Flink SQL
Key: FLINK-9166
URL: https://issues.apache.org/jira/browse/FLINK-9166
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436512#comment-16436512
]
Kostas Kloudas commented on FLINK-9164:
---
Hi Romain,
What if you remove the skipPast
[
https://issues.apache.org/jira/browse/FLINK-9165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436465#comment-16436465
]
ASF GitHub Bot commented on FLINK-9165:
---
Github user Bekreth commented on the issue:
Github user Bekreth commented on the issue:
https://github.com/apache/flink/pull/5844
What I was hoping to achieve was a CassandraSink that could write objects
as single statements, or in a batch statement. This would allow for minor
transaction protection, guarenteeing a group of el
[
https://issues.apache.org/jira/browse/FLINK-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436419#comment-16436419
]
Aljoscha Krettek commented on FLINK-9152:
-
Fixed on release-1.5 in
833b83b3c2
179b
[
https://issues.apache.org/jira/browse/FLINK-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-9152.
---
Resolution: Fixed
> Harmonize BroadcastProcessFunction Context names
> ---
[
https://issues.apache.org/jira/browse/FLINK-9160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-9160.
---
Resolution: Fixed
> Make subclasses of RuntimeContext internal that should be internal
> -
[
https://issues.apache.org/jira/browse/FLINK-9160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436415#comment-16436415
]
Aljoscha Krettek commented on FLINK-9160:
-
Fixed on release-1.5 in
179ae583e2d01f7
[
https://issues.apache.org/jira/browse/FLINK-9103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9103:
---
Component/s: Network
> SSL verification on TaskManager when parallelism > 1
>
[
https://issues.apache.org/jira/browse/FLINK-9165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436328#comment-16436328
]
Christopher Hughes commented on FLINK-9165:
---
Released a pull request for this is
[
https://issues.apache.org/jira/browse/FLINK-9165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436318#comment-16436318
]
ASF GitHub Bot commented on FLINK-9165:
---
GitHub user Bekreth opened a pull request:
GitHub user Bekreth opened a pull request:
https://github.com/apache/flink/pull/5844
[FLINK-9165] [DataSink] Upgrading CassandraSinkBase to submit collections
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the com
Christopher Hughes created FLINK-9165:
-
Summary: Improve CassandraSinkBase to send Collections
Key: FLINK-9165
URL: https://issues.apache.org/jira/browse/FLINK-9165
Project: Flink
Issue T
Romain Revol created FLINK-9164:
---
Summary: times(#,#) quantifier does not seem to work
Key: FLINK-9164
URL: https://issues.apache.org/jira/browse/FLINK-9164
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen reassigned FLINK-1913:
-
Assignee: Zhenqiu Huang
> Document how to access data in HCatalog
> -
[
https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436032#comment-16436032
]
ASF GitHub Bot commented on FLINK-8744:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5843
[FLINK-8744][docs] Generate "Common Option" section
Base on #5822.
## What is the purpose of the change
With this PR the "Common Options" section is now generated by the
`ConfigOpti
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5820
@zentol which scala checkstyle mvn plugin are you looking at? I didn't find
any available ones, and I'm afraid there might will not be one.
scalastyle explicitly said that they will not sup
[
https://issues.apache.org/jira/browse/FLINK-9144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435876#comment-16435876
]
ASF GitHub Bot commented on FLINK-9144:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5842
[FLINK-9144][network] fix SpillableSubpartition causing jobs to hang when
spilling
## What is the purpose of the change
This should fix various scenarios where the backlog accounting in the
[
https://issues.apache.org/jira/browse/FLINK-9156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435871#comment-16435871
]
ASF GitHub Bot commented on FLINK-9156:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-9156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435870#comment-16435870
]
ASF GitHub Bot commented on FLINK-9156:
---
Github user GJL commented on a diff in the
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5838#discussion_r181141707
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java
---
@@ -677,6 +682,37 @@ public void testGetAccumulators()
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5838#discussion_r181140084
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java
---
@@ -677,6 +682,37 @@ public void testGetAccumulators()
[
https://issues.apache.org/jira/browse/FLINK-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435865#comment-16435865
]
Chesnay Schepler commented on FLINK-8795:
-
[~Tison] you may have to set {{mode}} t
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-8707:
-
Assignee: (was: Piotr Nowojski)
> Excessive amount of files opened by flink task mana
[
https://issues.apache.org/jira/browse/FLINK-8707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435853#comment-16435853
]
Alexander Gardner commented on FLINK-8707:
--
Hi Stephan
Sorry for delay, will en
[
https://issues.apache.org/jira/browse/FLINK-8795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435845#comment-16435845
]
Zili Chen commented on FLINK-8795:
--
Applying the workaround, but DataSet API example in
[
https://issues.apache.org/jira/browse/FLINK-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435818#comment-16435818
]
ASF GitHub Bot commented on FLINK-9152:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435817#comment-16435817
]
Aljoscha Krettek commented on FLINK-9152:
-
Fixed on master in
584229dc00e62a6a8540
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5830
Thanks for the review! I merged
---
[
https://issues.apache.org/jira/browse/FLINK-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435819#comment-16435819
]
ASF GitHub Bot commented on FLINK-9152:
---
Github user aljoscha closed the pull reques
[
https://issues.apache.org/jira/browse/FLINK-9160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435816#comment-16435816
]
Aljoscha Krettek commented on FLINK-9160:
-
Fixed on master in
d5d6842f62d5a476541d
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/5830
---
[
https://issues.apache.org/jira/browse/FLINK-9163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435780#comment-16435780
]
ASF GitHub Bot commented on FLINK-9163:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5841
[FLINK-9163[e2e-tests] harden signal traps and config restoration
## What is the purpose of the change
Signal traps on certain systems, e.g. Linux, may be called concurrently
when the trap is
[
https://issues.apache.org/jira/browse/FLINK-9163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9163:
---
Description: Signal traps on certain systems, e.g. Linux, may be called
concurrently when the trap is
Nico Kruber created FLINK-9163:
--
Summary: Harden e2e tests' signal traps and config restoration
during abort
Key: FLINK-9163
URL: https://issues.apache.org/jira/browse/FLINK-9163
Project: Flink
GitHub user kai-chi opened a pull request:
https://github.com/apache/flink/pull/5840
[FLINK-7850] [build system] Give each maven profile an activation property
## What is the purpose of the change
This PR gives every maven profile an activation property so they can be
activ
[
https://issues.apache.org/jira/browse/FLINK-7850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435694#comment-16435694
]
ASF GitHub Bot commented on FLINK-7850:
---
GitHub user kai-chi opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8684.
---
Resolution: Fixed
master: a926bc69416059acca91b13508bf1b159d921c73
1.5: 21a66eab348173233016e8
[
https://issues.apache.org/jira/browse/FLINK-9162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9162.
---
Resolution: Duplicate
> Scala REPL hanging when running example
>
[
https://issues.apache.org/jira/browse/FLINK-9162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9162:
Affects Version/s: (was: 1.5.1)
1.5.0
> Scala REPL hanging when r
[
https://issues.apache.org/jira/browse/FLINK-9162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
陈梓立 updated FLINK-9162:
---
Description:
{code:java}
➜ build-target git:(master) bin/start-cluster.sh
Starting cluster.
Starting standalonesessio
陈梓立 created FLINK-9162:
--
Summary: Scala REPL hanging when running example
Key: FLINK-9162
URL: https://issues.apache.org/jira/browse/FLINK-9162
Project: Flink
Issue Type: Bug
Components: Scala
[
https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435419#comment-16435419
]
ASF GitHub Bot commented on FLINK-9008:
---
Github user zhangminglei commented on the i
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5823
Hello, @zentol. I have updated the code. CI run without error. Could you
please take another look ?
---
[
https://issues.apache.org/jira/browse/FLINK-8744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8744:
Fix Version/s: 1.5.0
> Add annotations for documentation common/advanced options
> -
[
https://issues.apache.org/jira/browse/FLINK-8743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8743:
Fix Version/s: 1.5.0
> Add annotation to override documented default
> -
[
https://issues.apache.org/jira/browse/FLINK-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435219#comment-16435219
]
Dmitrii Kober commented on FLINK-9157:
--
Hello [~walterddr]! I can try this one. If it
Github user bachrc commented on the issue:
https://github.com/apache/flink/pull/3554
Why isn't it implemented yet ? Expect the conflicting files, it's still not
possible to launch a flink job in a detached mode.
---
Shuyi Chen created FLINK-9161:
-
Summary: Support AS STRUCT syntax to create named STRUCT in SQL
Key: FLINK-9161
URL: https://issues.apache.org/jira/browse/FLINK-9161
Project: Flink
Issue Type: Ne
[
https://issues.apache.org/jira/browse/FLINK-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen updated FLINK-9161:
--
Summary: Support STRUCT syntax to create named STRUCT in SQL (was: Support
AS STRUCT syntax to create n
[
https://issues.apache.org/jira/browse/FLINK-9151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christopher Ng closed FLINK-9151.
-
Resolution: Won't Fix
This can be handled by `env.ssh.opts` provided your target servers allow you
Github user facboy closed the pull request at:
https://github.com/apache/flink/pull/5831
---
[
https://issues.apache.org/jira/browse/FLINK-9151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435145#comment-16435145
]
ASF GitHub Bot commented on FLINK-9151:
---
Github user facboy commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435146#comment-16435146
]
ASF GitHub Bot commented on FLINK-9151:
---
Github user facboy closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435142#comment-16435142
]
ASF GitHub Bot commented on FLINK-9151:
---
Github user facboy commented on the issue:
Github user facboy commented on the issue:
https://github.com/apache/flink/pull/5831
Actually this can be handled by `env.ssh.opts` provided your target servers
allow you to send the `FLINK_CONF_DIR` env var in an ssh session.
---
[
https://issues.apache.org/jira/browse/FLINK-9151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435144#comment-16435144
]
ASF GitHub Bot commented on FLINK-9151:
---
Github user facboy closed the pull request
Github user facboy closed the pull request at:
https://github.com/apache/flink/pull/5832
---
Github user facboy commented on the issue:
https://github.com/apache/flink/pull/5832
Actually this can be handled by `env.ssh.opts` provided your target servers
allow you to send the `FLINK_CONF_DIR` env var in an ssh session.
---
[
https://issues.apache.org/jira/browse/FLINK-8426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435112#comment-16435112
]
ASF GitHub Bot commented on FLINK-8426:
---
Github user mylog00 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435113#comment-16435113
]
ASF GitHub Bot commented on FLINK-8426:
---
Github user mylog00 closed the pull request
Github user mylog00 closed the pull request at:
https://github.com/apache/flink/pull/5837
---
Github user mylog00 commented on the issue:
https://github.com/apache/flink/pull/5837
Already merged
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5820
I wouldn't bother cleaning up unused imports until we have a checkstyle
rule in place to enforce it.
---
[
https://issues.apache.org/jira/browse/FLINK-8426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435071#comment-16435071
]
ASF GitHub Bot commented on FLINK-8426:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5837
The PR has been merged, @mylog00 could you close it?
---
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9087.
---
Resolution: Fixed
Fix Version/s: 1.5.0
master: 0a5a64ab746107c36a207a7cc62a75a88eabf1ae
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-9087:
---
Assignee: Triones Deng
> Change the method signature of RecordWriter#broadcastEvent()
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9087:
Affects Version/s: (was: 1.6.0)
> Change the method signature of RecordWriter#broadcastE
[
https://issues.apache.org/jira/browse/FLINK-9140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9140.
---
Resolution: Fixed
Fix Version/s: (was: 1.6.0)
master: 4742c348889e7ae761c332cbbadce
[
https://issues.apache.org/jira/browse/FLINK-9147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9147.
---
Resolution: Fixed
master: 1a5bb36d12ca7acb395315b429f085981a595c0b
1.5: 190ebae1ea15ce616f0dbe
[
https://issues.apache.org/jira/browse/FLINK-9140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435065#comment-16435065
]
ASF GitHub Bot commented on FLINK-9140:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435063#comment-16435063
]
ASF GitHub Bot commented on FLINK-9087:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435062#comment-16435062
]
ASF GitHub Bot commented on FLINK-9147:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-8426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8426.
---
Resolution: Fixed
Fix Version/s: 1.5.0
master: 0e0ba5d8ff394ea9be4d1b8e988d15776197
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5828
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5802
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5819
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5827
---
[
https://issues.apache.org/jira/browse/FLINK-9158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435056#comment-16435056
]
Chesnay Schepler commented on FLINK-9158:
-
What is the reasoning for this change?
[
https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16435048#comment-16435048
]
Juho Autio commented on FLINK-5479:
---
[~tzulitai]:
{quote}Raised this to blocker for 1.5.
92 matches
Mail list logo
