[
https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16445353#comment-16445353
]
Sihua Zhou commented on FLINK-7289:
---
Hi [~srichter], I think it's quite hard to tell what is the best
[
https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16445330#comment-16445330
]
ASF GitHub Bot commented on FLINK-8836:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5880
+1, Will this PR also get into 1.4.x?
---
[
https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16445315#comment-16445315
]
ASF GitHub Bot commented on FLINK-9190:
---
GitHub user sihuazhou opened a pull request:
GitHub user sihuazhou opened a pull request:
https://github.com/apache/flink/pull/5881
[FLINK-9190][yarn] fix YarnResourceManager sometimes does not request new
Containers
## What is the purpose of the change
This PR fixes the problem that `YarnResourceManager` does not
[
https://issues.apache.org/jira/browse/FLINK-9190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reassigned FLINK-9190:
-
Assignee: Sihua Zhou
> YarnResourceManager sometimes does not request new Containers
>
[
https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16445084#comment-16445084
]
ASF GitHub Bot commented on FLINK-8302:
---
Github user dubin555 closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9223:
---
Assignee: vinoyang
> bufferConsumers should be closed in
>
Github user dubin555 closed the pull request at:
https://github.com/apache/flink/pull/5202
---
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5845
Welcome to the community!
@sijie I think for this a general discussion email thread will be enough.
---
[
https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444501#comment-16444501
]
ASF GitHub Bot commented on FLINK-9168:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1658#comment-1658
]
ASF GitHub Bot commented on FLINK-9210:
---
Github user Silven1117 commented on the issue:
Github user Silven1117 commented on the issue:
https://github.com/apache/flink/pull/5875
Thanks that would be great! Will assign myself next time I create issues.
---
[
https://issues.apache.org/jira/browse/FLINK-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1618#comment-1618
]
ASF GitHub Bot commented on FLINK-9168:
---
Github user sijie commented on the issue:
Github user sijie commented on the issue:
https://github.com/apache/flink/pull/5845
@tzulitai thank you for your comments. Glad to hear your opinions about
pulsar connectors. I was the original person who initiated the idea of flink
pulsar connectors with @XiaoZYang, I am also from
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444399#comment-16444399
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user walterddr commented on the issue:
Github user walterddr commented on the issue:
https://github.com/apache/flink/pull/
Hi @fhueske . Thanks for the review, all very good points. I will follow up
with the next steps. Actually @hequn8128 and I had some discussions regarding
the follow up in FLINK-8690 already and I
Ted Yu created FLINK-9223:
-
Summary: bufferConsumers should be closed in
SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd
Key: FLINK-9223
URL: https://issues.apache.org/jira/browse/FLINK-9223
[
https://issues.apache.org/jira/browse/FLINK-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444342#comment-16444342
]
Amit Jain edited comment on FLINK-2685 at 4/19/18 4:42 PM:
---
[~NicoK] I've
[
https://issues.apache.org/jira/browse/FLINK-9206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9206.
---
Resolution: Fixed
master: 727370aacf63cefc6aed7c46dc2d63517e4b708d
1.5:
[
https://issues.apache.org/jira/browse/FLINK-2685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444342#comment-16444342
]
Amit Jain commented on FLINK-2685:
--
[~NicoK] I've checked in WebUI and found there is no progress at all.
[
https://issues.apache.org/jira/browse/FLINK-8715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-8715:
--
Assignee: Tzu-Li (Gordon) Tai
> RocksDB does not propagate reconfiguration of
[
https://issues.apache.org/jira/browse/FLINK-9207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444306#comment-16444306
]
Amit Jain commented on FLINK-9207:
--
[~aljoscha] I believe, many of us submit Batch job via some scheduler
[
https://issues.apache.org/jira/browse/FLINK-9189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9189:
---
Summary: Add a SBT Quickstart (was: Add a SBT Quickstarts)
> Add a SBT Quickstart
>
[
https://issues.apache.org/jira/browse/FLINK-9222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444291#comment-16444291
]
Nico Kruber commented on FLINK-9222:
actually, what is wrong with the existing SBT quickstarts at
[
https://issues.apache.org/jira/browse/FLINK-9222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9222:
---
Comment: was deleted
(was: actually, what is wrong with the existing SBT quickstarts at
[
https://issues.apache.org/jira/browse/FLINK-9189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444292#comment-16444292
]
Nico Kruber commented on FLINK-9189:
actually, what is wrong with the existing SBT quickstarts at
[
https://issues.apache.org/jira/browse/FLINK-9189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9189:
---
Summary: Add a SBT Quickstarts (was: Add a SBT and Gradle Quickstarts)
> Add a SBT Quickstarts
>
[
https://issues.apache.org/jira/browse/FLINK-9189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9189:
---
Description:
Having a proper project template helps a lot in getting dependencies right. For
[
https://issues.apache.org/jira/browse/FLINK-9222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9222:
---
Description:
Having a proper project template helps a lot in getting dependencies right. For
Nico Kruber created FLINK-9222:
--
Summary: Add a Gradle Quickstart
Key: FLINK-9222
URL: https://issues.apache.org/jira/browse/FLINK-9222
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-9222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-9222:
--
Assignee: Nico Kruber
> Add a Gradle Quickstart
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-9202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444261#comment-16444261
]
Timo Walther commented on FLINK-9202:
-
I could reproduce the exception {{"local class incompatible:
[
https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josh Lemer updated FLINK-9221:
--
Component/s: DataSet API
> Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B]
>
[
https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444250#comment-16444250
]
Josh Lemer commented on FLINK-9221:
---
Fixed!
> Add method SinkFunction[A]#contramap[B](f: B => A):
[
https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josh Lemer updated FLINK-9221:
--
Labels: flink (was: )
> Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B]
>
[
https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josh Lemer updated FLINK-9221:
--
Affects Version/s: 1.5.0
> Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B]
>
[
https://issues.apache.org/jira/browse/FLINK-9207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444252#comment-16444252
]
Gary Yao commented on FLINK-9207:
-
[~amit.jain] Is the priority only _minor_ for you?
> Client returns
[
https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josh Lemer updated FLINK-9221:
--
Component/s: DataStream API
> Add method SinkFunction[A]#contramap[B](f: B => A): SinkFunction[B]
>
[
https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josh Lemer updated FLINK-9221:
--
Description:
Just like it is very useful to use `DataStream[T]` as a sort of Functor or
Monad with
[
https://issues.apache.org/jira/browse/FLINK-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-9211:
---
Assignee: Aljoscha Krettek
> Job submission via REST/dashboard does not work on
[
https://issues.apache.org/jira/browse/FLINK-9221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444236#comment-16444236
]
Ted Yu commented on FLINK-9221:
---
bq. .setBucketr
Should be {{.setBucketer}}
> Add method
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444215#comment-16444215
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444231#comment-16444231
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444221#comment-16444221
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444230#comment-16444230
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444223#comment-16444223
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
Josh Lemer created FLINK-9221:
-
Summary: Add method SinkFunction[A]#contramap[B](f: B => A):
SinkFunction[B]
Key: FLINK-9221
URL: https://issues.apache.org/jira/browse/FLINK-9221
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444216#comment-16444216
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444218#comment-16444218
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444222#comment-16444222
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444224#comment-16444224
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444229#comment-16444229
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444225#comment-16444225
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444226#comment-16444226
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444219#comment-16444219
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444228#comment-16444228
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444220#comment-16444220
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444217#comment-16444217
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444227#comment-16444227
]
ASF GitHub Bot commented on FLINK-8689:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182496636
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1439,7 +1467,47 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182226785
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1439,7 +1467,47 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182753514
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -151,8 +157,15 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182478446
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -93,6 +97,8 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182481625
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/DistinctAccumulator.scala
---
@@ -0,0 +1,102 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182479163
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -93,6 +97,8 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182768521
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -327,19 +392,41 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182218521
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1439,7 +1467,47 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182496465
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1439,7 +1467,47 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182773359
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -417,13 +530,26 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182219690
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/OverWindowITCase.scala
---
@@ -50,6 +51,96 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182489141
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1439,7 +1467,47 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182233134
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1439,7 +1467,47 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182753219
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -151,8 +157,15 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182254735
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -327,19 +392,41 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182768726
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -327,19 +392,41 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/#discussion_r182469110
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/OverAggregate.scala
---
@@ -70,7 +70,12 @@ trait OverAggregate {
[
https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444174#comment-16444174
]
ASF GitHub Bot commented on FLINK-8836:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5880#discussion_r182777472
--- Diff:
flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializerConcurrencyTest.java
---
@@ -24,21 +24,71 @@
import
[
https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444169#comment-16444169
]
ASF GitHub Bot commented on FLINK-8836:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5880#discussion_r182776735
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java
---
@@ -140,14 +140,37 @@ public
[
https://issues.apache.org/jira/browse/FLINK-8979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8979:
Fix Version/s: (was: 1.5.0)
1.5.1
1.6.0
> Extend
[
https://issues.apache.org/jira/browse/FLINK-8982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8982:
Fix Version/s: (was: 1.5.0)
1.5.1
1.6.0
>
[
https://issues.apache.org/jira/browse/FLINK-8977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8977:
Fix Version/s: (was: 1.5.0)
1.5.1
1.6.0
>
[
https://issues.apache.org/jira/browse/FLINK-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444149#comment-16444149
]
Aljoscha Krettek commented on FLINK-8286:
-
[~suez1224] Is there any update on this?
> Investigate
[
https://issues.apache.org/jira/browse/FLINK-7431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7431.
---
Resolution: Cannot Reproduce
Closing because we haven't seen this in a while and also because
[
https://issues.apache.org/jira/browse/FLINK-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444092#comment-16444092
]
Timo Walther commented on FLINK-9220:
-
Which package has your function? According to the exception
[
https://issues.apache.org/jira/browse/FLINK-9155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444080#comment-16444080
]
Tzu-Li (Gordon) Tai commented on FLINK-9155:
I think we can implement both logging and metrics
[
https://issues.apache.org/jira/browse/FLINK-9204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-9204.
Resolution: Duplicate
> Improve visibility of records being skipped by the
[
https://issues.apache.org/jira/browse/FLINK-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444072#comment-16444072
]
Saurabh Garg commented on FLINK-9220:
-
Registered this ScalarFunction on StreamTableEnvironment. Flink
[
https://issues.apache.org/jira/browse/FLINK-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444070#comment-16444070
]
Saurabh Garg commented on FLINK-9220:
-
Query: select id, HashCode(id) as hashcode from input1
[
https://issues.apache.org/jira/browse/FLINK-9220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Saurabh Garg updated FLINK-9220:
Description:
Flink job gets failed with scalar UDF. I am using Flink 1.4. Issue came with
Scalar
[
https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444068#comment-16444068
]
ASF GitHub Bot commented on FLINK-8836:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5880#discussion_r182750453
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java
---
@@ -140,14 +140,37 @@ public
[
https://issues.apache.org/jira/browse/FLINK-8836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444066#comment-16444066
]
ASF GitHub Bot commented on FLINK-8836:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5880#discussion_r182749960
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java
---
@@ -140,14 +140,37 @@ public
[
https://issues.apache.org/jira/browse/FLINK-8785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444055#comment-16444055
]
ASF GitHub Bot commented on FLINK-8785:
---
Github user buptljy commented on the issue:
Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/5877
@zentol ok, I thought that it was a small change before, so you mean we
can make more changes on the messages of the exceptions and let them reported
more properly ?
I will test all the cases
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/5813
Sounds good @twalthr !
---
[
https://issues.apache.org/jira/browse/FLINK-8980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444044#comment-16444044
]
ASF GitHub Bot commented on FLINK-8980:
---
Github user kl0u commented on the issue:
1 - 100 of 244 matches
Mail list logo
