[
https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242255#comment-16242255
]
Muhammad Imran Tariq commented on FLINK-8008:
-
I am using POJO way to read CSV
[
https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242254#comment-16242254
]
Chesnay Schepler commented on FLINK-8009:
-
avro and jackson are still pulled in. T
[
https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-8009:
---
Assignee: Chesnay Schepler
> flink-dist contains flink-runtime's transitive hadoop de
[
https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8009:
Summary: flink-dist pulls in flink-runtime's transitive avro/jackson
dependency (was: flink
[
https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242262#comment-16242262
]
Aljoscha Krettek commented on FLINK-7419:
-
Do you know if generated code uses the
[
https://issues.apache.org/jira/browse/FLINK-7073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-7073:
Assignee: Till Rohrmann
> Create RESTful JobManager endpoint
>
[
https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242275#comment-16242275
]
Aljoscha Krettek commented on FLINK-8009:
-
Btw, with the recent changes by [~Steph
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4972
[FLINK-8009][build][runtime] Remove transitive dependency promotion
## What is the purpose of the change
This PR replaces the dependency promotion from flink-runtime. The promotion
appears t
[
https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242278#comment-16242278
]
ASF GitHub Bot commented on FLINK-8009:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8011:
Fix Version/s: (was: 1.4.0)
> Set dist flink-python dependency to provided
> ---
Fabian Hueske created FLINK-8012:
Summary: Table with time attribute cannot be written to
CsvTableSink
Key: FLINK-8012
URL: https://issues.apache.org/jira/browse/FLINK-8012
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242290#comment-16242290
]
ASF GitHub Bot commented on FLINK-8011:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4973
[FLINK-8011][dist] Set flink-python to provided
## What is the purpose of the change
Minor clean-up in the flink-dist pom. flink-python is now set to provided,
similar to other libraries, an
Fabian Hueske created FLINK-8013:
Summary: Check of AggregateFunction merge function signature is
too strict.
Key: FLINK-8013
URL: https://issues.apache.org/jira/browse/FLINK-8013
Project: Flink
Fabian Hueske created FLINK-8014:
Summary: Add Kafka010JsonTableSink
Key: FLINK-8014
URL: https://issues.apache.org/jira/browse/FLINK-8014
Project: Flink
Issue Type: Improvement
Com
Fabian Hueske created FLINK-8015:
Summary: Add Kafka011JsonTableSink
Key: FLINK-8015
URL: https://issues.apache.org/jira/browse/FLINK-8015
Project: Flink
Issue Type: Improvement
Com
[
https://issues.apache.org/jira/browse/FLINK-8015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-8015:
-
Issue Type: New Feature (was: Improvement)
> Add Kafka011JsonTableSink
>
Fabian Hueske created FLINK-8016:
Summary: Add documentation for KafkaJsonTableSink
Key: FLINK-8016
URL: https://issues.apache.org/jira/browse/FLINK-8016
Project: Flink
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242328#comment-16242328
]
Chesnay Schepler commented on FLINK-8009:
-
yes, but they should only be pulled in
[
https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242337#comment-16242337
]
Chesnay Schepler commented on FLINK-7419:
-
I'm not entirely sure. Avro _does_ expo
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4972
Currently this fails because of missing entries in `dependencyManagement`
in the root pom.
---
[
https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242350#comment-16242350
]
ASF GitHub Bot commented on FLINK-8009:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-7419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242398#comment-16242398
]
Chesnay Schepler commented on FLINK-7419:
-
We could still relocating it though. Th
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4972
@aljoscha fixed
---
[
https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242407#comment-16242407
]
ASF GitHub Bot commented on FLINK-8009:
---
Github user zentol commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4945
Isn't this API compatibility rather than checkpoint/savepoint
compatibility? And if the former should not 1.4 be checked against 1.3 (which
should be checked against 1.2, etc.)?
---
[
https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242409#comment-16242409
]
ASF GitHub Bot commented on FLINK-7977:
---
Github user greghogan commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-7481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hai Zhou UTC+8 closed FLINK-7481.
-
Resolution: Won't Fix
> Binary search with integer overflow possibility
>
[
https://issues.apache.org/jira/browse/FLINK-5633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242418#comment-16242418
]
Stephan Ewen commented on FLINK-5633:
-
[~erikvanoosten] Okay, I assume that the revere
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/4974
[FLINK-8012] [table] Fix TableSink config for tables with time attributes.
## What is the purpose of the change
Fix the configuration of TableSinks for Tables with time attributes
(`TimeInd
[
https://issues.apache.org/jira/browse/FLINK-8012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242458#comment-16242458
]
ASF GitHub Bot commented on FLINK-8012:
---
GitHub user fhueske opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4975
[FLINK-7991][examples][kafka] Cleanup kafka10 example jar
## What is the purpose of the change
This PR cleans up the kafka example shading configuration, removing plenty
of unnecessary class
[
https://issues.apache.org/jira/browse/FLINK-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242460#comment-16242460
]
ASF GitHub Bot commented on FLINK-7991:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7905.
---
Resolution: Fixed
> HadoopS3FileSystemITCase failed on travis
> --
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4972
This looks good to go! I actually checked it out and manually ran the
end-to-end tests because it's quicker than waiting for travis. ð
---
[
https://issues.apache.org/jira/browse/FLINK-8009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242475#comment-16242475
]
ASF GitHub Bot commented on FLINK-8009:
---
Github user aljoscha commented on the issue
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4968
Do we also need to quote within sub-expressions? Have you looked at the
stop script?
---
[
https://issues.apache.org/jira/browse/FLINK-8006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242480#comment-16242480
]
ASF GitHub Bot commented on FLINK-8006:
---
Github user greghogan commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242495#comment-16242495
]
Bowen Li commented on FLINK-7977:
-
[~greghogan] You're right, it should be API compatibili
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4961#discussion_r149449571
--- Diff: flink-filesystems/flink-s3-fs-hadoop/pom.xml ---
@@ -33,6 +33,7 @@ under the License.
jar
+
--- End diff --
[
https://issues.apache.org/jira/browse/FLINK-7973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242502#comment-16242502
]
ASF GitHub Bot commented on FLINK-7973:
---
Github user NicoK commented on a diff in th
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4945
@greghogan I commented on the issue. Yes this is the API compatibility
check and the API should actually stay stable for all of the 1.x series. That's
also why I'm wondering why we're comparing agai
[
https://issues.apache.org/jira/browse/FLINK-7977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242503#comment-16242503
]
ASF GitHub Bot commented on FLINK-7977:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242512#comment-16242512
]
Aljoscha Krettek commented on FLINK-8008:
-
What method is this using for reading?
[
https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7978.
---
Resolution: Fixed
Fixed on release-1.4 in
3cbf467ebdf639df4d7d4da78b7bc2929aa4b5d9
460e27aeb5e
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4955
Thanks for fixing this! And thanks for the review!
I merged, could you please close the PR?
---
[
https://issues.apache.org/jira/browse/FLINK-7978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242540#comment-16242540
]
ASF GitHub Bot commented on FLINK-7978:
---
Github user aljoscha commented on the issue
Github user elbaulp commented on the issue:
https://github.com/apache/flink/pull/4968
@greghogan Didn't realized!, its failing too. I am going to fix it.
---
[
https://issues.apache.org/jira/browse/FLINK-8006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242567#comment-16242567
]
ASF GitHub Bot commented on FLINK-8006:
---
Github user elbaulp commented on the issue:
Github user elbaulp commented on the issue:
https://github.com/apache/flink/pull/4968
@greghogan Done, sorry for ignoring the stop script.
---
[
https://issues.apache.org/jira/browse/FLINK-8006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242636#comment-16242636
]
ASF GitHub Bot commented on FLINK-8006:
---
Github user elbaulp commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7897:
--
Description:
nio.Files#delete() provides better clue as to why the deletion may fail:
https://docs.oracle.com/j
[
https://issues.apache.org/jira/browse/FLINK-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242848#comment-16242848
]
ASF GitHub Bot commented on FLINK-8010:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4959
Looks good but I have not tested. Can we also fix the parameter swap
referenced in the JIRA?
---
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4971
Is anyone else seeing the red/green highlights shifted two lines up for
this PR? I'm seeing this in multiple browsers and with plug-ins disabled but
only on this PR.
---
[
https://issues.apache.org/jira/browse/FLINK-7998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242834#comment-16242834
]
ASF GitHub Bot commented on FLINK-7998:
---
Github user greghogan commented on the issu
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4971
@greghogan I also had this in another PR but not this one.
---
[
https://issues.apache.org/jira/browse/FLINK-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242872#comment-16242872
]
ASF GitHub Bot commented on FLINK-8010:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4971
scratch that, i have it in this one, here:
```
org.apache.flink
flink-shaded-guava
- 18.0-1.0
+
[
https://issues.apache.org/jira/browse/FLINK-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242873#comment-16242873
]
ASF GitHub Bot commented on FLINK-8010:
---
Github user zentol commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4965
LGTM.
---
[
https://issues.apache.org/jira/browse/FLINK-8004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242875#comment-16242875
]
ASF GitHub Bot commented on FLINK-8004:
---
Github user greghogan commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242916#comment-16242916
]
Jing Fan edited comment on FLINK-4809 at 11/7/17 9:26 PM:
--
Do we
[
https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242916#comment-16242916
]
Jing Fan commented on FLINK-4809:
-
Do we have any update on the PR? It has been handing fo
[
https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16242917#comment-16242917
]
ASF GitHub Bot commented on FLINK-4809:
---
Github user PangZhi commented on the issue:
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4729#discussion_r149540088
--- Diff:
flink-yarn/src/test/java/org/apache/flink/yarn/YarnResourceManagerTest.java ---
@@ -0,0 +1,354 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16243101#comment-16243101
]
ASF GitHub Bot commented on FLINK-7076:
---
Github user suez1224 commented on a diff in
GitHub user dkelley-accretive opened a pull request:
https://github.com/apache/flink/pull/4976
[FLINK-8017] Fix High availability cluster-id key in documentation
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the
[
https://issues.apache.org/jira/browse/FLINK-7076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16243264#comment-16243264
]
ASF GitHub Bot commented on FLINK-7076:
---
Github user suez1224 commented on the issue
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/4729
@tillrohrmann Updated the PR that addresses your comments. Could you please
take another look when you have time?
---
Dan Kelley created FLINK-8017:
-
Summary: High availability cluster-id option incorrect in
documentation
Key: FLINK-8017
URL: https://issues.apache.org/jira/browse/FLINK-8017
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16243292#comment-16243292
]
ASF GitHub Bot commented on FLINK-7996:
---
GitHub user xccui opened a pull request:
GitHub user xccui opened a pull request:
https://github.com/apache/flink/pull/4977
[FLINK-7996] [table] Add support for (left.time = right.time) predicates to
window join
## What is the purpose of the change
This PR adds `left.time = right.time` predicates support for time-
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/4978
[FLINK-7704][hotfix][flip6] Fix JobPlanInfoTest package path
This PR fix the package path of `JobPlanInfoTest`, consistent with the
JobPlanInfo `org.apache.flink.runtime.rest.messages`.
You ca
[
https://issues.apache.org/jira/browse/FLINK-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16243362#comment-16243362
]
Muhammad Imran Tariq edited comment on FLINK-8008 at 11/8/17 4:40 AM:
--
Github user PangZhi commented on the issue:
https://github.com/apache/flink/pull/4883
@StefanRRichter do we have any update on this PR?
---
[
https://issues.apache.org/jira/browse/FLINK-7998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16243230#comment-16243230
]
ASF GitHub Bot commented on FLINK-7998:
---
Github user naeioi commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16243419#comment-16243419
]
ASF GitHub Bot commented on FLINK-8001:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-8017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16243227#comment-16243227
]
ASF GitHub Bot commented on FLINK-8017:
---
GitHub user dkelley-accretive opened a pull
Github user naeioi commented on the issue:
https://github.com/apache/flink/pull/4959
Also can you replace `params.get("order")` with `params.get("orders")` in
TPCHQuery3.scala for consistency with java and the input hint?
---
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4978
LGTM ð
---
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4967
Merging ..
---
[
https://issues.apache.org/jira/browse/FLINK-7704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16243422#comment-16243422
]
ASF GitHub Bot commented on FLINK-7704:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-8018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16243453#comment-16243453
]
ASF GitHub Bot commented on FLINK-8018:
---
GitHub user sihuazhou opened a pull request
[
https://issues.apache.org/jira/browse/FLINK-8019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Jiang updated FLINK-8019:
Attachment: jstack-20171108-2.log
> Flink streaming job stopped at consuming Kafka data
> --
[
https://issues.apache.org/jira/browse/FLINK-7704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16243348#comment-16243348
]
ASF GitHub Bot commented on FLINK-7704:
---
GitHub user yew1eb opened a pull request:
Sihua Zhou created FLINK-8018:
-
Summary: RMQ does not support disabling queueDeclare, when the
user has no declaration permissions, it cannot connect
Key: FLINK-8018
URL: https://issues.apache.org/jira/browse/FLINK-80
GitHub user sihuazhou opened a pull request:
https://github.com/apache/flink/pull/4979
RMQSource support disabling queue declaration
## What is the purpose of the change
This PR fixs
[FLINK-8018](https://issues.apache.org/jira/browse/FLINK-8018), RabbitMQ
connector should
Weihua Jiang created FLINK-8019:
---
Summary: Flink streaming job stopped at consuming Kafka data
Key: FLINK-8019
URL: https://issues.apache.org/jira/browse/FLINK-8019
Project: Flink
Issue Type: B
201 - 289 of 289 matches
Mail list logo