[
https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16263908#comment-16263908
]
Fabian Hueske commented on FLINK-6101:
--
In the example you gave, I'd think that {{'ad
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-2170.
Resolution: Implemented
Fix Version/s: 1.5.0
1.4.0
Implemented for 1.4.0 w
[
https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16263755#comment-16263755
]
lincoln.lee commented on FLINK-6101:
[~fhueske] Agree with you that SQL is not perfe
[
https://issues.apache.org/jira/browse/FLINK-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16263669#comment-16263669
]
ASF GitHub Bot commented on FLINK-7967:
---
Github user zhangminglei commented on the i
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/4946
Thanks, @greghogan . I will make a first refinement based on your
suggestions.
---
[
https://issues.apache.org/jira/browse/FLINK-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16263600#comment-16263600
]
ASF GitHub Bot commented on FLINK-8104:
---
Github user walterddr commented on the issu
Github user walterddr commented on the issue:
https://github.com/apache/flink/pull/5040
Thanks for the prompt review @twalthr . Yeah I think generalizing the
codegen part would be great.
Also do you think I can put in TableAPI support in this PR as well? I will
update the documen
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16263443#comment-16263443
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16263442#comment-16263442
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4670
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5043
---
[
https://issues.apache.org/jira/browse/FLINK-8126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16263215#comment-16263215
]
ASF GitHub Bot commented on FLINK-8126:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5044
Setting the version in IntelliJ to 8.4 seems to work.
Settings -> Other Settings -> Checkstyle -> Checkstyle version drop-down
menu
---
[
https://issues.apache.org/jira/browse/FLINK-8126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16263209#comment-16263209
]
ASF GitHub Bot commented on FLINK-8126:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5044
Which checkstyle version is configured in IntelliJ @StephanEwen ? Could be
that we have to upgrade it there as well. IIRC we set recommend setting it to
6.X in the IDE setup guide because of some pars
[
https://issues.apache.org/jira/browse/FLINK-7718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16263050#comment-16263050
]
ASF GitHub Bot commented on FLINK-7718:
---
GitHub user GJL opened a pull request:
GitHub user GJL opened a pull request:
https://github.com/apache/flink/pull/5055
[FLINK-7718] [flip6] Add JobVertexMetricsHandler to DispatcherRestEndpoint
## Brief change log
- *Migrate logic in
`org.apache.flink.runtime.rest.handler.legacy.metrics.JobVertexMetricsHandler`
t
[
https://issues.apache.org/jira/browse/FLINK-8126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262995#comment-16262995
]
ASF GitHub Bot commented on FLINK-8126:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5044
I am not seeing some problem in IntelliJ with the checkstyle plugin (seems
to not be able to parse the checkstyle config).
Anyone else seeing this issue? I am on an older IntelliJ version
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262976#comment-16262976
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user fhueske commented on the issue:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152634076
--- Diff:
flink-connectors/flink-orc/src/test/java/org/apache/flink/orc/OrcTableSourceITCase.java
---
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the Apac
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5043
Thanks for the review @twalthr!
I'll address your comments and will merge this PR.
---
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262973#comment-16262973
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8136.
-
Resolution: Fixed
Fix Version/s: 1.5.0
1.4.0
Fixed in 1.5: 5017c679c06de
[
https://issues.apache.org/jira/browse/FLINK-8136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262943#comment-16262943
]
ASF GitHub Bot commented on FLINK-8136:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5054
---
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262932#comment-16262932
]
Aljoscha Krettek commented on FLINK-7913:
-
What is the default Kafka partitioner d
[
https://issues.apache.org/jira/browse/FLINK-8136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262930#comment-16262930
]
ASF GitHub Bot commented on FLINK-8136:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5054
Merging...
---
[
https://issues.apache.org/jira/browse/FLINK-8050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reopened FLINK-8050:
---
> RestServer#shutdown() ignores exceptions thrown when shutting down netty.
>
[
https://issues.apache.org/jira/browse/FLINK-8137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joshua Griffith updated FLINK-8137:
---
Description:
When submitting a new {{FlinkPlan}} using the {{StandaloneClusterClient}}, the
J
[
https://issues.apache.org/jira/browse/FLINK-8137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joshua Griffith updated FLINK-8137:
---
Description:
When submitting a new {{FlinkPlan}} using the {{StandaloneClusterClient}}, the
J
[
https://issues.apache.org/jira/browse/FLINK-8137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joshua Griffith updated FLINK-8137:
---
Description:
When submitting a new {{FlinkPlan}} using the {{StandaloneClusterClient}}, the
J
[
https://issues.apache.org/jira/browse/FLINK-8137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joshua Griffith updated FLINK-8137:
---
Description:
When submitting a new {{FlinkPlan}} using the {{StandaloneClusterClient}}, the
J
[
https://issues.apache.org/jira/browse/FLINK-8137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joshua Griffith updated FLINK-8137:
---
Description:
When submitting a new {{FlinkPlan}} using the {{StandaloneClusterClient}}, the
J
[
https://issues.apache.org/jira/browse/FLINK-8137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joshua Griffith updated FLINK-8137:
---
Environment: Flink 1.3.2 running a batch job in Kubernetes.
> Flink JobManager API non-respons
Joshua Griffith created FLINK-8137:
--
Summary: Flink JobManager API non-responsive during job submission
Key: FLINK-8137
URL: https://issues.apache.org/jira/browse/FLINK-8137
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-8136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262911#comment-16262911
]
ASF GitHub Bot commented on FLINK-8136:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5054
+1
---
[
https://issues.apache.org/jira/browse/FLINK-8136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262908#comment-16262908
]
ASF GitHub Bot commented on FLINK-8136:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/5054
[FLINK-8136] [table] Fix code generation with JodaTime shading
## What is the purpose of the change
Fix `DATE_FORMAT` with shaded JodaTime.
## Brief change log
Do not
[
https://issues.apache.org/jira/browse/FLINK-8132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262893#comment-16262893
]
ASF GitHub Bot commented on FLINK-8132:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5053#discussion_r152618042
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafka011Exception.java
---
@@ -0,0 +1,
[
https://issues.apache.org/jira/browse/FLINK-8136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262885#comment-16262885
]
Timo Walther commented on FLINK-8136:
-
I will look into the issue.
> Cast exception e
[
https://issues.apache.org/jira/browse/FLINK-8136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-8136:
---
Assignee: Timo Walther
> Cast exception error on Flink SQL when using DATE_FORMAT
> -
David Marcos created FLINK-8136:
---
Summary: Cast exception error on Flink SQL when using DATE_FORMAT
Key: FLINK-8136
URL: https://issues.apache.org/jira/browse/FLINK-8136
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-8132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262878#comment-16262878
]
ASF GitHub Bot commented on FLINK-8132:
---
GitHub user pnowojski opened a pull request
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/5053
[FLINK-8132][kafka] Re-initialize transactional KafkaProducer on each
checkpoint
Previously faulty scenario with producer pool of 2.
1. started transaction 1 with producerA, written r
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5040#discussion_r152588446
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala
---
@@ -835,6 +836,43 @@ object ScalarOperat
[
https://issues.apache.org/jira/browse/FLINK-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262870#comment-16262870
]
ASF GitHub Bot commented on FLINK-8104:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5040#discussion_r152614003
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/FlinkTypeFactory.scala
---
@@ -417,6 +417,10 @@ object FlinkTypeFactory
[
https://issues.apache.org/jira/browse/FLINK-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262872#comment-16262872
]
ASF GitHub Bot commented on FLINK-8104:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5040#discussion_r152588168
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala
---
@@ -835,6 +836,43 @@ object ScalarOperat
[
https://issues.apache.org/jira/browse/FLINK-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262871#comment-16262871
]
ASF GitHub Bot commented on FLINK-8104:
---
Github user twalthr commented on a diff in
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5045#discussion_r152608576
--- Diff: docs/concepts/programming-model.md ---
@@ -33,53 +33,52 @@ Flink offers different levels of abstraction to develop
streaming/batch applicat
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5045#discussion_r152608405
--- Diff: docs/concepts/programming-model.md ---
@@ -132,14 +131,13 @@ One typically distinguishes different types of
windows, such as *tumbling window
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5045#discussion_r152607252
--- Diff: docs/concepts/programming-model.md ---
@@ -33,53 +33,52 @@ Flink offers different levels of abstraction to develop
streaming/batch applicat
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5045#discussion_r152612059
--- Diff: docs/concepts/runtime.md ---
@@ -107,21 +107,20 @@ With hyper-threading, each slot then takes 2 or more
hardware thread contexts.
## S
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5045#discussion_r152605878
--- Diff: docs/concepts/programming-model.md ---
@@ -33,53 +33,52 @@ Flink offers different levels of abstraction to develop
streaming/batch applicat
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5045#discussion_r152609451
--- Diff: docs/concepts/runtime.md ---
@@ -74,10 +74,10 @@ To control how many tasks a worker accepts, a worker
has so called **task slots*
Each *task
[
https://issues.apache.org/jira/browse/FLINK-8132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-8132:
--
Description:
Faulty scenario with producer pool of 2.
1. started transaction 1 with producerA,
[
https://issues.apache.org/jira/browse/FLINK-4822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262841#comment-16262841
]
ASF GitHub Bot commented on FLINK-4822:
---
Github user taizilongxu commented on the is
Github user taizilongxu commented on the issue:
https://github.com/apache/flink/pull/5050
the prefix is the same as kafka high level api, contain the uuid string, so
it could be unique
---
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5047
This change doesn't work since `WordWithCount` needs to be a POJO which
requires a default or no-args constructor and non-final public attributes or
getters/setters. Since the type is not a POJO th
[
https://issues.apache.org/jira/browse/FLINK-8081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262785#comment-16262785
]
ASF GitHub Bot commented on FLINK-8081:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5049
+1
---
[
https://issues.apache.org/jira/browse/FLINK-8070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262775#comment-16262775
]
ASF GitHub Bot commented on FLINK-8070:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5012
Ah, thanks @zentol for the clarification. Very nice to have this!
---
[
https://issues.apache.org/jira/browse/FLINK-7841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7841.
---
Resolution: Fixed
> Add docs for Flink's S3 support
> ---
>
>
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/5006#discussion_r152591791
--- Diff: docs/dev/stream/state/queryable_state.md ---
@@ -162,14 +161,19 @@ So far, you have set up your cluster to run with
queryable state and you have
[
https://issues.apache.org/jira/browse/FLINK-7574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262746#comment-16262746
]
ASF GitHub Bot commented on FLINK-7574:
---
Github user yew1eb closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262747#comment-16262747
]
Aljoscha Krettek commented on FLINK-4716:
-
What's the state of this? And also: wha
Github user yew1eb closed the pull request at:
https://github.com/apache/flink/pull/4712
---
[
https://issues.apache.org/jira/browse/FLINK-4822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262720#comment-16262720
]
ASF GitHub Bot commented on FLINK-4822:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5050
Don't you need a unique ID for this to work properly? (The task name is not
unique)
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5051
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5051
+1, merging.
---
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/5052
Thanks @zentol I will have a look.
---
[
https://issues.apache.org/jira/browse/FLINK-8133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262716#comment-16262716
]
ASF GitHub Bot commented on FLINK-8133:
---
Github user kl0u commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262704#comment-16262704
]
ASF GitHub Bot commented on FLINK-8133:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5052
[FLINK-8133][REST][docs] Generate REST API documentation
## What is the purpose of the change
This PR adds a generator for the REST API documentation. The generated has
to be run manually (a
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262597#comment-16262597
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152580041
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcUtils.java ---
@@ -0,0 +1,1511 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262593#comment-16262593
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152579106
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java
---
@@ -0,0 +1,747 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262591#comment-16262591
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152578874
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java
---
@@ -0,0 +1,747 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-5465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262584#comment-16262584
]
Andrey edited comment on FLINK-5465 at 11/22/17 2:19 PM:
-
We were
[
https://issues.apache.org/jira/browse/FLINK-5465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262584#comment-16262584
]
Andrey commented on FLINK-5465:
---
We were able to reproduce this issue on Flink 1.3.2. This i
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262583#comment-16262583
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152577385
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/logical/FlinkLogicalTableSourceScan.scala
---
@@ -62,7 +62,19 @@ clas
[
https://issues.apache.org/jira/browse/FLINK-8132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262565#comment-16262565
]
Kostas Kloudas commented on FLINK-8132:
---
This is a bug or a blocker?
> FlinkKafkaPr
[
https://issues.apache.org/jira/browse/FLINK-3924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262564#comment-16262564
]
Robert Metzger commented on FLINK-3924:
---
I think this will be a problem till Kinesis
[
https://issues.apache.org/jira/browse/FLINK-8118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262563#comment-16262563
]
Xingcan Cui commented on FLINK-8118:
Hi [~fhueske], thanks for the suggestions!
Sinc
[
https://issues.apache.org/jira/browse/FLINK-8132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-8132:
--
Comment: was deleted
(was: This is a bug or a blocker?)
> FlinkKafkaProducer011 can commit inco
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262546#comment-16262546
]
ASF GitHub Bot commented on FLINK-2170:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5043#discussion_r152571674
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java
---
@@ -355,4 +355,21 @@ public void addComparatorField(int fieldId,
Chesnay Schepler created FLINK-8135:
---
Summary: Add description to MessageParameter
Key: FLINK-8135
URL: https://issues.apache.org/jira/browse/FLINK-8135
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16262540#comment-16262540
]
Fabian Hueske commented on FLINK-6101:
--
You are right that SQL doesn't support `AS`.
Chesnay Schepler created FLINK-8134:
---
Summary: Add description to MessageHeaders
Key: FLINK-8134
URL: https://issues.apache.org/jira/browse/FLINK-8134
Project: Flink
Issue Type: Improvement
1 - 100 of 218 matches
Mail list logo
