Re: Apache Flink Sink + Ignite: Ouch! Argument is invalid

[Humphrey]

It is working fine here.

Tweaked the main method a bit:
    public static void main(String[] args) throws Exception {
        System.setProperty("IGNITE_QUIET", "false");            

        final StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
        env.setParallelism(1);
        env.getConfig().enableSysoutLogging();

        IgniteSink<Map&lt;String, String>> igniteSink = new
IgniteSink<>("DemoCache", "flink-config.xml");
        igniteSink.setAllowOverwrite(true);
        igniteSink.setAutoFlushFrequency(10);

        igniteSink.start();

        System.out.println("\n\nSTARTED SUCCESSFULLY\n\n");
        //DataStream<String> text = env.socketTextStream("localhost",
12200);

        //DataStream<Map&lt;String, String>> datastream = text.flatMap(new
Splitter());
        //datastream.addSink(igniteSink);

        //env.execute("Demo Streamer");
        igniteSink.stop();
    }

I added the following dependency:
        <dependency>
            <groupId>org.apache.ignite</groupId>
                <artifactId>ignite-log4j</artifactId>   
            <version>${ignite.version}</version>
        </dependency>

The log:

>>> +----------------------------------------------------------------------+
>>> Ignite ver. 2.5.0#20180523-sha1:86e110c750a340dc9be2d396415f0b80d7ed8813
>>> +----------------------------------------------------------------------+
>>> OS name: Windows 7 6.1 amd64
>>> CPU(s): 4
>>> Heap: 3.5GB
>>> VM name: 13908@WPU8L0031201
>>> Local node [ID=C91AF628-B784-4CB9-8FF9-AA2E0F04D303, order=1,
>>> clientMode=false]
>>> Local node addresses: [WPU8L0031201.ad.ing.net/0:0:0:0:0:0:0:1,
>>> WPU8L0031201.ad.ing.net/127.0.0.1, WPU8L0031201.ad.ing.net/192.168.1.69,
>>> /192.168.56.1, /192.168.99.1]
>>> Local ports: TCP:10800 TCP:11211 TCP:47100 TCP:47500 

17:27:42,928 INFO 
org.apache.ignite.internal.managers.discovery.GridDiscoveryManager  -
Topology snapshot [ver=1, servers=1, clients=0, CPUs=4, offheap=5.1GB,
heap=3.5GB]
17:27:42,928 INFO 
org.apache.ignite.internal.managers.discovery.GridDiscoveryManager  -   ^--
Node [id=C91AF628-B784-4CB9-8FF9-AA2E0F04D303, clusterState=ACTIVE]
17:27:42,928 INFO 
org.apache.ignite.internal.managers.discovery.GridDiscoveryManager  - Data
Regions Configured:
17:27:42,930 INFO 
org.apache.ignite.internal.managers.discovery.GridDiscoveryManager  -   ^--
default [initSize=256,0 MiB, maxSize=3,1 GiB, persistenceEnabled=false]
17:27:42,930 INFO 
org.apache.ignite.internal.managers.discovery.GridDiscoveryManager  -   ^--
Data_Region [initSize=1,0 GiB, maxSize=2,0 GiB, persistenceEnabled=false]


STARTED SUCCESSFULLY


17:27:43,105 INFO 
org.apache.ignite.internal.processors.rest.protocols.tcp.GridTcpRestProtocol 
- Command protocol successfully stopped: TCP binary
17:27:43,159 INFO 
org.apache.ignite.internal.processors.cache.GridCacheProcessor  - Stopped
cache [cacheName=DemoCache]
17:27:43,159 INFO 
org.apache.ignite.internal.processors.cache.GridCacheProcessor  - Stopped
cache [cacheName=ignite-sys-cache]
17:27:43,238 INFO  org.apache.ignite.internal.IgniteKernal                      
- 

>>> +---------------------------------------------------------------------------------+
>>> Ignite ver. 2.5.0#20180523-sha1:86e110c750a340dc9be2d396415f0b80d7ed8813
>>> stopped OK
>>> +---------------------------------------------------------------------------------+
>>> Grid uptime: 00:00:00.306



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/